Searched refs:MessagePipeDispatcher (Results 1 - 5 of 5) sorted by relevance
/external/libmojo/mojo/edk/system/ |
H A D | message_pipe_dispatcher.cc | 43 // 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 D | message_pipe_dispatcher.h | 26 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 D | 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...] |
H A D | dispatcher.cc | 162 return MessagePipeDispatcher::Deserialize(
|
H A D | core.cc | 330 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