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 2016/05/17 00:09:44 UTC
incubator-geode git commit: handle NOT_AVAILABLE in callers of
getRawOldValue
Repository: incubator-geode
Updated Branches:
refs/heads/feature/GEODE-1401 [created] a4d8ab000
handle NOT_AVAILABLE in callers of getRawOldValue
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/a4d8ab00
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/a4d8ab00
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/a4d8ab00
Branch: refs/heads/feature/GEODE-1401
Commit: a4d8ab000bc92dfcbb3158ba38322d2c555755b1
Parents: 34d3791
Author: Darrel Schneider <ds...@pivotal.io>
Authored: Mon May 16 16:57:56 2016 -0700
Committer: Darrel Schneider <ds...@pivotal.io>
Committed: Mon May 16 16:57:56 2016 -0700
----------------------------------------------------------------------
.../gemfire/internal/cache/BucketRegionQueue.java | 10 ++--------
.../gemstone/gemfire/internal/cache/EntryEventImpl.java | 2 +-
.../gemfire/internal/cache/RemoteDestroyMessage.java | 2 +-
3 files changed, 4 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a4d8ab00/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/BucketRegionQueue.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/BucketRegionQueue.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/BucketRegionQueue.java
index 0243cde..a3d9d97 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/BucketRegionQueue.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/BucketRegionQueue.java
@@ -269,10 +269,7 @@ public class BucketRegionQueue extends AbstractBucketRegionQueue {
requireOldValue, lastModified, overwriteDestroyed);
if (success) {
- Object ov = event.getRawOldValue();
- if (ov instanceof GatewaySenderEventImpl) {
- ((GatewaySenderEventImpl) ov).release();
- }
+ GatewaySenderEventImpl.release(event.getRawOldValue());
if (getPartitionedRegion().getColocatedWith() == null) {
return success;
@@ -370,10 +367,7 @@ public class BucketRegionQueue extends AbstractBucketRegionQueue {
}
super.basicDestroy(event, cacheWrite, expectedOldValue);
- Object rov = event.getRawOldValue();
- if (rov instanceof GatewaySenderEventImpl) {
- ((GatewaySenderEventImpl) rov).release();
- }
+ GatewaySenderEventImpl.release(event.getRawOldValue());
// Primary buckets should already remove the key while peeking
if (!this.getBucketAdvisor().isPrimary()) {
if (logger.isDebugEnabled()) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a4d8ab00/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
index e241622..b833ecb 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/EntryEventImpl.java
@@ -1407,7 +1407,7 @@ public class EntryEventImpl
importer.importOldObject(cdV, true);
}
} else {
- importer.importOldObject(ov, true);
+ importer.importOldObject(AbstractRegion.handleNotAvailable(ov), true);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a4d8ab00/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RemoteDestroyMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RemoteDestroyMessage.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RemoteDestroyMessage.java
index bb97d9c..f7109bb 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RemoteDestroyMessage.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/RemoteDestroyMessage.java
@@ -232,7 +232,7 @@ public class RemoteDestroyMessage extends RemoteOperationMessageWithDirectReply
setOldValBytes((byte[]) old);
} else {
this.oldValueIsSerialized = true;
- setOldValObj(old);
+ setOldValObj(AbstractRegion.handleNotAvailable(old));
}
}
}