Searched refs:peer_closed_ (Results 1 – 5 of 5) sorted by relevance
165 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in ReadData()171 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in ReadData()223 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in BeginReadData()347 state->flags = peer_closed_ ? kFlagPeerClosed : 0; in EndSerialize()426 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()487 } else if (!peer_closed_ && shared_ring_buffer_) { in GetHandleSignalsStateNoLock()492 if (new_data_available_ || !peer_closed_) in GetHandleSignalsStateNoLock()496 if (peer_closed_) in GetHandleSignalsStateNoLock()531 bool was_peer_closed = peer_closed_; in UpdateSignalsStateNoLock()539 peer_closed_ = true; in UpdateSignalsStateNoLock()[all …]
132 if (peer_closed_) in WriteData()198 if (peer_closed_) in BeginWriteData()202 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in BeginWriteData()325 state->flags = peer_closed_ ? kFlagPeerClosed : 0; in EndSerialize()403 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()455 if (!peer_closed_) { in GetHandleSignalsStateNoLock()495 bool was_peer_closed = peer_closed_; in UpdateSignalsStateNoLock()503 peer_closed_ = true; in UpdateSignalsStateNoLock()510 peer_closed_ = true; in UpdateSignalsStateNoLock()513 peer_closed_ = true; in UpdateSignalsStateNoLock()[all …]
116 bool peer_closed_ = false; variable
114 bool peer_closed_ = false; variable
38 peer_closed_(false), in InterfaceEndpoint()58 bool peer_closed() const { return peer_closed_; } in peer_closed()61 peer_closed_ = true; in set_peer_closed()173 DCHECK(peer_closed_); in ~InterfaceEndpoint()195 if (!more_to_process && peer_closed_) { in OnHandleReady()243 bool peer_closed_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint