Lines Matching defs:MessagePipe
19 MessagePipe* MessagePipe::CreateLocalLocal() {
20 MessagePipe* message_pipe = new MessagePipe();
27 MessagePipe* MessagePipe::CreateLocalProxy(
30 MessagePipe* message_pipe = new MessagePipe();
39 MessagePipe* MessagePipe::CreateProxyLocal(
42 MessagePipe* message_pipe = new MessagePipe();
51 unsigned MessagePipe::GetPeerPort(unsigned port) {
56 MessagePipeEndpoint::Type MessagePipe::GetType(unsigned port) {
64 void MessagePipe::CancelAllWaiters(unsigned port) {
72 void MessagePipe::Close(unsigned port) {
89 MojoResult MessagePipe::WriteMessage(
106 MojoResult MessagePipe::ReadMessage(unsigned port,
121 HandleSignalsState MessagePipe::GetHandleSignalsState(unsigned port) const {
130 MojoResult MessagePipe::AddWaiter(unsigned port,
143 void MessagePipe::RemoveWaiter(unsigned port,
154 scoped_refptr<ChannelEndpoint> MessagePipe::ConvertLocalToProxy(unsigned port) {
162 // |MessagePipe| with two proxy endpoints, which will then act as a proxy
182 MojoResult MessagePipe::EnqueueMessage(unsigned port,
187 void MessagePipe::OnRemove(unsigned port) {
202 MessagePipe::MessagePipe() {
205 MessagePipe::~MessagePipe() {
213 MojoResult MessagePipe::EnqueueMessageInternal(
245 MojoResult MessagePipe::AttachTransportsNoLock(
289 MojoResult MessagePipe::HandleControlMessage(
292 LOG(WARNING) << "Unrecognized MessagePipe control message subtype "
