You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2017/10/23 23:26:14 UTC
[geode] branch develop updated: GEODE-3764: prevent early idle
expiration (#940)
This is an automated email from the ASF dual-hosted git repository.
dschneider pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 0259f77 GEODE-3764: prevent early idle expiration (#940)
0259f77 is described below
commit 0259f7765a7043813f0a786a7fd5d01e422d2408
Author: Darrel Schneider <ds...@pivotal.io>
AuthorDate: Mon Oct 23 16:26:11 2017 -0700
GEODE-3764: prevent early idle expiration (#940)
Idle expiration now sends a message to others checking
if they have been read more recently. If so and if given
the new last access time the entry is not expired then
the expiration is rescheduled.
This is only done for distributed expiration actions.
This change applies to both replicates and partitioned regions.
The system property "geode.restoreIdleExpirationBehavior" can
be set to true to restore the previous idle expiration behavior.
---
.../org/apache/geode/internal/DSFIDFactory.java | 2 +
.../geode/internal/DataSerializableFixedID.java | 4 +-
.../java/org/apache/geode/internal/Version.java | 1 +
.../geode/internal/cache/DistributedRegion.java | 9 +-
.../geode/internal/cache/EntryExpiryTask.java | 32 ++++++
.../apache/geode/internal/cache/ExpiryTask.java | 37 +++++-
...lRegion.java => InternalDistributedRegion.java} | 23 +---
.../geode/internal/cache/InternalRegion.java | 5 +-
.../cache/LatestLastAccessTimeMessage.java | 93 +++++++++++++++
.../cache/LatestLastAccessTimeOperation.java | 60 ++++++++++
.../cache/LatestLastAccessTimeReplyProcessor.java | 69 +++++++++++
.../geode/internal/cache/LeafRegionEntry.cpp | 3 +-
.../apache/geode/internal/cache/LocalRegion.java | 9 ++
.../apache/geode/internal/cache/RegionEntry.java | 7 ++
.../cache/VMStatsDiskLRURegionEntryHeapIntKey.java | 3 +-
.../VMStatsDiskLRURegionEntryHeapLongKey.java | 3 +-
.../VMStatsDiskLRURegionEntryHeapObjectKey.java | 3 +-
.../VMStatsDiskLRURegionEntryHeapStringKey1.java | 3 +-
.../VMStatsDiskLRURegionEntryHeapStringKey2.java | 3 +-
.../VMStatsDiskLRURegionEntryHeapUUIDKey.java | 3 +-
.../VMStatsDiskLRURegionEntryOffHeapIntKey.java | 3 +-
.../VMStatsDiskLRURegionEntryOffHeapLongKey.java | 3 +-
.../VMStatsDiskLRURegionEntryOffHeapObjectKey.java | 3 +-
...VMStatsDiskLRURegionEntryOffHeapStringKey1.java | 3 +-
...VMStatsDiskLRURegionEntryOffHeapStringKey2.java | 3 +-
.../VMStatsDiskLRURegionEntryOffHeapUUIDKey.java | 3 +-
.../cache/VMStatsDiskRegionEntryHeapIntKey.java | 3 +-
.../cache/VMStatsDiskRegionEntryHeapLongKey.java | 3 +-
.../cache/VMStatsDiskRegionEntryHeapObjectKey.java | 3 +-
.../VMStatsDiskRegionEntryHeapStringKey1.java | 3 +-
.../VMStatsDiskRegionEntryHeapStringKey2.java | 3 +-
.../cache/VMStatsDiskRegionEntryHeapUUIDKey.java | 3 +-
.../cache/VMStatsDiskRegionEntryOffHeapIntKey.java | 3 +-
.../VMStatsDiskRegionEntryOffHeapLongKey.java | 3 +-
.../VMStatsDiskRegionEntryOffHeapObjectKey.java | 3 +-
.../VMStatsDiskRegionEntryOffHeapStringKey1.java | 3 +-
.../VMStatsDiskRegionEntryOffHeapStringKey2.java | 3 +-
.../VMStatsDiskRegionEntryOffHeapUUIDKey.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapIntKey.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapLongKey.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapObjectKey.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapStringKey1.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapStringKey2.java | 3 +-
.../cache/VMStatsLRURegionEntryHeapUUIDKey.java | 3 +-
.../cache/VMStatsLRURegionEntryOffHeapIntKey.java | 3 +-
.../cache/VMStatsLRURegionEntryOffHeapLongKey.java | 3 +-
.../VMStatsLRURegionEntryOffHeapObjectKey.java | 3 +-
.../VMStatsLRURegionEntryOffHeapStringKey1.java | 3 +-
.../VMStatsLRURegionEntryOffHeapStringKey2.java | 3 +-
.../cache/VMStatsLRURegionEntryOffHeapUUIDKey.java | 3 +-
.../cache/VMStatsRegionEntryHeapIntKey.java | 3 +-
.../cache/VMStatsRegionEntryHeapLongKey.java | 3 +-
.../cache/VMStatsRegionEntryHeapObjectKey.java | 3 +-
.../cache/VMStatsRegionEntryHeapStringKey1.java | 3 +-
.../cache/VMStatsRegionEntryHeapStringKey2.java | 3 +-
.../cache/VMStatsRegionEntryHeapUUIDKey.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapIntKey.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapLongKey.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapObjectKey.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapStringKey1.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapStringKey2.java | 3 +-
.../cache/VMStatsRegionEntryOffHeapUUIDKey.java | 3 +-
...VersionedStatsDiskLRURegionEntryHeapIntKey.java | 3 +-
...ersionedStatsDiskLRURegionEntryHeapLongKey.java | 3 +-
...sionedStatsDiskLRURegionEntryHeapObjectKey.java | 3 +-
...ionedStatsDiskLRURegionEntryHeapStringKey1.java | 3 +-
...ionedStatsDiskLRURegionEntryHeapStringKey2.java | 3 +-
...ersionedStatsDiskLRURegionEntryHeapUUIDKey.java | 3 +-
...sionedStatsDiskLRURegionEntryOffHeapIntKey.java | 3 +-
...ionedStatsDiskLRURegionEntryOffHeapLongKey.java | 3 +-
...nedStatsDiskLRURegionEntryOffHeapObjectKey.java | 3 +-
...edStatsDiskLRURegionEntryOffHeapStringKey1.java | 3 +-
...edStatsDiskLRURegionEntryOffHeapStringKey2.java | 3 +-
...ionedStatsDiskLRURegionEntryOffHeapUUIDKey.java | 3 +-
.../VersionedStatsDiskRegionEntryHeapIntKey.java | 3 +-
.../VersionedStatsDiskRegionEntryHeapLongKey.java | 3 +-
...VersionedStatsDiskRegionEntryHeapObjectKey.java | 3 +-
...ersionedStatsDiskRegionEntryHeapStringKey1.java | 3 +-
...ersionedStatsDiskRegionEntryHeapStringKey2.java | 3 +-
.../VersionedStatsDiskRegionEntryHeapUUIDKey.java | 3 +-
...VersionedStatsDiskRegionEntryOffHeapIntKey.java | 3 +-
...ersionedStatsDiskRegionEntryOffHeapLongKey.java | 3 +-
...sionedStatsDiskRegionEntryOffHeapObjectKey.java | 3 +-
...ionedStatsDiskRegionEntryOffHeapStringKey1.java | 3 +-
...ionedStatsDiskRegionEntryOffHeapStringKey2.java | 3 +-
...ersionedStatsDiskRegionEntryOffHeapUUIDKey.java | 3 +-
.../VersionedStatsLRURegionEntryHeapIntKey.java | 3 +-
.../VersionedStatsLRURegionEntryHeapLongKey.java | 3 +-
.../VersionedStatsLRURegionEntryHeapObjectKey.java | 3 +-
...VersionedStatsLRURegionEntryHeapStringKey1.java | 3 +-
...VersionedStatsLRURegionEntryHeapStringKey2.java | 3 +-
.../VersionedStatsLRURegionEntryHeapUUIDKey.java | 3 +-
.../VersionedStatsLRURegionEntryOffHeapIntKey.java | 3 +-
...VersionedStatsLRURegionEntryOffHeapLongKey.java | 3 +-
...rsionedStatsLRURegionEntryOffHeapObjectKey.java | 3 +-
...sionedStatsLRURegionEntryOffHeapStringKey1.java | 3 +-
...sionedStatsLRURegionEntryOffHeapStringKey2.java | 3 +-
...VersionedStatsLRURegionEntryOffHeapUUIDKey.java | 3 +-
.../cache/VersionedStatsRegionEntryHeapIntKey.java | 3 +-
.../VersionedStatsRegionEntryHeapLongKey.java | 3 +-
.../VersionedStatsRegionEntryHeapObjectKey.java | 3 +-
.../VersionedStatsRegionEntryHeapStringKey1.java | 3 +-
.../VersionedStatsRegionEntryHeapStringKey2.java | 3 +-
.../VersionedStatsRegionEntryHeapUUIDKey.java | 3 +-
.../VersionedStatsRegionEntryOffHeapIntKey.java | 3 +-
.../VersionedStatsRegionEntryOffHeapLongKey.java | 3 +-
.../VersionedStatsRegionEntryOffHeapObjectKey.java | 3 +-
...VersionedStatsRegionEntryOffHeapStringKey1.java | 3 +-
...VersionedStatsRegionEntryOffHeapStringKey2.java | 3 +-
.../VersionedStatsRegionEntryOffHeapUUIDKey.java | 3 +-
.../geode/internal/lang/SystemPropertyHelper.java | 13 +++
.../internal/cache/PREntryIdleExpirationTest.java | 50 ++++++++
.../cache/ReplicateEntryIdleExpirationTest.java | 128 +++++++++++++++++++++
.../codeAnalysis/sanctionedDataSerializables.txt | 4 +
114 files changed, 710 insertions(+), 127 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/DSFIDFactory.java b/geode-core/src/main/java/org/apache/geode/internal/DSFIDFactory.java
index d60a913..1edb488 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/DSFIDFactory.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/DSFIDFactory.java
@@ -239,6 +239,7 @@ import org.apache.geode.internal.cache.InvalidatePartitionedRegionMessage;
import org.apache.geode.internal.cache.InvalidateRegionOperation.InvalidateRegionMessage;
import org.apache.geode.internal.cache.JtaAfterCompletionMessage;
import org.apache.geode.internal.cache.JtaBeforeCompletionMessage;
+import org.apache.geode.internal.cache.LatestLastAccessTimeMessage;
import org.apache.geode.internal.cache.MemberFunctionStreamingMessage;
import org.apache.geode.internal.cache.Node;
import org.apache.geode.internal.cache.PRQueryProcessor;
@@ -831,6 +832,7 @@ public class DSFIDFactory implements DataSerializableFixedID {
registerDSFID(DURABLE_CLIENT_INFO_REQUEST, DurableClientInfoRequest.class);
registerDSFID(DURABLE_CLIENT_INFO_RESPONSE, DurableClientInfoResponse.class);
registerDSFID(CLIENT_INTEREST_MESSAGE, ClientInterestMessageImpl.class);
+ registerDSFID(LATEST_LAST_ACCESS_TIME_MESSAGE, LatestLastAccessTimeMessage.class);
registerDSFID(STAT_ALERT_DEFN_NUM_THRESHOLD, NumberThresholdDecoratorImpl.class);
registerDSFID(STAT_ALERT_DEFN_GAUGE_THRESHOLD, GaugeThresholdDecoratorImpl.class);
registerDSFID(CLIENT_HEALTH_STATS, ClientHealthStats.class);
diff --git a/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java b/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
index 7f8cd5d..32e89b6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
@@ -234,7 +234,9 @@ public interface DataSerializableFixedID extends SerializationVersions {
public static final byte CLIENT_INTEREST_MESSAGE = -21;
- // IDs -20 .. -16 are not used
+ public static final byte LATEST_LAST_ACCESS_TIME_MESSAGE = -20;
+
+ // IDs -19 .. -16 are not used
/**
* A header byte meaning that the next element in the stream is a <code>VMIdProfile</code>.
diff --git a/geode-core/src/main/java/org/apache/geode/internal/Version.java b/geode-core/src/main/java/org/apache/geode/internal/Version.java
index aa91c40..15a4366 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/Version.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/Version.java
@@ -207,6 +207,7 @@ public class Version implements Comparable<Version> {
public static final Version GEODE_140 =
new Version("GEODE", "1.4.0", (byte) 1, (byte) 4, (byte) 0, (byte) 0, GEODE_140_ORDINAL);
+
/**
* This constant must be set to the most current version of the product. !!! NOTE: update
* HIGHEST_VERSION when changing CURRENT !!!
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java
index c76e813..7111c83 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java
@@ -127,7 +127,7 @@ import org.apache.geode.internal.sequencelog.RegionLogger;
import org.apache.geode.internal.util.concurrent.StoppableCountDownLatch;
@SuppressWarnings("deprecation")
-public class DistributedRegion extends LocalRegion implements CacheDistributionAdvisee {
+public class DistributedRegion extends LocalRegion implements InternalDistributedRegion {
private static final Logger logger = LogService.getLogger();
/** causes cache profile to be added to afterRemoteRegionCreate notification for testing */
@@ -3869,4 +3869,11 @@ public class DistributedRegion extends LocalRegion implements CacheDistributionA
public boolean hasNetLoader() {
return this.hasNetLoader(getCacheDistributionAdvisor());
}
+
+ @Override
+ public long getLatestLastAccessTimeFromOthers(Object key) {
+ LatestLastAccessTimeOperation op = new LatestLastAccessTimeOperation(this, key);
+ return op.getLatestLastAccessTime();
+ }
+
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java
index 45df435..294f221 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java
@@ -22,6 +22,7 @@ package org.apache.geode.internal.cache;
import org.apache.geode.cache.*;
import org.apache.geode.distributed.internal.DistributionConfig;
import org.apache.geode.internal.InternalStatisticsDisabledException;
+import org.apache.geode.internal.lang.SystemPropertyHelper;
import org.apache.geode.internal.logging.LogService;
import org.apache.geode.internal.offheap.annotations.Released;
import org.apache.logging.log4j.Logger;
@@ -253,6 +254,37 @@ public class EntryExpiryTask extends ExpiryTask {
return action;
}
+ @Override
+ protected boolean isIdleExpiredOnOthers() throws EntryNotFoundException {
+ if (getIdleAttributes().getTimeout() <= 0L) {
+ // idle expiration is not being used
+ return true;
+ }
+ if (getIdleAttributes().getAction().isLocal()) {
+ // no need to consult with others if using a local action
+ return true;
+ }
+ if (SystemPropertyHelper.restoreIdleExpirationBehavior()) {
+ return true;
+ }
+
+ long latestLastAccessTime = getLatestLastAccessTimeOnOtherMembers();
+ if (latestLastAccessTime > getLastAccessedTime()) {
+ setLastAccessedTime(latestLastAccessTime);
+ return false;
+ }
+ return true;
+ }
+
+ private long getLatestLastAccessTimeOnOtherMembers() {
+ return getLocalRegion().getLatestLastAccessTimeFromOthers(getKey());
+ }
+
+ private void setLastAccessedTime(long lastAccessedTime) throws EntryNotFoundException {
+ RegionEntry re = getCheckedRegionEntry();
+ re.setLastAccessed(lastAccessedTime);
+ }
+
/**
* Called by LocalRegion#performExpiryTimeout
*/
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java
index 9e21115..6fcaa52 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java
@@ -121,15 +121,21 @@ public abstract class ExpiryTask extends SystemTimer.SystemTimerTask {
/** Return the absolute time when idle expiration occurs, or 0 if not used */
public long getIdleExpirationTime() throws EntryNotFoundException {
+ long idle = getIdleTimeoutInMillis();
+ if (idle > 0) {
+ return getLastAccessedTime() + idle;
+ }
+ return 0L;
+ }
+
+ protected long getIdleTimeoutInMillis() {
long idle = getIdleAttributes().getTimeout();
- long tilt = 0;
if (idle > 0) {
if (getLocalRegion() != null && !getLocalRegion().EXPIRY_UNITS_MS) {
idle *= 1000;
}
- tilt = getLastAccessedTime() + idle;
}
- return tilt;
+ return idle;
}
/**
@@ -149,13 +155,34 @@ public abstract class ExpiryTask extends SystemTimer.SystemTimerTask {
*/
protected boolean isExpirationPossible() throws EntryNotFoundException {
long expTime = getExpirationTime();
- if (expTime > 0L && getNow() >= expTime) {
- return true;
+ if (expTime > 0L) {
+ long now = getNow();
+ if (now >= expTime) {
+ if (isIdleExpiredOnOthers()) {
+ return true;
+ } else {
+ // our last access time was reset so recheck
+ expTime = getExpirationTime();
+ if (expTime > 0L && now >= expTime) {
+ return true;
+ }
+ }
+ }
}
return false;
}
/**
+ * Added for GEODE-3764.
+ *
+ * @return true if other members last access time indicates we have expired
+ */
+ protected boolean isIdleExpiredOnOthers() throws EntryNotFoundException {
+ // by default return true since we don't need to check with others
+ return true;
+ }
+
+ /**
* Returns false if the region reliability state does not allow this expiry task to fire.
*/
protected boolean isExpirationAllowed() {
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDistributedRegion.java
similarity index 59%
copy from geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java
copy to geode-core/src/main/java/org/apache/geode/internal/cache/InternalDistributedRegion.java
index a58df4c..281f96b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDistributedRegion.java
@@ -14,25 +14,6 @@
*/
package org.apache.geode.internal.cache;
-import org.apache.geode.cache.Region;
-
-/**
- * Interface to be used instead of type-casting to LocalRegion.
- *
- * <p>
- * The following interfaces are implemented by LocalRegion and may need to be extended by
- * InternalRegion to completely allow code to move to using InternalRegion:
- * <ul>
- * <li>RegionAttributes
- * <li>AttributesMutator
- * <li>CacheStatistics
- * <li>DataSerializableFixedID
- * <li>RegionEntryContext
- * <li>Extensible
- * </pre>
- * </ul>
- */
-public interface InternalRegion extends Region, HasCachePerfStats {
-
- CachePerfStats getCachePerfStats();
+public interface InternalDistributedRegion<K, V>
+ extends InternalRegion<K, V>, CacheDistributionAdvisee {
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java
index a58df4c..a4a635d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegion.java
@@ -15,6 +15,7 @@
package org.apache.geode.internal.cache;
import org.apache.geode.cache.Region;
+import org.apache.geode.distributed.internal.DM;
/**
* Interface to be used instead of type-casting to LocalRegion.
@@ -32,7 +33,7 @@ import org.apache.geode.cache.Region;
* </pre>
* </ul>
*/
-public interface InternalRegion extends Region, HasCachePerfStats {
+public interface InternalRegion<K, V> extends Region<K, V>, HasCachePerfStats {
- CachePerfStats getCachePerfStats();
+ RegionEntry getRegionEntry(K key);
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeMessage.java
new file mode 100644
index 0000000..063e0ae
--- /dev/null
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeMessage.java
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+import java.util.Set;
+
+import org.apache.geode.DataSerializer;
+import org.apache.geode.distributed.internal.DistributionManager;
+import org.apache.geode.distributed.internal.MessageWithReply;
+import org.apache.geode.distributed.internal.PooledDistributionMessage;
+import org.apache.geode.distributed.internal.ReplyMessage;
+import org.apache.geode.distributed.internal.membership.InternalDistributedMember;
+import org.apache.geode.internal.InternalStatisticsDisabledException;
+
+/**
+ * Sends the region name and key of the entry that we want the last access time for. If for any
+ * reason this message can not obtain the last access time then zero will be returned.
+ *
+ * @since Geode 1.4
+ */
+public class LatestLastAccessTimeMessage<K> extends PooledDistributionMessage
+ implements MessageWithReply {
+
+ private int processorId;
+ private String regionName;
+ private K key;
+
+ public LatestLastAccessTimeMessage() {
+ // nothing
+ }
+
+ public LatestLastAccessTimeMessage(LatestLastAccessTimeReplyProcessor replyProcessor,
+ Set<InternalDistributedMember> recipients, InternalDistributedRegion<K, ?> region, K key) {
+ this.setRecipients(recipients);
+ this.processorId = replyProcessor.getProcessorId();
+ this.key = key;
+ this.regionName = region.getFullPath();
+ }
+
+ @Override
+ public int getDSFID() {
+ return LATEST_LAST_ACCESS_TIME_MESSAGE;
+ }
+
+ @Override
+ protected void process(DistributionManager dm) {
+ long latestLastAccessTime = 0L;
+ InternalDistributedRegion<K, ?> region =
+ (InternalDistributedRegion<K, ?>) dm.getCache().getRegion(this.regionName);
+ if (region != null) {
+ RegionEntry entry = region.getRegionEntry(this.key);
+ if (entry != null) {
+ try {
+ latestLastAccessTime = entry.getLastAccessed();
+ } catch (InternalStatisticsDisabledException ignored) {
+ // last access time is not available
+ }
+ }
+ }
+ ReplyMessage.send(getSender(), this.processorId, latestLastAccessTime, dm);
+ }
+
+ @Override
+ public void fromData(DataInput in) throws IOException, ClassNotFoundException {
+ super.fromData(in);
+ this.processorId = DataSerializer.readPrimitiveInt(in);
+ this.regionName = DataSerializer.readString(in);
+ this.key = DataSerializer.readObject(in);
+ }
+
+ @Override
+ public void toData(DataOutput out) throws IOException {
+ super.toData(out);
+ DataSerializer.writePrimitiveInt(this.processorId, out);
+ DataSerializer.writeString(this.regionName, out);
+ DataSerializer.writeObject(this.key, out);
+ }
+}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeOperation.java
new file mode 100644
index 0000000..231e83f
--- /dev/null
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeOperation.java
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache;
+
+import java.util.Set;
+
+import org.apache.geode.CancelException;
+import org.apache.geode.distributed.internal.DM;
+import org.apache.geode.distributed.internal.ReplyException;
+import org.apache.geode.distributed.internal.membership.InternalDistributedMember;
+import org.apache.geode.internal.Version;
+
+/**
+ * Operation that determines the latest last access time for a given region and key
+ *
+ * @since Geode 1.4
+ */
+public class LatestLastAccessTimeOperation<K> {
+ private final InternalDistributedRegion<K, ?> region;
+ private final K key;
+
+ public LatestLastAccessTimeOperation(InternalDistributedRegion<K, ?> region, K key) {
+ this.region = region;
+ this.key = key;
+ }
+
+ public long getLatestLastAccessTime() {
+ final Set<InternalDistributedMember> recipients =
+ this.region.getCacheDistributionAdvisor().adviseInitializedReplicates();
+ final DM dm = this.region.getDistributionManager();
+ dm.retainMembersWithSameOrNewerVersion(recipients, Version.GEODE_140);
+ final LatestLastAccessTimeReplyProcessor replyProcessor =
+ new LatestLastAccessTimeReplyProcessor(dm, recipients);
+ dm.putOutgoing(
+ new LatestLastAccessTimeMessage<>(replyProcessor, recipients, this.region, this.key));
+ try {
+ replyProcessor.waitForReplies();
+ } catch (ReplyException e) {
+ if (!(e.getCause() instanceof CancelException)) {
+ throw e;
+ }
+ } catch (InterruptedException e) {
+ dm.getCancelCriterion().checkCancelInProgress(e);
+ Thread.currentThread().interrupt();
+ }
+ return replyProcessor.getLatestLastAccessTime();
+ }
+}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeReplyProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeReplyProcessor.java
new file mode 100644
index 0000000..b211875
--- /dev/null
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LatestLastAccessTimeReplyProcessor.java
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache;
+
+import java.util.Set;
+
+import org.apache.logging.log4j.Logger;
+
+import org.apache.geode.distributed.internal.DM;
+import org.apache.geode.distributed.internal.DistributionMessage;
+import org.apache.geode.distributed.internal.ReplyMessage;
+import org.apache.geode.distributed.internal.ReplyProcessor21;
+import org.apache.geode.distributed.internal.membership.InternalDistributedMember;
+import org.apache.geode.internal.logging.LogService;
+import org.apache.geode.internal.logging.log4j.LogMarker;
+
+/**
+ * Processes the replies from a LatestLastAccessTimeMessage. This reply processor only keeps the
+ * largest value returned. It waits for every recipient to respond.
+ *
+ * @since Geode 1.4
+ */
+public class LatestLastAccessTimeReplyProcessor extends ReplyProcessor21 {
+ private static final Logger logger = LogService.getLogger();
+
+ private long latestLastAccessTime = 0;
+
+ public LatestLastAccessTimeReplyProcessor(DM dm, Set<InternalDistributedMember> recipients) {
+ super(dm, recipients);
+ }
+
+ @Override
+ public void process(DistributionMessage msg) {
+ try {
+ ReplyMessage reply = (ReplyMessage) msg;
+ long replyTime = (long) reply.getReturnValue();
+ updateLatestLastAccessTime(replyTime);
+ if (logger.isTraceEnabled(LogMarker.DM)) {
+ logger.trace(LogMarker.DM, "LatestLastAccessTimeReplyMessage return value is {}",
+ replyTime);
+ }
+ } finally {
+ super.process(msg);
+ }
+ }
+
+ private synchronized void updateLatestLastAccessTime(long newTime) {
+ if (newTime > this.latestLastAccessTime) {
+ this.latestLastAccessTime = newTime;
+ }
+ }
+
+ public synchronized long getLatestLastAccessTime() {
+ return this.latestLastAccessTime;
+ }
+
+}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LeafRegionEntry.cpp b/geode-core/src/main/java/org/apache/geode/internal/cache/LeafRegionEntry.cpp
index e8d3a2a..1ad1fd0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/LeafRegionEntry.cpp
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LeafRegionEntry.cpp
@@ -461,7 +461,8 @@ public class LEAF_CLASS extends PARENT_CLASS {
public long getLastAccessed() throws InternalStatisticsDisabledException {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
@Override
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
index 35a0cc3..6ff6f7f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
@@ -12026,4 +12026,13 @@ public class LocalRegion extends AbstractRegion implements InternalRegion, Loade
return result;
}
+ /**
+ * Send a message to all other members that can have this same region entry and return the latest
+ * last access time.
+ */
+ public long getLatestLastAccessTimeFromOthers(Object key) {
+ // local regions have no other members so return 0.
+ return 0L;
+ }
+
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java
index 2650626..785defa 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java
@@ -76,6 +76,13 @@ public interface RegionEntry {
public long getLastAccessed() throws InternalStatisticsDisabledException;
+ /**
+ * Sets the entry's last accessed time if it has one.
+ */
+ public default void setLastAccessed(long lastAccessed) {
+ // do nothing by default
+ }
+
public long getHitCount() throws InternalStatisticsDisabledException;
public long getMissCount() throws InternalStatisticsDisabledException;
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java
index 12052ee..82e4373 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java
@@ -272,7 +272,8 @@ public class VMStatsDiskLRURegionEntryHeapIntKey extends VMStatsDiskLRURegionEnt
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java
index 219dbfa..001be3f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java
@@ -272,7 +272,8 @@ public class VMStatsDiskLRURegionEntryHeapLongKey extends VMStatsDiskLRURegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java
index b2fb66f..aac0beb 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java
@@ -276,7 +276,8 @@ public class VMStatsDiskLRURegionEntryHeapObjectKey extends VMStatsDiskLRURegion
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java
index f2387b9..4747686 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java
@@ -293,7 +293,8 @@ public class VMStatsDiskLRURegionEntryHeapStringKey1 extends VMStatsDiskLRURegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java
index 38e5392..2af8f53 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java
@@ -305,7 +305,8 @@ public class VMStatsDiskLRURegionEntryHeapStringKey2 extends VMStatsDiskLRURegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java
index 6833e87..5307f60 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java
@@ -274,7 +274,8 @@ public class VMStatsDiskLRURegionEntryHeapUUIDKey extends VMStatsDiskLRURegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java
index e02c26d..c194890 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java
@@ -330,7 +330,8 @@ public class VMStatsDiskLRURegionEntryOffHeapIntKey extends VMStatsDiskLRURegion
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java
index a565062..c05f189 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java
@@ -330,7 +330,8 @@ public class VMStatsDiskLRURegionEntryOffHeapLongKey extends VMStatsDiskLRURegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java
index 8a1cd29..f7c73cf 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java
@@ -331,7 +331,8 @@ public class VMStatsDiskLRURegionEntryOffHeapObjectKey extends VMStatsDiskLRUReg
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java
index f961f19..c019bf8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java
@@ -348,7 +348,8 @@ public class VMStatsDiskLRURegionEntryOffHeapStringKey1 extends VMStatsDiskLRURe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java
index 64e7c9a..d56af51 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java
@@ -360,7 +360,8 @@ public class VMStatsDiskLRURegionEntryOffHeapStringKey2 extends VMStatsDiskLRURe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java
index 088e072..0565109 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java
@@ -332,7 +332,8 @@ public class VMStatsDiskLRURegionEntryOffHeapUUIDKey extends VMStatsDiskLRURegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java
index 50c6239..09d3951 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java
@@ -170,7 +170,8 @@ public class VMStatsDiskRegionEntryHeapIntKey extends VMStatsDiskRegionEntryHeap
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java
index 184ca7d..bf3ce32 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java
@@ -170,7 +170,8 @@ public class VMStatsDiskRegionEntryHeapLongKey extends VMStatsDiskRegionEntryHea
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapObjectKey.java
index f3a37fe..34eeebf 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapObjectKey.java
@@ -170,7 +170,8 @@ public class VMStatsDiskRegionEntryHeapObjectKey extends VMStatsDiskRegionEntryH
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey1.java
index a77495f..735eefe 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey1.java
@@ -188,7 +188,8 @@ public class VMStatsDiskRegionEntryHeapStringKey1 extends VMStatsDiskRegionEntry
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey2.java
index dacd9a6..29a745a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapStringKey2.java
@@ -200,7 +200,8 @@ public class VMStatsDiskRegionEntryHeapStringKey2 extends VMStatsDiskRegionEntry
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapUUIDKey.java
index 6122a4e..5057232 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapUUIDKey.java
@@ -172,7 +172,8 @@ public class VMStatsDiskRegionEntryHeapUUIDKey extends VMStatsDiskRegionEntryHea
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapIntKey.java
index 11000e5..e6f50c1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapIntKey.java
@@ -225,7 +225,8 @@ public class VMStatsDiskRegionEntryOffHeapIntKey extends VMStatsDiskRegionEntryO
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapLongKey.java
index 10d05a2..fa19898 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapLongKey.java
@@ -225,7 +225,8 @@ public class VMStatsDiskRegionEntryOffHeapLongKey extends VMStatsDiskRegionEntry
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapObjectKey.java
index 2ad59d7..af43ec4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapObjectKey.java
@@ -228,7 +228,8 @@ public class VMStatsDiskRegionEntryOffHeapObjectKey extends VMStatsDiskRegionEnt
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey1.java
index e1a3d9c..22e4090 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey1.java
@@ -245,7 +245,8 @@ public class VMStatsDiskRegionEntryOffHeapStringKey1 extends VMStatsDiskRegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey2.java
index 6c091a5..aa1b463 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapStringKey2.java
@@ -257,7 +257,8 @@ public class VMStatsDiskRegionEntryOffHeapStringKey2 extends VMStatsDiskRegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapUUIDKey.java
index aca0cf3..57963e3 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryOffHeapUUIDKey.java
@@ -227,7 +227,8 @@ public class VMStatsDiskRegionEntryOffHeapUUIDKey extends VMStatsDiskRegionEntry
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapIntKey.java
index de18af0..1bf274e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapIntKey.java
@@ -216,7 +216,8 @@ public class VMStatsLRURegionEntryHeapIntKey extends VMStatsLRURegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapLongKey.java
index 30e2777..91daafb 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapLongKey.java
@@ -216,7 +216,8 @@ public class VMStatsLRURegionEntryHeapLongKey extends VMStatsLRURegionEntryHeap
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapObjectKey.java
index 5d53244..86f27a6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapObjectKey.java
@@ -216,7 +216,8 @@ public class VMStatsLRURegionEntryHeapObjectKey extends VMStatsLRURegionEntryHea
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey1.java
index aab6d19..3df8fb0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey1.java
@@ -234,7 +234,8 @@ public class VMStatsLRURegionEntryHeapStringKey1 extends VMStatsLRURegionEntryHe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey2.java
index 3b5d2f9..a9966b0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapStringKey2.java
@@ -246,7 +246,8 @@ public class VMStatsLRURegionEntryHeapStringKey2 extends VMStatsLRURegionEntryHe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapUUIDKey.java
index 10620fa..77cb60d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryHeapUUIDKey.java
@@ -218,7 +218,8 @@ public class VMStatsLRURegionEntryHeapUUIDKey extends VMStatsLRURegionEntryHeap
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapIntKey.java
index 443885c..cadb2ee 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapIntKey.java
@@ -271,7 +271,8 @@ public class VMStatsLRURegionEntryOffHeapIntKey extends VMStatsLRURegionEntryOff
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapLongKey.java
index abab53c..a1e79ee 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapLongKey.java
@@ -271,7 +271,8 @@ public class VMStatsLRURegionEntryOffHeapLongKey extends VMStatsLRURegionEntryOf
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapObjectKey.java
index 7ea99d5..c7c2e7f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapObjectKey.java
@@ -273,7 +273,8 @@ public class VMStatsLRURegionEntryOffHeapObjectKey extends VMStatsLRURegionEntry
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey1.java
index 38e6080..ea326b5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey1.java
@@ -291,7 +291,8 @@ public class VMStatsLRURegionEntryOffHeapStringKey1 extends VMStatsLRURegionEntr
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey2.java
index 450a72c..8439998 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapStringKey2.java
@@ -303,7 +303,8 @@ public class VMStatsLRURegionEntryOffHeapStringKey2 extends VMStatsLRURegionEntr
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapUUIDKey.java
index 48e20ae..7ffddd5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsLRURegionEntryOffHeapUUIDKey.java
@@ -273,7 +273,8 @@ public class VMStatsLRURegionEntryOffHeapUUIDKey extends VMStatsLRURegionEntryOf
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapIntKey.java
index b01a3f7..a48ff98 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapIntKey.java
@@ -130,7 +130,8 @@ public class VMStatsRegionEntryHeapIntKey extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapLongKey.java
index a910522..93a470d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapLongKey.java
@@ -130,7 +130,8 @@ public class VMStatsRegionEntryHeapLongKey extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapObjectKey.java
index 9716f41..e2a70d9 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapObjectKey.java
@@ -130,7 +130,8 @@ public class VMStatsRegionEntryHeapObjectKey extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey1.java
index 01ca1cb..63bb9a6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey1.java
@@ -148,7 +148,8 @@ public class VMStatsRegionEntryHeapStringKey1 extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey2.java
index ecf9f2f..6c217c4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapStringKey2.java
@@ -160,7 +160,8 @@ public class VMStatsRegionEntryHeapStringKey2 extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapUUIDKey.java
index c88c600..2e62df2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryHeapUUIDKey.java
@@ -132,7 +132,8 @@ public class VMStatsRegionEntryHeapUUIDKey extends VMStatsRegionEntryHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapIntKey.java
index d6ef8ec..7ba3ef0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapIntKey.java
@@ -185,7 +185,8 @@ public class VMStatsRegionEntryOffHeapIntKey extends VMStatsRegionEntryOffHeap {
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapLongKey.java
index a6ea1d8..f349001 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapLongKey.java
@@ -185,7 +185,8 @@ public class VMStatsRegionEntryOffHeapLongKey extends VMStatsRegionEntryOffHeap
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapObjectKey.java
index 3ad6d3e..36b218f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapObjectKey.java
@@ -185,7 +185,8 @@ public class VMStatsRegionEntryOffHeapObjectKey extends VMStatsRegionEntryOffHea
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey1.java
index bc500ae..2c4d7a7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey1.java
@@ -202,7 +202,8 @@ public class VMStatsRegionEntryOffHeapStringKey1 extends VMStatsRegionEntryOffHe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey2.java
index aa47230..2578cfd 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapStringKey2.java
@@ -214,7 +214,8 @@ public class VMStatsRegionEntryOffHeapStringKey2 extends VMStatsRegionEntryOffHe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapUUIDKey.java
index e391ff7..c6dbf34 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsRegionEntryOffHeapUUIDKey.java
@@ -187,7 +187,8 @@ public class VMStatsRegionEntryOffHeapUUIDKey extends VMStatsRegionEntryOffHeap
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapIntKey.java
index 92c56b5..ae524f7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapIntKey.java
@@ -282,7 +282,8 @@ public class VersionedStatsDiskLRURegionEntryHeapIntKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapLongKey.java
index 4594de9..8be0c3f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapLongKey.java
@@ -282,7 +282,8 @@ public class VersionedStatsDiskLRURegionEntryHeapLongKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapObjectKey.java
index 2048451..9b829d3 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapObjectKey.java
@@ -282,7 +282,8 @@ public class VersionedStatsDiskLRURegionEntryHeapObjectKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey1.java
index f4121b7..a7bf1ff 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey1.java
@@ -299,7 +299,8 @@ public class VersionedStatsDiskLRURegionEntryHeapStringKey1
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey2.java
index dcbd4e5..7adf88b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapStringKey2.java
@@ -311,7 +311,8 @@ public class VersionedStatsDiskLRURegionEntryHeapStringKey2
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapUUIDKey.java
index 77c2633..2b39488 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryHeapUUIDKey.java
@@ -284,7 +284,8 @@ public class VersionedStatsDiskLRURegionEntryHeapUUIDKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapIntKey.java
index 61b5ada..7618bad 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapIntKey.java
@@ -337,7 +337,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapIntKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapLongKey.java
index c948ceb..4207026 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapLongKey.java
@@ -337,7 +337,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapLongKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapObjectKey.java
index 7a8292b..166c33b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapObjectKey.java
@@ -337,7 +337,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapObjectKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey1.java
index 64df56c..38e9495 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey1.java
@@ -354,7 +354,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapStringKey1
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey2.java
index f7a06aa..9922420 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapStringKey2.java
@@ -366,7 +366,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapStringKey2
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapUUIDKey.java
index 7df21b1..a65b91f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskLRURegionEntryOffHeapUUIDKey.java
@@ -339,7 +339,8 @@ public class VersionedStatsDiskLRURegionEntryOffHeapUUIDKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapIntKey.java
index e848cca..9dd509a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapIntKey.java
@@ -179,7 +179,8 @@ public class VersionedStatsDiskRegionEntryHeapIntKey extends VersionedStatsDiskR
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapLongKey.java
index 940be11..7234639 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapLongKey.java
@@ -179,7 +179,8 @@ public class VersionedStatsDiskRegionEntryHeapLongKey extends VersionedStatsDisk
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapObjectKey.java
index df9e83d..e27955b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapObjectKey.java
@@ -179,7 +179,8 @@ public class VersionedStatsDiskRegionEntryHeapObjectKey extends VersionedStatsDi
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey1.java
index d5271e5..a1b15fa 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey1.java
@@ -196,7 +196,8 @@ public class VersionedStatsDiskRegionEntryHeapStringKey1 extends VersionedStatsD
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey2.java
index 5d20543..5fd38b7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapStringKey2.java
@@ -208,7 +208,8 @@ public class VersionedStatsDiskRegionEntryHeapStringKey2 extends VersionedStatsD
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapUUIDKey.java
index 6c70576..7bff6e1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryHeapUUIDKey.java
@@ -181,7 +181,8 @@ public class VersionedStatsDiskRegionEntryHeapUUIDKey extends VersionedStatsDisk
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapIntKey.java
index f2ff689..eea2af0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapIntKey.java
@@ -235,7 +235,8 @@ public class VersionedStatsDiskRegionEntryOffHeapIntKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapLongKey.java
index 5bcc4c1..606742a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapLongKey.java
@@ -235,7 +235,8 @@ public class VersionedStatsDiskRegionEntryOffHeapLongKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapObjectKey.java
index 14217bd..385e05a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapObjectKey.java
@@ -235,7 +235,8 @@ public class VersionedStatsDiskRegionEntryOffHeapObjectKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey1.java
index 5fd2d8e..54159d7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey1.java
@@ -252,7 +252,8 @@ public class VersionedStatsDiskRegionEntryOffHeapStringKey1
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey2.java
index 1dc0cf2..13250b1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapStringKey2.java
@@ -264,7 +264,8 @@ public class VersionedStatsDiskRegionEntryOffHeapStringKey2
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapUUIDKey.java
index cfd8623..26c4468 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsDiskRegionEntryOffHeapUUIDKey.java
@@ -237,7 +237,8 @@ public class VersionedStatsDiskRegionEntryOffHeapUUIDKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapIntKey.java
index a6446b5..9a8c481 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapIntKey.java
@@ -224,7 +224,8 @@ public class VersionedStatsLRURegionEntryHeapIntKey extends VersionedStatsLRUReg
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapLongKey.java
index 1bdd183..8016766 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapLongKey.java
@@ -225,7 +225,8 @@ public class VersionedStatsLRURegionEntryHeapLongKey extends VersionedStatsLRURe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapObjectKey.java
index de0111d..e7b8ba8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapObjectKey.java
@@ -225,7 +225,8 @@ public class VersionedStatsLRURegionEntryHeapObjectKey extends VersionedStatsLRU
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey1.java
index 27f43a5..98c5fe2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey1.java
@@ -242,7 +242,8 @@ public class VersionedStatsLRURegionEntryHeapStringKey1 extends VersionedStatsLR
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey2.java
index 675e19b..0be92b7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapStringKey2.java
@@ -254,7 +254,8 @@ public class VersionedStatsLRURegionEntryHeapStringKey2 extends VersionedStatsLR
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapUUIDKey.java
index 43736b9..49bc7ed 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryHeapUUIDKey.java
@@ -227,7 +227,8 @@ public class VersionedStatsLRURegionEntryHeapUUIDKey extends VersionedStatsLRURe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapIntKey.java
index 7309f9d..cb67874 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapIntKey.java
@@ -280,7 +280,8 @@ public class VersionedStatsLRURegionEntryOffHeapIntKey extends VersionedStatsLRU
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapLongKey.java
index f1a969f..b6153a5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapLongKey.java
@@ -281,7 +281,8 @@ public class VersionedStatsLRURegionEntryOffHeapLongKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapObjectKey.java
index ce01dd5..4cf5aa6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapObjectKey.java
@@ -281,7 +281,8 @@ public class VersionedStatsLRURegionEntryOffHeapObjectKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey1.java
index f93d7b3..6c883fc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey1.java
@@ -298,7 +298,8 @@ public class VersionedStatsLRURegionEntryOffHeapStringKey1
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey2.java
index 068b954..ca0c1ae 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapStringKey2.java
@@ -310,7 +310,8 @@ public class VersionedStatsLRURegionEntryOffHeapStringKey2
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapUUIDKey.java
index 86f05a2..9fa6b04 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsLRURegionEntryOffHeapUUIDKey.java
@@ -283,7 +283,8 @@ public class VersionedStatsLRURegionEntryOffHeapUUIDKey
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapIntKey.java
index 1dff8be..9c7a9ff 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapIntKey.java
@@ -135,7 +135,8 @@ public class VersionedStatsRegionEntryHeapIntKey extends VersionedStatsRegionEnt
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapLongKey.java
index dd944b3..8075a6d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapLongKey.java
@@ -135,7 +135,8 @@ public class VersionedStatsRegionEntryHeapLongKey extends VersionedStatsRegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapObjectKey.java
index eeaabfc..d176609 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapObjectKey.java
@@ -139,7 +139,8 @@ public class VersionedStatsRegionEntryHeapObjectKey extends VersionedStatsRegion
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey1.java
index 1b49858..7e4ebc4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey1.java
@@ -156,7 +156,8 @@ public class VersionedStatsRegionEntryHeapStringKey1 extends VersionedStatsRegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey2.java
index 3a51688..7017e5b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapStringKey2.java
@@ -168,7 +168,8 @@ public class VersionedStatsRegionEntryHeapStringKey2 extends VersionedStatsRegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapUUIDKey.java
index 35cc901..a8db8f1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryHeapUUIDKey.java
@@ -137,7 +137,8 @@ public class VersionedStatsRegionEntryHeapUUIDKey extends VersionedStatsRegionEn
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapIntKey.java
index 2fe5fc8..33e0edc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapIntKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapIntKey.java
@@ -193,7 +193,8 @@ public class VersionedStatsRegionEntryOffHeapIntKey extends VersionedStatsRegion
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapLongKey.java
index c224bd1..37fdfc7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapLongKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapLongKey.java
@@ -193,7 +193,8 @@ public class VersionedStatsRegionEntryOffHeapLongKey extends VersionedStatsRegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapObjectKey.java
index a046f1b..c5f7268 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapObjectKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapObjectKey.java
@@ -194,7 +194,8 @@ public class VersionedStatsRegionEntryOffHeapObjectKey extends VersionedStatsReg
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey1.java
index 37a17e7..fbc233b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey1.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey1.java
@@ -211,7 +211,8 @@ public class VersionedStatsRegionEntryOffHeapStringKey1 extends VersionedStatsRe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey2.java
index b60e4af..ffd62aa 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey2.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapStringKey2.java
@@ -223,7 +223,8 @@ public class VersionedStatsRegionEntryOffHeapStringKey2 extends VersionedStatsRe
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapUUIDKey.java
index 6b493b7..19b3bc2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapUUIDKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VersionedStatsRegionEntryOffHeapUUIDKey.java
@@ -195,7 +195,8 @@ public class VersionedStatsRegionEntryOffHeapUUIDKey extends VersionedStatsRegio
return this.lastAccessed;
}
- private void setLastAccessed(long lastAccessed) {
+ @Override
+ public void setLastAccessed(long lastAccessed) {
this.lastAccessed = lastAccessed;
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/lang/SystemPropertyHelper.java b/geode-core/src/main/java/org/apache/geode/internal/lang/SystemPropertyHelper.java
index ec8a1f8..178f14c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/lang/SystemPropertyHelper.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/lang/SystemPropertyHelper.java
@@ -54,4 +54,17 @@ public class SystemPropertyHelper {
public static boolean restoreSetOperationTransactionBehavior() {
return getProductBooleanProperty("restoreSetOperationTransactionBehavior");
}
+
+ /**
+ * As of Geode 1.4.0, idle expiration on a replicate or partitioned region will now do a
+ * distributed check for a more recent last access time on one of the other copies of the region.
+ *
+ * This system property can be set to true to turn off this new check and restore the previous
+ * behavior of only using the local last access time as the basis for expiration.
+ *
+ * @since Geode 1.4.0
+ */
+ public static boolean restoreIdleExpirationBehavior() {
+ return getProductBooleanProperty("restoreIdleExpirationBehavior");
+ }
}
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/PREntryIdleExpirationTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/PREntryIdleExpirationTest.java
new file mode 100644
index 0000000..630cf8a
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/PREntryIdleExpirationTest.java
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache;
+
+import static org.apache.geode.cache.ExpirationAction.DESTROY;
+import static org.apache.geode.cache.RegionShortcut.PARTITION;
+
+import org.junit.Before;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.cache.ExpirationAttributes;
+import org.apache.geode.cache.PartitionAttributesFactory;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.RegionFactory;
+import org.apache.geode.test.junit.categories.DistributedTest;
+
+@Category(DistributedTest.class)
+@SuppressWarnings("serial")
+public class PREntryIdleExpirationTest extends ReplicateEntryIdleExpirationTest {
+
+ @Before
+ public void setUpPREntryIdleExpirationTest() throws Exception {
+ // make member1 the primary bucket for KEY
+ member1.invoke(() -> {
+ Region<String, String> region = cacheRule.getCache().getRegion(regionName);
+ region.put(KEY, VALUE);
+ });
+ }
+
+ @Override
+ protected void createRegion() {
+ RegionFactory<String, String> factory = cacheRule.getCache().createRegionFactory(PARTITION);
+ factory.setPartitionAttributes(
+ new PartitionAttributesFactory<String, String>().setRedundantCopies(2).create());
+ factory.setEntryIdleTimeout(new ExpirationAttributes(1, DESTROY));
+ factory.create(regionName);
+ }
+}
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/ReplicateEntryIdleExpirationTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/ReplicateEntryIdleExpirationTest.java
new file mode 100644
index 0000000..eb26680
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/ReplicateEntryIdleExpirationTest.java
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache;
+
+import static java.util.concurrent.TimeUnit.SECONDS;
+import static org.apache.geode.cache.ExpirationAction.DESTROY;
+import static org.apache.geode.cache.RegionShortcut.REPLICATE;
+import static org.apache.geode.test.dunit.Host.getHost;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+import java.io.Serializable;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import com.google.common.base.Stopwatch;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.ClassRule;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.cache.ExpirationAttributes;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.RegionFactory;
+import org.apache.geode.test.dunit.AsyncInvocation;
+import org.apache.geode.test.dunit.VM;
+import org.apache.geode.test.dunit.rules.CacheRule;
+import org.apache.geode.test.dunit.rules.DistributedTestRule;
+import org.apache.geode.test.junit.categories.DistributedTest;
+
+@Category(DistributedTest.class)
+@SuppressWarnings("serial")
+public class ReplicateEntryIdleExpirationTest implements Serializable {
+
+ @ClassRule
+ public static DistributedTestRule distributedTestRule = new DistributedTestRule();
+
+ private static final AtomicBoolean KEEP_READING = new AtomicBoolean(true);
+
+ protected static final String KEY = "KEY";
+ protected static final String VALUE = "VALUE";
+
+ protected final VM member1 = getHost(0).getVM(0);
+ protected final VM member2 = getHost(0).getVM(1);
+ protected final VM member3 = getHost(0).getVM(2);
+ protected final String regionName = getClass().getSimpleName();
+
+ @Rule
+ public CacheRule cacheRule = CacheRule.builder().createCacheIn(member1).createCacheIn(member2)
+ .createCacheIn(member3).build();
+
+ @Before
+ public void setUp() throws Exception {
+ VM[] vms = new VM[] {member1, member2, member3};
+ for (VM vm : vms) {
+ vm.invoke(() -> {
+ KEEP_READING.set(true);
+ ExpiryTask.suspendExpiration();
+ createRegion();
+ });
+ }
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ VM[] vms = new VM[] {member1, member2, member3};
+ for (VM vm : vms) {
+ vm.invoke(() -> {
+ KEEP_READING.set(false);
+ ExpiryTask.permitExpiration();
+ });
+ }
+ }
+
+ @Test
+ public void readsInOtherMemberShouldPreventExpiration() throws Exception {
+ AsyncInvocation<?> memberReading = member3.invokeAsync(() -> {
+ Region<String, String> region = cacheRule.getCache().getRegion(regionName);
+ region.put(KEY, VALUE);
+ while (KEEP_READING.get()) {
+ region.get(KEY);
+ Thread.sleep(10);
+ }
+ });
+
+ member2.invoke(() -> {
+ Region<String, String> region = cacheRule.getCache().getRegion(regionName);
+ await().atMost(30, SECONDS).until(() -> region.containsKey(KEY));
+ assertThat(region.containsKey(KEY)).isTrue();
+ });
+
+ member1.invoke(() -> {
+ Region<String, String> region = cacheRule.getCache().getRegion(regionName);
+ await().atMost(30, SECONDS).until(() -> region.containsKey(KEY));
+ assertThat(region.containsKey(KEY)).isTrue();
+
+ ExpiryTask.permitExpiration();
+ Stopwatch stopwatch = Stopwatch.createStarted();
+ while (stopwatch.elapsed(SECONDS) <= 5 && region.containsKey(KEY)) {
+ Thread.sleep(10);
+ }
+ assertThat(region.containsKey(KEY)).isTrue();
+ });
+
+ member3.invoke(() -> KEEP_READING.set(false));
+
+ memberReading.await();
+ }
+
+ protected void createRegion() {
+ RegionFactory<String, String> factory = cacheRule.getCache().createRegionFactory(REPLICATE);
+ factory.setEntryIdleTimeout(new ExpirationAttributes(1, DESTROY));
+ factory.create(regionName);
+ }
+}
diff --git a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
index 56f79cb..d5e8b78 100644
--- a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
+++ b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
@@ -1138,6 +1138,10 @@ org/apache/geode/internal/cache/JtaAfterCompletionMessage,2
fromData,26,2a2bb700232a2bb900240100b500042a2bb900240100b50002b1
toData,26,2a2bb700212b2ab40004b9002202002b2ab40002b900220200b1
+org/apache/geode/internal/cache/LatestLastAccessTimeMessage,2
+fromData,30,2a2bb700122a2bb80013b500042a2bb80014b500072a2bb80015b50005b1
+toData,30,2a2bb700162ab400042bb800172ab400072bb800182ab400052bb80019b1
+
org/apache/geode/internal/cache/MemberFunctionStreamingMessage,2
fromData,163,2a2bb700522bb9005301003d1c047e9900142a2bb900540100b500082ab40008b800551c077e99000d2a2bb900540100b500051c057e99000e2a2bb80056c00057b500062bb800564e2dc1002b9900252a03b5000a2a2dc0002bb80058b500072ab40007c7001b2a2dc0002bb5001ba700102a2dc00059b500072a04b5000a2a2bb80056b500092a2bb80056c0005ab500102a1c10407e99000704a7000403b5000bb1
toData,162,2a2bb7005c033d2ab400089900081c0480933d2ab40005029f00081c0780933d2ab40006c600081c0580933d2ab4000b9900091c104080933d2b1cb9005d02002ab4000899000d2b2ab40008b9005e02002ab40005029f000d2b2ab40005b9005e02002ab40006c6000b2ab400062bb8005f2ab4000a99000e2ab400072bb8005fa700102ab40007b9002001002bb8005f2ab400092bb8005f2ab400102bb8005fb1
--
To stop receiving notification emails like this one, please contact
['"commits@geode.apache.org" <co...@geode.apache.org>'].