HomeSort by relevance Sort by last modified time
    Searched refs:MessagePipeDispatcher (Results 1 - 5 of 5) sorted by null

  /external/libmojo/mojo/edk/system/
message_pipe_dispatcher.h 25 class MessagePipeDispatcher : public Dispatcher {
27 // Constructs a MessagePipeDispatcher permanently tied to a specific port.
32 // A MessagePipeDispatcher may not be transferred while in a disconnected
38 MessagePipeDispatcher(NodeController* node_controller,
46 bool Fuse(MessagePipeDispatcher* other);
92 ~MessagePipeDispatcher() override;
115 DISALLOW_COPY_AND_ASSIGN(MessagePipeDispatcher);
message_pipe_dispatcher.cc 44 // A PortObserver which forwards to a MessagePipeDispatcher. This owns a
46 class MessagePipeDispatcher::PortObserverThunk
49 explicit PortObserverThunk(scoped_refptr<MessagePipeDispatcher> dispatcher)
58 scoped_refptr<MessagePipeDispatcher> dispatcher_;
68 // various (unowned) local state within MessagePipeDispatcher::ReadMessage.
160 MessagePipeDispatcher::MessagePipeDispatcher(NodeController* node_controller,
168 DVLOG(2) << "Creating new MessagePipeDispatcher for port " << port.name()
176 bool MessagePipeDispatcher::Fuse(MessagePipeDispatcher* other)
    [all...]
wait_set_dispatcher_unittest.cc 58 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...]
core.cc 194 MojoHandle handle = AddDispatcher(new MessagePipeDispatcher(
344 new MessagePipeDispatcher(GetNodeController(), port0,
355 new MessagePipeDispatcher(GetNodeController(), port0,
623 new MessagePipeDispatcher(GetNodeController(), port0, pipe_id, 0));
628 new MessagePipeDispatcher(GetNodeController(), port1, pipe_id, 1));
750 MessagePipeDispatcher* mpd0 =
751 static_cast<MessagePipeDispatcher*>(dispatcher0.get());
752 MessagePipeDispatcher* mpd1 =
753 static_cast<MessagePipeDispatcher*>(dispatcher1.get());
    [all...]
dispatcher.cc 162 return MessagePipeDispatcher::Deserialize(

Completed in 159 milliseconds