Removed testChildReaperCleansUpLockNodes() as the Reaper is now deprecated
Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/ff3fbd75 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/ff3fbd75 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/ff3fbd75 Branch: refs/heads/CURATOR-3.0 Commit: ff3fbd759879e677f84b9628b1f2f4a91c3d521d Parents: 208317a Author: randgalt <randg...@apache.org> Authored: Sat Oct 10 16:51:15 2015 -0500 Committer: randgalt <randg...@apache.org> Committed: Sat Oct 10 16:51:15 2015 -0500 ---------------------------------------------------------------------- .../locks/TestInterProcessSemaphore.java | 40 -------------------- 1 file changed, 40 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/ff3fbd75/curator-recipes/src/test/java/org/apache/curator/framework/recipes/locks/TestInterProcessSemaphore.java ---------------------------------------------------------------------- diff --git a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/locks/TestInterProcessSemaphore.java b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/locks/TestInterProcessSemaphore.java index 3ba75d8..2797b5f 100644 --- a/curator-recipes/src/test/java/org/apache/curator/framework/recipes/locks/TestInterProcessSemaphore.java +++ b/curator-recipes/src/test/java/org/apache/curator/framework/recipes/locks/TestInterProcessSemaphore.java @@ -534,44 +534,4 @@ public class TestInterProcessSemaphore extends BaseClassForTests TestCleanState.closeAndTestClean(client); } } - - @Test - public void testChildReaperCleansUpLockNodes() throws Exception - { - Timing timing = new Timing(); - CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1)); - client.start(); - - ChildReaper childReaper = null; - try - { - InterProcessSemaphoreV2 semaphore = new InterProcessSemaphoreV2(client, "/test/lock", 1); - semaphore.returnLease(semaphore.acquire(timing.forWaiting().seconds(), TimeUnit.SECONDS)); - - Assert.assertTrue(client.getChildren().forPath("/test").size() > 0); - - childReaper = new ChildReaper( - client, - "/test", - Reaper.Mode.REAP_UNTIL_GONE, - ChildReaper.newExecutorService(), - 1, - "/test-leader", - InterProcessSemaphoreV2.LOCK_SCHEMA - ); - childReaper.start(); - - timing.forWaiting().sleepABit(); - - List<String> children = client.getChildren().forPath("/test"); - - Assert.assertEquals(children.size(), 0, "All children of /test should have been reaped"); - } - finally - { - CloseableUtils.closeQuietly(childReaper); - CloseableUtils.closeQuietly(client); - } - - } }
