Repository: tinkerpop Updated Branches: refs/heads/TINKERPOP-1564 a406a8827 -> 15575e5a7
removed the need for Thread.sleep() in one of the GraphActorsTest. Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/15575e5a Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/15575e5a Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/15575e5a Branch: refs/heads/TINKERPOP-1564 Commit: 15575e5a784b148f2280bc4629a6aea9c252549d Parents: a406a88 Author: Marko A. Rodriguez <okramma...@gmail.com> Authored: Wed Jan 25 14:40:44 2017 -0700 Committer: Marko A. Rodriguez <okramma...@gmail.com> Committed: Wed Jan 25 14:40:44 2017 -0700 ---------------------------------------------------------------------- .../process/actors/TestSetupTerminateActorProgram.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/15575e5a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/actors/TestSetupTerminateActorProgram.java ---------------------------------------------------------------------- diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/actors/TestSetupTerminateActorProgram.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/actors/TestSetupTerminateActorProgram.java index cffc61a..0347794 100644 --- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/actors/TestSetupTerminateActorProgram.java +++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/actors/TestSetupTerminateActorProgram.java @@ -59,6 +59,7 @@ class TestSetupTerminateActorProgram implements ActorProgram<List<Integer>> { public void terminate() { assertTrue(this.hasSetup); worker.send(worker.master(), WORKER_TERMINATE); + worker.send(worker.master(), "kill"); } }; } @@ -74,11 +75,6 @@ class TestSetupTerminateActorProgram implements ActorProgram<List<Integer>> { @Override public void setup() { master.send(master.address(), MASTER_SETUP); - try { - Thread.sleep(250); - } catch (final Exception e) { - } - master.send(master.address(), "kill"); } @Override @@ -98,6 +94,7 @@ class TestSetupTerminateActorProgram implements ActorProgram<List<Integer>> { assertEquals(1, this.masterSetup); assertEquals(0, this.masterTerminate); assertEquals(this.workerSetup, this.workerTerminate); + assertEquals(master.workers().size(), master.workers().stream().map(Address::toString).distinct().count()); master.close(); } }
