| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service.cc | 157 call->SendResponse(ToGrpcStatus(status)); in CreateSessionHandler()
168 call->SendResponse(ToGrpcStatus(status)); in ExtendSessionHandler()
178 call->SendResponse(ToGrpcStatus(status)); in PartialRunSetupHandler()
207 call->SendResponse(ToGrpcStatus(Status::OK())); in RunStepHandler()
209 call->SendResponse(ToGrpcStatus(status)); in RunStepHandler()
220 call->SendResponse(ToGrpcStatus(status)); in CloseSessionHandler()
230 call->SendResponse(ToGrpcStatus(status)); in ListDevicesHandler()
239 call->SendResponse(ToGrpcStatus(status)); in ResetHandler()
249 call->SendResponse(ToGrpcStatus(status)); in MakeCallableHandler()
269 call->SendResponse(ToGrpcStatus(status)); in RunCallableHandler()
[all …]
|
| D | grpc_worker_service.cc | 199 call->SendResponse(ToGrpcStatus(s)); \
227 call->SendResponse(ToGrpcStatus(s)); in GetStepSequenceHandler()
237 call->SendResponse(::grpc::Status::OK); in MarkRecvFinishedHandler()
260 call->SendResponse(ToGrpcStatus(s)); in RunGraphHandler()
280 call->SendResponse(ToGrpcStatus(s)); in RecvTensorHandlerRaw()
297 call->SendResponse(ToGrpcStatus(s)); in RecvBufHandler()
316 call->SendResponse(ToGrpcStatus(s)); in CompleteGroupHandler()
335 call->SendResponse(ToGrpcStatus(s)); in CompleteInstanceHandler()
|
| D | grpc_call.h | 175 void SendResponse(::grpc::Status status) { in SendResponse() function
457 void SendResponse() { in SendResponse() function
|
| /external/webrtc/webrtc/p2p/base/ |
| D | stunserver.cc | 55 SendResponse(response, remote_addr); in OnBindingRequest()
70 SendResponse(err_msg, addr); in SendErrorResponse()
73 void StunServer::SendResponse( in SendResponse() function in cricket::StunServer
|
| D | teststunserver.h | 48 SendResponse(response, remote_addr); in OnBindingRequest()
|
| D | stunserver.h | 52 void SendResponse(const StunMessage& msg,
|
| D | turnserver.cc | 647 SendResponse(&response); in HandleAllocateRequest()
668 SendResponse(&response); in HandleRefreshRequest()
716 SendResponse(&response); in HandleCreatePermissionRequest()
765 SendResponse(&response); in HandleChannelBindRequest()
869 void TurnServerAllocation::SendResponse(TurnMessage* msg) { in SendResponse() function in cricket::TurnServerAllocation
|
| D | turnserver.h | 114 void SendResponse(TurnMessage* msg);
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 63 bool result = SendResponse(message->name(), message->request_id(), in AcceptWithResponder()
70 bool ResponseGenerator::SendResponse(uint32_t name, in SendResponse() function in mojo::test::ResponseGenerator
104 SendResponse(name_, request_id_, request_string_.c_str(), responder_.get()); in Complete()
|
| D | router_test_util.h | 48 bool SendResponse(uint32_t name,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 58 call->SendResponse( \
102 call->SendResponse(); in StreamingEnqueueHandler()
|
| /external/libchrome/dbus/ |
| D | exported_object.cc | 234 base::Bind(&ExportedObject::SendResponse, in HandleMessage()
251 base::Bind(&ExportedObject::SendResponse, in RunMethod()
257 void ExportedObject::SendResponse(base::TimeTicks start_time, in SendResponse() function in dbus::ExportedObject
|
| D | exported_object.h | 149 void SendResponse(base::TimeTicks start_time,
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 233 SendResponse(stream, response_and_delay.first, response_and_delay.second); in BalanceLoad()
322 void SendResponse(Stream* stream, const LoadBalanceResponse& response, in SendResponse() function in grpc::testing::__anon105c9b2c0111::BalancerServiceImpl
|