Searched refs:NodeChannel (Results 1 – 5 of 5) sorted by relevance
| /external/libchrome/mojo/core/ |
| D | node_channel.cc | 160 scoped_refptr<NodeChannel> NodeChannel::Create( in Create()
169 return new NodeChannel(delegate, std::move(connection_params), io_task_runner, in Create()
175 Channel::MessagePtr NodeChannel::CreateEventMessage(size_t capacity, in CreateEventMessage()
184 void NodeChannel::GetEventMessageData(Channel::Message* message, in GetEventMessageData()
193 void NodeChannel::Start() { in Start()
200 void NodeChannel::ShutDown() { in ShutDown()
208 void NodeChannel::LeakHandleOnShutdown() { in LeakHandleOnShutdown()
215 void NodeChannel::NotifyBadMessage(const std::string& error) { in NotifyBadMessage()
220 void NodeChannel::SetRemoteProcessHandle(ScopedProcessHandle process_handle) { in SetRemoteProcessHandle()
233 bool NodeChannel::HasRemoteProcessHandle() { in HasRemoteProcessHandle()
[all …]
|
| D | node_controller.cc | 75 auto message = NodeChannel::CreateEventMessage(size, size, &data, 0); in SerializeEventMessage()
85 NodeChannel::GetEventMessageData(channel_message.get(), &data, &size); in DeserializeEventMessage()
262 scoped_refptr<NodeChannel> inviter; in MergePortIntoInviter()
316 scoped_refptr<NodeChannel> peer = GetPeerChannel(source_node); in NotifyBadMessageFrom()
352 scoped_refptr<NodeChannel> channel = in SendBrokerClientInvitationOnIOThread()
353 NodeChannel::Create(this, std::move(node_connection_params), in SendBrokerClientInvitationOnIOThread()
357 scoped_refptr<NodeChannel> channel = in SendBrokerClientInvitationOnIOThread()
358 NodeChannel::Create(this, std::move(connection_params), io_task_runner_, in SendBrokerClientInvitationOnIOThread()
388 NodeChannel::Create(this, std::move(connection_params), io_task_runner_, in AcceptBrokerClientInvitationOnIOThread()
404 scoped_refptr<NodeChannel> channel = NodeChannel::Create( in ConnectIsolatedOnIOThread()
[all …]
|
| D | node_controller.h | 48 public NodeChannel::Delegate {
137 std::unordered_map<ports::NodeName, scoped_refptr<NodeChannel>>;
145 IsolatedConnection(scoped_refptr<NodeChannel> channel,
154 scoped_refptr<NodeChannel> channel;
171 scoped_refptr<NodeChannel> GetPeerChannel(const ports::NodeName& name);
172 scoped_refptr<NodeChannel> GetInviterChannel();
173 scoped_refptr<NodeChannel> GetBrokerChannel();
176 scoped_refptr<NodeChannel> channel,
178 void DropPeer(const ports::NodeName& name, NodeChannel* channel);
230 NodeChannel* channel) override;
[all …]
|
| D | node_channel.h | 29 class NodeChannel : public base::RefCountedThreadSafe<NodeChannel>,
76 NodeChannel* channel) = 0;
79 static scoped_refptr<NodeChannel> Create(
149 friend class base::RefCountedThreadSafe<NodeChannel>;
155 NodeChannel(Delegate* delegate,
159 ~NodeChannel() override;
182 DISALLOW_COPY_AND_ASSIGN(NodeChannel);
|
| D | user_message_impl.cc | 144 Channel::MessagePtr message = NodeChannel::CreateEventMessage( in CreateOrExtendSerializedEventMessage()
411 NodeChannel::GetEventMessageData(channel_message.get(), &data, &size); in FinalizeEventMessage()
|