Lines Matching refs:response
64 GetStatusResponse* response,
66 IssueRequest(request, response, getstatus_, std::move(done));
70 CreateWorkerSessionResponse* response,
72 IssueRequest(request, response, createworkersession_, std::move(done));
76 DeleteWorkerSessionResponse* response,
78 IssueRequest(request, response, deleteworkersession_, std::move(done));
82 RegisterGraphResponse* response,
84 IssueRequest(request, response, registergraph_, std::move(done));
88 DeregisterGraphResponse* response,
90 IssueRequest(request, response, deregistergraph_, std::move(done));
94 RunGraphResponse* response, StatusCallback done) override {
95 IssueRequest(request, response, rungraph_, std::move(done), call_opts);
98 MutableRunGraphResponseWrapper* response,
100 IssueRequest(&request->ToProto(), get_proto_from_wrapper(response),
105 CleanupGraphResponse* response,
107 IssueRequest(request, response, cleanupgraph_, std::move(done));
111 CleanupAllResponse* response,
113 IssueRequest(request, response, cleanupall_, std::move(done));
117 TensorResponse* response, StatusCallback done) override {
127 wrapper_done = [this, request, response, done, start_usec](Status s) {
131 int64 bytes = response->tensor().TotalBytes();
136 if (response->metadata().send_start_micros()) {
138 // remote machine began to send the RecvTensor response.
144 // the RecvTensor response can not have been sent before
149 static_cast<int64>(response->metadata().send_start_micros()));
165 << " response " << response->metadata().DebugString();
171 IssueRequest(request, response, recvtensor_, *cb_to_use, call_opts);
174 void LoggingAsync(const LoggingRequest* request, LoggingResponse* response,
176 IssueRequest(request, response, logging_, done);
179 void TracingAsync(const TracingRequest* request, TracingResponse* response,
181 IssueRequest(request, response, tracing_, done);
188 protobuf::Message* response, const ::grpc::string& method,
190 new RPCState<protobuf::Message>(&stub_, cq_, method, *request, response,
193 void IssueRequest(const protobuf::Message* request, TensorResponse* response,
196 new RPCState<TensorResponse>(&stub_, cq_, method, *request, response,
