http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java index 089dfe8..a4cf7e9 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/ha/HARegionQueue.java @@ -131,7 +131,7 @@ import com.gemstone.gemfire.i18n.StringId; * (See BlockingHARegionQueue) * * - * @since 4.3 + * @since GemFire 4.3 * */ public class HARegionQueue implements RegionQueue @@ -304,13 +304,13 @@ public class HARegionQueue implements RegionQueue private final CancelCriterion stopper; - /** @since 5.7 */ + /** @since GemFire 5.7 */ protected byte clientConflation = HandShake.CONFLATION_DEFAULT; /** * Boolean to indicate whether client is a slow receiver * - * @since 6.0 + * @since GemFire 6.0 */ public boolean isClientSlowReciever = false; @@ -322,7 +322,7 @@ public class HARegionQueue implements RegionQueue /** * Test hooks for periodic ack * - * @since 6.0 + * @since GemFire 6.0 */ static boolean testMarkerMessageRecieved = false; static boolean isUsedByTest = false; @@ -567,7 +567,7 @@ public class HARegionQueue implements RegionQueue * * @param val * @throws InterruptedException - * @since 5.7 + * @since GemFire 5.7 */ protected void putInQueue(Object val) throws InterruptedException { if (val instanceof HAEventWrapper @@ -584,7 +584,7 @@ public class HARegionQueue implements RegionQueue /** * Check whether to conflate an event - * @since 5.7 + * @since GemFire 5.7 */ protected boolean shouldBeConflated(Conflatable event) { boolean retVal = event.shouldBeConflated(); @@ -2228,7 +2228,7 @@ public class HARegionQueue implements RegionQueue * @throws ClassNotFoundException * @throws CacheException * @throws InterruptedException - * @since 5.7 + * @since GemFire 5.7 */ public static HARegionQueue getHARegionQueueInstance(String regionName, Cache cache, HARegionQueueAttributes hrqa, final int haRgnQType, @@ -2878,7 +2878,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * @throws ClassNotFoundException * @throws CacheException * @throws InterruptedException - * @since 5.7 + * @since GemFire 5.7 */ TestOnlyHARegionQueue(String regionName, Cache cache, Map haContainer) throws IOException, ClassNotFoundException, CacheException, @@ -2917,7 +2917,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * @throws ClassNotFoundException * @throws CacheException * @throws InterruptedException - * @since 5.7 + * @since GemFire 5.7 */ TestOnlyHARegionQueue(String regionName, Cache cache, HARegionQueueAttributes hrqa) throws IOException, @@ -3748,7 +3748,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * * @param event * @param position - * @since 5.7 + * @since GemFire 5.7 */ protected void putEventInHARegion(Conflatable event, Long position) { if (event instanceof HAEventWrapper) { @@ -3845,7 +3845,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * * @param haEventWrapper * An instance of <code>HAEventWrapper</code> - * @since 5.7 + * @since GemFire 5.7 */ protected void putEntryConditionallyIntoHAContainer( HAEventWrapper haEventWrapper) { @@ -3907,7 +3907,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * HAEventWrapper instances held by this queue. Also, removes those instances * whose referenceCount becomes zero. * - * @since 5.7 + * @since GemFire 5.7 */ private void updateHAContainer() { @@ -3981,7 +3981,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * * @param conflatable * @return An instance of <code>ClientUpdateMessage</code> - * @since 5.7 + * @since GemFire 5.7 */ public Conflatable getAndRemoveFromHAContainer(Conflatable conflatable) { @@ -4007,7 +4007,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, * is zero and put is not in progress, removes the entry from the haContainer. * * @param wrapper - * @since 5.7 + * @since GemFire 5.7 */ public void decAndRemoveFromHAContainer(HAEventWrapper wrapper) { @@ -4079,7 +4079,7 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, /** * Set client conflation override - * @since 5.7 + * @since GemFire 5.7 */ public void setClientConflation(byte value) { if (value != HandShake.CONFLATION_OFF &&
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/locks/TXLockUpdateParticipantsMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/locks/TXLockUpdateParticipantsMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/locks/TXLockUpdateParticipantsMessage.java index a82b335..8165cea 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/locks/TXLockUpdateParticipantsMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/locks/TXLockUpdateParticipantsMessage.java @@ -46,7 +46,7 @@ import java.util.Set; * @see TXOriginatorRecoveryProcessor * @see com.gemstone.gemfire.internal.cache.TXFarSideCMTracker * - * @since 4.1.1 + * @since GemFire 4.1.1 */ public final class TXLockUpdateParticipantsMessage extends PooledDistributionMessage http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapEvictor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapEvictor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapEvictor.java index 95b806b..6aac4a9 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapEvictor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapEvictor.java @@ -56,7 +56,7 @@ import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; * Triggers centralized eviction(asynchronously) when the ResourceManager sends * an eviction event for on-heap regions. This is registered with the ResourceManager. * - * @since 6.0 + * @since GemFire 6.0 * */ public class HeapEvictor implements ResourceListener<MemoryEvent> { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUCapacityController.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUCapacityController.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUCapacityController.java index c0b8ef6..948a9d7 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUCapacityController.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUCapacityController.java @@ -57,7 +57,7 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; * options improve the behavior of the <code>HeapLRUCapacityController</code>. * * - * @since 3.2 + * @since GemFire 3.2 */ @SuppressWarnings("synthetic-access") public class HeapLRUCapacityController extends LRUAlgorithm { @@ -173,7 +173,7 @@ public class HeapLRUCapacityController extends LRUAlgorithm { /** * Returns a brief description of this eviction controller. * - * @since 4.0 + * @since GemFire 4.0 */ @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/lru/HeapLRUStatistics.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUStatistics.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUStatistics.java index e74793d..cc0e494 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUStatistics.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/HeapLRUStatistics.java @@ -27,7 +27,7 @@ import com.gemstone.gemfire.*; * * @see com.gemstone.gemfire.internal.cache.lru.MemLRUCapacityController * @see com.gemstone.gemfire.internal.cache.lru.LRUCapacityController - * @since 4.0 + * @since GemFire 4.0 */ public class HeapLRUStatistics extends LRUStatistics { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUAlgorithm.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUAlgorithm.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUAlgorithm.java index b30ed15..3e440ca 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUAlgorithm.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUAlgorithm.java @@ -69,7 +69,7 @@ import java.util.*; * region will result in an {@link IllegalStateException} being * thrown. * - * @since 3.2 + * @since GemFire 3.2 */ public abstract class LRUAlgorithm implements CacheCallback, Serializable, Cloneable @@ -207,7 +207,7 @@ public abstract class LRUAlgorithm * This method is an artifact when eviction controllers used to * called capacity controllers and were configured in the cache.xml * file as <code>Declarable</code> - * @since 4.1.1 + * @since GemFire 4.1.1 */ public abstract Properties getProperties(); @@ -271,7 +271,7 @@ public abstract class LRUAlgorithm /** * Force subclasses to have a reasonable <code>toString</code> * - * @since 4.0 + * @since GemFire 4.0 */ @Override public abstract String toString(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUCapacityController.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUCapacityController.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUCapacityController.java index 828a4fb..0e5afab 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUCapacityController.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUCapacityController.java @@ -51,7 +51,7 @@ import java.util.*; * </region-attributes> * </pre> * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public final class LRUCapacityController extends LRUAlgorithm implements Declarable { @@ -346,7 +346,7 @@ public final class LRUCapacityController extends LRUAlgorithm /** * Returns a brief description of this capacity controller. * - * @since 4.0 + * @since GemFire 4.0 */ @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/lru/LRUClockNode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUClockNode.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUClockNode.java index 9516fd7..fd11644 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUClockNode.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/LRUClockNode.java @@ -29,7 +29,7 @@ public interface LRUClockNode { public int updateEntrySize(EnableLRU ccHelper); /** compute the new entry size and return the delta from the previous entry size * @param value then entry's value - * @since 6.1.2.9 + * @since GemFire 6.1.2.9 */ public int updateEntrySize(EnableLRU ccHelper, Object value); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/MemLRUCapacityController.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/MemLRUCapacityController.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/MemLRUCapacityController.java index e62f95d..d1634b4 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/MemLRUCapacityController.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/MemLRUCapacityController.java @@ -78,7 +78,7 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings; * @see LRUCapacityController * * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public final class MemLRUCapacityController extends LRUAlgorithm implements Declarable { @@ -533,7 +533,7 @@ public final class MemLRUCapacityController extends LRUAlgorithm /** * Returns a brief description of this capacity controller. * - * @since 4.0 + * @since GemFire 4.0 */ @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/lru/NewLIFOClockHand.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/NewLIFOClockHand.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/NewLIFOClockHand.java index 67a135e..4299f1c 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/NewLIFOClockHand.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/NewLIFOClockHand.java @@ -24,7 +24,7 @@ import com.gemstone.gemfire.internal.cache.AbstractRegionEntry; * NewLIFOClockHand holds the behavior for LIFO logic , Overwriting * getLRUEntry() to return most recently added Entry * - * @since 5.7 + * @since GemFire 5.7 */ public class NewLIFOClockHand extends NewLRUClockHand { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/OffHeapEvictor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/OffHeapEvictor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/OffHeapEvictor.java index 693a651..4b1270b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/OffHeapEvictor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/OffHeapEvictor.java @@ -29,7 +29,7 @@ import com.gemstone.gemfire.internal.offheap.MemoryAllocator; * Triggers centralized eviction(asynchronously) when the ResourceManager sends * an eviction event for off-heap regions. This is registered with the ResourceManager. * - * @since 9.0 + * @since Geode 1.0 */ public class OffHeapEvictor extends HeapEvictor { private static final String EVICTOR_THREAD_GROUP_NAME = "OffHeapEvictorThreadGroup"; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/Sizeable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/Sizeable.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/Sizeable.java index 32446c6..be67ebe 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/Sizeable.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/lru/Sizeable.java @@ -46,7 +46,7 @@ package com.gemstone.gemfire.internal.cache.lru; }<br> * * - * @since 3.2 + * @since GemFire 3.2 */ public interface Sizeable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/operations/ContainsKeyOperationContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/operations/ContainsKeyOperationContext.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/operations/ContainsKeyOperationContext.java index b3a7536..da2fcc7 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/operations/ContainsKeyOperationContext.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/operations/ContainsKeyOperationContext.java @@ -23,7 +23,7 @@ import com.gemstone.gemfire.cache.operations.KeyOperationContext; * Encapsulates a {@link com.gemstone.gemfire.cache.operations.OperationContext.OperationCode#CONTAINS_KEY} region operation having the * key object for the pre-operation case. * - * @since 5.5 + * @since GemFire 5.5 */ public class ContainsKeyOperationContext extends KeyOperationContext { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java index 6f5eb00..8951a50 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/AllBucketProfilesUpdateMessage.java @@ -42,7 +42,7 @@ import com.gemstone.gemfire.internal.logging.LogService; * A Partitioned Region meta-data update message. This is used to send * all local bucket's meta-data to other members with the same Partitioned Region. * - * @since 6.6 + * @since GemFire 6.6 */ public final class AllBucketProfilesUpdateMessage extends DistributionMessage implements MessageWithReply http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/Bucket.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/Bucket.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/Bucket.java index 094405d..77b1cd3 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/Bucket.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/Bucket.java @@ -64,7 +64,7 @@ public interface Bucket extends CacheDistributionAdvisee { /** * Report members that are currently hosting the bucket * @return set of members - * @since gemfire59poc + * @since GemFire 5.9 */ public Set/*InternalDistributedMembers*/ getBucketOwners(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketBackupMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketBackupMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketBackupMessage.java index 04d25e3..d6eff09 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketBackupMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketBackupMessage.java @@ -38,7 +38,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * if one or more needs to be backed-up in order to satisfy the redundantCopies * setting * - * @since 5.0 + * @since GemFire 5.0 */ public final class BucketBackupMessage extends PartitionMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketProfileUpdateMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketProfileUpdateMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketProfileUpdateMessage.java index 7345b44..1cba153 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketProfileUpdateMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketProfileUpdateMessage.java @@ -42,7 +42,7 @@ import com.gemstone.gemfire.internal.logging.LogService; * A Partitioned Region meta-data update message. This is used to send * a bucket's meta-data to other members with the same Partitioned Region. * - * @since 5.1 + * @since GemFire 5.1 */ public final class BucketProfileUpdateMessage extends DistributionMessage implements MessageWithReply http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketSizeMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketSizeMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketSizeMessage.java index 29d3dfb..5309f1f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketSizeMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/BucketSizeMessage.java @@ -44,7 +44,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * A message used to determine the number of bytes a Bucket consumes. - * @since 5.0 + * @since GemFire 5.0 */ public final class BucketSizeMessage extends PartitionMessage @@ -232,7 +232,7 @@ public final class BucketSizeMessage extends PartitionMessage /** * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} - * @since 5.0 + * @since GemFire 5.0 */ public static class BucketSizeResponse extends ReplyProcessor21 { private volatile long returnValue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ContainsKeyValueMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ContainsKeyValueMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ContainsKeyValueMessage.java index 4a9c684..f3f534a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ContainsKeyValueMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ContainsKeyValueMessage.java @@ -282,7 +282,7 @@ public final class ContainsKeyValueMessage extends PartitionMessageWithDirectRep * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.ContainsKeyValueMessage.ContainsKeyValueReplyMessage} * - * @since 5.0 + * @since GemFire 5.0 */ public static class ContainsKeyValueResponse extends PartitionResponse { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/CreateBucketMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/CreateBucketMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/CreateBucketMessage.java index d8b479f..6a3f4c0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/CreateBucketMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/CreateBucketMessage.java @@ -57,7 +57,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * the redundancy to be impaired if that datastore crashes (even if it * never hosted that bucket). * - * @since 6.0 + * @since GemFire 6.0 * */ public final class CreateBucketMessage extends PartitionMessage { @@ -198,7 +198,7 @@ public final class CreateBucketMessage extends PartitionMessage { /** * A class that contains the reply to a {@link CreateBucketMessage} message * which contains the {@link Node} that has accepted to manage the bucket. - * @since 5.0 + * @since GemFire 5.0 */ public static final class CreateBucketReplyMessage extends ReplyMessage { private InternalDistributedMember primary; @@ -296,7 +296,7 @@ public final class CreateBucketMessage extends PartitionMessage { /** * A processor to capture the {@link Node} returned by {@link CreateBucketMessage} - * @since 5.0 + * @since GemFire 5.0 */ static public class NodeResponse extends ReplyProcessor21 { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyMessage.java index c706a3c..2700c61 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyMessage.java @@ -71,7 +71,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Retained; * frequently, if they are not then it makes sense to fold the destroy and the * invalidate into the same message and use an extra bit to differentiate * - * @since 5.0 + * @since GemFire 5.0 * */ public class DestroyMessage extends PartitionMessageWithDirectReply { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java index 0130372..225d1af 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/DestroyRegionOnDataStoreMessage.java @@ -41,7 +41,7 @@ import com.gemstone.gemfire.internal.cache.PartitionedRegionDataStore; * A message sent to a data store telling that data store to globally * destroy the region on behalf of a PR accessor. * - * @since 5.0 + * @since GemFire 5.0 */ public final class DestroyRegionOnDataStoreMessage extends PartitionMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchBulkEntriesMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchBulkEntriesMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchBulkEntriesMessage.java index ea47e91..8a6563b 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchBulkEntriesMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchBulkEntriesMessage.java @@ -65,7 +65,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * - * @since 8.0 + * @since GemFire 8.0 */ public final class FetchBulkEntriesMessage extends PartitionMessage { @@ -477,7 +477,7 @@ public final class FetchBulkEntriesMessage extends PartitionMessage /** * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.FetchBulkEntriesMessage} - * @since 8.0 + * @since GemFire 8.0 */ public static class FetchBulkEntriesResponse extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntriesMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntriesMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntriesMessage.java index d27e33e..d7a3a5f 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntriesMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntriesMessage.java @@ -448,7 +448,7 @@ public final class FetchEntriesMessage extends PartitionMessage /** * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} - * @since 5.0 + * @since GemFire 5.0 */ public static class FetchEntriesResponse extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntryMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntryMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntryMessage.java index ae363ba..fafb546 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntryMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchEntryMessage.java @@ -60,7 +60,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * reply is sent in a {@link * com.gemstone.gemfire.internal.cache.partitioned.FetchEntryMessage.FetchEntryReplyMessage}. * - * @since 5.1 + * @since GemFire 5.1 */ public final class FetchEntryMessage extends PartitionMessage { @@ -241,7 +241,7 @@ public final class FetchEntryMessage extends PartitionMessage /** * This message is used for the reply to a {@link FetchEntryMessage}. * - * @since 5.0 + * @since GemFire 5.0 */ public static final class FetchEntryReplyMessage extends ReplyMessage { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchKeysMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchKeysMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchKeysMessage.java index d7c7d71..3faf1da 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchKeysMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FetchKeysMessage.java @@ -453,7 +453,7 @@ public final class FetchKeysMessage extends PartitionMessage /** * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} - * @since 5.0 + * @since GemFire 5.0 */ public static class FetchKeysResponse extends PartitionResponse { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FlushMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FlushMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FlushMessage.java index 1d9bf58..089c4ea 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FlushMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/FlushMessage.java @@ -44,7 +44,7 @@ import com.gemstone.gemfire.internal.logging.LogService; * as the reply. This was to leverage the fact that the message is a * {@link com.gemstone.gemfire.distributed.internal.SerialDistributionMessage}.</p> * - * @since 5.1 + * @since GemFire 5.1 */ public final class FlushMessage extends SerialDistributionMessage implements MessageWithReply { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/GetMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/GetMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/GetMessage.java index 3fef790..76cdeb3 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/GetMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/GetMessage.java @@ -75,7 +75,7 @@ import com.gemstone.gemfire.internal.util.BlobHelper; * Since the {@link com.gemstone.gemfire.cache.Region#get(Object)}operation is * used <bold>very </bold> frequently the performance of this class is critical. * - * @since 5.0 + * @since GemFire 5.0 */ public final class GetMessage extends PartitionMessageWithDirectReply { @@ -327,7 +327,7 @@ public final class GetMessage extends PartitionMessageWithDirectReply * is used <bold>very </bold> frequently the performance of this class is * critical. * - * @since 5.0 + * @since GemFire 5.0 */ public static final class GetReplyMessage extends ReplyMessage { @@ -534,7 +534,7 @@ public final class GetMessage extends PartitionMessageWithDirectReply * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} * - * @since 5.0 + * @since GemFire 5.0 */ public static class GetResponse extends PartitionResponse { private volatile GetReplyMessage getReply; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityRequestMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityRequestMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityRequestMessage.java index 31eb415..44bd06d 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityRequestMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityRequestMessage.java @@ -41,7 +41,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * A message sent to determine the most recent PartitionedRegion identity - * @since 5.0 + * @since GemFire 5.0 */ public final class IdentityRequestMessage extends DistributionMessage implements MessageWithReply { @@ -177,7 +177,7 @@ public final class IdentityRequestMessage extends DistributionMessage implements /** * The message that contains the <code>Integer</code> identity response to the {@link IdentityRequestMessage} * - * @since 5.0 + * @since GemFire 5.0 */ public static final class IdentityReplyMessage extends HighPriorityDistributionMessage { private int Id = UNINITIALIZED; @@ -276,7 +276,7 @@ public final class IdentityRequestMessage extends DistributionMessage implements /** * The response to a {@link IdentityRequestMessage} use {@link #waitForId()} to * capture the identity - * @since 5.0 + * @since GemFire 5.0 */ public static class IdentityResponse extends ReplyProcessor21 { private Integer returnValue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityUpdateMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityUpdateMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityUpdateMessage.java index 8605670..18f05e6 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityUpdateMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/IdentityUpdateMessage.java @@ -145,7 +145,7 @@ public final class IdentityUpdateMessage extends DistributionMessage implements /** * A processor that ignores exceptions, silently removing those nodes that reply with problems - * @since 5.0 + * @since GemFire 5.0 */ public static class IdentityUpdateResponse extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InterestEventMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InterestEventMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InterestEventMessage.java index ce242cd..3931e90 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InterestEventMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InterestEventMessage.java @@ -45,7 +45,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * This message is used as the notification that a client interest registration or * unregistration event occurred. * - * @since 5.8BetaSUISSE + * @since GemFire 5.8BetaSUISSE */ public class InterestEventMessage extends PartitionMessage { private static final Logger logger = LogService.getLogger(); @@ -157,7 +157,7 @@ public class InterestEventMessage extends PartitionMessage { /** * This message is used for the reply to a {@link InterestEventMessage}. * - * @since 5.8BetaSUISSE + * @since GemFire 5.8BetaSUISSE */ public static class InterestEventReplyMessage extends HighPriorityDistributionMessage { @@ -248,7 +248,7 @@ public class InterestEventMessage extends PartitionMessage { * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.InterestEventMessage.InterestEventReplyMessage} * - * @since 5.1 + * @since GemFire 5.1 */ public static class InterestEventResponse extends PartitionResponse { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InvalidateMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InvalidateMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InvalidateMessage.java index 60508c1..6f86acd 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InvalidateMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/InvalidateMessage.java @@ -89,7 +89,7 @@ public final class InvalidateMessage extends DestroyMessage { * @param original invalidateMessage originated at remote vm. * @param event EntryEventImpl generated by operation on the bucket region. * @param members list of members which needs old value. - * @since 5.5 + * @since GemFire 5.5 */ InvalidateMessage(InvalidateMessage original, EntryEventImpl event, Set members) { super(original, event, members); @@ -364,7 +364,7 @@ public final class InvalidateMessage extends DestroyMessage { } /** * A processor to capture the value returned by {@link InvalidateMessage} - * @since 5.1 + * @since GemFire 5.1 */ public static class InvalidateResponse extends PartitionResponse { private volatile boolean returnValueReceived; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBackupBucketMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBackupBucketMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBackupBucketMessage.java index 7c9070a..3ff2dae 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBackupBucketMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBackupBucketMessage.java @@ -47,7 +47,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * A request to manage a particular bucket * - * @since 5.0 + * @since GemFire 5.0 * */ public final class ManageBackupBucketMessage extends PartitionMessage { @@ -224,7 +224,7 @@ public final class ManageBackupBucketMessage extends PartitionMessage { /** * A class that contains the reply to a {@link ManageBackupBucketMessage} message * which contains the {@link Node} that has accepted to manage the bucket. - * @since 5.0 + * @since GemFire 5.0 */ public static final class ManageBackupBucketReplyMessage extends ReplyMessage { @@ -352,7 +352,7 @@ public final class ManageBackupBucketMessage extends PartitionMessage { /** * A processor to capture the {@link Node} returned by {@link ManageBackupBucketMessage} - * @since 5.0 + * @since GemFire 5.0 */ static public class NodeResponse extends ReplyProcessor21 { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBucketMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBucketMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBucketMessage.java index 25acd5a..3ca238c 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBucketMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/ManageBucketMessage.java @@ -47,7 +47,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * A request to manage a particular bucket * - * @since 5.0 + * @since GemFire 5.0 * */ public final class ManageBucketMessage extends PartitionMessage { @@ -209,7 +209,7 @@ public final class ManageBucketMessage extends PartitionMessage { /** * A class that contains the reply to a {@link ManageBucketMessage} message * which contains the {@link Node} that has accepted to manage the bucket. - * @since 5.0 + * @since GemFire 5.0 */ public static final class ManageBucketReplyMessage extends ReplyMessage { @@ -337,7 +337,7 @@ public final class ManageBucketMessage extends PartitionMessage { /** * A processor to capture the {@link Node} returned by {@link ManageBucketMessage} - * @since 5.0 + * @since GemFire 5.0 */ static public class NodeResponse extends ReplyProcessor21 { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLoad.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLoad.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLoad.java index f8f1f78..c33f8b1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLoad.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLoad.java @@ -28,7 +28,7 @@ import com.gemstone.gemfire.DataSerializer; * A class which holds the load for a partitioned region * on a given VM. * - * @since 6.0 + * @since GemFire 6.0 */ public final class PRLoad implements DataSerializable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLocallyDestroyedException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLocallyDestroyedException.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLocallyDestroyedException.java index 6ea159e..d5d3fef 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLocallyDestroyedException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRLocallyDestroyedException.java @@ -22,7 +22,7 @@ import com.gemstone.gemfire.internal.cache.DataLocationException; /** * An exception indicating that a PartitionedRegion was found to be Locally * Destroyed - * @since 5.1 + * @since GemFire 5.1 * */ public class PRLocallyDestroyedException extends DataLocationException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRTombstoneMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRTombstoneMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRTombstoneMessage.java index d004182..d5d43cb 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRTombstoneMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PRTombstoneMessage.java @@ -50,7 +50,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; /** * This message class sends tombstone GC information to other PR holders - * @since 7.0 + * @since GemFire 7.0 */ public final class PRTombstoneMessage extends PartitionMessageWithDirectReply implements SerializationVersions { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage.java index 626efef..db4cc59 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionMessage.java @@ -71,7 +71,7 @@ import com.gemstone.gemfire.internal.sequencelog.EntryLogger; * The base PartitionedRegion message type upon which other messages should be * based. * - * @since 5.0 + * @since GemFire 5.0 */ public abstract class PartitionMessage extends DistributionMessage implements MessageWithReply, TransactionMessage @@ -644,7 +644,7 @@ public abstract class PartitionMessage extends DistributionMessage implements /** * added to support old value to be written on wire. * @param value true or false - * @since 5.5 + * @since GemFire 5.5 */ public void setHasOldValue(boolean value) { // override in subclasses which need old value to be serialized. @@ -700,7 +700,7 @@ public abstract class PartitionMessage extends DistributionMessage implements * recipient, capturing any CacheException thrown by the recipient and handle * it as an expected exception. * - * @since 5.0 + * @since GemFire 5.0 * @see #waitForCacheException() */ public static class PartitionResponse extends DirectReplyProcessor { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PrimaryRequestMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PrimaryRequestMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PrimaryRequestMessage.java index 5ae1b1f..42ff7bc 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PrimaryRequestMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PrimaryRequestMessage.java @@ -180,7 +180,7 @@ public final class PrimaryRequestMessage extends PartitionMessage /** * A processor to capture the member who was selected as primary for the bucket requested - * @since 5.1 + * @since GemFire 5.1 */ static public class PrimaryResponse extends ReplyProcessor21 { private volatile PrimaryRequestReplyMessage msg; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage.java index 8aaf587..7bbe5ce 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutAllPRMessage.java @@ -80,7 +80,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Retained; * a bucket's primary owner. In addition to updating an entry it is also used to * send Partitioned Region event information. * - * @since 6.0 + * @since GemFire 6.0 */ public final class PutAllPRMessage extends PartitionMessageWithDirectReply { @@ -839,7 +839,7 @@ public final class PutAllPRMessage extends PartitionMessageWithDirectReply /** * A processor to capture the value returned by {@link PutAllPRMessage} - * @since 5.8 + * @since GemFire 5.8 */ public static class PutAllResponse extends PartitionResponse { private volatile boolean returnValue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutMessage.java index a6a39dc..db137c6 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/PutMessage.java @@ -80,7 +80,7 @@ import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifie * a bucket's primary owner. In addition to updating an entry it is also used to * send Partitioned Region event information. * - * @since 5.0 + * @since GemFire 5.0 */ public final class PutMessage extends PartitionMessageWithDirectReply implements NewValueImporter { private static final Logger logger = LogService.getLogger(); @@ -1205,7 +1205,7 @@ public final class PutMessage extends PartitionMessageWithDirectReply implements /** * A processor to capture the value returned by {@link PutMessage} - * @since 5.1 + * @since GemFire 5.1 */ public static class PutResponse extends PartitionResponse { private volatile boolean returnValue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RegionAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RegionAdvisor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RegionAdvisor.java index 03df3fb..bdb3c25 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RegionAdvisor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RegionAdvisor.java @@ -556,7 +556,7 @@ public class RegionAdvisor extends CacheDistributionAdvisor /** * requiresNotification determines whether a member needs to be notified of cache * operations so that cache listeners and other hooks can be engaged - * @since 5.1 + * @since GemFire 5.1 */ public boolean requiresNotification = false; @@ -1033,7 +1033,7 @@ public class RegionAdvisor extends CacheDistributionAdvisor /** * return the set of all members who must receive operation notifications - * @since 5.1 + * @since GemFire 5.1 * */ public Set adviseRequiresNotification(final EntryEventImpl event) { return adviseFilter(new Filter() { @@ -1816,7 +1816,7 @@ public class RegionAdvisor extends CacheDistributionAdvisor * A real bucket profile is one that for a bucket that actually has storage * in this vm. * @return a list of BucketProfileAndId instances; may be null - * @since 5.5 + * @since GemFire 5.5 */ public ArrayList getBucketRegionProfiles() { final ProxyBucketRegion[] bucs = this.buckets; @@ -1842,7 +1842,7 @@ public class RegionAdvisor extends CacheDistributionAdvisor /** * Takes a list of BucketProfileAndId and adds them to thsi advisors * proxy buckets. - * @since 5.5 + * @since GemFire 5.5 */ public void putBucketRegionProfiles(ArrayList l) { int size = l.size(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoteSizeMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoteSizeMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoteSizeMessage.java index 566a222..f909692 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoteSizeMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoteSizeMessage.java @@ -46,7 +46,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * This message is used to determine the number of Entries in a Region, or its * size. * - * @since 5.0 + * @since GemFire 5.0 */ public final class RemoteSizeMessage extends RemoteOperationMessage { @@ -301,7 +301,7 @@ public final class RemoteSizeMessage extends RemoteOperationMessage * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} * - * @since 5.0 + * @since GemFire 5.0 */ public static class SizeResponse extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoveAllPRMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoveAllPRMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoveAllPRMessage.java index fb46e0c..125cdb0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoveAllPRMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/RemoveAllPRMessage.java @@ -79,7 +79,7 @@ import com.gemstone.gemfire.internal.offheap.annotations.Retained; /** * PR removeAll * - * @since 8.1 + * @since GemFire 8.1 */ public final class RemoveAllPRMessage extends PartitionMessageWithDirectReply { @@ -769,7 +769,7 @@ public final class RemoveAllPRMessage extends PartitionMessageWithDirectReply /** * A processor to capture the value returned by {@link RemoveAllPRMessage} - * @since 8.1 + * @since GemFire 8.1 */ public static class RemoveAllResponse extends PartitionResponse { private volatile boolean returnValue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizeMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizeMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizeMessage.java index 2c5064e..1fa049a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizeMessage.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizeMessage.java @@ -51,7 +51,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * This message is used to determine the number of Entries in a Region, or its * size. * - * @since 5.0 + * @since GemFire 5.0 */ public final class SizeMessage extends PartitionMessage { @@ -312,7 +312,7 @@ public final class SizeMessage extends PartitionMessage * A processor to capture the value returned by {@link * com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetReplyMessage} * - * @since 5.0 + * @since GemFire 5.0 */ public static class SizeResponse extends ReplyProcessor21 { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizedBasedLoadProbe.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizedBasedLoadProbe.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizedBasedLoadProbe.java index 52a7c5f..068c6a4 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizedBasedLoadProbe.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/SizedBasedLoadProbe.java @@ -29,7 +29,7 @@ import java.io.IOException; * A load probe which calculates the load of a pr using * the size of the buckets in bytes. * - * @since 6.0 + * @since GemFire 6.0 */ public class SizedBasedLoadProbe implements LoadProbe, DataSerializableFixedID { private static final long serialVersionUID = 7040814060882774875L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/PartitionedRegionLoadModel.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/PartitionedRegionLoadModel.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/PartitionedRegionLoadModel.java index 1cfa4a4..6111561 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/PartitionedRegionLoadModel.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/partitioned/rebalance/PartitionedRegionLoadModel.java @@ -70,7 +70,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; * * This model is not threadsafe. * - * @since 6.0 + * @since GemFire 6.0 * */ @SuppressWarnings("synthetic-access") http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/BytesAndBits.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/BytesAndBits.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/BytesAndBits.java index e5af55b..c55dae0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/BytesAndBits.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/BytesAndBits.java @@ -21,7 +21,7 @@ import com.gemstone.gemfire.internal.Version; /** * Used to fetch a record's raw bytes and user bits. * - * @since prPersistSprint1 + * @since GemFire prPersistSprint1 */ public class BytesAndBits { private final byte[] data; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/DiskRecoveryStore.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/DiskRecoveryStore.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/DiskRecoveryStore.java index a9238c8..4d2e80d 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/DiskRecoveryStore.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/DiskRecoveryStore.java @@ -34,7 +34,7 @@ import com.gemstone.gemfire.internal.cache.versions.VersionTag; * The primary implementor of this interface is LocalRegion. * * - * @since prPersistSprint3 + * @since GemFire prPersistSprint3 */ public interface DiskRecoveryStore { public DiskRegionView getDiskRegionView(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/PersistentMemberPattern.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/PersistentMemberPattern.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/PersistentMemberPattern.java index 193a558..a0e1f0a 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/PersistentMemberPattern.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/PersistentMemberPattern.java @@ -34,7 +34,7 @@ import com.gemstone.gemfire.internal.SocketCreator; * has revoked. Any fields that are null will be considered a wildcard * matching any members. * - * @since prPersistSprint1 + * @since GemFire prPersistSprint1 */ public class PersistentMemberPattern implements PersistentID, Comparable<PersistentMemberPattern> { protected InetAddress host; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/IndexMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/IndexMap.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/IndexMap.java index c51d38b..9d906ce 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/IndexMap.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/IndexMap.java @@ -38,7 +38,7 @@ import com.gemstone.gemfire.internal.cache.CachedDeserializable; * * TODO - Do we need getKey, getValue, * - * @since cedar + * @since GemFire cedar */ public interface IndexMap { @@ -163,7 +163,7 @@ public interface IndexMap { /** * A single entry in an index - * @since cedar + * @since GemFire cedar */ interface IndexEntry { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultBag.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultBag.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultBag.java index c7cf05e..e24ab90 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultBag.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultBag.java @@ -35,7 +35,7 @@ import com.gemstone.gemfire.internal.cache.CachedDeserializable; * The result set should be closed using the close method to free up resources * when it is no longer in use. * - * @since cedar + * @since GemFire cedar */ public interface ResultBag { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultList.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultList.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultList.java index 26cb115..9e04bc0 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultList.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultList.java @@ -27,7 +27,7 @@ import com.gemstone.gemfire.internal.cache.CachedDeserializable; * may or may not reflect modifications to the set while the iteration is in progress. * They will guarantee that entries will be returned in the correct order. * - * @since cedar + * @since GemFire cedar */ public interface ResultList { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultMap.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultMap.java index 5c86c5d..6ca2ee1 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultMap.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultMap.java @@ -29,7 +29,7 @@ import com.gemstone.gemfire.internal.cache.CachedDeserializable; * * The key and value are both allowed to be an object, or a CachedDeserializable. * - * @since cedar + * @since GemFire cedar */ public interface ResultMap { @@ -107,7 +107,7 @@ public interface ResultMap { /** * A single entry in an index - * @since cedar + * @since GemFire cedar */ interface Entry { /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultSet.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultSet.java index 2649118..47ec854 100644 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultSet.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/persistence/query/ResultSet.java @@ -35,7 +35,7 @@ import com.gemstone.gemfire.internal.cache.CachedDeserializable; * The result set should be closed using the close method to free up resources * when it is no longer in use. * - * @since cedar + * @since GemFire cedar */ public interface ResultSet { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/properties.html ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/properties.html b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/properties.html index 1cd1b72..5c27a71 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/properties.html +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/properties.html @@ -2568,7 +2568,7 @@ See <code>com.gemstone.gemfire.distributed.DistributedSystem#PROPERTY_FILE</code system path then the above search is done. If it is an absolute file system path then that file must exist; no search for it is done. - @since 5.0 + @since GemFire 5.0 </pre> <p> TBA http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/Acceptor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/Acceptor.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/Acceptor.java index 59cd367..1d1100b 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/Acceptor.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/Acceptor.java @@ -26,7 +26,7 @@ import com.gemstone.gemfire.internal.Version; * Server. Multiple communication stacks may provide implementations for the * interfaces defined in this package * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public abstract class Acceptor { @@ -80,7 +80,7 @@ public abstract class Acceptor /** * The GFE version of the server. - * @since 5.7 + * @since GemFire 5.7 */ public static final Version VERSION = Version.CURRENT.getGemFireVersion(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/BatchException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/BatchException.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/BatchException.java index f5b761d..38718ee 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/BatchException.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/BatchException.java @@ -22,7 +22,7 @@ import com.gemstone.gemfire.GemFireCheckedException; * An exception thrown during batch processing. * * - * @since 4.2 + * @since GemFire 4.2 */ // 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/tier/CachedRegionHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/CachedRegionHelper.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/CachedRegionHelper.java index 4e382f5..8897dd7 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/CachedRegionHelper.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/CachedRegionHelper.java @@ -25,7 +25,7 @@ import com.gemstone.gemfire.internal.cache.InternalCache; /** * Helper class that maintains a weak hashmap of referenced regions * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public class CachedRegionHelper { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ClientHandShake.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ClientHandShake.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ClientHandShake.java index 0906bd5..51e537a 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ClientHandShake.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ClientHandShake.java @@ -28,7 +28,7 @@ import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; /** * <code>ClientHandShake</code> represents a handshake from the client. * - * @since 5.7 + * @since GemFire 5.7 */ public interface ClientHandShake { public boolean isOK(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ConnectionProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ConnectionProxy.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ConnectionProxy.java index 02f1714..a0e6252 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ConnectionProxy.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/ConnectionProxy.java @@ -21,14 +21,14 @@ import com.gemstone.gemfire.internal.Version; /** * Provides the version of the client. * - * @since 2.0.2 + * @since GemFire 2.0.2 */ @SuppressWarnings("deprecation") public interface ConnectionProxy { /** * The GFE version of the client. - * @since 5.7 + * @since GemFire 5.7 */ public static final Version VERSION = Version.CURRENT.getGemFireVersion(); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InterestType.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InterestType.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InterestType.java index ccacb5f..469d7d7 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InterestType.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InterestType.java @@ -20,7 +20,7 @@ package com.gemstone.gemfire.internal.cache.tier; * Pre-defined interest list types supported by the system * * @version $Revision: 13166 $ - * @since 2.0.2 + * @since GemFire 2.0.2 */ public class InterestType { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InternalClientMembership.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InternalClientMembership.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InternalClientMembership.java index 7e1ae2a..04752b3 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InternalClientMembership.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/InternalClientMembership.java @@ -56,7 +56,7 @@ import com.gemstone.gemfire.management.membership.ClientMembershipListener; * <code>ClientMembershipListener</code>s. The public counterpart for this * class is {@link com.gemstone.gemfire.management.membership.ClientMembership}. * - * @since 4.2.1 + * @since GemFire 4.2.1 */ public final class InternalClientMembership { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/MessageType.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/MessageType.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/MessageType.java index fdba064..4af7ccc 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/MessageType.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/MessageType.java @@ -19,7 +19,7 @@ package com.gemstone.gemfire.internal.cache.tier; /** * Pre-defined message types supported by the system * - * @since 2.0.2 + * @since GemFire 2.0.2 */ public class MessageType { /** An invalid message, typically due to problems receiving a complete message */ @@ -47,118 +47,118 @@ public class MessageType { /** Put data into the cache * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int PUT = 7; /** The put request data was bad (null key or value, for example) * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int PUT_DATA_ERROR = 8; /** Destroy an entry from the cache * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int DESTROY = 9; /** The destroy request data was bad (null key, for example) * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int DESTROY_DATA_ERROR = 10; /** Destroy a region from the cache * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int DESTROY_REGION = 11; /** The destroy region request data was bad (null region name, for example) * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int DESTROY_REGION_DATA_ERROR = 12; /** A client wished to be notified of updates * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int CLIENT_NOTIFICATION = 13; /** Information about a client receiving updates has changed * - * @since 3.5 + * @since GemFire 3.5 */ public static final int UPDATE_CLIENT_NOTIFICATION = 14; /** The receiver (which is an edge client in this case) should * locally invalidate a piece of data * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int LOCAL_INVALIDATE = 15; /** The receiver (which is an edge client in this case) should * locally destroy a piece of data * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int LOCAL_DESTROY = 16; /** The receiver (which is an edge client in this case) should * locally destroy a region * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int LOCAL_DESTROY_REGION = 17; /** A message to close the client connection * - * @since 3.5 */ + * @since GemFire 3.5 */ public static final int CLOSE_CONNECTION = 18; /** A message to process a batch of messages * - * @since 4.1.1 */ + * @since GemFire 4.1.1 */ public static final int PROCESS_BATCH = 19; /** A message to register interest in a specific key * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int REGISTER_INTEREST = 20; /** The register interest request data was bad (null region name, for example) * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int REGISTER_INTEREST_DATA_ERROR = 21; /** A message to unregister interest in a specific key * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int UNREGISTER_INTEREST = 22; /** The unregister interest request data was bad (null region name, for example) * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int UNREGISTER_INTEREST_DATA_ERROR = 23; /** A message to register interest in a specific list of keys * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int REGISTER_INTEREST_LIST = 24; /** A message to unregister interest in a specific list of keys * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int UNREGISTER_INTEREST_LIST = 25; /** An unknown message type. This is being used for responses. * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int UNKNOWN_MESSAGE_TYPE_ERROR = 26; /** The receiver (which is an edge client in this case) should * locally create a piece of data * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int LOCAL_CREATE = 27; /** The receiver (which is an edge client in this case) should * locally update a piece of data * - * @since 4.1.2 */ + * @since GemFire 4.1.2 */ public static final int LOCAL_UPDATE = 28; public static final int CREATE_REGION = 29; @@ -166,17 +166,17 @@ public class MessageType { /** * A message to make primary server - * @since 5.1 + * @since GemFire 5.1 */ public static final int MAKE_PRIMARY = 31; /** Response message type from primary server - * @since 5.1 + * @since GemFire 5.1 */ public static final int RESPONSE_FROM_PRIMARY = 32; /** Response message type from secondary server - * @since 5.1 + * @since GemFire 5.1 */ public static final int RESPONSE_FROM_SECONDARY = 33; @@ -184,7 +184,7 @@ public class MessageType { * A query request message * * <p>author gregp - * @since 4.1.1 + * @since GemFire 4.1.1 */ public static final int QUERY = 34; @@ -222,7 +222,7 @@ public class MessageType { /** A message to register the Instantiators. * - * @since 5.0 + * @since GemFire 5.0 */ public static final int REGISTER_INSTANTIATORS = 51; @@ -319,10 +319,10 @@ public class MessageType { public static final int GET_ALL_70 = 100; - /** gets the pdx type definitions @since 7.0 */ + /** gets the pdx type definitions @since GemFire 7.0 */ public static final int GET_PDX_TYPES = 101; - /** gets the pdx enum definitions @since 7.0 */ + /** gets the pdx enum definitions @since GemFire 7.0 */ public static final int GET_PDX_ENUMS = 102; public static final int TOMBSTONE_OPERATION = 103; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8eac0fa8/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/AcceptorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/AcceptorImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/AcceptorImpl.java index c2f3828..e1c22b7 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/AcceptorImpl.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/AcceptorImpl.java @@ -95,7 +95,7 @@ import com.gemstone.gemfire.internal.util.ArrayUtils; * Implements the acceptor thread on the bridge server. Accepts connections from * the edge and starts up threads to process requests from these. * - * @since 2.0.2 + * @since GemFire 2.0.2 */ @SuppressWarnings("deprecation") public class AcceptorImpl extends Acceptor implements Runnable @@ -243,7 +243,7 @@ public class AcceptorImpl extends Acceptor implements Runnable * The ip address or host name this acceptor is to bind to; * <code>null</code> or "" indicates * it will listen on all local addresses. - * @since 5.7 + * @since GemFire 5.7 */ private final String bindHostName; @@ -296,7 +296,7 @@ public class AcceptorImpl extends Acceptor implements Runnable * * @see SocketCreator#createServerSocket(int, int, InetAddress) * @see ClientHealthMonitor - * @since 5.7 + * @since GemFire 5.7 */ public AcceptorImpl(int port, String bindHostName, boolean notifyBySubscription, @@ -1700,7 +1700,7 @@ public class AcceptorImpl extends Acceptor implements Runnable // /** // * Calculates the bind address based on gemfire.properties. // * Returns null if no bind address is configured. -// * @since 5.7 +// * @since GemFire 5.7 // */ // public static InetAddress calcBindAddress(Cache cache) throws IOException { // InternalDistributedSystem system = (InternalDistributedSystem)cache @@ -1728,7 +1728,7 @@ public class AcceptorImpl extends Acceptor implements Runnable * @return the ip address or host name this acceptor will listen on. * An "" if all local addresses will be listened to. - * @since 5.7 + * @since GemFire 5.7 */ private static String calcBindHostName(Cache cache, String bindName) { if (bindName != null && !bindName.equals("")) { @@ -1766,7 +1766,7 @@ public class AcceptorImpl extends Acceptor implements Runnable /** * Gets the address that this bridge server can be contacted on from external * processes. - * @since 5.7 + * @since GemFire 5.7 */ public String getExternalAddress() { String result = this.bindHostName;
