diff options
author | 2016-02-02 09:36:36 -0800 | |
---|---|---|
committer | 2016-02-02 09:36:36 -0800 | |
commit | 21e5d2b2f10bc6d175caf7ad44d729517528a78a (patch) | |
tree | 6058ebb5815554e3850b3a5f289e599fd9425b80 /test/cpp/qps/qps_worker.h | |
parent | 0727180da8891485168fbe39b4c9ebb859b6b390 (diff) |
Add a Quit RPC so that we can conveniently shut down the workers from the driver.
Diffstat (limited to 'test/cpp/qps/qps_worker.h')
-rw-r--r-- | test/cpp/qps/qps_worker.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/test/cpp/qps/qps_worker.h b/test/cpp/qps/qps_worker.h index 27de69fa65..f14a5c95ad 100644 --- a/test/cpp/qps/qps_worker.h +++ b/test/cpp/qps/qps_worker.h @@ -36,6 +36,8 @@ #include <memory> +#include <grpc/support/atm.h> + namespace grpc { class Server; @@ -49,9 +51,13 @@ class QpsWorker { explicit QpsWorker(int driver_port, int server_port = 0); ~QpsWorker(); + bool Done() const; + void MarkDone(); private: std::unique_ptr<WorkerServiceImpl> impl_; std::unique_ptr<Server> server_; + + gpr_atm done_; }; } // namespace testing |