Skip to content

Commit

Permalink
Finish fix to async client
Browse files Browse the repository at this point in the history
  • Loading branch information
adferguson committed Sep 5, 2012
1 parent 4986a65 commit 1a11266
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 9 deletions.
17 changes: 9 additions & 8 deletions benchmark.conf
Expand Up @@ -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
Expand Up @@ -110,7 +110,6 @@ protected void finish() {
synchronized (_asyncRunning) {
_asyncRunning.notify();
_asyncRunning = false;

}
}

Expand Down
Expand Up @@ -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);
}
}
}

0 comments on commit 1a11266

Please sign in to comment.