| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 60 MessageReceiverWithStatus* responder) { in AcceptWithResponder() argument
65 responder); in AcceptWithResponder()
66 EXPECT_TRUE(responder->IsValid()); in AcceptWithResponder()
67 delete responder; in AcceptWithResponder()
74 MessageReceiver* responder) { in SendResponse() argument
80 return responder->Accept(&response); in SendResponse()
92 MessageReceiverWithStatus* responder) { in AcceptWithResponder() argument
97 responder_ = responder; in AcceptWithResponder()
|
| D | router_test_util.h | 46 MessageReceiverWithStatus* responder) override;
51 MessageReceiver* responder);
62 MessageReceiverWithStatus* responder) override;
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| D | control_message_handler.cc | 42 MessageReceiverWithStatus* responder) { in AcceptWithResponder() argument
44 return Run(message, responder); in AcceptWithResponder()
51 MessageReceiverWithStatus* responder) { in Run() argument
66 bool ok = responder->Accept(builder.message()); in Run()
68 delete responder; in Run()
|
| D | interface_endpoint_client.cc | 207 MessageReceiver* responder) { in AcceptWithResponder() argument
228 async_responders_[request_id] = base::WrapUnique(responder); in AcceptWithResponder()
235 std::unique_ptr<MessageReceiver> sync_responder(responder); in AcceptWithResponder()
281 MessageReceiverWithStatus* responder = in HandleValidatedMessage() local
283 bool ok = incoming_receiver_->AcceptWithResponder(message, responder); in HandleValidatedMessage()
285 delete responder; in HandleValidatedMessage()
303 std::unique_ptr<MessageReceiver> responder = std::move(it->second); in HandleValidatedMessage() local
305 return responder->Accept(message); in HandleValidatedMessage()
|
| D | router.cc | 149 bool Router::AcceptWithResponder(Message* message, MessageReceiver* responder) { in AcceptWithResponder() argument
165 async_responders_[request_id] = base::WrapUnique(responder); in AcceptWithResponder()
172 std::unique_ptr<MessageReceiver> sync_responder(responder); in AcceptWithResponder()
257 MessageReceiverWithStatus* responder = new ResponderThunk( in HandleMessageInternal() local
259 bool ok = incoming_receiver_->AcceptWithResponder(message, responder); in HandleMessageInternal()
261 delete responder; in HandleMessageInternal()
284 std::unique_ptr<MessageReceiver> responder = std::move(it->second); in HandleMessageInternal() local
286 return responder->Accept(message); in HandleMessageInternal()
|
| D | control_message_proxy.cc | 63 MessageReceiver* responder = new RunResponseForwardToCallback(callback); in SendRunMessage() local
64 if (!receiver->AcceptWithResponder(builder.message(), responder)) in SendRunMessage()
65 delete responder; in SendRunMessage()
|
| D | control_message_handler.h | 29 MessageReceiverWithStatus* responder) override;
32 bool Run(Message* message, MessageReceiverWithStatus* responder);
|
| D | no_interface.cc | 16 MessageReceiver* responder) { in AcceptWithResponder() argument
|
| D | router.h | 82 MessageReceiver* responder) override;
|
| /external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | RouterImpl.java | 167 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
189 mResponders.put(requestId, responder); in acceptWithResponder()
233 MessageReceiver responder; in handleIncomingMessage() local
236 responder = mResponders.get(requestId); in handleIncomingMessage()
237 if (responder == null) { in handleIncomingMessage()
242 return responder.accept(message); in handleIncomingMessage()
|
| D | AutoCloseableRouter.java | 68 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
69 return mRouter.acceptWithResponder(message, responder); in acceptWithResponder()
|
| D | InterfaceControlMessagesHelper.java | 66 Core core, Manager<I, P> manager, ServiceMessage message, MessageReceiver responder) { in handleRun() argument
73 return responder.accept(response.serializeWithHeader( in handleRun()
|
| D | MessageReceiverWithResponder.java | 20 boolean acceptWithResponder(Message message, MessageReceiver responder); in acceptWithResponder() argument
|
| /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 | 120 responder = match.group(3)
125 return DBusSendResult(sender=sender, responder=responder, response=ret_val)
|
| /external/libmojo/mojo/public/tools/bindings/generators/cpp_templates/ |
| D | interface_definition.tmpl | 171 mojo::MessageReceiver* responder =
177 if (!receiver_->AcceptWithResponder(builder.message(), responder))
178 delete responder;
198 mojo::MessageReceiver* responder =
201 if (!receiver_->AcceptWithResponder(builder.message(), responder))
202 delete responder;
227 mojo::MessageReceiverWithStatus* responder,
232 request_id, is_sync, responder, group_controller);
244 mojo::MessageReceiverWithStatus* responder,
248 responder_(responder),
[all …]
|
| D | interface_stub_declaration.tmpl | 13 mojo::MessageReceiverWithStatus* responder) override;
|
| /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/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/ |
| D | BindingsTestUtils.java | 55 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder() argument
56 messagesWithReceivers.add(Pair.create(message, responder)); in acceptWithResponder()
|
| /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/libmojo/mojo/public/cpp/bindings/ |
| D | message.h | 145 virtual bool AcceptWithResponder(Message* message, MessageReceiver* responder)
185 MessageReceiverWithStatus* responder)
|
| D | no_interface.h | 42 MessageReceiver* responder) override;
|
| D | interface_endpoint_client.h | 79 MessageReceiver* responder) override;
|
| /external/mdnsresponder/mDNSPosix/ |
| D | ReadMe.txt | 211 To continue with the test you should start the responder in another
216 This will start the responder and tell it to advertise a AppleShare
224 Back in the responder window you can quit the responder cleanly using
231 As the responder quits it will multicast that the "Foo" service is
|
| /external/libmojo/mojo/public/tools/bindings/generators/js_templates/ |
| D | interface_definition.tmpl | 82 function(message, responder) {
105 responder.accept(message);
|