Searched refs:MessagePipeDispatcher (Results 1 – 5 of 5) sorted by relevance
| /external/libmojo/mojo/edk/system/ |
| D | message_pipe_dispatcher.cc | 45 class MessagePipeDispatcher::PortObserverThunk
48 explicit PortObserverThunk(scoped_refptr<MessagePipeDispatcher> dispatcher) in PortObserverThunk()
57 scoped_refptr<MessagePipeDispatcher> dispatcher_;
62 MessagePipeDispatcher::MessagePipeDispatcher(NodeController* node_controller, in MessagePipeDispatcher() function in mojo::edk::MessagePipeDispatcher
78 bool MessagePipeDispatcher::Fuse(MessagePipeDispatcher* other) { in Fuse()
103 Dispatcher::Type MessagePipeDispatcher::GetType() const { in GetType()
107 MojoResult MessagePipeDispatcher::Close() { in Close()
114 MojoResult MessagePipeDispatcher::Watch(MojoHandleSignals signals, in Watch()
126 MojoResult MessagePipeDispatcher::CancelWatch(uintptr_t context) { in CancelWatch()
135 MojoResult MessagePipeDispatcher::WriteMessage( in WriteMessage()
[all …]
|
| D | message_pipe_dispatcher.h | 26 class MessagePipeDispatcher : public Dispatcher {
39 MessagePipeDispatcher(NodeController* node_controller,
47 bool Fuse(MessagePipeDispatcher* other);
93 ~MessagePipeDispatcher() override;
116 DISALLOW_COPY_AND_ASSIGN(MessagePipeDispatcher);
|
| D | wait_set_dispatcher_unittest.cc | 58 void CreateMessagePipe(scoped_refptr<MessagePipeDispatcher>* d0, in CreateMessagePipe()
59 scoped_refptr<MessagePipeDispatcher>* d1) { in CreateMessagePipe()
64 *d0 = scoped_refptr<MessagePipeDispatcher>( in CreateMessagePipe()
65 static_cast<MessagePipeDispatcher*>(core->GetDispatcher(h0).get())); in CreateMessagePipe()
66 *d1 = scoped_refptr<MessagePipeDispatcher>( in CreateMessagePipe()
67 static_cast<MessagePipeDispatcher*>(core->GetDispatcher(h1).get())); in CreateMessagePipe()
78 void WriteMessage(MessagePipeDispatcher* dispatcher, in WriteMessage()
97 void ReadMessage(MessagePipeDispatcher* dispatcher, in ReadMessage()
108 scoped_refptr<MessagePipeDispatcher> dispatcher0_;
109 scoped_refptr<MessagePipeDispatcher> dispatcher1_;
[all …]
|
| D | core.cc | 330 new MessagePipeDispatcher(GetNodeController(), port0, in CreateParentMessagePipe()
341 new MessagePipeDispatcher(GetNodeController(), port0, in CreateChildMessagePipe()
609 new MessagePipeDispatcher(GetNodeController(), port0, pipe_id, 0)); in CreateMessagePipe()
614 new MessagePipeDispatcher(GetNodeController(), port1, pipe_id, 1)); in CreateMessagePipe()
736 MessagePipeDispatcher* mpd0 = in FuseMessagePipes()
737 static_cast<MessagePipeDispatcher*>(dispatcher0.get()); in FuseMessagePipes()
738 MessagePipeDispatcher* mpd1 = in FuseMessagePipes()
739 static_cast<MessagePipeDispatcher*>(dispatcher1.get()); in FuseMessagePipes()
|
| D | dispatcher.cc | 162 return MessagePipeDispatcher::Deserialize( in Deserialize()
|