http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionAdvisor.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionAdvisor.java index fc280f1..08cf39d 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionAdvisor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionAdvisor.java @@ -72,7 +72,7 @@ import com.gemstone.gemfire.internal.util.ArrayUtils; * of members in the distributed system. * * - * @since 3.0 + * @since GemFire 3.0 */ public class DistributionAdvisor { @@ -154,7 +154,7 @@ public class DistributionAdvisor { /** * the version of the profile set - * @since 5.1 + * @since GemFire 5.1 */ private long membershipVersion; @@ -388,7 +388,7 @@ public class DistributionAdvisor { /** * Free up resources used by this advisor once it is no longer being used. - * @since 3.5 + * @since GemFire 3.5 */ public void close() { try { @@ -482,7 +482,7 @@ public class DistributionAdvisor { * Polls the isInitialized state. Unlike {@link #isInitialized} it will * not wait for it to become initialized if it is in the middle of being * initialized. - * @since 5.7 + * @since GemFire 5.7 */ public final boolean pollIsInitialized() { return this.initialized; @@ -542,7 +542,7 @@ public class DistributionAdvisor { /** * Return true if the memberId on the specified Profile is a current * member of the distributed system. - * @since 5.7 + * @since GemFire 5.7 */ protected boolean isCurrentMember(Profile p) { return getDistributionManager().isCurrentMember(p.getDistributedMember()); @@ -721,7 +721,7 @@ public class DistributionAdvisor { * Create a new version of the membership profile set. This is * used in flushing state out of the VM for previous versions of * the set. - * @since 5.1 + * @since GemFire 5.1 */ public synchronized void forceNewMembershipVersion() { if (!membershipClosed) { @@ -746,7 +746,7 @@ public class DistributionAdvisor { * messages for the operation have been put in the DistributionManager's * outgoing "queue". * @return the current membership version for this advisor - * @since 5.1 + * @since GemFire 5.1 */ public final synchronized long startOperation() { if (logger.isTraceEnabled(LogMarker.DISTRIBUTION_STATE_FLUSH_OP)) { @@ -766,7 +766,7 @@ public class DistributionAdvisor { * been put in the DistributionManager's outgoing queue. * @param version * The membership version returned by startOperation - * @since 5.1 + * @since GemFire 5.1 */ public final synchronized long endOperation(long version) { synchronized(this.opCountLock) { @@ -795,7 +795,7 @@ public class DistributionAdvisor { /** * wait for the current operations being sent on views prior to the joining * of the given member to be placed on communication channels before returning - * @since 5.1 + * @since GemFire 5.1 */ public void waitForCurrentOperations(long timeout) { @@ -908,7 +908,7 @@ public class DistributionAdvisor { /** * Removes the specified profile if it is registered with this advisor. * @return true if it was registered; false if not. - * @since 5.7 + * @since GemFire 5.7 */ public boolean removeProfile(Profile profile, boolean destroyed) { return removeId(profile.getId(), false, destroyed, false/*fromMembershipListener*/); @@ -1094,7 +1094,7 @@ public class DistributionAdvisor { // /** // * get the profile for a specific member -// * @since 5.1 +// * @since GemFire 5.1 // * @return the Profile or null // */ // synchronized public Profile getProfile(InternalDistributedMember memberId) { @@ -1194,7 +1194,7 @@ public class DistributionAdvisor { /** * Returns a set of the members this advisor should distribute to by default - * @since 5.7 + * @since GemFire 5.7 */ @SuppressWarnings("unchecked") protected final Set<InternalDistributedMember> getDefaultDistributionMembers() { @@ -1377,7 +1377,7 @@ public class DistributionAdvisor { /** Get an unmodifiable list of the <code>Profile</code>s * that match the given <code>Filter</code>. - * @since 5.7 + * @since GemFire 5.7 */ protected List/*<Profile>*/ fetchProfiles(Filter f) { initializationGate(); @@ -1407,7 +1407,7 @@ public class DistributionAdvisor { /** * Provide recipients for profile remove. - * @since 5.7 + * @since GemFire 5.7 */ public Set adviseProfileRemove() { return adviseGeneric(); @@ -1530,7 +1530,7 @@ public class DistributionAdvisor { /** * The DistributionAdvisor's membership version where this member * was added - * @since 5.1 + * @since GemFire 5.1 */ public transient long initialMembershipVersion; @@ -1548,7 +1548,7 @@ public class DistributionAdvisor { /** * Return object that uniquely identifies this profile. - * @since 5.7 + * @since GemFire 5.7 */ public ProfileId getId() { return this.peerMemberId; @@ -1575,7 +1575,7 @@ public class DistributionAdvisor { } /** Return the DistributedMember associated with this profile - * @since 5.0 + * @since GemFire 5.0 */ public final InternalDistributedMember getDistributedMember() { return this.peerMemberId;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionChannel.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionChannel.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionChannel.java index a31c92f..e96753f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionChannel.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionChannel.java @@ -127,7 +127,7 @@ public class DistributionChannel { * the port of the JavaGroups channel's {@link InternalDistributedMember address} is * returned. * - * @since 3.0 + * @since GemFire 3.0 */ public long getId() { MembershipManager mgr = this.membershipManager; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfig.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfig.java index 2dbb5c9..f35ce8c 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfig.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfig.java @@ -50,7 +50,7 @@ import com.gemstone.gemfire.memcached.GemFireMemcachedServer; * @see com.gemstone.gemfire.internal.Config * * - * @since 2.1 + * @since GemFire 2.1 */ public interface DistributionConfig extends Config, LogConfig { @@ -1140,7 +1140,7 @@ public interface DistributionConfig extends Config, LogConfig { * com.gemstone.gemfire.i18n.LogWriterI18n} instance to log to. * Set this property with put(), not with setProperty() * - * @since 4.0 */ + * @since GemFire 4.0 */ public static final String LOG_WRITER_NAME = "log-writer"; /** The name of an internal property that specifies a @@ -1148,14 +1148,14 @@ public interface DistributionConfig extends Config, LogConfig { * in to a ds connect. * Set this property with put(), not with setProperty() * - * @since 7.0 */ + * @since GemFire 7.0 */ public static final String DS_CONFIG_NAME = "ds-config"; /** * The name of an internal property that specifies whether * the distributed system is reconnecting after a forced- * disconnect. - * @since 8.1 + * @since GemFire 8.1 */ public static final String DS_RECONNECTING_NAME = "ds-reconnecting"; @@ -1172,7 +1172,7 @@ public interface DistributionConfig extends Config, LogConfig { * com.gemstone.gemfire.LogWriter} instance to log security messages to. Set * this property with put(), not with setProperty() * - * @since 5.5 + * @since GemFire 5.5 */ public static final String SECURITY_LOG_WRITER_NAME = "security-log-writer"; @@ -1182,7 +1182,7 @@ public interface DistributionConfig extends Config, LogConfig { * FileOutputStream will be closed when the distributed * system disconnects. Set this property with put(), not * with setProperty() - * @since 5.0 + * @since GemFire 5.0 */ public static final String LOG_OUTPUTSTREAM_NAME = "log-output-stream"; @@ -1192,7 +1192,7 @@ public interface DistributionConfig extends Config, LogConfig { * property is set, the FileOutputStream will be closed when the distributed * system disconnects. Set this property with put(), not with setProperty() * - * @since 5.5 + * @since GemFire 5.5 */ public static final String SECURITY_LOG_OUTPUTSTREAM_NAME = "security-log-output-stream"; @@ -1844,18 +1844,18 @@ public interface DistributionConfig extends Config, LogConfig { /** The name of the "asyncMaxQueueSize" property */ @ConfigAttribute(type=Integer.class, min=MIN_ASYNC_MAX_QUEUE_SIZE, max=MAX_ASYNC_MAX_QUEUE_SIZE) public static final String ASYNC_MAX_QUEUE_SIZE_NAME = "async-max-queue-size"; - /** @since 5.7 */ + /** @since GemFire 5.7 */ @ConfigAttribute(type=String.class) public static final String CLIENT_CONFLATION_PROP_NAME = "conflate-events"; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final String CLIENT_CONFLATION_PROP_VALUE_DEFAULT = "server"; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final String CLIENT_CONFLATION_PROP_VALUE_ON = "true"; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final String CLIENT_CONFLATION_PROP_VALUE_OFF = "false"; - /** @since 9.0 */ + /** @since Geode 1.0 */ @ConfigAttribute(type=Boolean.class) public static final String DISTRIBUTED_TRANSACTIONS_NAME = "distributed-transactions"; public static final boolean DEFAULT_DISTRIBUTED_TRANSACTIONS = false; @@ -1870,7 +1870,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#conflate-events">"conflate-events"</a> * property. - * @since 5.7 + * @since GemFire 5.7 */ @ConfigAttributeGetter(name=CLIENT_CONFLATION_PROP_NAME) public String getClientConflation(); @@ -1878,7 +1878,7 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the value of the <a * href="../DistributedSystem.html#conflate-events">"conflate-events"</a> * property. - * @since 5.7 + * @since GemFire 5.7 */ @ConfigAttributeSetter(name=CLIENT_CONFLATION_PROP_NAME) public void setClientConflation(String clientConflation); @@ -2272,7 +2272,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#remove-unresponsive-client">"remove-unresponsive-client"</a> * property. - * @since 6.0 + * @since GemFire 6.0 */ @ConfigAttributeGetter(name=REMOVE_UNRESPONSIVE_CLIENT_PROP_NAME) public boolean getRemoveUnresponsiveClient(); @@ -2280,12 +2280,12 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the value of the <a * href="../DistributedSystem.html#remove-unresponsive-client">"remove-unresponsive-client"</a> * property. - * @since 6.0 + * @since GemFire 6.0 */ @ConfigAttributeSetter(name=REMOVE_UNRESPONSIVE_CLIENT_PROP_NAME) public void setRemoveUnresponsiveClient(boolean value); - /** @since 6.3 */ + /** @since GemFire 6.3 */ @ConfigAttribute(type=Boolean.class) public static final String DELTA_PROPAGATION_PROP_NAME = "delta-propagation"; @@ -2294,7 +2294,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#delta-propagation">"delta-propagation"</a> * property. - * @since 6.3 + * @since GemFire 6.3 */ @ConfigAttributeGetter(name=DELTA_PROPAGATION_PROP_NAME) public boolean getDeltaPropagation(); @@ -2303,7 +2303,7 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the value of the <a * href="../DistributedSystem.html#delta-propagation">"delta-propagation"</a> * property. - * @since 6.3 + * @since GemFire 6.3 */ @ConfigAttributeSetter(name=DELTA_PROPAGATION_PROP_NAME) public void setDeltaPropagation(boolean value); @@ -2311,7 +2311,7 @@ public interface DistributionConfig extends Config, LogConfig { public static final int MIN_DISTRIBUTED_SYSTEM_ID = -1; public static final int MAX_DISTRIBUTED_SYSTEM_ID = 255; /** - * @since 6.6 + * @since GemFire 6.6 */ @ConfigAttribute(type=Integer.class) public static final String DISTRIBUTED_SYSTEM_ID_NAME = "distributed-system-id"; @@ -2322,7 +2322,7 @@ public interface DistributionConfig extends Config, LogConfig { public static final String DEFAULT_REDUNDANCY_ZONE = ""; /** - * @since 6.6 + * @since GemFire 6.6 */ @ConfigAttributeSetter(name=DISTRIBUTED_SYSTEM_ID_NAME) public void setDistributedSystemId(int distributedSystemId); @@ -2331,7 +2331,7 @@ public interface DistributionConfig extends Config, LogConfig { public void setRedundancyZone(String redundancyZone); /** - * @since 6.6 + * @since GemFire 6.6 */ @ConfigAttributeGetter(name=DISTRIBUTED_SYSTEM_ID_NAME) public int getDistributedSystemId(); @@ -2340,23 +2340,23 @@ public interface DistributionConfig extends Config, LogConfig { public String getRedundancyZone(); /** - * @since 6.6.2 + * @since GemFire 6.6.2 */ public void setSSLProperty(String attName, String attValue); /** - * @since 6.6.2 + * @since GemFire 6.6.2 */ public Properties getSSLProperties(); public Properties getClusterSSLProperties(); /** - * @since 8.0 + * @since GemFire 8.0 */ public Properties getJmxSSLProperties(); /** - * @since 6.6 + * @since GemFire 6.6 */ @ConfigAttribute(type=Boolean.class) public static final String ENFORCE_UNIQUE_HOST_NAME = "enforce-unique-host"; @@ -2379,7 +2379,7 @@ public interface DistributionConfig extends Config, LogConfig { * href="../DistributedSystem.html#name">"groups"</a> property * <p> The default value is: {@link #DEFAULT_GROUPS}. * @return the value of the property - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttributeGetter(name=GROUPS_NAME) public String getGroups(); @@ -2390,20 +2390,20 @@ public interface DistributionConfig extends Config, LogConfig { * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttributeSetter(name=GROUPS_NAME) public void setGroups(String value); /** The name of the "groups" property - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttribute(type=String.class) public static final String GROUPS_NAME = "groups"; /** * The default groups. * <p> Actual value of this constant is <code>""</code>. - * @since 7.0 + * @since GemFire 7.0 */ public static final String DEFAULT_GROUPS = ""; @@ -2492,7 +2492,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#off-heap-memory-size">"off-heap-memory-size"</a> * property. - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttributeGetter(name=OFF_HEAP_MEMORY_SIZE_NAME) public String getOffHeapMemorySize(); @@ -2500,13 +2500,13 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the value of the <a * href="../DistributedSystem.html#off-heap-memory-size">"off-heap-memory-size"</a> * property. - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttributeSetter(name=OFF_HEAP_MEMORY_SIZE_NAME) public void setOffHeapMemorySize(String value); /** * The name of the "off-heap-memory-size" property - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttribute(type=String.class) public static final String OFF_HEAP_MEMORY_SIZE_NAME = "off-heap-memory-size"; @@ -2514,7 +2514,7 @@ public interface DistributionConfig extends Config, LogConfig { * The default <a * href="../DistributedSystem.html#off-heap-memory-size">"off-heap-memory-size"</a> * value of <code>""</code>. - * @since 9.0 + * @since Geode 1.0 */ public static final String DEFAULT_OFF_HEAP_MEMORY_SIZE = ""; @@ -2810,7 +2810,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#memcached-port">"memcached-port"</a> property * @return the port on which GemFireMemcachedServer should be started - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttributeGetter(name=MEMCACHED_PORT_NAME) public int getMemcachedPort(); @@ -2825,7 +2825,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#memcached-protocol">"memcached-protocol"</a> property * @return the protocol for GemFireMemcachedServer - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttributeGetter(name=MEMCACHED_PROTOCOL_NAME) public String getMemcachedProtocol(); @@ -2840,7 +2840,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#memcached-bind-address">"memcached-bind-address"</a> property * @return the bind address for GemFireMemcachedServer - * @since 7.0 + * @since GemFire 7.0 */ @ConfigAttributeGetter(name=MEMCACHED_BIND_ADDRESS_NAME) public String getMemcachedBindAddress(); @@ -2855,7 +2855,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#redis-port">"redis-port"</a> property * @return the port on which GemFireRedisServer should be started - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=REDIS_PORT_NAME) public int getRedisPort(); @@ -2870,7 +2870,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#redis-bind-address">"redis-bind-address"</a> property * @return the bind address for GemFireRedisServer - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=REDIS_BIND_ADDRESS_NAME) public String getRedisBindAddress(); @@ -2885,7 +2885,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#redis-password">"redis-password"</a> property * @return the authentication password for GemFireRedisServer - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=REDIS_PASSWORD_NAME) public String getRedisPassword(); @@ -2903,7 +2903,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#http-service-port">"http-service-port"</a> property * @return the HTTP service port - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=HTTP_SERVICE_PORT_NAME) public int getHttpServicePort(); @@ -2911,14 +2911,14 @@ public interface DistributionConfig extends Config, LogConfig { /** * Set the http-service-port for HTTP service. * @param value the port number for HTTP service - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeSetter(name=HTTP_SERVICE_PORT_NAME) public void setHttpServicePort(int value); /** * The name of the "http-service-port" property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttribute(type=Integer.class, min=0, max=65535) public static String HTTP_SERVICE_PORT_NAME = "http-service-port"; @@ -2926,7 +2926,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * The default value of the "http-service-port" property. * Current value is a <code>7070</code> - * @since 8.0 + * @since GemFire 8.0 */ public static int DEFAULT_HTTP_SERVICE_PORT = 7070; @@ -2934,7 +2934,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#http-service-bind-address">"http-service-bind-address"</a> property * @return the bind-address for HTTP service - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=HTTP_SERVICE_BIND_ADDRESS_NAME) public String getHttpServiceBindAddress(); @@ -2942,14 +2942,14 @@ public interface DistributionConfig extends Config, LogConfig { /** * Set the http-service-bind-address for HTTP service. * @param value the bind-address for HTTP service - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeSetter(name=HTTP_SERVICE_BIND_ADDRESS_NAME) public void setHttpServiceBindAddress(String value); /** * The name of the "http-service-bind-address" property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttribute(type=String.class) public static String HTTP_SERVICE_BIND_ADDRESS_NAME = "http-service-bind-address"; @@ -2957,7 +2957,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * The default value of the "http-service-bind-address" property. * Current value is an empty string <code>""</code> - * @since 8.0 + * @since GemFire 8.0 */ public static String DEFAULT_HTTP_SERVICE_BIND_ADDRESS = ""; @@ -3194,7 +3194,7 @@ public interface DistributionConfig extends Config, LogConfig { * Returns the value of the <a * href="../DistributedSystem.html#start-dev-rest-api">"start-dev-rest-api"</a> property * @return the value of the property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeGetter(name=START_DEV_REST_API_NAME) public boolean getStartDevRestApi(); @@ -3202,14 +3202,14 @@ public interface DistributionConfig extends Config, LogConfig { /** * Set the start-dev-rest-api for HTTP service. * @param value for the property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttributeSetter(name=START_DEV_REST_API_NAME) public void setStartDevRestApi(boolean value); /** * The name of the "start-dev-rest-api" property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttribute(type=Boolean.class) public static String START_DEV_REST_API_NAME = "start-dev-rest-api"; @@ -3217,13 +3217,13 @@ public interface DistributionConfig extends Config, LogConfig { /** * The default value of the "start-dev-rest-api" property. * Current value is <code>"false"</code> - * @since 8.0 + * @since GemFire 8.0 */ public static boolean DEFAULT_START_DEV_REST_API = false; /** * The name of the "default-auto-reconnect" property - * @since 8.0 + * @since GemFire 8.0 */ @ConfigAttribute(type=Boolean.class) public static final String DISABLE_AUTO_RECONNECT_NAME = "disable-auto-reconnect"; @@ -3724,21 +3724,21 @@ public interface DistributionConfig extends Config, LogConfig { /** * The name of the "lock-memory" property. Used to cause pages to be locked * into memory, thereby preventing them from being swapped to disk. - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttribute(type=Boolean.class) public static String LOCK_MEMORY_NAME = "lock-memory"; public static final boolean DEFAULT_LOCK_MEMORY = false; /** * Gets the value of <a href="../DistributedSystem.html#lock-memory">"lock-memory"</a> - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttributeGetter(name=LOCK_MEMORY_NAME) public boolean getLockMemory(); /** * Set the value of <a href="../DistributedSystem.html#lock-memory">"lock-memory"</a> * @param value the new setting - * @since 9.0 + * @since Geode 1.0 */ @ConfigAttributeSetter(name=LOCK_MEMORY_NAME) public void setLockMemory(boolean value); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfigImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfigImpl.java index 8b6b632..64f7cc0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfigImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionConfigImpl.java @@ -54,7 +54,7 @@ import com.gemstone.gemfire.memcached.GemFireMemcachedServer; * @see InternalDistributedSystem * * - * @since 2.1 + * @since GemFire 2.1 */ public class DistributionConfigImpl extends AbstractDistributionConfig @@ -196,7 +196,7 @@ public class DistributionConfigImpl protected int asyncQueueTimeout = DEFAULT_ASYNC_QUEUE_TIMEOUT; protected int asyncMaxQueueSize = DEFAULT_ASYNC_MAX_QUEUE_SIZE; - /** @since 5.7 */ + /** @since GemFire 5.7 */ private String clientConflation = CLIENT_CONFLATION_PROP_VALUE_DEFAULT; /** The id of the durable client */ @@ -623,7 +623,7 @@ public class DistributionConfigImpl * whether to skip loading distributed system properties from * gemfire.properties file * - * @since 6.5 + * @since GemFire 6.5 */ public DistributionConfigImpl(Properties nonDefault, @@ -647,7 +647,7 @@ public class DistributionConfigImpl * properties to other ssl properties. This parameter will be used * till we provide support for ssl-* properties. * - * @since 8.0 + * @since GemFire 8.0 */ public DistributionConfigImpl(Properties nonDefault, boolean ignoreGemFirePropsFile, boolean isConnected) { @@ -1874,12 +1874,12 @@ public class DistributionConfigImpl memberTimeout = (Integer)checkAttribute(MEMBER_TIMEOUT_NAME, value); } - /** @since 5.7 */ + /** @since GemFire 5.7 */ public String getClientConflation() { return this.clientConflation; } - /** @since 5.7 */ + /** @since GemFire 5.7 */ public void setClientConflation(String value) { this.clientConflation = (String)checkAttribute(CLIENT_CONFLATION_PROP_NAME, value); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionManager.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionManager.java index b0bc82a..3f002cd 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionManager.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionManager.java @@ -123,7 +123,7 @@ import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; * So, we refactored the code of those two subclasses into * <code>DistributionManager</code>. * - * @since 2.0 + * @since GemFire 2.0 * * @see DistributionMessage#process * @see IgnoredByManager @@ -215,7 +215,7 @@ public class DistributionManager public static final int NORMAL_DM_TYPE = 10; /** The DM type for locator distribution managers - * @since 7.0 + * @since GemFire 7.0 */ public static final int LOCATOR_DM_TYPE = 11; @@ -289,7 +289,7 @@ public class DistributionManager * JMX agent)? If so, then it creates {@link #ADMIN_ONLY_DM_TYPE} * type distribution managers. * - * @since 4.0 + * @since GemFire 4.0 */ public static volatile boolean isDedicatedAdminVM = false; @@ -321,12 +321,12 @@ public class DistributionManager new MembershipListenersLock(); /** The <code>MembershipListener</code>s that are registered on this * manager for ALL members. - * @since 5.7 + * @since GemFire 5.7 */ protected volatile Set allMembershipListeners = Collections.EMPTY_SET; /** * A lock to hold while adding and removing all membership listeners. - * @since 5.7 + * @since GemFire 5.7 */ protected final Object allMembershipListenersLock = new MembershipListenersLock(); @@ -1626,7 +1626,7 @@ public class DistributionManager * hosted locators. The value is a collection of host[port] strings. If a * bind-address was used for a locator then the form is bind-addr[port]. * - * @since 6.6.3 + * @since GemFire 6.6.3 */ public void addHostedLocators(InternalDistributedMember member, Collection<String> locators, boolean isSharedConfigurationEnabled) { synchronized (this.membersLock) { @@ -1700,7 +1700,7 @@ public class DistributionManager * hosted locators. The value is a collection of host[port] strings. If a * bind-address was used for a locator then the form is bind-addr[port]. * - * @since 6.6.3 + * @since GemFire 6.6.3 */ public Collection<String> getHostedLocators(InternalDistributedMember member) { synchronized (this.membersLock) { @@ -1713,7 +1713,7 @@ public class DistributionManager * member, and the value is a collection of host[port] strings. If a * bind-address was used for a locator then the form is bind-addr[port]. * - * @since 6.6.3 + * @since GemFire 6.6.3 */ public Map<InternalDistributedMember, Collection<String>> getAllHostedLocators() { synchronized (this.membersLock) { @@ -1725,7 +1725,7 @@ public class DistributionManager * member, and the value is a collection of host[port] strings. If a * bind-address was used for a locator then the form is bind-addr[port]. * - * @since 8.0 + * @since GemFire 8.0 */ @Override public Map<InternalDistributedMember, Collection<String>> getAllHostedLocatorsWithSharedConfiguration() { @@ -1750,7 +1750,7 @@ public class DistributionManager * Returns the low-level distribution channel for this distribution * manager. (brought over from ConsoleDistributionManager) * - * @since 4.0 + * @since GemFire 4.0 */ public DistributionChannel getDistributionChannel() { return this.channel; @@ -1838,7 +1838,7 @@ public class DistributionManager * Returns the id of the underlying distribution channel used for * communication. * - * @since 3.0 + * @since GemFire 3.0 */ public long getChannelId() { return this.channel.getId(); @@ -2318,7 +2318,7 @@ public class DistributionManager /** * Returns the transport configuration for this distribution manager - * @since 5.0 + * @since GemFire 5.0 */ public RemoteTransportConfig getTransport() { return this.transport; @@ -2348,7 +2348,7 @@ public class DistributionManager /** * Adds a <code>MembershipListener</code> to this distribution * manager. - * @since 5.7 + * @since GemFire 5.7 */ public void addAllMembershipListener(MembershipListener l) { synchronized (this.allMembershipListenersLock) { @@ -2366,7 +2366,7 @@ public class DistributionManager * @throws IllegalArgumentException * <code>l</code> was not registered on this distribution * manager - * @since 5.7 + * @since GemFire 5.7 */ public void removeAllMembershipListener(MembershipListener l) { synchronized (this.allMembershipListenersLock) { @@ -2575,7 +2575,7 @@ public class DistributionManager // * Initializes and returns a <code>DistributedSystem</code> to be // * sent to new members of the distributed system. // * -// * @since 3.0 +// * @since GemFire 3.0 // */ // protected DistributedState getNewDistributedState() { // DistributedState state = new DistributedState(); @@ -2618,7 +2618,7 @@ public class DistributionManager /** * Add a membership listener for all members * and return other DistribtionManagerIds as an atomic operation - * @since 5.7 + * @since GemFire 5.7 */ public Set addAllMembershipListenerAndGetAllIds(MembershipListener l) { // TO fix this deadlock: @@ -3897,7 +3897,7 @@ public class DistributionManager * Sets the administration agent associated with this distribution * manager. * - * @since 4.0 + * @since GemFire 4.0 */ public void setAgent(RemoteGfManagerAgent agent) { // Don't let the agent be set twice. There should be a one-to-one @@ -3918,7 +3918,7 @@ public class DistributionManager /** * Returns the agent that owns this distribution manager. * (in ConsoleDistributionManager) - * @since 3.5 + * @since GemFire 3.5 */ public RemoteGfManagerAgent getAgent(){ return this.agent; @@ -3931,7 +3931,7 @@ public class DistributionManager * @return <code>null</code> if no admin {@linkplain #getAgent * agent} is associated with this distribution manager * - * @since 3.5 + * @since GemFire 3.5 */ public String getDistributionConfigDescription() { if (this.agent == null) { @@ -3971,7 +3971,7 @@ public class DistributionManager * @param owner the agent that owns the returned monitor * @return the health monitor created by the owner; <code>null</code> * if the owner has now created a monitor. - * @since 3.5 + * @since GemFire 3.5 */ public HealthMonitor getHealthMonitor(InternalDistributedMember owner) { return (HealthMonitor)this.hmMap.get(owner); @@ -3981,7 +3981,7 @@ public class DistributionManager * * @param owner the agent that owns the created monitor * @param cfg the configuration to use when creating the monitor - * @since 3.5 + * @since GemFire 3.5 */ public void createHealthMonitor(InternalDistributedMember owner, GemFireHealthConfig cfg) { @@ -4652,7 +4652,7 @@ public class DistributionManager /* (non-Javadoc) * @see com.gemstone.gemfire.distributed.internal.DM#getMembersOnThisHost() - * @since gemfire59poc + * @since GemFire 5.9 */ public Set<InternalDistributedMember> getMembersInThisZone() { return getMembersInSameZone(getDistributionManagerId()); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionMessage.java index bb36b80..3a64d06 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionMessage.java @@ -180,7 +180,7 @@ public abstract class DistributionMessage /** * If true then this message most be sent on an ordered channel. * If false then it can be unordered. - * @since 5.5 + * @since GemFire 5.5 */ public boolean orderedDelivery() { final int processorType = getProcessorType(); @@ -216,14 +216,14 @@ public abstract class DistributionMessage /** * Causes this message to be send using multicast if v is true. - * @since 5.0 + * @since GemFire 5.0 */ public void setMulticast(boolean v) { this.multicast = v; } /** * Return true if this message should be sent using multicast. - * @since 5.0 + * @since GemFire 5.0 */ public boolean getMulticast() { return this.multicast; @@ -643,7 +643,7 @@ public abstract class DistributionMessage * * @return null if message is not conflatable. Otherwise return * a key that can be used to identify the entry to conflate. - * @since 4.2.2 + * @since GemFire 4.2.2 */ public ConflationKey getConflationKey() { return null; // by default conflate nothing; override in subclasses @@ -651,7 +651,7 @@ public abstract class DistributionMessage /** * @return the ID of the reply processor for this message, or zero if none - * @since 5.7 + * @since GemFire 5.7 */ public int getProcessorId() { return 0; @@ -673,7 +673,7 @@ public abstract class DistributionMessage * Returns true if the message is for internal-use such as a meta-data region. * * @return true if the message is for internal-use such as a meta-data region - * @since 7.0 + * @since GemFire 7.0 */ public boolean isInternal() { return false; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionStats.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionStats.java index 75c77ad..c4803ab 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DistributionStats.java @@ -776,7 +776,7 @@ public class DistributionStats implements DMStats { /** * Returns the current NanoTime or, if clock stats are disabled, zero. - * @since 5.0 + * @since GemFire 5.0 */ public static long getStatTime() { return enableClockStats? NanoTimer.getTime() : 0; @@ -1477,7 +1477,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the overflow queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public ThrottledQueueStatHelper getOverflowQueueHelper() { return new ThrottledQueueStatHelper() { @@ -1502,7 +1502,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the waiting queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public QueueStatHelper getWaitingQueueHelper() { return new QueueStatHelper() { @@ -1521,7 +1521,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the high priority queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public ThrottledQueueStatHelper getHighPriorityQueueHelper() { return new ThrottledQueueStatHelper() { @@ -1546,7 +1546,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the partitioned region queue can record its * stats to the proper distribution stats. - * @since 5.0 + * @since GemFire 5.0 */ public ThrottledQueueStatHelper getPartitionedRegionQueueHelper() { return new ThrottledQueueStatHelper() { @@ -1570,7 +1570,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the partitioned region pool can record its * stats to the proper distribution stats. - * @since 5.0.2 + * @since GemFire 5.0.2 */ public PoolStatHelper getPartitionedRegionPoolHelper() { return new PoolStatHelper() { @@ -1586,7 +1586,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the function execution queue can record its * stats to the proper distribution stats. - * @since 6.0 + * @since GemFire 6.0 */ public ThrottledQueueStatHelper getFunctionExecutionQueueHelper() { return new ThrottledQueueStatHelper() { @@ -1610,7 +1610,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the function execution pool can record its * stats to the proper distribution stats. - * @since 6.0 + * @since GemFire 6.0 */ public PoolStatHelper getFunctionExecutionPoolHelper() { return new PoolStatHelper() { @@ -1626,7 +1626,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the serial queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public ThrottledMemQueueStatHelper getSerialQueueHelper() { return new ThrottledMemQueueStatHelper() { @@ -1657,7 +1657,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the normal pool can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public PoolStatHelper getNormalPoolHelper() { return new PoolStatHelper() { @@ -1673,7 +1673,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the waiting pool can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public PoolStatHelper getWaitingPoolHelper() { return new PoolStatHelper() { @@ -1689,7 +1689,7 @@ public class DistributionStats implements DMStats { /** * Returns a helper object so that the highPriority pool can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public PoolStatHelper getHighPriorityPoolHelper() { return new PoolStatHelper() { @@ -1745,7 +1745,7 @@ public class DistributionStats implements DMStats { } /** - * @since 5.0.2.4 + * @since GemFire 5.0.2.4 */ public void incReceiverBufferSize(int inc, boolean direct) { if (direct) { @@ -1755,7 +1755,7 @@ public class DistributionStats implements DMStats { } } /** - * @since 5.0.2.4 + * @since GemFire 5.0.2.4 */ public void incSenderBufferSize(int inc, boolean direct) { if (direct) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/FlowControlParams.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/FlowControlParams.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/FlowControlParams.java index 3d9d8c2..b656805 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/FlowControlParams.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/FlowControlParams.java @@ -25,7 +25,7 @@ package com.gemstone.gemfire.distributed.internal; <p> The byteAllowance and rechargeBlockMs settings are used in hashcode calculations, and should not be changed if the hashcode of a FlowControlParams needs to remain invariant. - @since 5.0 + @since GemFire 5.0 */ public class FlowControlParams implements java.io.Serializable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitor.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitor.java index 2ef5b9f..92cafe8 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitor.java @@ -21,7 +21,7 @@ import com.gemstone.gemfire.admin.GemFireHealth; /** * Represents a thread that monitor the health of the vm it lives in. - * @since 3.5 + * @since GemFire 3.5 */ public interface HealthMonitor { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitorImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitorImpl.java index 38692dc..7862390 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitorImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HealthMonitorImpl.java @@ -31,7 +31,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; /** * Implements a thread that monitors the health of the vm it lives in. - * @since 3.5 + * @since GemFire 3.5 */ public class HealthMonitorImpl implements HealthMonitor, Runnable { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HighPriorityAckedMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HighPriorityAckedMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HighPriorityAckedMessage.java index c5590d1..ffae0fe 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HighPriorityAckedMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/HighPriorityAckedMessage.java @@ -44,7 +44,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * messages have been received and applied to the cache. Their reply messages * may not necessarily have been sent back or processed (if they have any). * - * @since 5.1 + * @since GemFire 5.1 */ public final class HighPriorityAckedMessage extends HighPriorityDistributionMessage implements MessageWithReply { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalDistributedSystem.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalDistributedSystem.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalDistributedSystem.java index 552dbe3..76a49db 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalDistributedSystem.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalDistributedSystem.java @@ -114,7 +114,7 @@ import com.gemstone.gemfire.security.GemFireSecurityException; * The concrete implementation of {@link DistributedSystem} that * provides internal-only functionality. * - * @since 3.0 + * @since GemFire 3.0 * */ public class InternalDistributedSystem @@ -306,7 +306,7 @@ public class InternalDistributedSystem * for administration. For administration, we are not as strict * when it comes to existing connections. * - * @since 4.0 + * @since GemFire 4.0 */ public static DistributedSystem connectForAdmin(Properties props) { return DistributedSystem.connectForAdmin(props); @@ -318,7 +318,7 @@ public class InternalDistributedSystem * This method synchronizes on the existingSystems collection. * * <p>author bruce - * @since 5.0 + * @since GemFire 5.0 */ public static InternalDistributedSystem getConnectedInstance() { InternalDistributedSystem result = null; @@ -337,7 +337,7 @@ public class InternalDistributedSystem * Returns the current distributed system, if there is one. * Note: this method is no longer unsafe size existingSystems uses copy-on-write. * <p>author bruce - * @since 5.0 + * @since GemFire 5.0 */ public static InternalDistributedSystem unsafeGetConnectedInstance() { InternalDistributedSystem result = getAnyInstance(); @@ -729,7 +729,7 @@ public class InternalDistributedSystem } /** - * @since 5.7 + * @since GemFire 5.7 */ private void startInitLocator() throws InterruptedException { String locatorString = this.originalConfig.getStartLocator(); @@ -777,7 +777,7 @@ public class InternalDistributedSystem } /** - * @since 5.7 + * @since GemFire 5.7 */ private void endInitLocator() throws IOException { InternalLocator loc = this.startedLocator; @@ -1473,7 +1473,7 @@ public class InternalDistributedSystem * to the same distributed system as this * <code>InternalDistributedSystem</code> connection. * - * @since 4.0 + * @since GemFire 4.0 */ public boolean sameSystemAs(Properties props) { DistributionConfig other = DistributionConfigImpl.produce(props); @@ -1504,7 +1504,7 @@ public class InternalDistributedSystem /** * Canonicalizes a locators string so that they may be compared. * - * @since 4.0 + * @since GemFire 4.0 */ private static String canonicalizeLocators(String locators) { SortedSet sorted = new TreeSet(); @@ -2264,7 +2264,7 @@ public class InternalDistributedSystem * Fires an "informational" <code>SystemMembershipEvent</code> in * admin VMs. * - * @since 4.0 + * @since GemFire 4.0 */ public void fireInfoEvent(Object callback) { throw new UnsupportedOperationException(LocalizedStrings.InternalDistributedSystem_NOT_IMPLEMENTED_YET.toLocalizedString()); @@ -2973,7 +2973,7 @@ public class InternalDistributedSystem /** * see {@link com.gemstone.gemfire.admin.AdminDistributedSystemFactory} - * @since 5.7 + * @since GemFire 5.7 */ public static void setEnableAdministrationOnly(boolean adminOnly) { DistributedSystem.setEnableAdministrationOnly(adminOnly); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java index cf8d91e..9d8e58c 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/InternalLocator.java @@ -104,7 +104,7 @@ import com.gemstone.gemfire.management.internal.configuration.messages.SharedCon * locator.startPeerLocation(); * locator.startDistributeSystem(); * - * @since 4.0 + * @since GemFire 4.0 */ public class InternalLocator extends Locator implements ConnectListener { @@ -131,7 +131,7 @@ public class InternalLocator extends Locator implements ConnectListener { private final TcpServer server; /** - * @since 5.7 + * @since GemFire 5.7 */ private final PrimaryHandler handler; @@ -308,7 +308,7 @@ public class InternalLocator extends Locator implements ConnectListener { * @param loadSharedConfigFromDir * load the shared configuration from the shared configuration directory * @throws IOException - * @since 7.0 + * @since GemFire 7.0 */ public static InternalLocator startLocator( int port, @@ -633,7 +633,7 @@ public class InternalLocator extends Locator implements ConnectListener { * * @param withDS true if a distributed system has been or will be started * @throws IOException - * @since 5.7 + * @since GemFire 5.7 */ public void startPeerLocation(boolean withDS) throws IOException { if(isPeerLocator()) { @@ -708,7 +708,7 @@ public class InternalLocator extends Locator implements ConnectListener { * distributed system already exists, this method will have no affect. * * @throws UnknownHostException - * @since 5.7 + * @since GemFire 5.7 */ public void startDistributedSystem() throws UnknownHostException { InternalDistributedSystem existing = InternalDistributedSystem.getConnectedInstance(); @@ -822,7 +822,7 @@ public class InternalLocator extends Locator implements ConnectListener { * @param distributedSystem * The distributed system to use for the statistics. * - * @since 5.7 + * @since GemFire 5.7 * * @throws UnknownHostException */ @@ -851,7 +851,7 @@ public class InternalLocator extends Locator implements ConnectListener { * The distributed system which the server location services * should use. If null, the method will try to find an already * connected distributed system. - * @since 5.7 + * @since GemFire 5.7 */ public void startServerLocation(InternalDistributedSystem distributedSystem) throws IOException http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshot.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshot.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshot.java index f563c13..c6a4325 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshot.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorLoadSnapshot.java @@ -42,7 +42,7 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; /** * A data structure used to hold load information for a locator * - * @since 5.7 + * @since GemFire 5.7 * */ public class LocatorLoadSnapshot { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorStats.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorStats.java index 1140b1f..6cad358 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LocatorStats.java @@ -28,7 +28,7 @@ import com.gemstone.gemfire.internal.StatisticsTypeFactoryImpl; /** * This class maintains statistics for the locator - * @since 5.7 + * @since GemFire 5.7 */ public class LocatorStats { private static StatisticsType type; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LonerDistributionManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LonerDistributionManager.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LonerDistributionManager.java index 54675c9..3920267 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LonerDistributionManager.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/LonerDistributionManager.java @@ -59,7 +59,7 @@ import com.gemstone.gemfire.internal.logging.InternalLogWriter; * * * - * @since 3.5 + * @since GemFire 3.5 */ public class LonerDistributionManager implements DM { private final InternalDistributedSystem system; @@ -911,7 +911,7 @@ public class LonerDistributionManager implements DM { /* (non-Javadoc) * @see com.gemstone.gemfire.distributed.internal.DM#getMembersOnThisHost() - * @since gemfire59poc + * @since GemFire 5.9 */ public Set<InternalDistributedMember> getMembersInThisZone() { return this.allIds; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/MessageWithReply.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/MessageWithReply.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/MessageWithReply.java index d83dc15..a5c028c 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/MessageWithReply.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/MessageWithReply.java @@ -24,7 +24,7 @@ import com.gemstone.gemfire.distributed.internal.membership.*; * be sent asynchronously through the transport layer. * * - * @since 3.0 + * @since GemFire 3.0 */ public interface MessageWithReply { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/PoolStatHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/PoolStatHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/PoolStatHelper.java index 130b6df..f4b8f83 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/PoolStatHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/PoolStatHelper.java @@ -22,7 +22,7 @@ package com.gemstone.gemfire.distributed.internal; * The implementation will call these methods at to proper time. * * - * @since 3.5 + * @since GemFire 3.5 */ public interface PoolStatHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ProductUseLog.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ProductUseLog.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ProductUseLog.java index 043ddc1..c8e066d 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ProductUseLog.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ProductUseLog.java @@ -38,7 +38,7 @@ import com.gemstone.gemfire.internal.logging.PureLogWriter; * default and can be adjusted with the system property <b>gemfire.max_product_use_file_size</b>, * though the size is not allowed to be less than 1mb. * - * @since 2013 + * @since GemFire 2013 */ public final class ProductUseLog implements MembershipListener { protected static long MAX_PRODUCT_USE_FILE_SIZE = Long.getLong("max_view_log_size", 5000000); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/QueueStatHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/QueueStatHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/QueueStatHelper.java index 32b9467..dd1837f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/QueueStatHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/QueueStatHelper.java @@ -22,7 +22,7 @@ package com.gemstone.gemfire.distributed.internal; * The implementation will call these methods at to proper time. * * - * @since 3.5 + * @since GemFire 3.5 */ public interface QueueStatHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReliableReplyProcessor21.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReliableReplyProcessor21.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReliableReplyProcessor21.java index 42953a4..93f89a3 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReliableReplyProcessor21.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReliableReplyProcessor21.java @@ -25,7 +25,7 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; * This is a reply processor which tracks departed members in order for * reliable messaging to determine which recipients departed before replying. * - * @since 5.0 + * @since GemFire 5.0 */ public class ReliableReplyProcessor21 extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyException.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyException.java index 322cae5..646243a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyException.java @@ -98,7 +98,7 @@ public class ReplyException extends GemFireException { * local stack frames. The remote stack elements have the sender id info. * * @param t Remote exception to fix up - * @since 5.1 + * @since GemFire 5.1 */ private void fixUpRemoteEx(Throwable t) { if (getSender() == null) { @@ -174,7 +174,7 @@ public class ReplyException extends GemFireException { /** * Sets the member that threw the received exception * @param sendr the member that threw the exception - * @since 6.0 + * @since GemFire 6.0 */ public synchronized void setSenderIfNull(InternalDistributedMember sendr) { if (this.sender == null) { @@ -185,7 +185,7 @@ public class ReplyException extends GemFireException { /** * Gets the member which threw the exception * @return the throwing member - * @since 6.0 + * @since GemFire 6.0 */ public synchronized InternalDistributedMember getSender() { return this.sender; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyProcessor21.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyProcessor21.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyProcessor21.java index e5e8cbf..5705689 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyProcessor21.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ReplyProcessor21.java @@ -79,7 +79,7 @@ import com.gemstone.gemfire.i18n.StringId; * @see MessageWithReply * * - * @since 2.1 + * @since GemFire 2.1 */ public class ReplyProcessor21 implements MembershipListener { @@ -551,7 +551,7 @@ public class ReplyProcessor21 * Registers this processor as a membership listener and * returns a set of the current members. * @return a Set of the current members - * @since 5.7 + * @since GemFire 5.7 */ protected Set addListenerAndGetMembers() { return getDistributionManager() @@ -559,7 +559,7 @@ public class ReplyProcessor21 } /** * Unregisters this processor as a membership listener - * @since 5.7 + * @since GemFire 5.7 */ protected void removeListener() { try { @@ -572,7 +572,7 @@ public class ReplyProcessor21 /** * Returns the set of members that this processor should care about. * @return a Set of the current members - * @since 5.7 + * @since GemFire 5.7 */ protected Set getDistributionManagerIds() { return getDistributionManager().getDistributionManagerIds(); @@ -868,7 +868,7 @@ public class ReplyProcessor21 /** * Used to cleanup resources allocated by the processor * after we are done using it. - * @since 5.1 + * @since GemFire 5.1 */ public void cleanup() { if (!this.keeperCleanedUp) { @@ -950,7 +950,7 @@ public class ReplyProcessor21 /** * Control of reply processor waiting behavior in the face of exceptions. - * @since 5.7 + * @since GemFire 5.7 * @return true to stop waiting when exceptions are present */ protected boolean stopBecauseOfExceptions() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/RuntimeDistributionConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/RuntimeDistributionConfigImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/RuntimeDistributionConfigImpl.java index 31ee698..010527f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/RuntimeDistributionConfigImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/RuntimeDistributionConfigImpl.java @@ -36,7 +36,7 @@ import java.util.List; * set the attSourceMap to the correct source after these methods return. * * - * @since 3.0 + * @since GemFire 3.0 */ public final class RuntimeDistributionConfigImpl extends DistributionConfigImpl { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ServerLocator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ServerLocator.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ServerLocator.java index b37a50b..f5b774f 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ServerLocator.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ServerLocator.java @@ -64,7 +64,7 @@ import com.gemstone.gemfire.internal.logging.LogService; /** * - * @since 5.7 + * @since GemFire 5.7 */ public class ServerLocator implements TcpHandler, DistributionAdvisee { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SharedConfiguration.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SharedConfiguration.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SharedConfiguration.java index ba9c7dc..ccccee3 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SharedConfiguration.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SharedConfiguration.java @@ -881,7 +881,7 @@ public class SharedConfiguration { * * @param xmlContent XML content to load and upgrade. * @return {@link Document} from xmlContent. - * @since 8.1 + * @since GemFire 8.1 */ // UnitTest SharedConfigurationJUnitTest.testCreateAndUpgradeDocumentFromXml static Document createAndUpgradeDocumentFromXml(final String xmlContent) throws SAXException, ParserConfigurationException, IOException, XPathExpressionException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/Sizeable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/Sizeable.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/Sizeable.java index 7a65374..76deee0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/Sizeable.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/Sizeable.java @@ -18,7 +18,7 @@ package com.gemstone.gemfire.distributed.internal; /** Sizeable objects have a getSize() method that returns the approximate size of the object. - @since 5.0 + @since GemFire 5.0 */ public interface Sizeable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SizeableRunnable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SizeableRunnable.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SizeableRunnable.java index 57a33bc..e6896e4 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SizeableRunnable.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/SizeableRunnable.java @@ -23,7 +23,7 @@ package com.gemstone.gemfire.distributed.internal; Instances/subclasses must provide the run() method to complete the Runnable interface.<p> - @since 5.0 + @since GemFire 5.0 */ public abstract class SizeableRunnable implements Runnable, Sizeable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessage.java index 6f5feb7..6df3dfe 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessage.java @@ -65,7 +65,7 @@ public final class StartupMessage extends HighPriorityDistributionMessage implem * will be regarded as an error by all who see it. * * @return list of addresses for this host - * @since 5.7 + * @since GemFire 5.7 */ public static Set getMyAddresses(DistributionManager dm) { try { @@ -107,7 +107,7 @@ public final class StartupMessage extends HighPriorityDistributionMessage implem /** * Sets the mcastEnabled flag for this message - * @since 5.0 + * @since GemFire 5.0 */ void setMcastEnabled(boolean flag) { isMcastEnabled = flag; @@ -142,7 +142,7 @@ public final class StartupMessage extends HighPriorityDistributionMessage implem /** * Sets the tcpDisabled flag for this message - * @since 5.0 + * @since GemFire 5.0 */ void setTcpDisabled(boolean flag) { isTcpDisabled = flag; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessageData.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessageData.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessageData.java index 060ba76..ad61b88 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessageData.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupMessageData.java @@ -37,7 +37,7 @@ import com.gemstone.gemfire.internal.GemFireVersion; * backwards compatibility. All new fields added should be written to allow * for version compatibility. * - * @since 7.0 + * @since GemFire 7.0 */ class StartupMessageData { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupResponseWithVersionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupResponseWithVersionMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupResponseWithVersionMessage.java index 26a7f54..3027486 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupResponseWithVersionMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/StartupResponseWithVersionMessage.java @@ -31,7 +31,7 @@ import com.gemstone.gemfire.internal.Version; import com.gemstone.gemfire.internal.logging.LogService; /** - * @since 6.6.2 + * @since GemFire 6.6.2 */ public class StartupResponseWithVersionMessage extends StartupResponseMessage { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledMemQueueStatHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledMemQueueStatHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledMemQueueStatHelper.java index a59a299..ee4cd91 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledMemQueueStatHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledMemQueueStatHelper.java @@ -22,7 +22,7 @@ package com.gemstone.gemfire.distributed.internal; * The implementation will call these methods at to proper time. * * - * @since 5.0 + * @since GemFire 5.0 */ public interface ThrottledMemQueueStatHelper extends QueueStatHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledQueueStatHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledQueueStatHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledQueueStatHelper.java index 03698b8..e7244c7 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledQueueStatHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottledQueueStatHelper.java @@ -22,7 +22,7 @@ package com.gemstone.gemfire.distributed.internal; * The implementation will call these methods at to proper time. * * - * @since 3.5 + * @since GemFire 3.5 */ public interface ThrottledQueueStatHelper extends QueueStatHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottlingMemLinkedQueueWithDMStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottlingMemLinkedQueueWithDMStats.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottlingMemLinkedQueueWithDMStats.java index 7423bb9..0db7267 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottlingMemLinkedQueueWithDMStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/ThrottlingMemLinkedQueueWithDMStats.java @@ -35,7 +35,7 @@ import java.util.*; * Inserting other types of objects will cause class cast exceptions to be thrown * on put/take. * - * @since 3.0 + * @since GemFire 3.0 * */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/direct/DirectChannel.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/direct/DirectChannel.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/direct/DirectChannel.java index 9fe5260..ac41d1c 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/direct/DirectChannel.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/direct/DirectChannel.java @@ -663,7 +663,7 @@ public class DirectChannel { /** * Returns null if no config is available. - * @since 4.2.2 + * @since GemFire 4.2.2 */ public DistributionConfig getDMConfig() { DM dm = getDM(); @@ -827,7 +827,7 @@ public class DirectChannel { /** * Returns the conduit over which this channel sends messages * - * @since 2.1 + * @since GemFire 2.1 */ public TCPConduit getConduit() { return this.conduit; @@ -877,7 +877,7 @@ public class DirectChannel { * the member whose state is to be captured * @param result * the map to add the state to - * @since 5.1 + * @since GemFire 5.1 */ public void getChannelStates(DistributedMember member, Map result) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockService.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockService.java index 844a93d..c0c97ff 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockService.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockService.java @@ -2496,7 +2496,7 @@ public class DLockService extends DistributedLockService { /** * Destroys an existing service and removes it from the map - * @since 3.5 + * @since GemFire 3.5 */ public void destroyAndRemove() { // isLockGrantor determines if we need to tell elder of destroy @@ -3179,7 +3179,7 @@ public class DLockService extends DistributedLockService { /** * Return a timestamp that represents the current time for locking purposes. - * @since 3.5 + * @since GemFire 3.5 */ static long getLockTimeStamp(DM dm) { return dm.cacheTimeMillis(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockStats.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockStats.java index ebdc83e..9a61c10 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DLockStats.java @@ -827,7 +827,7 @@ public class DLockStats implements DistributedLockStats { /** * Returns a helper object so that the serial queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public QueueStatHelper getSerialQueueHelper() { return new QueueStatHelper() { @@ -846,7 +846,7 @@ public class DLockStats implements DistributedLockStats { /** * Returns a helper object so that the waiting pool can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public PoolStatHelper getWaitingPoolHelper() { return new PoolStatHelper() { @@ -862,7 +862,7 @@ public class DLockStats implements DistributedLockStats { /** * Returns a helper object so that the waiting queue can record its * stats to the proper distribution stats. - * @since 3.5 + * @since GemFire 3.5 */ public QueueStatHelper getWaitingQueueHelper() { return new QueueStatHelper() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DeposeGrantorProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DeposeGrantorProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DeposeGrantorProcessor.java index e951176..08d459b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DeposeGrantorProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DeposeGrantorProcessor.java @@ -39,7 +39,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * A processor for telling the old grantor that he is deposed by a new grantor. * Processor waits for ack before completing. * - * @since 4.0 + * @since GemFire 4.0 * (renamed from ExpectTransferProcessor) */ public class DeposeGrantorProcessor extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DistributedMemberLock.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DistributedMemberLock.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DistributedMemberLock.java index cacf9b9..9655bda 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DistributedMemberLock.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/DistributedMemberLock.java @@ -42,7 +42,7 @@ import java.util.concurrent.locks.Lock; * com.gemstone.gemfire.distributed.DistributedLockService} and may throw * LockNotHeldException or LockServiceDestroyedException. * - * @since 5.1 + * @since GemFire 5.1 */ public final class DistributedMemberLock implements Lock { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderInitProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderInitProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderInitProcessor.java index e799f79..5d2833d 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderInitProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderInitProcessor.java @@ -48,7 +48,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * A processor for initializing the ElderState. This may involve sending * a message to every existing member to discover what services they have. * - * @since 4.0 + * @since GemFire 4.0 */ public class ElderInitProcessor extends ReplyProcessor21 { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderState.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderState.java index 245bc60..8b1d631 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderState.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/ElderState.java @@ -34,7 +34,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * Keeps track of all the information kept by the elder. * - * @since 4.0 + * @since GemFire 4.0 */ public class ElderState { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorInfo.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorInfo.java index f3cc947..664921b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorInfo.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorInfo.java @@ -22,7 +22,7 @@ import com.gemstone.gemfire.distributed.internal.membership.*; /** * Used to provide information on a grantor request made to the elder. * - * @since 4.0 + * @since GemFire 4.0 */ public class GrantorInfo { private final InternalDistributedMember id; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorRequestProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorRequestProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorRequestProcessor.java index 6b64616..ec5cd96 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorRequestProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/GrantorRequestProcessor.java @@ -48,7 +48,7 @@ import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; * A processor for sending a message to the elder asking it for the * grantor of a dlock service. * - * @since 4.0 + * @since GemFire 4.0 */ public class GrantorRequestProcessor extends ReplyProcessor21 { private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorDestroyedException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorDestroyedException.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorDestroyedException.java index f0843d0..aede763 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorDestroyedException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorDestroyedException.java @@ -21,7 +21,7 @@ package com.gemstone.gemfire.distributed.internal.locks; * A <code>LockGrantorDestroyedException</code> is thrown when attempting * use a distributed lock grantor that has been destroyed. * - * @since 4.0 + * @since GemFire 4.0 */ public class LockGrantorDestroyedException extends IllegalStateException { private static final long serialVersionUID = -3540124531032570817L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorId.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorId.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorId.java index b0a438b..49fdd07 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorId.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/locks/LockGrantorId.java @@ -23,7 +23,7 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; /** * Identifies specific lock grantor member and version. * - * @since 5.1 + * @since GemFire 5.1 */ public class LockGrantorId {
