47 class ClientRpcContext {  class
49   ClientRpcContext() {}  in ClientRpcContext()  function in grpc::testing::ClientRpcContext
50   virtual ~ClientRpcContext() {}  in ~ClientRpcContext()
54   static void* tag(ClientRpcContext* c) { return static_cast<void*>(c); }  in tag()
55   static ClientRpcContext* detag(void* t) {  in detag()
56     return static_cast<ClientRpcContext*>(t);  in detag()
64 class ClientRpcContextUnaryImpl : public ClientRpcContext {
97                                  ClientRpcContext::tag(this));  in RunNextState()
144       alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in StartInternal()
161               std::function<ClientRpcContext*(  in AsyncClient()
199         delete ClientRpcContext::detag(got_tag);  in ~AsyncClient()
241   ClientRpcContext* ProcessTag(size_t thread_idx, void* tag) {  in ProcessTag()
242     ClientRpcContext* ctx = ClientRpcContext::detag(tag);  in ProcessTag()
248         ctx = ClientRpcContext::detag(tag);  in ProcessTag()
268     ClientRpcContext* ctx = ProcessTag(thread_idx, got_tag);  in ThreadFunc()
326   static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,  in SetupCtx()
336 class ClientRpcContextStreamingPingPongImpl : public ClientRpcContext {
373           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
383                                ClientRpcContext::tag(this));  in RunNextState()
385             stream_->Write(req_, ClientRpcContext::tag(this));  in RunNextState()
393           stream_->Read(&response_, ClientRpcContext::tag(this));  in RunNextState()
407             stream_->WritesDone(ClientRpcContext::tag(this));  in RunNextState()
414           stream_->Finish(&status_, ClientRpcContext::tag(this));  in RunNextState()
480     stream_->StartCall(ClientRpcContext::tag(this));  in StartInternal()
509   static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,  in SetupCtx()
521 class ClientRpcContextStreamingFromClientImpl : public ClientRpcContext {
557           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
566           stream_->Write(req_, ClientRpcContext::tag(this));  in RunNextState()
617     stream_->StartCall(ClientRpcContext::tag(this));  in StartInternal()
640   static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,  in SetupCtx()
652 class ClientRpcContextStreamingFromServerImpl : public ClientRpcContext {
685           stream_->Read(&response_, ClientRpcContext::tag(this));  in RunNextState()
732     stream_->StartCall(ClientRpcContext::tag(this));  in StartInternal()
755   static ClientRpcContext* SetupCtx(BenchmarkService::Stub* stub,  in SetupCtx()
766 class ClientRpcContextGenericStreamingImpl : public ClientRpcContext {
803           alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this));  in RunNextState()
811           stream_->Write(req_, ClientRpcContext::tag(this));  in RunNextState()
818           stream_->Read(&response_, ClientRpcContext::tag(this));  in RunNextState()
827             stream_->WritesDone(ClientRpcContext::tag(this));  in RunNextState()
834           stream_->Finish(&status_, ClientRpcContext::tag(this));  in RunNextState()
893     stream_->StartCall(ClientRpcContext::tag(this));  in StartInternal()
921   static ClientRpcContext* SetupCtx(grpc::GenericStub* stub,  in SetupCtx()