diff options
author | Siddharth Rakesh <sidrakesh@google.com> | 2015-06-08 15:44:23 -0700 |
---|---|---|
committer | Siddharth Rakesh <sidrakesh@google.com> | 2015-06-08 15:44:23 -0700 |
commit | 9865e0d8a3e1ec19a0b55eb10a9a20e7a500015f (patch) | |
tree | aa19a9dd2481adacaf48e0ec9a85171f098c7e74 /test | |
parent | ef3ca1b3bf0f3f8f05bfc47f84ace7be0d0052ee (diff) | |
parent | 5ce0469d3f1b5e77eba0cef90eb2d959c2078ede (diff) |
Merge branch 'master' of https://github.com/grpc/grpc into leaderboard
Diffstat (limited to 'test')
-rw-r--r-- | test/cpp/qps/server_async.cc | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/test/cpp/qps/server_async.cc b/test/cpp/qps/server_async.cc index 977dfc2372..4b0678bb2c 100644 --- a/test/cpp/qps/server_async.cc +++ b/test/cpp/qps/server_async.cc @@ -101,10 +101,11 @@ class AsyncQpsServerTest : public Server { ServerRpcContext *ctx = detag(got_tag); // The tag is a pointer to an RPC context to invoke bool still_going = ctx->RunNextState(ok); - std::lock_guard<std::mutex> g(shutdown_mutex_); + std::unique_lock<std::mutex> g(shutdown_mutex_); if (!shutdown_) { // this RPC context is done, so refresh it if (!still_going) { + g.unlock(); ctx->Reset(); } } else { |