Home
last modified time | relevance | path

Searched refs:MessageReceiver (Results 1 – 25 of 56) sorted by relevance

123

/external/oss-fuzz/projects/fast-dds/
Dpatch.diff17 diff --git a/src/cpp/rtps/messages/MessageReceiver.cpp b/src/cpp/rtps/messages/MessageReceiver.cpp
19 --- a/src/cpp/rtps/messages/MessageReceiver.cpp
20 +++ b/src/cpp/rtps/messages/MessageReceiver.cpp
21 @@ -324,7 +324,11 @@ void MessageReceiver::processCDRMsg(
33 @@ -513,7 +517,9 @@ void MessageReceiver::processCDRMsg(
42 bool MessageReceiver::checkRTPSHeader(
55 +#include <fastrtps/rtps/messages/MessageReceiver.h>
60 + eprosima::fastrtps::rtps::MessageReceiver* rcv = new eprosima::fastrtps::rtps::MessageReceiver…
/external/libchrome/mojo/public/cpp/bindings/
Dfilter_chain.h19 class MOJO_CPP_BINDINGS_EXPORT FilterChain : public MessageReceiver {
23 explicit FilterChain(MessageReceiver* sink = nullptr);
32 void Append(std::unique_ptr<MessageReceiver> filter);
36 void SetSink(MessageReceiver* sink);
42 std::vector<std::unique_ptr<MessageReceiver>> filters_;
44 MessageReceiver* sink_;
Dpipe_control_message_proxy.h18 class MessageReceiver; variable
27 explicit PipeControlMessageProxy(MessageReceiver* receiver);
38 MessageReceiver* receiver_;
Dinterface_endpoint_client.h47 std::unique_ptr<MessageReceiver> payload_validator,
84 void AddFilter(std::unique_ptr<MessageReceiver> filter);
101 std::unique_ptr<MessageReceiver> responder) override;
121 std::map<uint64_t, std::unique_ptr<MessageReceiver>>;
141 class HandleIncomingMessageThunk : public MessageReceiver {
Dmessage.h251 class COMPONENT_EXPORT(MOJO_CPP_BINDINGS_BASE) MessageReceiver { in COMPONENT_EXPORT()
253 virtual ~MessageReceiver() {} in COMPONENT_EXPORT()
264 class MessageReceiverWithResponder : public MessageReceiver {
273 std::unique_ptr<MessageReceiver> responder)
280 class MessageReceiverWithStatus : public MessageReceiver {
298 class MessageReceiverWithResponderStatus : public MessageReceiver {
312 : public MessageReceiver { in COMPONENT_EXPORT()
Dthread_safe_interface_ptr.h47 base::Callback<void(Message, std::unique_ptr<MessageReceiver>)>;
106 std::unique_ptr<MessageReceiver> responder) override { in AcceptWithResponder()
183 class SyncResponseSignaler : public MessageReceiver {
216 class ForwardToCallingThread : public MessageReceiver {
218 explicit ForwardToCallingThread(std::unique_ptr<MessageReceiver> responder) in ForwardToCallingThread()
239 std::unique_ptr<MessageReceiver> responder, in CallAcceptAndDeleteResponder()
244 std::unique_ptr<MessageReceiver> responder_;
359 std::unique_ptr<MessageReceiver> responder) { in AcceptWithResponder()
Dconnector.h42 class MOJO_CPP_BINDINGS_EXPORT Connector : public MessageReceiver {
93 void set_incoming_receiver(MessageReceiver* receiver) { in set_incoming_receiver()
232 MessageReceiver* incoming_receiver_ = nullptr;
275 std::unique_ptr<MessageReceiver> message_dumper_;
Dassociated_binding.h29 class MessageReceiver; variable
41 void AddFilter(std::unique_ptr<MessageReceiver> filter);
74 std::unique_ptr<MessageReceiver> payload_validator,
Dbinding.h25 class MessageReceiver; variable
107 void AddFilter(std::unique_ptr<MessageReceiver> filter) { in AddFilter()
/external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
DRouterImpl.java26 private class HandleIncomingMessageThunk implements MessageReceiver {
50 class ResponderThunk implements MessageReceiver {
102 private Map<Long, MessageReceiver> mResponders = new HashMap<Long, MessageReceiver>();
167 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder()
230 MessageReceiver responder = mResponders.get(requestId); in handleIncomingMessage()
DConnector.java25 public class Connector implements MessageReceiver, HandleOwner<MessagePipeHandle> {
45 private MessageReceiver mIncomingMessageReceiver;
72 public void setIncomingMessageReceiver(MessageReceiver incomingMessageReceiver) { in setIncomingMessageReceiver()
130 MessageReceiver incomingMessageReceiver = mIncomingMessageReceiver; in close()
196 MessagePipeHandle handle, MessageReceiver receiver) { in readAndDispatchMessage()
DMessageReceiverWithResponder.java11 public interface MessageReceiverWithResponder extends MessageReceiver {
20 boolean acceptWithResponder(Message message, MessageReceiver responder); in acceptWithResponder()
DInterfaceControlMessagesHelper.java30 extends SideEffectFreeCloseable implements MessageReceiver {
74 Core core, Manager<I, P> manager, ServiceMessage message, MessageReceiver responder) { in handleRun()
/external/libchrome/mojo/public/cpp/bindings/lib/
Dfilter_chain.cc13 FilterChain::FilterChain(MessageReceiver* sink) : sink_(sink) { in FilterChain()
30 void FilterChain::SetSink(MessageReceiver* sink) { in SetSink()
43 void FilterChain::Append(std::unique_ptr<MessageReceiver> filter) { in Append()
Dassociated_binding.cc16 void AssociatedBindingBase::AddFilter(std::unique_ptr<MessageReceiver> filter) { in AddFilter()
52 std::unique_ptr<MessageReceiver> payload_validator, in BindImpl()
Dbinding_state.cc16 void BindingStateBase::AddFilter(std::unique_ptr<MessageReceiver> filter) { in AddFilter()
85 std::unique_ptr<MessageReceiver> request_validator, in BindInternal()
Dbinding_state.h41 void AddFilter(std::unique_ptr<MessageReceiver> filter);
87 std::unique_ptr<MessageReceiver> request_validator,
Dinterface_endpoint_client.cc141 std::unique_ptr<MessageReceiver> payload_validator, in InterfaceEndpointClient()
200 std::unique_ptr<MessageReceiver> filter) { in AddFilter()
247 std::unique_ptr<MessageReceiver> responder) { in AcceptWithResponder()
412 std::unique_ptr<MessageReceiver> responder = std::move(it->second); in HandleValidatedMessage()
Dassociated_interface_ptr_state.h75 std::unique_ptr<MessageReceiver> responder) { in ForwardMessageWithResponder()
83 std::unique_ptr<MessageReceiver> validator,
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/
DBindingsTestUtils.java27 extends SideEffectFreeCloseable implements MessageReceiver {
45 public final List<Pair<Message, MessageReceiver>> messagesWithReceivers =
46 new ArrayList<Pair<Message, MessageReceiver>>();
52 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder()
DValidationTest.java117 private static void runTest(String prefix, MessageReceiver messageReceiver) in runTest()
142 private static class RoutingMessageReceiver implements MessageReceiver {
144 private final MessageReceiver mResponse;
147 MessageReceiverWithResponder request, MessageReceiver response) { in RoutingMessageReceiver()
189 public boolean acceptWithResponder(Message message, MessageReceiver responder) { in acceptWithResponder()
DRouterTest.java124 Pair<Message, MessageReceiver> receivedMessage = in sendMessageToRouter()
137 Pair<Message, MessageReceiver> receivedMessage = in sendResponseFromRouter()
168 for (Pair<Message, MessageReceiver> receivedMessage : in clearAllMessageReceivers()
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/test/mojom/mojo/
DIntegrationTestInterfaceTestHelper.java7 import org.chromium.mojo.bindings.MessageReceiver;
25 public static MessageReceiver newIntegrationTestInterfaceMethodCallback() { in newIntegrationTestInterfaceMethodCallback()
/external/libchrome/mojo/public/cpp/bindings/tests/
Drouter_test_util.h26 class MessageAccumulator : public MessageReceiver {
51 MessageReceiver* responder);
Dbindings_perftest.cc141 PingPongPaddle(MessageReceiver* sender) : sender_(sender) {} in PingPongPaddle()
143 void set_sender(MessageReceiver* sender) { sender_ = sender; } in set_sender()
189 MessageReceiver* sender_;

123