Searched refs:MessagePipeDispatcher (Results 1 - 5 of 5) sorted by relevance

/external/libmojo/mojo/edk/system/
H A Dmessage_pipe_dispatcher.cc43 // A PortObserver which forwards to a MessagePipeDispatcher. This owns a
45 class MessagePipeDispatcher::PortObserverThunk
48 explicit PortObserverThunk(scoped_refptr<MessagePipeDispatcher> dispatcher)
57 scoped_refptr<MessagePipeDispatcher> dispatcher_;
62 MessagePipeDispatcher::MessagePipeDispatcher(NodeController* node_controller, function in class:mojo::edk::MessagePipeDispatcher
70 DVLOG(2) << "Creating new MessagePipeDispatcher for port " << port.name()
78 bool MessagePipeDispatcher::Fuse(MessagePipeDispatcher* other) {
103 Dispatcher::Type MessagePipeDispatcher
[all...]
H A Dmessage_pipe_dispatcher.h26 class MessagePipeDispatcher : public Dispatcher { class in namespace:mojo::edk
28 // Constructs a MessagePipeDispatcher permanently tied to a specific port.
33 // A MessagePipeDispatcher may not be transferred while in a disconnected
39 MessagePipeDispatcher(NodeController* node_controller,
47 bool Fuse(MessagePipeDispatcher* other);
93 ~MessagePipeDispatcher() override;
116 DISALLOW_COPY_AND_ASSIGN(MessagePipeDispatcher);
H A Dwait_set_dispatcher_unittest.cc58 void CreateMessagePipe(scoped_refptr<MessagePipeDispatcher>* d0,
59 scoped_refptr<MessagePipeDispatcher>* d1) {
64 *d0 = scoped_refptr<MessagePipeDispatcher>(
65 static_cast<MessagePipeDispatcher*>(core->GetDispatcher(h0).get()));
66 *d1 = scoped_refptr<MessagePipeDispatcher>(
67 static_cast<MessagePipeDispatcher*>(core->GetDispatcher(h1).get()));
78 void WriteMessage(MessagePipeDispatcher* dispatcher,
97 void ReadMessage(MessagePipeDispatcher* dispatcher,
108 scoped_refptr<MessagePipeDispatcher> dispatcher0_;
109 scoped_refptr<MessagePipeDispatcher> dispatcher1
[all...]
H A Ddispatcher.cc162 return MessagePipeDispatcher::Deserialize(
H A Dcore.cc330 new MessagePipeDispatcher(GetNodeController(), port0,
341 new MessagePipeDispatcher(GetNodeController(), port0,
609 new MessagePipeDispatcher(GetNodeController(), port0, pipe_id, 0));
614 new MessagePipeDispatcher(GetNodeController(), port1, pipe_id, 1));
736 MessagePipeDispatcher* mpd0 =
737 static_cast<MessagePipeDispatcher*>(dispatcher0.get());
738 MessagePipeDispatcher* mpd1 =
739 static_cast<MessagePipeDispatcher*>(dispatcher1.get());

Completed in 182 milliseconds