geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dschnei...@apache.org
Subject incubator-geode git commit: fix 100ms delay in stopping tombstone sweeper
Date Wed, 20 Jul 2016 23:39:38 GMT
Repository: incubator-geode
Updated Branches:
  refs/heads/feature/GEODE-1420 [created] 447f442a6


fix 100ms delay in stopping tombstone sweeper


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/447f442a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/447f442a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/447f442a

Branch: refs/heads/feature/GEODE-1420
Commit: 447f442a6a16ac3c7b24f06dbce95e5bd361a9e0
Parents: 50aedb1
Author: Darrel Schneider <dschneider@pivotal.io>
Authored: Wed Jul 20 16:39:00 2016 -0700
Committer: Darrel Schneider <dschneider@pivotal.io>
Committed: Wed Jul 20 16:39:00 2016 -0700

----------------------------------------------------------------------
 .../com/gemstone/gemfire/internal/cache/TombstoneService.java | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/447f442a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/TombstoneService.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/TombstoneService.java
b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/TombstoneService.java
index 192e24d..2241b33 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/TombstoneService.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/TombstoneService.java
@@ -787,9 +787,9 @@ public class TombstoneService {
       this.sweeperThread.start();
     }
 
-    synchronized void stop() {
-      this.isStopped = true;
-      if (this.sweeperThread != null) {
+    void stop() {
+      synchronized (this) {
+        this.isStopped = true;
         notifyAll();
       }
       try {
@@ -797,7 +797,6 @@ public class TombstoneService {
       } catch (InterruptedException e) {
         Thread.currentThread().interrupt();
       }
-      getQueue().clear();
     }
 
     private void lockQueueHead() {


Mime
View raw message