OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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 1346 milliseconds