diff options
author | Craig Tiller <ctiller@google.com> | 2016-10-17 13:56:13 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-10-17 13:56:13 -0700 |
commit | 14c836fcd10e4f96ae1f4ac22fe43d42e2e293ba (patch) | |
tree | c05471f028482aa52a87f61d8c030aaaaddef91c | |
parent | 68cf8ce8662e58aa1ebdb2dbccbb8bc270f8aade (diff) |
Delambdaify
-rw-r--r-- | test/cpp/qps/server_async.cc | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/test/cpp/qps/server_async.cc b/test/cpp/qps/server_async.cc index 191c6566ad..73a96a8443 100644 --- a/test/cpp/qps/server_async.cc +++ b/test/cpp/qps/server_async.cc @@ -131,12 +131,7 @@ class AsyncQpsServerTest : public Server { std::lock_guard<std::mutex> lock((*ss)->mutex); (*ss)->shutdown = true; } - // TODO (vpai): Remove this deadline and allow Shutdown to finish properly - std::thread shutdown_thread([this]() { - auto deadline = - std::chrono::system_clock::now() + std::chrono::seconds(3); - server_->Shutdown(deadline); - }); + std::thread shutdown_thread(&AsyncQpsServerTest::ShutdownThreadFunc, this); for (auto cq = srv_cqs_.begin(); cq != srv_cqs_.end(); ++cq) { (*cq)->Shutdown(); } @@ -153,6 +148,12 @@ class AsyncQpsServerTest : public Server { } private: + void ShutdownThreadFunc() { + // TODO (vpai): Remove this deadline and allow Shutdown to finish properly + auto deadline = std::chrono::system_clock::now() + std::chrono::seconds(3); + server_->Shutdown(deadline); + } + void ThreadFunc(int thread_idx) { // Wait until work is available or we are shutting down bool ok; |