From 1a112667800a4e125f45d89818ffd4703429eba0 Mon Sep 17 00:00:00 2001 From: Andrew Ferguson Date: Wed, 5 Sep 2012 14:24:58 -0400 Subject: [PATCH] Finish fix to async client --- benchmark.conf | 17 +++++++++-------- .../cs/zkbenchmark/AsyncBenchmarkClient.java | 1 - .../brown/cs/zkbenchmark/BenchmarkListener.java | 1 + 3 files changed, 10 insertions(+), 9 deletions(-) diff --git a/benchmark.conf b/benchmark.conf index 9d75d94..d3e285f 100644 --- a/benchmark.conf +++ b/benchmark.conf @@ -18,13 +18,14 @@ lowerbound=8000 # Whether requests should be submitted synchronously or asynchronously. # Can also be set on the command-line. -sync=false +sync=true # List of ZooKeeper servers to connect to. -#server.1=host1:2181 -#server.2=host2:2181 -#server.3=host3:2181 -#server.4=host4:2181 -#server.5=host5:2181 -server.1=127.0.0.1:2181 -server.2=127.0.0.1:2182 +server.1=host1:2181 +server.2=host2:2181 +server.3=host3:2181 +server.4=host4:2181 +server.5=host5:2181 +#server.1=127.0.0.1:2181 +#server.2=127.0.0.1:2182 +#server.3=127.0.0.1:2183 diff --git a/src/main/java/edu/brown/cs/zkbenchmark/AsyncBenchmarkClient.java b/src/main/java/edu/brown/cs/zkbenchmark/AsyncBenchmarkClient.java index 472bd62..ee32918 100644 --- a/src/main/java/edu/brown/cs/zkbenchmark/AsyncBenchmarkClient.java +++ b/src/main/java/edu/brown/cs/zkbenchmark/AsyncBenchmarkClient.java @@ -110,7 +110,6 @@ protected void finish() { synchronized (_asyncRunning) { _asyncRunning.notify(); _asyncRunning = false; - } } diff --git a/src/main/java/edu/brown/cs/zkbenchmark/BenchmarkListener.java b/src/main/java/edu/brown/cs/zkbenchmark/BenchmarkListener.java index 9bfe914..f3df0ba 100644 --- a/src/main/java/edu/brown/cs/zkbenchmark/BenchmarkListener.java +++ b/src/main/java/edu/brown/cs/zkbenchmark/BenchmarkListener.java @@ -28,6 +28,7 @@ public void eventReceived(CuratorFramework client, CuratorEvent event) { (type == CuratorEventType.CREATE && _client.getBenchmark().getCurrentTest() == TestType.CREATE)) { _client.getBenchmark().incrementFinished(); _client.recordEvent(event); + _client.resubmit(1); } } }