Lines Matching defs:MessagePipeDispatcher
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,
70 DVLOG(2) << "Creating new MessagePipeDispatcher for port " << port.name()
78 bool MessagePipeDispatcher::Fuse(MessagePipeDispatcher* other) {
103 Dispatcher::Type MessagePipeDispatcher::GetType() const {
107 MojoResult MessagePipeDispatcher::Close() {
114 MojoResult MessagePipeDispatcher::Watch(MojoHandleSignals signals,
126 MojoResult MessagePipeDispatcher::CancelWatch(uintptr_t context) {
135 MojoResult MessagePipeDispatcher::WriteMessage(
166 MojoResult MessagePipeDispatcher::ReadMessage(
341 MessagePipeDispatcher::GetHandleSignalsState() const {
346 MojoResult MessagePipeDispatcher::AddAwakable(
388 void MessagePipeDispatcher::RemoveAwakable(Awakable* awakable,
405 void MessagePipeDispatcher::StartSerialize(uint32_t* num_bytes,
413 bool MessagePipeDispatcher::EndSerialize(void* destination,
424 bool MessagePipeDispatcher::BeginTransit() {
432 void MessagePipeDispatcher::CompleteTransitAndClose() {
441 void MessagePipeDispatcher::CancelTransit() {
450 scoped_refptr<Dispatcher> MessagePipeDispatcher::Deserialize(
467 return new MessagePipeDispatcher(internal::g_core->GetNodeController(), port,
471 MessagePipeDispatcher::~MessagePipeDispatcher() {
475 MojoResult MessagePipeDispatcher::CloseNoLock() {
491 HandleSignalsState MessagePipeDispatcher::GetHandleSignalsStateNoLock() const {
517 void MessagePipeDispatcher::OnPortStatusChanged() {
