| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 60 std::unique_ptr<MessageReceiverWithStatus> responder) { in AcceptWithResponder() argument
65 responder.get()); in AcceptWithResponder()
66 EXPECT_TRUE(responder->IsConnected()); in AcceptWithResponder()
73 MessageReceiver* responder) { in SendResponse() argument
79 return responder->Accept(&response); in SendResponse()
89 std::unique_ptr<MessageReceiverWithStatus> responder) { in AcceptWithResponder() argument
94 responder_ = std::move(responder); in AcceptWithResponder()
|
| D | router_test_util.h | 47 std::unique_ptr<MessageReceiverWithStatus> responder) override;
51 MessageReceiver* responder);
63 std::unique_ptr<MessageReceiverWithStatus> responder) override;
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | thread_safe_interface_ptr.h | 106 std::unique_ptr<MessageReceiver> responder) override { in AcceptWithResponder() argument
118 std::make_unique<ForwardToCallingThread>(std::move(responder)); in AcceptWithResponder()
129 forward_with_responder_.Run(std::move(*message), std::move(responder)); in AcceptWithResponder()
164 ignore_result(responder->Accept(&response->message)); in AcceptWithResponder()
218 explicit ForwardToCallingThread(std::unique_ptr<MessageReceiver> responder) in ForwardToCallingThread() argument
219 : responder_(std::move(responder)), in ForwardToCallingThread()
239 std::unique_ptr<MessageReceiver> responder, in CallAcceptAndDeleteResponder() argument
241 ignore_result(responder->Accept(&message)); in CallAcceptAndDeleteResponder()
359 std::unique_ptr<MessageReceiver> responder) { in AcceptWithResponder() argument
361 std::move(responder)); in AcceptWithResponder()
|
| D | message.h | 273 std::unique_ptr<MessageReceiver> responder)
308 responder) WARN_UNUSED_RESULT = 0;
|
| /external/autotest/client/common_lib/cros/ |
| D | dbus_send_unittest.py | 193 assert result.responder == ':1.40', 'Responder == %r' % result.responder
208 assert result.responder == ':1.37', 'Responder == %r' % result.responder
|
| D | dbus_send.py | 123 responder = match.group(3)
128 return DBusSendResult(sender=sender, responder=responder, response=ret_val)
|
| /external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | RouterImpl.java | 167 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
187 mResponders.put(requestId, responder); in acceptWithResponder()
230 MessageReceiver responder = mResponders.get(requestId); in handleIncomingMessage() local
231 if (responder == null) { in handleIncomingMessage()
235 return responder.accept(message); in handleIncomingMessage()
|
| D | AutoCloseableRouter.java | 74 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
75 return mRouter.acceptWithResponder(message, responder); in acceptWithResponder()
|
| D | InterfaceControlMessagesHelper.java | 74 Core core, Manager<I, P> manager, ServiceMessage message, MessageReceiver responder) { in handleRun() argument
86 return responder.accept(response.serializeWithHeader( in handleRun()
|
| D | MessageReceiverWithResponder.java | 20 boolean acceptWithResponder(Message message, MessageReceiver responder); in acceptWithResponder() argument
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | interface_endpoint_client.cc | 247 std::unique_ptr<MessageReceiver> responder) { in AcceptWithResponder() argument
273 async_responders_[request_id] = std::move(responder); in AcceptWithResponder()
292 ignore_result(responder->Accept(&iter->second->response)); in AcceptWithResponder()
387 std::unique_ptr<MessageReceiverWithStatus> responder = in HandleValidatedMessage() local
392 std::move(responder)); in HandleValidatedMessage()
395 std::move(responder)); in HandleValidatedMessage()
412 std::unique_ptr<MessageReceiver> responder = std::move(it->second); in HandleValidatedMessage() local
414 return responder->Accept(message); in HandleValidatedMessage()
|
| D | control_message_handler.cc | 84 std::unique_ptr<MessageReceiverWithStatus> responder) { in AcceptWithResponder() argument
89 return Run(message, std::move(responder)); in AcceptWithResponder()
97 std::unique_ptr<MessageReceiverWithStatus> responder) { in Run() argument
126 ignore_result(responder->Accept(&response_message)); in Run()
|
| D | control_message_handler.h | 32 std::unique_ptr<MessageReceiverWithStatus> responder) override;
36 std::unique_ptr<MessageReceiverWithStatus> responder);
|
| D | associated_interface_ptr_state.h | 75 std::unique_ptr<MessageReceiver> responder) { in ForwardMessageWithResponder() argument
76 endpoint_client_->AcceptWithResponder(&message, std::move(responder)); in ForwardMessageWithResponder()
|
| D | interface_ptr_state.h | 191 std::unique_ptr<MessageReceiver> responder) { in ForwardMessageWithResponder() argument
193 endpoint_client()->AcceptWithResponder(&message, std::move(responder)); in ForwardMessageWithResponder()
|
| D | control_message_proxy.cc | 83 std::unique_ptr<MessageReceiver> responder = in SendRunMessage() local
85 ignore_result(receiver->AcceptWithResponder(&message, std::move(responder))); in SendRunMessage()
|
| /external/libchrome/mojo/public/js/lib/ |
| D | control_message_handler.js | 54 function run(message, responder, interfaceVersion) { argument
79 responder.accept(builder.finish());
98 responder) { argument
100 return run(message, responder, this.interfaceVersion_);
|
| /external/libchrome/mojo/public/tools/bindings/generators/cpp_templates/ |
| D | interface_stub_declaration.tmpl | 7 std::unique_ptr<mojo::MessageReceiverWithStatus> responder);
32 std::unique_ptr<mojo::MessageReceiverWithStatus> responder) override {
36 ImplRefTraits::GetRawPointer(&sink_), message, std::move(responder));
|
| D | interface_definition.tmpl | 151 std::unique_ptr<mojo::MessageReceiver> responder(
157 ignore_result(receiver_->AcceptWithResponder(&message, std::move(responder)));
194 std::unique_ptr<mojo::MessageReceiver> responder(
197 ignore_result(receiver_->AcceptWithResponder(&message, std::move(responder)));
221 std::unique_ptr<mojo::MessageReceiverWithStatus> responder) {
224 request_id, is_sync, std::move(responder)));
244 // If the Callback was dropped then deleting the responder will close
253 std::unique_ptr<mojo::MessageReceiverWithStatus> responder)
256 responder_(std::move(responder)) {
461 std::unique_ptr<mojo::MessageReceiverWithStatus> responder) {
[all …]
|
| /external/grpc-grpc/test/cpp/server/ |
| D | server_request_call_test.cc | 60 ServerAsyncResponseWriter<testing::EchoResponse> responder(&ctx); in TEST() local
66 service.RequestEcho(&ctx, &req, &responder, cq.get(), cq.get(), in TEST()
108 responder.Finish(response, grpc::Status::OK, (void*)2); in TEST()
|
| /external/ukey2/src/main/proto/ |
| D | device_to_device_messages.proto | 34 // sent as the first message from initiator to responder
37 // The session public key to send to the responder
44 // sent inside the header of the first message from the responder to the
|
| /external/nanohttpd/nanolets/src/main/java/fi/iki/elonen/router/ |
| D | RouterNanoHTTPD.java | 375 UriResponder responder = (UriResponder) object; in process() local
378 return responder.get(this, urlParams, session); in process()
380 return responder.post(this, urlParams, session); in process()
382 return responder.put(this, urlParams, session); in process()
384 return responder.delete(this, urlParams, session); in process()
386 … return responder.other(session.getMethod().toString(), this, urlParams, session); in process()
|
| /external/iputils/ |
| D | rdisc.c | 189 int responder; variable
318 responder = 1; in main()
376 if (responder) in main()
390 if (responder) in main()
406 if (solicit && responder) { in main()
430 if (responder) in main()
507 if (responder && left_until_advertise <= 0) { in timer()
745 if (responder) in pr_pack()
834 if (!responder) in pr_pack()
965 if (responder) { in finish()
|
| /external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
| D | BindingsTestUtils.java | 52 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
53 messagesWithReceivers.add(Pair.create(message, responder)); in acceptWithResponder()
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | README.md | 220 ServerAsyncResponseWriter<HelloReply> responder;
221 service.RequestSayHello(&context, &request, &responder, &cq, &cq, (void*)1);
225 responder are ready once the tag is retrieved.
235 responder.Finish(reply, status, (void*)2);
|