49 class AsyncQpsServerTest final : public grpc::testing::Server {  class
51   AsyncQpsServerTest(  in AsyncQpsServerTest()  function in grpc::testing::AsyncQpsServerTest
158       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()
339       stream_.Read(&req_, AsyncQpsServerTest::tag(this));  in request_done()
350         stream_.Write(response_, AsyncQpsServerTest::tag(this));  in read_done()
354         stream_.Finish(Status::OK, AsyncQpsServerTest::tag(this));  in read_done()
362         stream_.Read(&req_, AsyncQpsServerTest::tag(this));  in write_done()
365         stream_.Finish(Status::OK, AsyncQpsServerTest::tag(this));  in write_done()
397       request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this));  in ServerRpcContextStreamingFromClientImpl()
409       request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this));  in Reset()
418       stream_.Read(&req_, AsyncQpsServerTest::tag(this));  in request_done()
426         stream_.Read(&req_, AsyncQpsServerTest::tag(this));  in read_done()
434         stream_.Finish(response_, Status::OK, AsyncQpsServerTest::tag(this));  in read_done()
466                       AsyncQpsServerTest::tag(this));  in ServerRpcContextStreamingFromServerImpl()
478                       AsyncQpsServerTest::tag(this));  in Reset()
491       stream_.Write(response_, AsyncQpsServerTest::tag(this));  in request_done()
499         stream_.Write(response_, AsyncQpsServerTest::tag(this));  in write_done()
502         stream_.Finish(Status::OK, AsyncQpsServerTest::tag(this));  in write_done()
572       new AsyncQpsServerTest<SimpleRequest, SimpleResponse,  in CreateAsyncServer()
585       new AsyncQpsServerTest<ByteBuffer, ByteBuffer, grpc::AsyncGenericService,  in CreateAsyncGenericServer()