| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 76 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) { in CallData()
91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
107 responder_.Finish(reply_, Status::OK, this); in Proceed()
132 ServerAsyncResponseWriter<HelloReply> responder_; member in ServerImpl::CallData
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 83 : responder_(nullptr), name_(0), request_id_(0), closure_(closure) {} in LazyResponseGenerator()
94 responder_ = std::move(responder); in AcceptWithResponder()
104 SendResponse(name_, request_id_, request_string_.c_str(), responder_.get()); in Complete()
106 responder_ = nullptr; in Complete()
|
| D | router_test_util.h | 65 bool has_responder() const { return !!responder_; } in has_responder()
67 bool responder_is_valid() const { return responder_->IsConnected(); } in responder_is_valid()
82 std::unique_ptr<MessageReceiverWithStatus> responder_; variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 164 : handle_request_function_(handle_request_function), responder_(&ctx_) {} in Call()
177 responder_.Finish(response, status, &response_sent_tag_); in SendResponse()
221 &call->responder_, cq, cq, in EnqueueRequest()
242 &call->responder_, cq, cq, in EnqueueRequestForMethod()
265 ::grpc::ServerAsyncResponseWriter<ResponseMessage> responder_;
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | thread_safe_interface_ptr.h | 219 : responder_(std::move(responder)), in ForwardToCallingThread()
222 caller_task_runner_->DeleteSoon(FROM_HERE, std::move(responder_)); in ~ForwardToCallingThread()
233 base::Passed(std::move(responder_)), in Accept()
244 std::unique_ptr<MessageReceiver> responder_; variable
|
| /external/libchrome/mojo/public/tools/bindings/generators/cpp_templates/ |
| D | interface_definition.tmpl | 236 if (responder_) {
241 responder_->IsConnectedAsync(base::BindOnce(&OnIsConnectedComplete));
246 responder_ = nullptr;
256 responder_(std::move(responder)) {
274 std::unique_ptr<mojo::MessageReceiverWithStatus> responder_;
326 const bool kSerialize = responder_->PrefersSerializedMessages();
349 ignore_result(responder_->Accept(&message));
353 responder_ = nullptr;
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_responder.cc | 298 responder_(responder), in TruncatedQuery()
302 OSP_DCHECK(responder_); in TruncatedQuery()
348 send_delay = responder_->random_delay_->GetTruncatedQueryResponseDelay(); in RescheduleSend()
363 responder_->RespondToTruncatedQuery(this); in SendResponse()
|
| D | mdns_service_impl.h | 90 std::unique_ptr<MdnsResponder> responder_; variable
|
| D | mdns_responder.h | 123 MdnsResponder* const responder_; variable
|
| D | mdns_service_impl.cc | 85 responder_ = std::make_unique<MdnsResponder>( in MdnsServiceImpl()
|
| D | mdns_responder_unittest.cc | 131 responder_(&record_handler_, in MdnsResponderTest()
173 responder_.OnMessageReceived(message, src); in OnMessageReceived()
220 MdnsResponder responder_; member in openscreen::discovery::MdnsResponderTest
|