Lines Matching refs:ports
43 class MOJO_SYSTEM_IMPL_EXPORT NodeController : public ports::NodeDelegate,
46 class PortObserver : public ports::UserData {
58 const ports::NodeName& name() const { return name_; } in name()
60 ports::Node* node() const { return node_.get(); } in node()
75 const std::vector<std::pair<std::string, ports::PortRef>>& attached_ports,
84 const ports::PortRef& port,
89 void SetPortObserver(const ports::PortRef& port,
94 void ClosePort(const ports::PortRef& port);
97 int SendUserMessage(const ports::PortRef& port_ref,
98 std::unique_ptr<ports::UserMessageEvent> message);
103 const ports::PortRef& port);
106 int MergeLocalPorts(const ports::PortRef& port0, const ports::PortRef& port1);
123 void NotifyBadMessageFrom(const ports::NodeName& source_node,
127 bool HasBadMessageHandler(const ports::NodeName& source_node);
142 std::unordered_map<ports::NodeName, scoped_refptr<NodeChannel>>;
144 using PortMap = std::map<std::string, ports::PortRef>;
151 const ports::PortRef& local_port,
160 ports::PortRef local_port;
167 ports::NodeName token,
174 ports::PortRef port,
177 scoped_refptr<NodeChannel> GetPeerChannel(const ports::NodeName& name);
181 void AddPeer(const ports::NodeName& name,
184 void DropPeer(const ports::NodeName& name, NodeChannel* channel);
185 void SendPeerEvent(const ports::NodeName& name, ports::ScopedEvent event);
189 void ForwardEvent(const ports::NodeName& node,
190 ports::ScopedEvent event) override;
191 void BroadcastEvent(ports::ScopedEvent event) override;
192 void PortStatusChanged(const ports::PortRef& port) override;
195 void OnAcceptInvitee(const ports::NodeName& from_node,
196 const ports::NodeName& inviter_name,
197 const ports::NodeName& token) override;
198 void OnAcceptInvitation(const ports::NodeName& from_node,
199 const ports::NodeName& token,
200 const ports::NodeName& invitee_name) override;
201 void OnAddBrokerClient(const ports::NodeName& from_node,
202 const ports::NodeName& client_name,
204 void OnBrokerClientAdded(const ports::NodeName& from_node,
205 const ports::NodeName& client_name,
207 void OnAcceptBrokerClient(const ports::NodeName& from_node,
208 const ports::NodeName& broker_name,
210 void OnEventMessage(const ports::NodeName& from_node,
212 void OnRequestPortMerge(const ports::NodeName& from_node,
213 const ports::PortName& connector_port_name,
215 void OnRequestIntroduction(const ports::NodeName& from_node,
216 const ports::NodeName& name) override;
217 void OnIntroduce(const ports::NodeName& from_node,
218 const ports::NodeName& name,
220 void OnBroadcast(const ports::NodeName& from_node,
223 void OnRelayEventMessage(const ports::NodeName& from_node,
225 const ports::NodeName& destination,
227 void OnEventMessageFromRelay(const ports::NodeName& from_node,
228 const ports::NodeName& source_node,
231 void OnAcceptPeer(const ports::NodeName& from_node,
232 const ports::NodeName& token,
233 const ports::NodeName& peer_name,
234 const ports::PortName& port_name) override;
235 void OnChannelError(const ports::NodeName& from_node,
258 const ports::NodeName name_;
259 const std::unique_ptr<ports::Node> node_;
269 std::unordered_map<ports::NodeName, OutgoingMessageQueue>
276 std::map<ports::NodeName, PortMap> reserved_ports_;
282 std::vector<std::pair<std::string, ports::PortRef>> pending_port_merges_;
292 ports::NodeName inviter_name_;
302 ports::NodeName broker_name_;
305 base::queue<ports::NodeName> pending_broker_clients_;
308 std::unordered_map<ports::NodeName, OutgoingMessageQueue>
327 std::map<ports::NodeName, IsolatedConnection> pending_isolated_connections_;
328 std::map<std::string, ports::NodeName> named_isolated_connections_;