| /external/chromium_org/mojo/system/ |
| D | channel_endpoint.cc | 14 ChannelEndpoint::ChannelEndpoint(MessagePipe* message_pipe, unsigned port) in ChannelEndpoint() function in mojo::system::ChannelEndpoint
25 void ChannelEndpoint::TakeMessages(MessageInTransitQueue* message_queue) { in TakeMessages()
30 bool ChannelEndpoint::EnqueueMessage(scoped_ptr<MessageInTransit> message) { in EnqueueMessage()
51 void ChannelEndpoint::DetachFromMessagePipe() { in DetachFromMessagePipe()
70 void ChannelEndpoint::AttachToChannel(Channel* channel, in AttachToChannel()
82 void ChannelEndpoint::Run(MessageInTransit::EndpointId remote_id) { in Run()
96 void ChannelEndpoint::DetachFromChannel() { in DetachFromChannel()
107 ChannelEndpoint::~ChannelEndpoint() { in ~ChannelEndpoint()
113 bool ChannelEndpoint::WriteMessageNoLock(scoped_ptr<MessageInTransit> message) { in WriteMessageNoLock()
|
| D | channel_endpoint.h | 110 class MOJO_SYSTEM_IMPL_EXPORT ChannelEndpoint
111 : public base::RefCountedThreadSafe<ChannelEndpoint> {
114 ChannelEndpoint(MessagePipe* message_pipe, unsigned port);
157 friend class base::RefCountedThreadSafe<ChannelEndpoint>;
158 ~ChannelEndpoint();
183 DISALLOW_COPY_AND_ASSIGN(ChannelEndpoint);
|
| D | channel.cc | 76 if (it->second->state_ == ChannelEndpoint::STATE_NORMAL) { in Shutdown()
100 scoped_refptr<ChannelEndpoint> endpoint) { in AttachEndpoint()
126 scoped_refptr<ChannelEndpoint> endpoint; in RunMessagePipeEndpoint()
127 ChannelEndpoint::State state; in RunMessagePipeEndpoint()
144 if (state != ChannelEndpoint::STATE_NORMAL) { in RunMessagePipeEndpoint()
206 scoped_refptr<ChannelEndpoint> endpoint_to_detach; in DetachMessagePipeEndpoint()
216 case ChannelEndpoint::STATE_NORMAL: in DetachMessagePipeEndpoint()
217 it->second->state_ = ChannelEndpoint::STATE_WAIT_REMOTE_REMOVE_ACK; in DetachMessagePipeEndpoint()
223 case ChannelEndpoint::STATE_WAIT_LOCAL_DETACH: in DetachMessagePipeEndpoint()
228 case ChannelEndpoint::STATE_WAIT_REMOTE_REMOVE_ACK: in DetachMessagePipeEndpoint()
[all …]
|
| D | message_pipe_test_utils.h | 18 class ChannelEndpoint; variable
33 scoped_refptr<ChannelEndpoint> channel_endpoint);
38 scoped_refptr<ChannelEndpoint> channel_endpoint);
55 void Init(scoped_refptr<ChannelEndpoint> ep);
|
| D | proxy_message_pipe_endpoint.h | 17 class ChannelEndpoint; variable
33 explicit ProxyMessagePipeEndpoint(ChannelEndpoint* channel_endpoint);
42 scoped_refptr<ChannelEndpoint> channel_endpoint_;
|
| D | message_pipe.h | 28 class ChannelEndpoint; variable
44 scoped_refptr<ChannelEndpoint>* channel_endpoint);
53 scoped_refptr<ChannelEndpoint>* channel_endpoint);
90 scoped_refptr<ChannelEndpoint> ConvertLocalToProxy(unsigned port);
|
| D | remote_message_pipe_unittest.cc | 64 void ConnectChannelEndpoints(scoped_refptr<ChannelEndpoint> ep0, in ConnectChannelEndpoints()
65 scoped_refptr<ChannelEndpoint> ep1) { in ConnectChannelEndpoints()
79 scoped_refptr<ChannelEndpoint> ep) { in BootstrapChannelEndpointNoWait()
130 void ConnectChannelEndpointsOnIOThread(scoped_refptr<ChannelEndpoint> ep0, in ConnectChannelEndpointsOnIOThread()
131 scoped_refptr<ChannelEndpoint> ep1) { in ConnectChannelEndpointsOnIOThread()
147 scoped_refptr<ChannelEndpoint> ep) { in BootstrapChannelEndpointOnIOThread()
190 scoped_refptr<ChannelEndpoint> ep0; in TEST_F()
192 scoped_refptr<ChannelEndpoint> ep1; in TEST_F()
303 scoped_refptr<ChannelEndpoint> ep0; in TEST_F()
305 scoped_refptr<ChannelEndpoint> ep1; in TEST_F()
[all …]
|
| D | message_pipe.cc | 28 scoped_refptr<ChannelEndpoint>* channel_endpoint) { in CreateLocalProxy()
32 *channel_endpoint = new ChannelEndpoint(message_pipe, 1); in CreateLocalProxy()
40 scoped_refptr<ChannelEndpoint>* channel_endpoint) { in CreateProxyLocal()
43 *channel_endpoint = new ChannelEndpoint(message_pipe, 0); in CreateProxyLocal()
154 scoped_refptr<ChannelEndpoint> MessagePipe::ConvertLocalToProxy(unsigned port) { in ConvertLocalToProxy()
172 scoped_refptr<ChannelEndpoint> channel_endpoint( in ConvertLocalToProxy()
173 new ChannelEndpoint(this, port)); in ConvertLocalToProxy()
|
| D | message_pipe_test_utils.cc | 45 scoped_refptr<ChannelEndpoint> channel_endpoint) { in Start()
73 scoped_refptr<ChannelEndpoint> channel_endpoint) { in InitChannelOnIOThread()
108 void MultiprocessMessagePipeTestBase::Init(scoped_refptr<ChannelEndpoint> ep) { in Init()
|
| D | channel.h | 34 class ChannelEndpoint; variable
87 scoped_refptr<ChannelEndpoint> endpoint);
182 scoped_refptr<ChannelEndpoint>> IdToEndpointMap;
|
| D | message_pipe_endpoint.h | 25 class ChannelEndpoint; variable
77 virtual void Attach(ChannelEndpoint* channel_endpoint);
|
| D | multiprocess_message_pipe_unittest.cc | 51 scoped_refptr<ChannelEndpoint> ep; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
107 scoped_refptr<ChannelEndpoint> ep; in TEST_F()
152 scoped_refptr<ChannelEndpoint> ep; in TEST_F()
219 scoped_refptr<ChannelEndpoint> ep; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
319 scoped_refptr<ChannelEndpoint> ep; in TEST_F()
415 scoped_refptr<ChannelEndpoint> ep; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
474 scoped_refptr<ChannelEndpoint> ep; in TEST_F()
|
| D | message_pipe_dispatcher.h | 17 class ChannelEndpoint; variable
54 scoped_refptr<ChannelEndpoint>* channel_endpoint);
|
| D | message_pipe_perftest.cc | 113 scoped_refptr<ChannelEndpoint> ep; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
160 scoped_refptr<ChannelEndpoint> ep; in TEST_F()
|
| D | channel_unittest.cc | 197 scoped_refptr<ChannelEndpoint> channel_endpoint; in TEST_F()
237 scoped_refptr<ChannelEndpoint> channel_endpoint; in TEST_F()
290 scoped_refptr<ChannelEndpoint> channel_endpoint; in TEST_F()
|
| D | proxy_message_pipe_endpoint.cc | 18 ChannelEndpoint* channel_endpoint) in ProxyMessagePipeEndpoint()
|
| D | message_pipe_endpoint.cc | 51 void MessagePipeEndpoint::Attach(ChannelEndpoint* /*channel_endpoint*/) { in Attach() argument
|
| D | message_pipe_dispatcher.cc | 88 scoped_refptr<ChannelEndpoint>* channel_endpoint) { in CreateRemoteMessagePipe()
107 scoped_refptr<ChannelEndpoint> channel_endpoint; in Deserialize()
|
| /external/chromium_org/mojo/embedder/ |
| D | embedder.cc | 44 scoped_refptr<system::ChannelEndpoint> channel_endpoint) { in MakeChannel()
85 scoped_refptr<system::ChannelEndpoint> channel_endpoint, in CreateChannelHelper()
113 scoped_refptr<system::ChannelEndpoint> channel_endpoint; in CreateChannelOnIOThread()
136 scoped_refptr<system::ChannelEndpoint> channel_endpoint; in CreateChannel()
|