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.cc164 : node_controller_(node_controller), in MessagePipeDispatcher()
171 node_controller_->SetPortObserver( in MessagePipeDispatcher()
177 node_controller_->SetPortObserver(port_, nullptr); in Fuse()
178 node_controller_->SetPortObserver(other->port_, nullptr); in Fuse()
197 int rv = node_controller_->MergeLocalPorts(port0, port1); in Fuse()
240 int rv = node_controller_->SendMessage(port_, message->TakePortsMessage()); in WriteMessage()
287 int rv = node_controller_->node()->GetMessage(port_, &ports_message, &filter); in ReadMessage()
383 if (!node_controller_->core()->AddDispatchersFromTransit(dispatchers, in ReadMessage()
486 node_controller_->SetPortObserver(port_, nullptr); in CompleteTransitAndClose()
538 node_controller_->ClosePort(port_); in CloseNoLock()
[all …]
Ddata_pipe_producer_dispatcher.cc79 node_controller_(node_controller), in DataPipeProducerDispatcher()
344 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()->GetMessage( in UpdateSignalsStateNoLock()
Ddata_pipe_consumer_dispatcher.cc80 node_controller_(node_controller), in DataPipeConsumerDispatcher()
366 node_controller_->SetPortObserver(control_port_, nullptr); in CompleteTransitAndClose()
453 node_controller_->SetPortObserver( in InitializeNoLock()
469 node_controller_->ClosePort(control_port_); in CloseNoLock()
508 SendDataPipeControlMessage(node_controller_, control_port_, in NotifyRead()
535 int rv = node_controller_->node()->GetStatus(control_port_, &port_status); in UpdateSignalsStateNoLock()
543 int rv = node_controller_->node()->GetMessage( 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.h99 NodeController* const node_controller_; variable
Ddata_pipe_producer_dispatcher.h99 NodeController* const node_controller_; variable
Ddata_pipe_consumer_dispatcher.h96 NodeController* const node_controller_; variable
Dcore.h296 std::unique_ptr<NodeController> node_controller_; variable