Searched refs:node_controller_ (Results 1 – 8 of 8) sorted by relevance
/external/libmojo/mojo/edk/system/ |
D | message_pipe_dispatcher.cc | 66 : 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 …]
|
D | data_pipe_producer_dispatcher.cc | 79 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()
|
D | data_pipe_consumer_dispatcher.cc | 80 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()
|
D | core.cc | 141 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()
|
D | message_pipe_dispatcher.h | 100 NodeController* const node_controller_; variable
|
D | data_pipe_consumer_dispatcher.h | 97 NodeController* const node_controller_; variable
|
D | data_pipe_producer_dispatcher.h | 99 NodeController* const node_controller_; variable
|
D | core.h | 285 std::unique_ptr<NodeController> node_controller_; variable
|