You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2020/07/07 17:57:45 UTC
[geode] branch feature/GEODE-8334 updated: the rvv should be cloned
after locked
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEODE-8334
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-8334 by this push:
new 79516da the rvv should be cloned after locked
79516da is described below
commit 79516dabe1175bc63211ed0170f10e4d982bae5d
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Tue Jul 7 10:56:17 2020 -0700
the rvv should be cloned after locked
---
.../src/main/java/org/apache/geode/internal/cache/BucketRegion.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java
index c37e1a3..6219386 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java
@@ -568,9 +568,6 @@ public class BucketRegion extends DistributedRegion implements Bucket {
boolean enableRVV = useRVV && getConcurrencyChecksEnabled();
RegionVersionVector rvv = null;
- if (enableRVV) {
- rvv = getVersionVector().getCloneForTransmission();
- }
// get rvvLock
Set<InternalDistributedMember> participants =
@@ -582,6 +579,9 @@ public class BucketRegion extends DistributedRegion implements Bucket {
if (!isLockedAlready) {
obtainWriteLocksForClear(regionEvent, participants);
}
+ if (enableRVV) {
+ rvv = getVersionVector().getCloneForTransmission();
+ }
// no need to dominate my own rvv.
// Clear is on going here, there won't be GII for this member
clearRegionLocally(regionEvent, cacheWrite, null);