http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java index 712244b..b8cd2f5 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifier.java @@ -60,7 +60,7 @@ import java.util.concurrent.*; * notifies them when updates occur. * * - * @since 3.2 + * @since GemFire 3.2 */ @SuppressWarnings({"synthetic-access", "deprecation"}) public class CacheClientNotifier { @@ -682,7 +682,7 @@ public class CacheClientNotifier { * * @param membershipID * Uniquely identifies the client pool - * @since 5.7 + * @since GemFire 5.7 */ public void setKeepAlive(ClientProxyMembershipID membershipID, boolean keepAlive) { @@ -1323,7 +1323,7 @@ public class CacheClientNotifier { * @param regionsWithEmptyDataPolicy * @param regionName * @param regionDataPolicy (0==empty) - * @since 6.1 + * @since GemFire 6.1 */ public void updateMapOfEmptyRegions(Map regionsWithEmptyDataPolicy, String regionName, int regionDataPolicy) { @@ -1430,7 +1430,7 @@ public class CacheClientNotifier { * haContainer. * * @param conflatable - * @since 5.7 + * @since GemFire 5.7 */ private void checkAndRemoveFromClientMsgsRegion(Conflatable conflatable) { if (haContainer == null) { @@ -1734,7 +1734,7 @@ public class CacheClientNotifier { * id for the durable-client * @return - true if a proxy is present for the given durable client * - * @since 5.6 + * @since GemFire 5.6 */ public boolean hasDurableClient(String durableId) { @@ -1755,7 +1755,7 @@ public class CacheClientNotifier { * id for the durable-client * @return - true if a primary proxy is present for the given durable client * - * @since 5.6 + * @since GemFire 5.6 */ public boolean hasPrimaryForDurableClient(String durableId) { @@ -1954,7 +1954,7 @@ public class CacheClientNotifier { * @param listener * The <code>InterestRegistrationListener</code> to register * - * @since 5.8Beta + * @since GemFire 5.8Beta */ public void registerInterestRegistrationListener( InterestRegistrationListener listener) { @@ -1969,7 +1969,7 @@ public class CacheClientNotifier { * The <code>InterestRegistrationListener</code> to * unregister * - * @since 5.8Beta + * @since GemFire 5.8Beta */ public void unregisterInterestRegistrationListener( InterestRegistrationListener listener) { @@ -1983,7 +1983,7 @@ public class CacheClientNotifier { * @return a read-only collection of <code>InterestRegistrationListener</code>s * registered with this notifier * - * @since 5.8Beta + * @since GemFire 5.8Beta */ public Set getInterestRegistrationListeners() { return this.readableInterestRegistrationListeners; @@ -1991,7 +1991,7 @@ public class CacheClientNotifier { /** * - * @since 5.8Beta + * @since GemFire 5.8Beta */ protected boolean containsInterestRegistrationListeners() { return !this.writableInterestRegistrationListeners.isEmpty(); @@ -1999,7 +1999,7 @@ public class CacheClientNotifier { /** * - * @since 5.8Beta + * @since GemFire 5.8Beta */ protected void notifyInterestRegistrationListeners( InterestRegistrationEvent event) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifierStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifierStats.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifierStats.java index b51ae5c..afc4235 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifierStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientNotifierStats.java @@ -30,7 +30,7 @@ import com.gemstone.gemfire.distributed.internal.DistributionStats; * are related to cache server client notifications. * * - * @since 4.1.2 + * @since GemFire 4.1.2 */ public class CacheClientNotifierStats { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java index 63c05ca..d9a71d5 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java @@ -113,7 +113,7 @@ import com.gemstone.gemfire.i18n.StringId; * client. * * - * @since 4.2 + * @since GemFire 4.2 */ @SuppressWarnings("synthetic-access") public class CacheClientProxy implements ClientSession { @@ -250,7 +250,7 @@ public class CacheClientProxy implements ClientSession { private boolean isPrimary; - /** @since 5.7 */ + /** @since GemFire 5.7 */ protected byte clientConflation = HandShake.CONFLATION_DEFAULT; /** @@ -278,7 +278,7 @@ public class CacheClientProxy implements ClientSession { * event's region name is present in this map, it's full value (and not * delta) is sent to the client represented by this proxy. * - * @since 6.1 + * @since GemFire 6.1 */ private volatile Map regionsWithEmptyDataPolicy = new HashMap(); @@ -793,7 +793,7 @@ public class CacheClientProxy implements ClientSession { * * @return whether the proxy is paused * - * @since 5.5 + * @since GemFire 5.5 */ public boolean isPaused() { return this._isPaused; @@ -3088,7 +3088,7 @@ public class CacheClientProxy implements ClientSession { /** * Get map of regions with empty data policy * - * @since 6.1 + * @since GemFire 6.1 */ public Map getRegionsWithEmptyDataPolicy() { return regionsWithEmptyDataPolicy; @@ -3107,7 +3107,7 @@ public class CacheClientProxy implements ClientSession { * Returns the number of seconds that have elapsed since the Client proxy * created. * - * @since 7.0 + * @since GemFire 7.0 */ public long getUpTime() { return (long) ((System.currentTimeMillis() - this.creationDate.getTime()) / 1000); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxyStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxyStats.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxyStats.java index dddcf1d..cf69d90 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxyStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxyStats.java @@ -31,7 +31,7 @@ import com.gemstone.gemfire.distributed.internal.DistributionStats; * client notifications for each client. * * - * @since 4.2 + * @since GemFire 4.2 */ public class CacheClientProxyStats implements MessageStats { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientUpdater.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientUpdater.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientUpdater.java index ce067d7..6e45d1d 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientUpdater.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientUpdater.java @@ -102,7 +102,7 @@ import com.gemstone.gemfire.security.GemFireSecurityException; * {@linkplain com.gemstone.gemfire.cache.Region#localInvalidate(Object) invalidates} * the local cache based on the contents of those messages. * - * @since 3.5 + * @since GemFire 3.5 */ public class CacheClientUpdater extends Thread implements ClientUpdater, DisconnectListener { @@ -1698,7 +1698,7 @@ public class CacheClientUpdater extends Thread implements ClientUpdater, // extract the eventId and verify if it is a duplicate event // if it is a duplicate event, ignore - // @since 5.1 + // @since GemFire 5.1 int numberOfParts = _message.getNumberOfParts(); eid = _message.getPart(numberOfParts - 1); // TODO the message handling methods also deserialized the eventID - inefficient @@ -1926,7 +1926,7 @@ public class CacheClientUpdater extends Thread implements ClientUpdater, /** * Stats for a CacheClientUpdater. Currently the only thing measured * are incoming bytes on the wire - * @since 5.7 + * @since GemFire 5.7 */ public static class CCUStats implements MessageStats { // static fields http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheServerHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheServerHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheServerHelper.java index 4e6d16a..dde8865 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheServerHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheServerHelper.java @@ -39,7 +39,7 @@ import java.util.zip.GZIPOutputStream; * <code>CacheServerHelper</code> is a static class that provides helper methods * for the CacheServer classes. * - * @since 3.5 + * @since GemFire 3.5 */ public class CacheServerHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ChunkedMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ChunkedMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ChunkedMessage.java index 2c49f90..dbea4c5 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ChunkedMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ChunkedMessage.java @@ -59,7 +59,7 @@ import org.apache.logging.log4j.Logger; * @see com.gemstone.gemfire.internal.cache.tier.MessageType * * - * @since 4.2 + * @since GemFire 4.2 */ public class ChunkedMessage extends Message { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientBlacklistProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientBlacklistProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientBlacklistProcessor.java index c7fb7c4..11ce992 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientBlacklistProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientBlacklistProcessor.java @@ -39,7 +39,7 @@ import java.util.Set; * A processor for sending client black list message to all nodes from primary. * This adds client to the blacklist and destroy it's queue if available on node. * - * @since 6.0 + * @since GemFire 6.0 * */ public class ClientBlacklistProcessor extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientHealthMonitor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientHealthMonitor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientHealthMonitor.java index c0f5021..ed38bd6 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientHealthMonitor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientHealthMonitor.java @@ -55,7 +55,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * dead and interrupts its threads. * * - * @since 4.2.3 + * @since GemFire 4.2.3 */ public class ClientHealthMonitor { private static final Logger logger = LogService.getLogger(); @@ -786,7 +786,7 @@ public class ClientHealthMonitor { /** * Returns a brief description of this <code>ClientHealthMonitor</code> * - * @since 5.1 + * @since GemFire 5.1 */ @Override public String toString() http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInstantiatorMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInstantiatorMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInstantiatorMessage.java index 288c3f8..bd37c4e 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInstantiatorMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInstantiatorMessage.java @@ -35,7 +35,7 @@ import com.gemstone.gemfire.internal.cache.tier.MessageType; * instantiators along with the unique <code>EventID</code> * * - * @since 5.0 + * @since GemFire 5.0 */ public final class ClientInstantiatorMessage extends ClientUpdateMessageImpl { private static final long serialVersionUID = 2949326125521840437L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInterestMessageImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInterestMessageImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInterestMessageImpl.java index 4e86478..c7fd61a 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInterestMessageImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientInterestMessageImpl.java @@ -32,7 +32,7 @@ import java.io.*; * client. * * - * @since 5.6 + * @since GemFire 5.6 */ public class ClientInterestMessageImpl implements ClientMessage { @@ -62,7 +62,7 @@ public class ClientInterestMessageImpl implements ClientMessage { /** * Whether the create or update events for this <code>ClientMessage</code> * is sent as an invalidate - * @since 6.0.3 + * @since GemFire 6.0.3 */ private boolean forUpdatesAsInvalidates; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMarkerMessageImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMarkerMessageImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMarkerMessageImpl.java index 97f53c2..ab616dc 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMarkerMessageImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMarkerMessageImpl.java @@ -31,7 +31,7 @@ import java.io.*; * to be used mostly by the durable clients, although all clients receive it. * * - * @since 5.5 + * @since GemFire 5.5 */ public final class ClientMarkerMessageImpl implements ClientMessage { private static final long serialVersionUID = 5423895238521508743L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMessage.java index c34e539..c435b3d 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientMessage.java @@ -27,7 +27,7 @@ import java.io.IOException; * operation that is sent from a server to an interested client. * * - * @since 5.5 + * @since GemFire 5.5 */ public interface ClientMessage extends Conflatable, DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientPingMessageImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientPingMessageImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientPingMessageImpl.java index b83bd30..4f46a0a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientPingMessageImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientPingMessageImpl.java @@ -31,7 +31,7 @@ import com.gemstone.gemfire.internal.cache.tier.MessageType; * the client connection is still alive. * * - * @since 6.6.2.x + * @since GemFire 6.6.2.x */ public final class ClientPingMessageImpl implements ClientMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientProxyMembershipID.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientProxyMembershipID.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientProxyMembershipID.java index 5610110..61ea62a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientProxyMembershipID.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientProxyMembershipID.java @@ -421,7 +421,7 @@ public final class ClientProxyMembershipID * Returns whether this <code>ClientProxyMembershipID</code> is durable. * @return whether this <code>ClientProxyMembershipID</code> is durable * - * @since 5.5 + * @since GemFire 5.5 */ public boolean isDurable() { String durableClientId = getDistributedMember().getDurableClientAttributes().getId(); @@ -432,7 +432,7 @@ public final class ClientProxyMembershipID * Returns this <code>ClientProxyMembershipID</code>'s durable attributes. * @return this <code>ClientProxyMembershipID</code>'s durable attributes * - * @since 5.5 + * @since GemFire 5.5 */ protected DurableClientAttributes getDurableAttributes() { return getDistributedMember().getDurableClientAttributes(); @@ -442,7 +442,7 @@ public final class ClientProxyMembershipID * Returns this <code>ClientProxyMembershipID</code>'s durable id. * @return this <code>ClientProxyMembershipID</code>'s durable id * - * @since 5.5 + * @since GemFire 5.5 */ public String getDurableId() { DurableClientAttributes dca = getDurableAttributes(); @@ -453,7 +453,7 @@ public final class ClientProxyMembershipID * Returns this <code>ClientProxyMembershipID</code>'s durable timeout. * @return this <code>ClientProxyMembershipID</code>'s durable timeout * - * @since 5.5 + * @since GemFire 5.5 */ protected int getDurableTimeout() { DurableClientAttributes dca = getDurableAttributes(); @@ -509,7 +509,7 @@ public final class ClientProxyMembershipID * @return the name of the <code>HARegion</code> queueing this proxy's * messages. * - * @since 5.5 + * @since GemFire 5.5 */ protected String getHARegionName() { return getBaseRegionName() + "_queue"; @@ -522,7 +522,7 @@ public final class ClientProxyMembershipID * @return the name of the region used for communicating interest changes * between servers * - * @since 5.6 + * @since GemFire 5.6 */ protected String getInterestRegionName() { return getBaseRegionName() + "_interest"; @@ -548,7 +548,7 @@ public final class ClientProxyMembershipID * stops/starts its cache. When it restarts its cache, it needs to maintain * the same unique id * - * @since 5.5 + * @since GemFire 5.5 */ public static synchronized void resetUniqueIdCounter() { synch_counter = 0; @@ -565,7 +565,7 @@ public final class ClientProxyMembershipID * <p> * This class is used to clean up resources associated with a particular * client and thus does not want to limit itself to the durable id. - * @since 5.7 + * @since GemFire 5.7 */ public class Identity { public int getUniqueId() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessage.java index 46ddf0a..5bd5d1b 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessage.java @@ -28,7 +28,7 @@ import java.util.HashMap; * operation that is sent from a server to an interested client. * * - * @since 5.5 + * @since GemFire 5.5 */ public interface ClientUpdateMessage extends ClientMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessageImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessageImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessageImpl.java index 1f715b0..0fb915e 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessageImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ClientUpdateMessageImpl.java @@ -63,7 +63,7 @@ import com.gemstone.gemfire.internal.offheap.MemoryAllocatorImpl; * operation that is sent from a server to an interested client. * * - * @since 4.2 + * @since GemFire 4.2 */ public class ClientUpdateMessageImpl implements ClientUpdateMessage, Sizeable, NewValueImporter { @@ -148,7 +148,7 @@ public class ClientUpdateMessageImpl implements ClientUpdateMessage, Sizeable, N /** * Represents the changed bytes of this event's _value. * - * @since 6.1 + * @since GemFire 6.1 */ private byte[] deltaBytes = null; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CommandInitializer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CommandInitializer.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CommandInitializer.java index 26ed47b..db475d9 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CommandInitializer.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CommandInitializer.java @@ -105,7 +105,7 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.command.UpdateClientNoti /** * A <code>CommandInitializer</code> maintains version specific commands map. * - * @since 5.7 + * @since GemFire 5.7 */ public class CommandInitializer { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListener.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListener.java index e79c579..35bb38a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListener.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListener.java @@ -20,7 +20,7 @@ package com.gemstone.gemfire.internal.cache.tier.sockets; * A listener which can be registered on {@link AcceptorImpl} * in order to receive events about connections created * or destroyed for this acceptor. - * @since 5.7 + * @since GemFire 5.7 * */ public interface ConnectionListener { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListenerAdapter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListenerAdapter.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListenerAdapter.java index 8c784e1..6264fc9 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListenerAdapter.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ConnectionListenerAdapter.java @@ -18,7 +18,7 @@ package com.gemstone.gemfire.internal.cache.tier.sockets; /** * A ConnectionListener that does nothing. - * @since 5.7 + * @since GemFire 5.7 * */ public class ConnectionListenerAdapter implements ConnectionListener { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAEventWrapper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAEventWrapper.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAEventWrapper.java index d60313d..5b08f51 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAEventWrapper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAEventWrapper.java @@ -49,7 +49,7 @@ import com.gemstone.gemfire.internal.logging.LogService; * <code>HARegionQueue</code> mechanics. It also has a property to indicate * the number of <code>HARegionQueue</code>s referencing this instance. * - * @since 5.7 + * @since GemFire 5.7 * */ public class HAEventWrapper implements Conflatable, DataSerializableFixedID, Sizeable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HandShake.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HandShake.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HandShake.java index 909b133..3e07cfe 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HandShake.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/HandShake.java @@ -212,30 +212,30 @@ public class HandShake implements ClientHandShake public static final String PRIVATE_KEY_PASSWD_PROP = "security-server-kspasswd"; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final byte CONFLATION_DEFAULT = 0; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final byte CONFLATION_ON = 1; - /** @since 5.7 */ + /** @since GemFire 5.7 */ public static final byte CONFLATION_OFF = 2; - /** @since 5.7 */ + /** @since GemFire 5.7 */ private byte clientConflation = CONFLATION_DEFAULT; - /** @since 6.0.3 + /** @since GemFire 6.0.3 * List of per client property override bits. */ private byte[] overrides = null; /** * Test hooks for per client conflation - * @since 5.7 + * @since GemFire 5.7 */ public static byte clientConflationForTesting = 0; public static boolean setClientConflationForTesting = false; /** * Test hook for client version support - * @since 5.7 + * @since GemFire 5.7 */ private static Version currentClientVersion = ConnectionProxy.VERSION; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/InterestResultPolicyImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/InterestResultPolicyImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/InterestResultPolicyImpl.java index bd51e0d..7ac84c2 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/InterestResultPolicyImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/InterestResultPolicyImpl.java @@ -28,7 +28,7 @@ import java.io.*; * Used to make InterestResultPolicy implement DataSerializableFixedID * * - * @since 5.7 + * @since GemFire 5.7 */ public final class InterestResultPolicyImpl extends InterestResultPolicy implements DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Message.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Message.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Message.java index a011875..aef2935 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Message.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Message.java @@ -1038,7 +1038,7 @@ public class Message { } /** * Undo any state changes done by setComms. - * @since 5.7 + * @since GemFire 5.7 */ public void unsetComms() { this.socket = null; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/MessageStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/MessageStats.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/MessageStats.java index 71a34d5..10b2ad8 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/MessageStats.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/MessageStats.java @@ -19,7 +19,7 @@ package com.gemstone.gemfire.internal.cache.tier.sockets; /** * Statistics supported by cache/server Message. - * @since 5.0.2 + * @since GemFire 5.0.2 */ public interface MessageStats { public void incReceivedBytes(long v); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ObjectPartList.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ObjectPartList.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ObjectPartList.java index b746f5f..d818e32 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ObjectPartList.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ObjectPartList.java @@ -40,7 +40,7 @@ import org.apache.logging.log4j.Logger; * exceptions. It can optionally also hold the list of associated keys. Assumes * that keys are either provided for all entries or for none. * - * @since 5.7 + * @since GemFire 5.7 */ public class ObjectPartList implements DataSerializableFixedID, Releasable { 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/internal/cache/tier/sockets/Part.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Part.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Part.java index bf90fab..5e52f96 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Part.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/Part.java @@ -32,7 +32,7 @@ import java.nio.channels.*; * * @see Message * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public class Part { private static final byte BYTE_CODE = 0; @@ -41,7 +41,7 @@ public class Part { private Version version; /** * Used to represent and empty byte array for bug 36279 - * @since 5.1 + * @since GemFire 5.1 */ private static final byte EMPTY_BYTEARRAY_CODE = 2; private static final byte[] EMPTY_BYTE_ARRAY = new byte[0]; @@ -188,7 +188,7 @@ public class Part { } /** - * @since 5.7 + * @since GemFire 5.7 */ public static void encodeInt(int v, byte[] bytes) { encodeInt(v, bytes, 0); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage.java index dd6edf1..917ca33 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage.java @@ -36,7 +36,7 @@ import com.gemstone.gemfire.internal.logging.LogService; /** * Distribution message for dropping client from blacklist. * - * @since 6.0 + * @since GemFire 6.0 * */ public class RemoveClientFromBlacklistMessage extends PooledDistributionMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerConnection.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerConnection.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerConnection.java index 56aba4d..e8afdb2 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerConnection.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerConnection.java @@ -72,7 +72,7 @@ import com.gemstone.gemfire.security.GemFireSecurityException; * cache connection. Each server connection runs in its own thread to maximize * concurrency and improve response times to edge requests * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public class ServerConnection implements Runnable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerHandShakeProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerHandShakeProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerHandShakeProcessor.java index 867f397..ea90e6e 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerHandShakeProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerHandShakeProcessor.java @@ -50,7 +50,7 @@ import java.util.Properties; /** * A <code>ServerHandShakeProcessor</code> verifies the client's version compatibility with server. * - * @since 5.7 + * @since GemFire 5.7 */ @@ -66,7 +66,7 @@ public class ServerHandShakeProcessor { /** * Test hook for server version support * - * @since 5.7 + * @since GemFire 5.7 */ public static void setSeverVersionForTesting(short ver) { currentServerVersion = Version.fromOrdinalOrCurrent(ver); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerQueueStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerQueueStatus.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerQueueStatus.java index c260c03..02a0acd 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerQueueStatus.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerQueueStatus.java @@ -24,7 +24,7 @@ import com.gemstone.gemfire.distributed.DistributedMember; * response of Handshake to server. This wrapper object is used to hold the * various info retrurned from Handshake. such as endpoint type and queue size. * - * @since 5.5 + * @since GemFire 5.5 * */ public class ServerQueueStatus http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerResponseMatrix.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerResponseMatrix.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerResponseMatrix.java index c518602..8c40695 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerResponseMatrix.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/ServerResponseMatrix.java @@ -40,7 +40,7 @@ import com.gemstone.gemfire.internal.cache.tier.MessageType; * entries are gathered up after the RI response is completed and removed from * the system * - * @since 5.1 + * @since GemFire 5.1 * */ public class ServerResponseMatrix http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/VersionedObjectList.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/VersionedObjectList.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/VersionedObjectList.java index 7f6bef4..53125f2 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/VersionedObjectList.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/VersionedObjectList.java @@ -56,7 +56,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * This class also implements Externalizable so that it can be serialized as * part of a PutAllPartialResultException. * - * @since 7.0 + * @since GemFire 7.0 */ public class VersionedObjectList extends ObjectPartList implements Externalizable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/CommitCommand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/CommitCommand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/CommitCommand.java index 79c73fc..71b0b21 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/CommitCommand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/CommitCommand.java @@ -40,7 +40,7 @@ import java.io.IOException; * This is the base command which read the parts for the * MessageType.COMMIT.<br> * - * @since 6.6 + * @since GemFire 6.6 */ public class CommitCommand extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction.java index 045eccd..8ceb001 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction.java @@ -60,7 +60,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; * If the hasResult byte is 1, then this command send back the result after the * execution to the client else do not send the reply back to the client * - * @since 5.8Beta + * @since GemFire 5.8Beta */ public class ExecuteFunction extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction65.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction65.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction65.java index 0bda7ff..d2869d1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction65.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction65.java @@ -54,7 +54,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** - * @since 6.5 + * @since GemFire 6.5 */ public class ExecuteFunction65 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction66.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction66.java index 296c029..3a20bc0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction66.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteFunction66.java @@ -64,7 +64,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** - * @since 6.6 + * @since GemFire 6.6 */ public class ExecuteFunction66 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction.java index 5a38567..40f0ee5 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction.java @@ -55,7 +55,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; * If the hasResult byte is 1, then this command send back the result after the * execution to the client else do not send the reply back to the client * - * @since 5.8LA + * @since GemFire 5.8LA */ public class ExecuteRegionFunction extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java index c54a65e..f92a366 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java @@ -52,7 +52,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** * * - * @since 6.1 + * @since GemFire 6.1 */ public class ExecuteRegionFunction61 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java index 9c92e98..001b912 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java @@ -53,7 +53,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** * - * @since 6.5 + * @since GemFire 6.5 */ public class ExecuteRegionFunction65 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java index 5d1443d..6e42316 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java @@ -55,7 +55,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** * - * @since 6.6 + * @since GemFire 6.6 */ public class ExecuteRegionFunction66 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java index 8dcc155..f5d8e51 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java @@ -53,7 +53,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; /** * - * @since 6.5 + * @since GemFire 6.5 */ public class ExecuteRegionFunctionSingleHop extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java index c926072..7e4d0b9 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java @@ -37,7 +37,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * {@link Command} for {@link GetClientPRMetadataCommand} * * - * @since 6.5 + * @since GemFire 6.5 */ public class GetClientPRMetadataCommand extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java index 45fe376..e3d18b2 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java @@ -35,7 +35,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * {@link Command} for {@link GetClientPRMetadataCommand66} * * - * @since 6.6 + * @since GemFire 6.6 */ public class GetClientPRMetadataCommand66 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand.java index 351c24f..204391d 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand.java @@ -38,7 +38,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * {@link Command} for {@link GetClientPartitionAttributesOp} operation * * - * @since 6.5 + * @since GemFire 6.5 * */ public class GetClientPartitionAttributesCommand extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand66.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand66.java index d9aeda0..3eca123 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand66.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetClientPartitionAttributesCommand66.java @@ -39,7 +39,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * {@link Command} for {@link GetClientPartitionAttributesOp} operation for 6.6 * clients * - * @since 6.6 + * @since GemFire 6.6 * */ public class GetClientPartitionAttributesCommand66 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntry70.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntry70.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntry70.java index 3a9c532..d975f1b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntry70.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntry70.java @@ -29,7 +29,7 @@ import com.gemstone.gemfire.internal.cache.versions.VersionTag; * getEntry(key) operation performed on server. * Extends Request, and overrides getValueAndIsObject() in Request * so as to not invoke loader. - * @since 6.6 + * @since GemFire 6.6 */ public class GetEntry70 extends Get70 { @@ -42,12 +42,12 @@ public class GetEntry70 extends Get70 { protected GetEntry70() { } - @Override - protected Get70.Entry getEntry(Region region, Object key, - Object callbackArg, ServerConnection servConn) { - return getValueAndIsObject(region, key, callbackArg, servConn); - } - + @Override + protected Get70.Entry getEntry(Region region, Object key, + Object callbackArg, ServerConnection servConn) { + return getValueAndIsObject(region, key, callbackArg, servConn); + } + @Override public Get70.Entry getValueAndIsObject(Region region, Object key, Object callbackArg, ServerConnection servConn) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntryCommand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntryCommand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntryCommand.java index f5226e9..b8075d1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntryCommand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/GetEntryCommand.java @@ -28,7 +28,7 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; * getEntry(key) operation performed on server. * Extends Request, and overrides getValueAndIsObject() in Request * so as to not invoke loader. - * @since 6.6 + * @since GemFire 6.6 */ public class GetEntryCommand extends Request { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ManagementCommand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ManagementCommand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ManagementCommand.java index cdf4399..2322429 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ManagementCommand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/ManagementCommand.java @@ -25,7 +25,7 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; /** * TODO: Javadoc everything and edit as needed * - * @since 7.0 + * @since GemFire 7.0 */ public class ManagementCommand extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put61.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put61.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put61.java index 941f711..4cadd20 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put61.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put61.java @@ -47,7 +47,7 @@ import com.gemstone.gemfire.internal.security.AuthorizeRequest; import com.gemstone.gemfire.security.GemFireSecurityException; /** - * @since 6.1 + * @since GemFire 6.1 */ public class Put61 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put65.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put65.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put65.java index 40a68ee..4ccc03a 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put65.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/Put65.java @@ -58,7 +58,7 @@ import com.gemstone.gemfire.internal.util.Breadcrumbs; import com.gemstone.gemfire.security.GemFireSecurityException; /** - * @since 6.5 + * @since GemFire 6.5 */ public class Put65 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterest61.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterest61.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterest61.java index 6100b52..5b4109c 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterest61.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterest61.java @@ -37,7 +37,7 @@ import com.gemstone.gemfire.i18n.StringId; import java.io.IOException; /** - * @since 6.1 + * @since GemFire 6.1 */ public class RegisterInterest61 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList61.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList61.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList61.java index 92c03f6..102e168 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList61.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList61.java @@ -38,7 +38,7 @@ import java.util.ArrayList; import java.util.List; /** - * @since 6.1 + * @since GemFire 6.1 */ public class RegisterInterestList61 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList66.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList66.java index 58051a1..862e58b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList66.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RegisterInterestList66.java @@ -45,7 +45,7 @@ import java.util.List; * as a separate part. * * - * @since 6.6 + * @since GemFire 6.6 */ public class RegisterInterestList66 extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RemoveAll.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RemoveAll.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RemoveAll.java index bdeba72..ac546fc 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RemoveAll.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RemoveAll.java @@ -16,7 +16,7 @@ */ /** * Author: dschneider - * @since 8.1 + * @since GemFire 8.1 */ package com.gemstone.gemfire.internal.cache.tier.sockets.command; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RequestEventValue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RequestEventValue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RequestEventValue.java index 3c72118..5eabef0 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RequestEventValue.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/command/RequestEventValue.java @@ -41,7 +41,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * Represents a request for (full) value of a given event from ha container * (client-messages-region). * - * @since 6.1 + * @since GemFire 6.1 */ public class RequestEventValue extends BaseCommand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/versions/ConcurrentCacheModificationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/versions/ConcurrentCacheModificationException.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/versions/ConcurrentCacheModificationException.java index af297d1..f7b21ed 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/versions/ConcurrentCacheModificationException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/versions/ConcurrentCacheModificationException.java @@ -26,7 +26,7 @@ import java.util.ConcurrentModificationException; * mechanism when a conflict is detected. It is not currently meant to be * exposed to customers. * - * @since 7.0 + * @since GemFire 7.0 */ public class ConcurrentCacheModificationException extends ConcurrentModificationException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySender.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySender.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySender.java index 713023f..0704bb8 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySender.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySender.java @@ -84,7 +84,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Unretained; * common functionality like initializing proxy. * * - * @since 7.0 + * @since GemFire 7.0 */ public abstract class AbstractGatewaySender implements GatewaySender, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java index 2ef5e19..3c70a4b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java @@ -67,7 +67,7 @@ import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; * {@link ConcurrentParallelGatewaySenderQueue}. * The dispatcher could be either GatewaySenderEventRemoteDispatcher or GatewaySenderEventCallbackDispatcher. * - * @since 7.0 + * @since GemFire 7.0 * */ public abstract class AbstractGatewaySenderEventProcessor extends Thread { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/BatchException70.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/BatchException70.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/BatchException70.java index 5183e45..adb59d3 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/BatchException70.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/BatchException70.java @@ -25,7 +25,7 @@ import java.util.List; * An exception thrown during batch processing. * * - * @since 7.0 + * @since GemFire 7.0 */ // Note that since this class is inside of an internal package, // we make it extend Exception, thereby making it a checked exception. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewayReceiverException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewayReceiverException.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewayReceiverException.java index a01b12c..727b6a1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewayReceiverException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewayReceiverException.java @@ -22,7 +22,7 @@ import com.gemstone.gemfire.cache.OperationAbortedException; /** * Exception observed during GatewayReceiver operations. * - * @since 8.1 + * @since GemFire 8.1 */ public class GatewayReceiverException extends OperationAbortedException { private static final long serialVersionUID = 7079321411869820364L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderConfigurationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderConfigurationException.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderConfigurationException.java index 07a6651..e55b114 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderConfigurationException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderConfigurationException.java @@ -23,7 +23,7 @@ package com.gemstone.gemfire.internal.cache.wan; * An exception indicating that a gateway configuration will not work with the * remote side of the gateway's configuration. * - * @since 7.0 + * @since GemFire 7.0 * */ public class GatewaySenderConfigurationException extends GatewaySenderException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackArgument.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackArgument.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackArgument.java index f6f8d88..f84dbbb 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackArgument.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackArgument.java @@ -42,7 +42,7 @@ import java.util.Set; * <p> * This class used to be in package <code>com.gemstone.gemfire.util</code>. * - * @since 7.0 + * @since GemFire 7.0 */ public final class GatewaySenderEventCallbackArgument extends WrappedCallbackArgument implements DataSerializableFixedID { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackDispatcher.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackDispatcher.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackDispatcher.java index 549c22b..48eaaa0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackDispatcher.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventCallbackDispatcher.java @@ -35,7 +35,7 @@ import com.gemstone.gemfire.i18n.StringId; * <code>GatewayEvent</code>s to <code>AsyncEventListener</code> * callback implementers. This dispatcher is used in the write-behind case. * - * @since 7.0 + * @since GemFire 7.0 */ public class GatewaySenderEventCallbackDispatcher implements GatewaySenderEventDispatcher{ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventDispatcher.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventDispatcher.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventDispatcher.java index 57f180c..b2f5244 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventDispatcher.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventDispatcher.java @@ -18,7 +18,7 @@ package com.gemstone.gemfire.internal.cache.wan; import java.util.List; /** - * @since 7.0 + * @since GemFire 7.0 * */ public interface GatewaySenderEventDispatcher { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl.java index 09d68f5..8a811e2 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/GatewaySenderEventImpl.java @@ -64,7 +64,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Unretained; * <code>GatewaySender</code> * * - * @since 7.0 + * @since GemFire 7.0 * */ public class GatewaySenderEventImpl implements http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage.java index fda0fc5..476c2c1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueBatchRemovalMessage.java @@ -54,7 +54,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * Removes a batch of events from the remote secondary queues * * - * @since 7.0 + * @since GemFire 7.0 * */ public class ParallelQueueBatchRemovalMessage extends PartitionMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java index 14d2f20..2b66227 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelQueueRemovalMessage.java @@ -51,7 +51,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; /** * Removes a batch of events from the remote secondary queues - * @since 8.0 + * @since GemFire 8.0 */ public class ParallelQueueRemovalMessage extends PooledDistributionMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java index 3abd17b..ba839f4 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java @@ -60,7 +60,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; /** - * @since 7.0 + * @since GemFire 7.0 * */ public class SerialGatewaySenderEventProcessor extends AbstractGatewaySenderEventProcessor { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java index 312fc4b..5c26bfe 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueue.java @@ -74,7 +74,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Unretained; import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; /** - * @since 7.0 + * @since GemFire 7.0 * */ public class SerialGatewaySenderQueue implements RegionQueue { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialSecondaryGatewayListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialSecondaryGatewayListener.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialSecondaryGatewayListener.java index 8250270..3d5c469 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialSecondaryGatewayListener.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialSecondaryGatewayListener.java @@ -27,7 +27,7 @@ import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; import com.gemstone.gemfire.internal.logging.LogService; /** - * @since 7.0 + * @since GemFire 7.0 * */ public class SerialSecondaryGatewayListener extends CacheListenerAdapter http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/AbstractXmlParser.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/AbstractXmlParser.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/AbstractXmlParser.java index dddc192..c66b242 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/AbstractXmlParser.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/AbstractXmlParser.java @@ -30,7 +30,7 @@ import com.gemstone.gemfire.i18n.LogWriterI18n; * references for {@link #logWriter} and {@link #stack} * * - * @since 8.1 + * @since GemFire 8.1 */ // UnitTest AbstractXmlParserTest public abstract class AbstractXmlParser implements XmlParser { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java index bdde29e..3bc743f 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheCreation.java @@ -125,7 +125,7 @@ import com.gemstone.gemfire.pdx.internal.TypeRegistry; * public for testing purposes. * * - * @since 3.0 + * @since GemFire 3.0 */ public class CacheCreation implements InternalCache { @@ -207,7 +207,7 @@ public class CacheCreation implements InternalCache { /** * {@link ExtensionPoint} support. - * @since 8.1 + * @since GemFire 8.1 */ private SimpleExtensionPoint<Cache> extensionPoint = new SimpleExtensionPoint<Cache>(this, this); @@ -228,7 +228,7 @@ public class CacheCreation implements InternalCache { /** * @param forParsing if true then this creation is used for parsing xml; * if false then it is used for generating xml. - * @since 5.7 + * @since GemFire 5.7 */ public CacheCreation(boolean forParsing) { initializeRegionShortcuts(); @@ -237,7 +237,7 @@ public class CacheCreation implements InternalCache { } } /** - * @since 5.7 + * @since GemFire 5.7 */ public void startingGenerate() { createInProgress.set(null); @@ -344,7 +344,7 @@ public class CacheCreation implements InternalCache { /** * create diskstore factory * - * @since prPersistSprint2 + * @since GemFire prPersistSprint2 */ public DiskStoreFactory createDiskStoreFactory() { return new DiskStoreFactoryImpl(this); @@ -353,7 +353,7 @@ public class CacheCreation implements InternalCache { /** * Store the current CacheCreation that is doing a create. * Used from PoolManager to defer to CacheCreation as a manager of pools. - * @since 5.7 + * @since GemFire 5.7 */ private static ThreadLocal createInProgress = new ThreadLocal(); @@ -361,7 +361,7 @@ public class CacheCreation implements InternalCache { * Returns null if the current thread is not doing a CacheCreation create. * Otherwise returns the PoolManagerImpl of the CacheCreation of the * create being invoked. - * @since 5.7 + * @since GemFire 5.7 */ public static final PoolManagerImpl getCurrentPoolManager() { return (PoolManagerImpl)createInProgress.get(); @@ -948,25 +948,25 @@ public class CacheCreation implements InternalCache { } /** - * @since 6.5 + * @since GemFire 6.5 */ public <K,V> RegionFactory<K,V> createRegionFactory(RegionShortcut atts) { throw new UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString()); } /** - * @since 6.5 + * @since GemFire 6.5 */ public <K,V> RegionFactory<K,V> createRegionFactory() { throw new UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString()); } /** - * @since 6.5 + * @since GemFire 6.5 */ public <K,V> RegionFactory<K,V> createRegionFactory(String regionAttributesId) { throw new UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString()); } /** - * @since 6.5 + * @since GemFire 6.5 */ public <K,V> RegionFactory<K,V> createRegionFactory(RegionAttributes<K,V> regionAttributes) { throw new UnsupportedOperationException(LocalizedStrings.SHOULDNT_INVOKE.toLocalizedString()); @@ -1111,7 +1111,7 @@ public class CacheCreation implements InternalCache { /** * Implementation of {@link Cache#setCopyOnRead} - * @since 4.0 + * @since GemFire 4.0 */ public void setCopyOnRead(boolean copyOnRead) { this.copyOnRead = copyOnRead; @@ -1120,7 +1120,7 @@ public class CacheCreation implements InternalCache { /** * Implementation of {@link Cache#getCopyOnRead} - * @since 4.0 + * @since GemFire 4.0 */ public boolean getCopyOnRead() { return this.copyOnRead; @@ -1133,7 +1133,7 @@ public class CacheCreation implements InternalCache { /** * Adds a CacheTransactionManagerCreation for this Cache (really just a * placeholder since a CacheTransactionManager is really a Cache singleton) - * @since 4.0 + * @since GemFire 4.0 * @see GemFireCacheImpl */ public void @@ -1163,7 +1163,7 @@ public class CacheCreation implements InternalCache { /** * Returns the DiskStore list * - * @since prPersistSprint2 + * @since GemFire prPersistSprint2 */ public Collection<DiskStoreImpl> listDiskStores() { return this.diskStores.values(); @@ -1297,7 +1297,7 @@ public class CacheCreation implements InternalCache { * Returns whether PdxInstance is preferred for PDX types instead of Java object. * @see com.gemstone.gemfire.cache.CacheFactory#setPdxReadSerialized(boolean) * - * @since 6.6 + * @since GemFire 6.6 */ public boolean getPdxReadSerialized() { return cacheConfig.isPdxReadSerialized(); @@ -1389,7 +1389,7 @@ public class CacheCreation implements InternalCache { /** * @see Extensible#getExtensionPoint() - * @since 8.1 + * @since GemFire 8.1 */ @Override public ExtensionPoint<Cache> getExtensionPoint() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheServerCreation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheServerCreation.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheServerCreation.java index 14527ad..22d684f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheServerCreation.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheServerCreation.java @@ -32,7 +32,7 @@ import java.util.Set; /** * Represents a {@link CacheServer} that is created declaratively. * - * @since 4.0 + * @since GemFire 4.0 */ public class CacheServerCreation extends AbstractCacheServer { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheTransactionManagerCreation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheTransactionManagerCreation.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheTransactionManagerCreation.java index cf37928..c8a4ab1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheTransactionManagerCreation.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/xmlcache/CacheTransactionManagerCreation.java @@ -31,7 +31,7 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; * Represents a {@link CacheTransactionManager} that is created declaratively. * * - * @since 4.0 + * @since GemFire 4.0 */ public class CacheTransactionManagerCreation implements CacheTransactionManager {
