Searched refs:peer_closed_ (Results 1 – 6 of 6) sorted by relevance
146 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in ReadData()154 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in ReadData()209 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in BeginReadData()312 state->flags = peer_closed_ ? kFlagPeerClosed : 0; in EndSerialize()408 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()484 } else if (!peer_closed_ && shared_ring_buffer_.IsValid()) { in GetHandleSignalsStateNoLock()489 if (new_data_available_ || !peer_closed_) in GetHandleSignalsStateNoLock()493 if (peer_closed_) { in GetHandleSignalsStateNoLock()533 const bool was_peer_closed = peer_closed_; in UpdateSignalsStateNoLock()543 peer_closed_ = true; in UpdateSignalsStateNoLock()[all …]
109 if (peer_closed_) in WriteData()170 if (peer_closed_) in BeginWriteData()174 return peer_closed_ ? MOJO_RESULT_FAILED_PRECONDITION in BeginWriteData()271 state->flags = peer_closed_ ? kFlagPeerClosed : 0; in EndSerialize()368 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()437 if (!peer_closed_) { in GetHandleSignalsStateNoLock()480 const bool was_peer_closed = peer_closed_; in UpdateSignalsStateNoLock()490 peer_closed_ = true; in UpdateSignalsStateNoLock()497 peer_closed_ = true; in UpdateSignalsStateNoLock()501 peer_closed_ = true; in UpdateSignalsStateNoLock()[all …]
105 bool peer_closed_ = false; variable
112 bool peer_closed_ = false; variable
416 return peer_closed_; in peer_closed()421 peer_closed_ = true; in set_peer_closed()531 DCHECK(peer_closed_); in ~Endpoint()570 if (!more_to_process && peer_closed_) in OnSyncMessageEventReady()583 if (peer_closed_ || !sync_messages_.empty()) in EnsureSyncWatcherExists()598 bool peer_closed_ = false; member in IPC::__anonefff342a0111::ChannelAssociatedGroupController::Endpoint
38 peer_closed_(false), in InterfaceEndpoint()57 bool peer_closed() const { return peer_closed_; } in peer_closed()60 peer_closed_ = true; in set_peer_closed()172 if (!more_to_process && peer_closed_) { in OnSyncEventSignaled()205 bool peer_closed_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint