GEODE-307: Clear DiskStoreObserver after each test An observer was being left over and causing later tests to fail.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/ba74e9ea Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/ba74e9ea Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/ba74e9ea Branch: refs/heads/feature/GEODE-12 Commit: ba74e9ea849e1ea38b742278e28d308218cedc63 Parents: f9d7084 Author: Dan Smith <[email protected]> Authored: Wed Sep 2 15:23:11 2015 -0700 Committer: Dan Smith <[email protected]> Committed: Thu Sep 3 10:46:10 2015 -0700 ---------------------------------------------------------------------- gemfire-core/src/test/java/dunit/DistributedTestCase.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ba74e9ea/gemfire-core/src/test/java/dunit/DistributedTestCase.java ---------------------------------------------------------------------- diff --git a/gemfire-core/src/test/java/dunit/DistributedTestCase.java b/gemfire-core/src/test/java/dunit/DistributedTestCase.java index 8aa8b6d..2e7ac03 100755 --- a/gemfire-core/src/test/java/dunit/DistributedTestCase.java +++ b/gemfire-core/src/test/java/dunit/DistributedTestCase.java @@ -52,6 +52,7 @@ import com.gemstone.gemfire.internal.InternalInstantiator; import com.gemstone.gemfire.internal.OSProcess; import com.gemstone.gemfire.internal.SocketCreator; import com.gemstone.gemfire.internal.admin.ClientStatsManager; +import com.gemstone.gemfire.internal.cache.DiskStoreObserver; import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; import com.gemstone.gemfire.internal.cache.InitialImageOperation; import com.gemstone.gemfire.internal.cache.LocalRegion; @@ -784,6 +785,7 @@ public abstract class DistributedTestCase extends TestCase implements java.io.Se Protocol.trace = GemFireTracer.DEBUG; DistributionMessageObserver.setInstance(null); QueryObserverHolder.reset(); + DiskStoreObserver.setInstance(null); if (InternalDistributedSystem.systemAttemptingReconnect != null) { InternalDistributedSystem.systemAttemptingReconnect.stopReconnecting(); }
