HomeSort by relevance Sort by last modified time
    Searched refs:ChannelEndpoint (Results 1 - 19 of 19) sorted by null

  /external/chromium_org/mojo/system/
proxy_message_pipe_endpoint.h 17 class ChannelEndpoint;
22 // |ChannelEndpoint|, which may be co-owned by a |Channel|. Like any
33 explicit ProxyMessagePipeEndpoint(ChannelEndpoint* channel_endpoint);
42 scoped_refptr<ChannelEndpoint> channel_endpoint_;
channel_endpoint.h 23 // - (Done.) Move |Channel::Endpoint| to |ChannelEndpoint|. Make it
25 // - (Done.) Give |ChannelEndpoint| a lock. The lock order (in order of
26 // allowable acquisition) is: |MessagePipe|, |ChannelEndpoint|, |Channel|.
28 // - Move logic from |ProxyMessagePipeEndpoint| into |ChannelEndpoint|. Right
33 // to |ChannelEndpoint| (hence the refcounting).
34 // - In essence, |ChannelEndpoint| becomes the thing that knows about
39 // |MessagePipe| and ports (but only |ChannelEndpoint|) and
110 class MOJO_SYSTEM_IMPL_EXPORT ChannelEndpoint
111 : public base::RefCountedThreadSafe<ChannelEndpoint> {
114 ChannelEndpoint(MessagePipe* message_pipe, unsigned port)
    [all...]
message_pipe_test_utils.h 18 class ChannelEndpoint;
33 scoped_refptr<ChannelEndpoint> channel_endpoint);
38 scoped_refptr<ChannelEndpoint> channel_endpoint);
55 void Init(scoped_refptr<ChannelEndpoint> ep);
channel_endpoint.cc 14 ChannelEndpoint::ChannelEndpoint(MessagePipe* message_pipe, unsigned port)
25 void ChannelEndpoint::TakeMessages(MessageInTransitQueue* message_queue) {
30 bool ChannelEndpoint::EnqueueMessage(scoped_ptr<MessageInTransit> message) {
51 void ChannelEndpoint::DetachFromMessagePipe() {
70 void ChannelEndpoint::AttachToChannel(Channel* channel,
82 void ChannelEndpoint::Run(MessageInTransit::EndpointId remote_id) {
96 void ChannelEndpoint::DetachFromChannel() {
107 ChannelEndpoint::~ChannelEndpoint() {
    [all...]
message_pipe_endpoint.h 25 class ChannelEndpoint;
77 virtual void Attach(ChannelEndpoint* channel_endpoint);
message_pipe.h 28 class ChannelEndpoint;
42 // (newly-created) |ChannelEndpoint| for the latter.
44 scoped_refptr<ChannelEndpoint>* channel_endpoint);
48 // (newly-created) |ChannelEndpoint| for the former.
53 scoped_refptr<ChannelEndpoint>* channel_endpoint);
90 scoped_refptr<ChannelEndpoint> ConvertLocalToProxy(unsigned port);
99 // |ChannelEndpoint| call it instead).
proxy_message_pipe_endpoint.cc 18 ChannelEndpoint* channel_endpoint)
channel.cc 76 if (it->second->state_ == ChannelEndpoint::STATE_NORMAL) {
97 // the temptation to simply pass the result of |new ChannelEndpoint(...)|
100 scoped_refptr<ChannelEndpoint> endpoint) {
126 scoped_refptr<ChannelEndpoint> endpoint;
127 ChannelEndpoint::State state;
144 if (state != ChannelEndpoint::STATE_NORMAL) {
206 scoped_refptr<ChannelEndpoint> endpoint_to_detach;
216 case ChannelEndpoint::STATE_NORMAL:
217 it->second->state_ = ChannelEndpoint::STATE_WAIT_REMOTE_REMOVE_ACK;
223 case ChannelEndpoint::STATE_WAIT_LOCAL_DETACH
    [all...]
channel.h 34 class ChannelEndpoint;
48 // |ChannelEndpoint|, |Channel|. Thus |Channel| may not call into
49 // |ChannelEndpoint| with |Channel|'s lock held.
84 // |ChannelEndpoint| instead.
87 scoped_refptr<ChannelEndpoint> endpoint);
182 scoped_refptr<ChannelEndpoint>> IdToEndpointMap;
message_pipe_test_utils.cc 45 scoped_refptr<ChannelEndpoint> channel_endpoint) {
73 scoped_refptr<ChannelEndpoint> channel_endpoint) {
108 void MultiprocessMessagePipeTestBase::Init(scoped_refptr<ChannelEndpoint> ep) {
message_pipe_endpoint.cc 51 void MessagePipeEndpoint::Attach(ChannelEndpoint* /*channel_endpoint*/) {
message_pipe_dispatcher.h 17 class ChannelEndpoint;
54 scoped_refptr<ChannelEndpoint>* channel_endpoint);
message_pipe.cc 28 scoped_refptr<ChannelEndpoint>* channel_endpoint) {
32 *channel_endpoint = new ChannelEndpoint(message_pipe, 1);
40 scoped_refptr<ChannelEndpoint>* channel_endpoint) {
43 *channel_endpoint = new ChannelEndpoint(message_pipe, 0);
154 scoped_refptr<ChannelEndpoint> MessagePipe::ConvertLocalToProxy(unsigned port) {
172 scoped_refptr<ChannelEndpoint> channel_endpoint(
173 new ChannelEndpoint(this, port));
remote_message_pipe_unittest.cc 63 // This connects the two given |ChannelEndpoint|s.
64 void ConnectChannelEndpoints(scoped_refptr<ChannelEndpoint> ep0,
65 scoped_refptr<ChannelEndpoint> ep1) {
79 scoped_refptr<ChannelEndpoint> ep) {
130 void ConnectChannelEndpointsOnIOThread(scoped_refptr<ChannelEndpoint> ep0,
131 scoped_refptr<ChannelEndpoint> ep1) {
147 scoped_refptr<ChannelEndpoint> ep) {
190 scoped_refptr<ChannelEndpoint> ep0;
192 scoped_refptr<ChannelEndpoint> ep1;
303 scoped_refptr<ChannelEndpoint> ep0
    [all...]
message_pipe_perftest.cc 113 scoped_refptr<ChannelEndpoint> ep;
160 scoped_refptr<ChannelEndpoint> ep;
multiprocess_message_pipe_unittest.cc 51 scoped_refptr<ChannelEndpoint> ep;
107 scoped_refptr<ChannelEndpoint> ep;
152 scoped_refptr<ChannelEndpoint> ep;
219 scoped_refptr<ChannelEndpoint> ep;
319 scoped_refptr<ChannelEndpoint> ep;
415 scoped_refptr<ChannelEndpoint> ep;
474 scoped_refptr<ChannelEndpoint> ep;
channel_unittest.cc 197 scoped_refptr<ChannelEndpoint> channel_endpoint;
237 scoped_refptr<ChannelEndpoint> channel_endpoint;
290 scoped_refptr<ChannelEndpoint> channel_endpoint;
message_pipe_dispatcher.cc 88 scoped_refptr<ChannelEndpoint>* channel_endpoint) {
107 scoped_refptr<ChannelEndpoint> channel_endpoint;
  /external/chromium_org/mojo/embedder/
embedder.cc 44 scoped_refptr<system::ChannelEndpoint> channel_endpoint) {
85 scoped_refptr<system::ChannelEndpoint> channel_endpoint,
113 scoped_refptr<system::ChannelEndpoint> channel_endpoint;
136 scoped_refptr<system::ChannelEndpoint> channel_endpoint;

Completed in 1265 milliseconds