[geode] 02/02: GEODE-3796 Changes are made to validate region version after the region is initialized.

[agingade]

This is an automated email from the ASF dual-hosted git repository.

agingade pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 6dece49edb674e9d345b1391fceda2762dc14c19
Author: Anil <aging...@pivotal.io>
AuthorDate: Tue Oct 10 14:49:06 2017 -0700

    GEODE-3796 Changes are made to validate region version after the region is 
initialized.
---
 .../apache/geode/internal/cache/versions/RegionVersionVector.java    | 5 ++---
 .../geode/internal/cache/versions/RegionVersionVectorJUnitTest.java  | 2 +-
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/versions/RegionVersionVector.java
 
b/geode-core/src/main/java/org/apache/geode/internal/cache/versions/RegionVersionVector.java
index af59f06..be22f38 100644
--- 
a/geode-core/src/main/java/org/apache/geode/internal/cache/versions/RegionVersionVector.java
+++ 
b/geode-core/src/main/java/org/apache/geode/internal/cache/versions/RegionVersionVector.java
@@ -112,7 +112,6 @@ public abstract class RegionVersionVector<T extends 
VersionSource<?>>
   /** a flag to prevent accidental serialization of a live member */
   private transient boolean isLiveVector;
 
-  /** for debugging we keep a reference to the region for use in log messages 
*/
   private transient LocalRegion region;
 
   private ConcurrentHashMap<T, Long> memberToGCVersion;
@@ -606,8 +605,8 @@ public abstract class RegionVersionVector<T extends 
VersionSource<?>>
       // recovers. So we can only assert that the local member has already seen
       // the replayed event.
       synchronized (localExceptions) {
-        if (region != null && region.isInitialized()
-            && this.localVersion.get() < tag.getRegionVersion()) {
+        if (this.localVersion.get() < tag.getRegionVersion() && region != null
+            && region.isInitialized()) {
           Assert.fail(
               "recordVersion invoked for a local version tag that is higher 
than our local version. rvv="
                   + this + ", tag=" + tag + " " + region.getName());
diff --git 
a/geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorJUnitTest.java
 
b/geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorJUnitTest.java
index b9d3cf6..12f7321 100644
--- 
a/geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorJUnitTest.java
+++ 
b/geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorJUnitTest.java
@@ -554,7 +554,6 @@ public class RegionVersionVectorJUnitTest {
 
   @Test
   public void testRecordVersionAfterRegionInitThrowsException() {
-    expectedException.expect(InternalGemFireError.class);
     LocalRegion mockRegion = mock(LocalRegion.class);
     when(mockRegion.isInitialized()).thenReturn(true);
     final String local = NetworkUtils.getIPLiteral();
@@ -563,6 +562,7 @@ public class RegionVersionVectorJUnitTest {
     tag.setRegionVersion(1L);
 
     RegionVersionVector rvv = createRegionVersionVector(ownerId, mockRegion);
+    expectedException.expect(InternalGemFireError.class);
     rvv.recordVersion(ownerId, tag);
   }
 

-- 
To stop receiving notification emails like this one, please contact
"commits@geode.apache.org" <commits@geode.apache.org>.