Searched refs:message_pipe_ (Results 1 – 2 of 2) sorted by relevance
145 : message_pipe_(std::move(message_pipe)), in Connector()199 ScopedMessagePipeHandle message_pipe = std::move(message_pipe_); in PassMessagePipe()227 if (deadline == 0 && !message_pipe_->QuerySignalsState().readable()) in WaitForIncomingMessage()231 rv = Wait(message_pipe_.get(), MOJO_HANDLE_SIGNAL_READABLE); in WaitForIncomingMessage()281 if (!message_pipe_.is_valid() || drop_writes_) in Accept()292 WriteMessageNew(message_pipe_.get(), message->TakeMojoMessage(), in Accept()399 message_pipe_.get(), MOJO_HANDLE_SIGNAL_READABLE, in WaitToReadMore()402 if (message_pipe_.is_valid()) { in WaitToReadMore()403 peer_remoteness_tracker_.emplace(message_pipe_.get(), in WaitToReadMore()433 const MojoResult rv = ReadMessage(message_pipe_.get(), &message); in ReadSingleMessage()[all …]
145 return message_pipe_.is_valid(); in is_valid()163 return message_pipe_.get(); in handle()231 ScopedMessagePipeHandle message_pipe_; variable