Cross Reference: /external/chromium_org/mojo/system/message

Lines Matching refs:port
51 unsigned MessagePipe::GetPeerPort(unsigned port) {
52   DCHECK(port == 0 || port == 1);
53   return port ^ 1;
56 MessagePipeEndpoint::Type MessagePipe::GetType(unsigned port) {
57   DCHECK(port == 0 || port == 1);
59   DCHECK(endpoints_[port]);
61   return endpoints_[port]->GetType();
64 void MessagePipe::CancelAllWaiters(unsigned port) {
65   DCHECK(port == 0 || port == 1);
68   DCHECK(endpoints_[port]);
69   endpoints_[port]->CancelAllWaiters();
72 void MessagePipe::Close(unsigned port) {
73   DCHECK(port == 0 || port == 1);
75   unsigned destination_port = GetPeerPort(port);
78   DCHECK(endpoints_[port]);
80   endpoints_[port]->Close();
85   endpoints_[port].reset();
90     unsigned port,
95   DCHECK(port == 0 || port == 1);
97       GetPeerPort(port),
106 MojoResult MessagePipe::ReadMessage(unsigned port,
112   DCHECK(port == 0 || port == 1);
115   DCHECK(endpoints_[port]);
117   return endpoints_[port]->ReadMessage(
121 HandleSignalsState MessagePipe::GetHandleSignalsState(unsigned port) const {
122   DCHECK(port == 0 || port == 1);
125   DCHECK(endpoints_[port]);
127   return endpoints_[port]->GetHandleSignalsState();
130 MojoResult MessagePipe::AddWaiter(unsigned port,
135   DCHECK(port == 0 || port == 1);
138   DCHECK(endpoints_[port]);
140   return endpoints_[port]->AddWaiter(waiter, signals, context, signals_state);
143 void MessagePipe::RemoveWaiter(unsigned port,
146   DCHECK(port == 0 || port == 1);
149   DCHECK(endpoints_[port]);
151   endpoints_[port]->RemoveWaiter(waiter, signals_state);
154 scoped_refptr<ChannelEndpoint> MessagePipe::ConvertLocalToProxy(unsigned port) {
155   DCHECK(port == 0 || port == 1);
158   DCHECK(endpoints_[port]);
159   DCHECK_EQ(endpoints_[port]->GetType(), MessagePipeEndpoint::kTypeLocal);
165           !!endpoints_[GetPeerPort(port)] &&
166               endpoints_[GetPeerPort(port)]->GetType() !=
171   scoped_ptr<MessagePipeEndpoint> old_endpoint(endpoints_[port].Pass());
173       new ChannelEndpoint(this, port));
174   endpoints_[port].reset(new ProxyMessagePipeEndpoint(channel_endpoint.get()));
182 MojoResult MessagePipe::EnqueueMessage(unsigned port,
184   return EnqueueMessageInternal(port, message.Pass(), nullptr);
187 void MessagePipe::OnRemove(unsigned port) {
188   unsigned destination_port = GetPeerPort(port);
192   if (!endpoints_[port])
199   endpoints_[port].reset();
214     unsigned port,
217   DCHECK(port == 0 || port == 1);
222     return HandleControlMessage(port, message.Pass());
228   DCHECK(endpoints_[GetPeerPort(port)]);
230   // The destination port need not be open, unlike the source port.
231   if (!endpoints_[port])
235     MojoResult result = AttachTransportsNoLock(port, message.get(), transports);
241   endpoints_[port]->EnqueueMessage(message.Pass());
246     unsigned port,
264         // The other case should have been disallowed by |Core|. (Note: |port|
265         // is the peer port of the handle given to |WriteMessage()|.)
266         DCHECK_EQ(mp_transport.GetPort(), port);
290     unsigned /*port*/,