Searched refs:port_status (Results 1 – 5 of 5) sorted by relevance
494 ports::PortStatus port_status; in GetHandleSignalsStateNoLock() local495 if (node_controller_->node()->GetStatus(port_, &port_status) != ports::OK) { in GetHandleSignalsStateNoLock()500 if (port_status.has_messages) { in GetHandleSignalsStateNoLock()504 if (port_status.receiving_messages) in GetHandleSignalsStateNoLock()506 if (!port_status.peer_closed) { in GetHandleSignalsStateNoLock()529 ports::PortStatus port_status; in OnPortStatusChanged() local530 if (node_controller_->node()->GetStatus(port_, &port_status) == ports::OK) { in OnPortStatusChanged()531 if (port_status.has_messages) { in OnPortStatusChanged()543 if (port_status.peer_closed) { in OnPortStatusChanged()
498 ports::PortStatus port_status; in UpdateSignalsStateNoLock() local499 int rv = node_controller_->node()->GetStatus(control_port_, &port_status); in UpdateSignalsStateNoLock()500 if (rv != ports::OK || !port_status.receiving_messages) { in UpdateSignalsStateNoLock()504 } else if (rv == ports::OK && port_status.has_messages && !in_transit_) { in UpdateSignalsStateNoLock()
520 ports::PortStatus port_status; in UpdateSignalsStateNoLock() local521 int rv = node_controller_->node()->GetStatus(control_port_, &port_status); in UpdateSignalsStateNoLock()522 if (rv != ports::OK || !port_status.receiving_messages) { in UpdateSignalsStateNoLock()526 } else if (rv == ports::OK && port_status.has_messages && !in_transit_) { in UpdateSignalsStateNoLock()
96 int GetStatus(const PortRef& port_ref, PortStatus* port_status);
250 int Node::GetStatus(const PortRef& port_ref, PortStatus* port_status) { in GetStatus() argument258 port_status->has_messages = port->message_queue.HasNextMessage(); in GetStatus()259 port_status->receiving_messages = CanAcceptMoreMessages(port); in GetStatus()260 port_status->peer_closed = port->peer_closed; in GetStatus()