OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:MessagePipeDispatcher
(Results
1 - 5
of
5
) sorted by null
/external/libmojo/mojo/edk/system/
message_pipe_dispatcher.h
25
class
MessagePipeDispatcher
: public Dispatcher {
27
// Constructs a
MessagePipeDispatcher
permanently tied to a specific port.
32
// A
MessagePipeDispatcher
may not be transferred while in a disconnected
38
MessagePipeDispatcher
(NodeController* node_controller,
46
bool Fuse(
MessagePipeDispatcher
* other);
92
~
MessagePipeDispatcher
() override;
115
DISALLOW_COPY_AND_ASSIGN(
MessagePipeDispatcher
);
message_pipe_dispatcher.cc
44
// A PortObserver which forwards to a
MessagePipeDispatcher
. This owns a
46
class
MessagePipeDispatcher
::PortObserverThunk
49
explicit PortObserverThunk(scoped_refptr<
MessagePipeDispatcher
> dispatcher)
58
scoped_refptr<
MessagePipeDispatcher
> dispatcher_;
68
// various (unowned) local state within
MessagePipeDispatcher
::ReadMessage.
160
MessagePipeDispatcher
::
MessagePipeDispatcher
(NodeController* node_controller,
168
DVLOG(2) << "Creating new
MessagePipeDispatcher
for port " << port.name()
176
bool
MessagePipeDispatcher
::Fuse(
MessagePipeDispatcher
* other)
[
all
...]
wait_set_dispatcher_unittest.cc
58
void CreateMessagePipe(scoped_refptr<
MessagePipeDispatcher
>* d0,
59
scoped_refptr<
MessagePipeDispatcher
>* d1) {
64
*d0 = scoped_refptr<
MessagePipeDispatcher
>(
65
static_cast<
MessagePipeDispatcher
*>(core->GetDispatcher(h0).get()));
66
*d1 = scoped_refptr<
MessagePipeDispatcher
>(
67
static_cast<
MessagePipeDispatcher
*>(core->GetDispatcher(h1).get()));
78
void WriteMessage(
MessagePipeDispatcher
* dispatcher,
97
void ReadMessage(
MessagePipeDispatcher
* dispatcher,
108
scoped_refptr<
MessagePipeDispatcher
> dispatcher0_;
109
scoped_refptr<
MessagePipeDispatcher
> dispatcher1_
[
all
...]
core.cc
194
MojoHandle handle = AddDispatcher(new
MessagePipeDispatcher
(
344
new
MessagePipeDispatcher
(GetNodeController(), port0,
355
new
MessagePipeDispatcher
(GetNodeController(), port0,
623
new
MessagePipeDispatcher
(GetNodeController(), port0, pipe_id, 0));
628
new
MessagePipeDispatcher
(GetNodeController(), port1, pipe_id, 1));
750
MessagePipeDispatcher
* mpd0 =
751
static_cast<
MessagePipeDispatcher
*>(dispatcher0.get());
752
MessagePipeDispatcher
* mpd1 =
753
static_cast<
MessagePipeDispatcher
*>(dispatcher1.get());
[
all
...]
dispatcher.cc
162
return
MessagePipeDispatcher
::Deserialize(
Completed in 159 milliseconds