Searched refs:AsyncQpsServerTest (Results 1 – 1 of 1) sorted by relevance
49 class AsyncQpsServerTest final : public grpc::testing::Server { class51 AsyncQpsServerTest( in AsyncQpsServerTest() function in grpc::testing::AsyncQpsServerTest158 threads_.emplace_back(&AsyncQpsServerTest::ThreadFunc, this, i); in AsyncQpsServerTest()161 ~AsyncQpsServerTest() { in ~AsyncQpsServerTest()166 std::thread shutdown_thread(&AsyncQpsServerTest::ShutdownThreadFunc, this); in ~AsyncQpsServerTest()263 AsyncQpsServerTest::tag(this)); in ServerRpcContextUnaryImpl()276 AsyncQpsServerTest::tag(this)); in Reset()291 response_writer_.Finish(response_, status, AsyncQpsServerTest::tag(this)); in invoker()318 request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this)); in ServerRpcContextStreamingImpl()330 request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this)); in Reset()[all …]