Home
last modified time | relevance | path

Searched refs:node_controller_ (Results 1 – 8 of 8) sorted by relevance

/external/libmojo/mojo/edk/system/
Dmessage_pipe_dispatcher.cc66 : node_controller_(node_controller), in MessagePipeDispatcher()
73 node_controller_->SetPortObserver( in MessagePipeDispatcher()
79 node_controller_->SetPortObserver(port_, nullptr); in Fuse()
80 node_controller_->SetPortObserver(other->port_, nullptr); in Fuse()
99 int rv = node_controller_->MergeLocalPorts(port0, port1); in Fuse()
142 int rv = node_controller_->SendMessage(port_, message->TakePortsMessage()); in WriteMessage()
189 int rv = node_controller_->node()->GetMessageIf( in ReadMessage()
330 if (!node_controller_->core()->AddDispatchersFromTransit(dispatchers, in ReadMessage()
433 node_controller_->SetPortObserver(port_, nullptr); in CompleteTransitAndClose()
485 node_controller_->ClosePort(port_); in CloseNoLock()
[all …]
Ddata_pipe_producer_dispatcher.cc79 node_controller_(node_controller), in DataPipeProducerDispatcher()
345 node_controller_->SetPortObserver(control_port_, nullptr); in CompleteTransitAndClose()
429 node_controller_->SetPortObserver( in InitializeNoLock()
445 node_controller_->ClosePort(control_port_); in CloseNoLock()
472 SendDataPipeControlMessage(node_controller_, control_port_, in NotifyWrite()
499 int rv = node_controller_->node()->GetStatus(control_port_, &port_status); in UpdateSignalsStateNoLock()
507 int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr, in UpdateSignalsStateNoLock()
Ddata_pipe_consumer_dispatcher.cc80 node_controller_(node_controller), in DataPipeConsumerDispatcher()
363 node_controller_->SetPortObserver(control_port_, nullptr); in CompleteTransitAndClose()
448 node_controller_->SetPortObserver( in InitializeNoLock()
464 node_controller_->ClosePort(control_port_); in CloseNoLock()
494 SendDataPipeControlMessage(node_controller_, control_port_, in NotifyRead()
521 int rv = node_controller_->node()->GetStatus(control_port_, &port_status); in UpdateSignalsStateNoLock()
529 int rv = node_controller_->node()->GetMessageIf(control_port_, nullptr, in UpdateSignalsStateNoLock()
Dcore.cc141 if (node_controller_ && node_controller_->io_task_runner()) { in ~Core()
146 node_controller_->io_task_runner(); in ~Core()
149 base::Passed(&node_controller_))); in ~Core()
159 if (!node_controller_) in GetNodeController()
160 node_controller_.reset(new NodeController(this)); in GetNodeController()
161 return node_controller_.get(); in GetNodeController()
Dmessage_pipe_dispatcher.h100 NodeController* const node_controller_; variable
Ddata_pipe_consumer_dispatcher.h97 NodeController* const node_controller_; variable
Ddata_pipe_producer_dispatcher.h99 NodeController* const node_controller_; variable
Dcore.h285 std::unique_ptr<NodeController> node_controller_; variable