Home
last modified time | relevance | path

Searched refs:NodeChannel (Results 1 – 5 of 5) sorted by relevance

/external/libmojo/mojo/edk/system/
Dnode_channel.cc154 scoped_refptr<NodeChannel> NodeChannel::Create( in Create()
163 return new NodeChannel(delegate, std::move(platform_handle), io_task_runner, in Create()
169 Channel::MessagePtr NodeChannel::CreatePortsMessage(size_t payload_size, in CreatePortsMessage()
177 void NodeChannel::GetPortsMessageData(Channel::Message* message, in GetPortsMessageData()
184 void NodeChannel::Start() { in Start()
197 void NodeChannel::ShutDown() { in ShutDown()
211 void NodeChannel::LeakHandleOnShutdown() { in LeakHandleOnShutdown()
218 void NodeChannel::NotifyBadMessage(const std::string& error) { in NotifyBadMessage()
223 void NodeChannel::SetRemoteProcessHandle(base::ProcessHandle process_handle) { in SetRemoteProcessHandle()
235 bool NodeChannel::HasRemoteProcessHandle() { in HasRemoteProcessHandle()
[all …]
Dnode_controller.cc86 NodeChannel::GetPortsMessageData(message, data, num_data_bytes); in ParsePortsMessage()
312 scoped_refptr<NodeChannel> parent; in MergePortIntoParent()
372 scoped_refptr<NodeChannel> peer = GetPeerChannel(source_node); in NotifyBadMessageFrom()
389 scoped_refptr<NodeChannel> channel = NodeChannel::Create( in ConnectToChildOnIOThread()
393 scoped_refptr<NodeChannel> channel = in ConnectToChildOnIOThread()
394 NodeChannel::Create(this, std::move(platform_handle), io_task_runner_, in ConnectToChildOnIOThread()
425 NodeChannel::Create(this, std::move(platform_handle), io_task_runner_, in ConnectToParentOnIOThread()
437 scoped_refptr<NodeChannel> NodeController::GetPeerChannel( in GetPeerChannel()
446 scoped_refptr<NodeChannel> NodeController::GetParentChannel() { in GetParentChannel()
455 scoped_refptr<NodeChannel> NodeController::GetBrokerChannel() { in GetBrokerChannel()
[all …]
Dnode_channel.h33 class NodeChannel : public base::RefCountedThreadSafe<NodeChannel>,
81 NodeChannel* channel) = 0;
88 static scoped_refptr<NodeChannel> Create(
157 friend class base::RefCountedThreadSafe<NodeChannel>;
163 NodeChannel(Delegate* delegate,
167 ~NodeChannel() override;
206 DISALLOW_COPY_AND_ASSIGN(NodeChannel);
Dnode_controller.h44 public NodeChannel::Delegate {
134 scoped_refptr<NodeChannel>>;
149 scoped_refptr<NodeChannel> GetPeerChannel(const ports::NodeName& name);
150 scoped_refptr<NodeChannel> GetParentChannel();
151 scoped_refptr<NodeChannel> GetBrokerChannel();
154 scoped_refptr<NodeChannel> channel,
156 void DropPeer(const ports::NodeName& name, NodeChannel* channel);
210 NodeChannel* channel) override;
267 scoped_refptr<NodeChannel> bootstrap_parent_channel_;
Dports_message.cc30 channel_message_ = NodeChannel::CreatePortsMessage(size, &ptr, num_handles); in PortsMessage()
45 NodeChannel::GetPortsMessageData(channel_message_.get(), &data, in PortsMessage()
56 NodeChannel::CreatePortsMessage(num_header_bytes, &ptr, 0); in PortsMessage()