aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2015-06-08 13:59:24 -0700
committerGravatar Vijay Pai <vpai@google.com>2015-06-08 13:59:24 -0700
commit93b0f63043c93d9be54fd83858f8733d2b682408 (patch)
tree216999395d35e12c4edccb7f5b83d2f4c4bd467b /test/cpp/qps
parentb6015c383c178522e35a027a542f7bb290e20ffe (diff)
parent52d646edddcb2bac053c73bff75ea9adff1d649c (diff)
Merge pull request #1979 from ctiller/cereal-is-bad-for-your-health
Dont serialize new call requests under the server test lock
Diffstat (limited to 'test/cpp/qps')
-rw-r--r--test/cpp/qps/server_async.cc3
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 {