Lines Matching defs:MessagePipeDispatcher
40 // A PortObserver which forwards to a MessagePipeDispatcher. This owns a
42 class MessagePipeDispatcher::PortObserverThunk
45 explicit PortObserverThunk(scoped_refptr<MessagePipeDispatcher> dispatcher)
54 scoped_refptr<MessagePipeDispatcher> dispatcher_;
86 MessagePipeDispatcher::MessagePipeDispatcher(NodeController* node_controller,
95 DVLOG(2) << "Creating new MessagePipeDispatcher for port " << port.name()
102 bool MessagePipeDispatcher::Fuse(MessagePipeDispatcher* other) {
127 Dispatcher::Type MessagePipeDispatcher::GetType() const {
131 MojoResult MessagePipeDispatcher::Close() {
138 MojoResult MessagePipeDispatcher::WriteMessage(
164 MojoResult MessagePipeDispatcher::ReadMessage(
196 MojoResult MessagePipeDispatcher::SetQuota(MojoQuotaType type, uint64_t limit) {
219 MojoResult MessagePipeDispatcher::QueryQuota(MojoQuotaType type,
246 HandleSignalsState MessagePipeDispatcher::GetHandleSignalsState() const {
251 MojoResult MessagePipeDispatcher::AddWatcherRef(
260 MojoResult MessagePipeDispatcher::RemoveWatcherRef(WatcherDispatcher* watcher,
268 void MessagePipeDispatcher::StartSerialize(uint32_t* num_bytes,
276 bool MessagePipeDispatcher::EndSerialize(void* destination,
287 bool MessagePipeDispatcher::BeginTransit() {
295 void MessagePipeDispatcher::CompleteTransitAndClose() {
304 void MessagePipeDispatcher::CancelTransit() {
313 scoped_refptr<Dispatcher> MessagePipeDispatcher::Deserialize(
334 return new MessagePipeDispatcher(Core::Get()->GetNodeController(), port,
338 MessagePipeDispatcher::~MessagePipeDispatcher() = default;
340 MojoResult MessagePipeDispatcher::CloseNoLock() {
356 HandleSignalsState MessagePipeDispatcher::GetHandleSignalsStateNoLock() const {
393 void MessagePipeDispatcher::OnPortStatusChanged() {
