| /external/pigweed/pw_rpc/nanopb/ |
| D | nanopb_client_call_test.cc | 90 context.SendResponse(OkStatus(), response); in TEST()
106 context.SendResponse(OkStatus(), bad_payload); in TEST()
133 context.SendResponse(Status::Unimplemented(), r1); in TEST()
135 context.SendResponse(Status::OutOfRange(), r2); in TEST()
137 context.SendResponse(Status::Internal(), r3); in TEST()
171 context.SendResponse(OkStatus(), r1); in TEST()
177 context.SendResponse(OkStatus(), r2); in TEST()
183 context.SendResponse(OkStatus(), r3); in TEST()
198 context.SendResponse(OkStatus(), r1); in TEST()
202 context.SendResponse(OkStatus(), r2); in TEST()
[all …]
|
| D | nanopb_method.cc | 35 SendResponse(call.channel(), request, response_struct, status); in CallUnary()
62 void NanopbMethod::SendResponse(Channel& channel, in SendResponse() function in pw::rpc::internal::NanopbMethod
|
| D | codegen_test.cc | 155 context.SendResponse(OkStatus(), response); in TEST()
180 context.SendResponse(OkStatus(), response); in TEST()
|
| /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/p2p/base/ |
| D | stun_server.cc | 58 SendResponse(response, remote_addr); in OnBindingRequest()
74 SendResponse(err_msg, addr); in SendErrorResponse()
77 void StunServer::SendResponse(const StunMessage& msg, in SendResponse() function in cricket::StunServer
|
| D | test_stun_server.cc | 34 SendResponse(response, remote_addr); in OnBindingRequest()
|
| D | stun_server.h | 58 void SendResponse(const StunMessage& msg, const rtc::SocketAddress& addr);
|
| D | turn_server.cc | 704 SendResponse(&response); in HandleAllocateRequest()
727 SendResponse(&response); in HandleRefreshRequest()
777 SendResponse(&response); in HandleCreatePermissionRequest()
826 SendResponse(&response); in HandleChannelBindRequest()
933 void TurnServerAllocation::SendResponse(TurnMessage* msg) { in SendResponse() function in cricket::TurnServerAllocation
|
| D | turn_server.h | 119 void SendResponse(TurnMessage* msg);
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_service.cc | 110 return call->SendResponse(ToGrpcStatus(s)); in GetTpuProgram()
115 return call->SendResponse(::grpc::Status( in GetTpuProgram()
135 return call->SendResponse(ToGrpcStatus(buffer_slices.status())); in GetTpuProgram()
140 return call->SendResponse(::grpc::Status()); in GetTpuProgram()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 58 call->SendResponse( \
78 call->SendResponse(ToGrpcStatus(local_impl_.Enqueue( in EnqueueHandler()
99 call->SendResponse(ToGrpcStatus(s)); in RunComponentFunctionHandler()
138 call->SendResponse(); in StreamingEnqueueHandler()
|
| /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/pigweed/pw_rpc/ |
| D | client_test.cc | 52 EXPECT_EQ(context.SendResponse(OkStatus(), {}), OkStatus()); in TEST()
60 EXPECT_EQ(context.SendResponse(OkStatus(), {}), Status::NotFound()); in TEST()
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_responder.cc | 351 alarm_.ScheduleFromNow([this]() { SendResponse(); }, send_delay); in RescheduleSend()
354 void MdnsResponder::TruncatedQuery::SendResponse() { in SendResponse() function in openscreen::discovery::MdnsResponder::TruncatedQuery
500 new_query->SendResponse(); in ProcessMultiPacketTruncatedMessage()
566 SendResponse(question, known_answers, send_response, is_exclusive_owner); in ProcessQueries()
571 SendResponse(question, known_answers, send_response, in ProcessQueries()
579 void MdnsResponder::SendResponse( in SendResponse() function in openscreen::discovery::MdnsResponder
|
| D | mdns_responder.h | 105 void SendResponse();
146 void SendResponse(const MdnsQuestion& question,
|
| /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/webrtc/test/network/ |
| D | feedback_generator.cc | 75 route_.SendResponse(conf_.feedback_packet_size.bytes<size_t>(), builder_); in OnRequest()
|
| D | network_emulation.h | 281 void SendResponse(size_t size, ResponsePacketType packet) { in SendResponse() function
|
| D | cross_traffic.cc | 266 route_.SendResponse(kAckPacketSize, sequence_number); in OnRequest()
|
| /external/pigweed/pw_rpc/pw_rpc_private/ |
| D | internal_test_utils.h | 159 Status SendResponse(Status status, std::span<const std::byte> payload) { in SendResponse() function
|
| /external/pigweed/pw_rpc/nanopb/public/pw_rpc/internal/ |
| D | nanopb_method.h | 289 void SendResponse(Channel& channel,
|