Lines Matching refs:Endpoint

171       Endpoint* sender_endpoint = new Endpoint(this, sender_id);  in CreateChannelEndpoints()
172 Endpoint* receiver_endpoint = new Endpoint(this, receiver_id); in CreateChannelEndpoints()
216 Endpoint* endpoint = new Endpoint(this, id); in AssociateInterface()
228 Endpoint* endpoint = FindEndpoint(id); in AssociateInterface()
255 Endpoint* endpoint = FindOrInsertEndpoint(id, &inserted); in CreateLocalEndpointHandle()
277 Endpoint* endpoint = endpoints_[id].get(); in CloseEndpointHandle()
299 Endpoint* endpoint = endpoints_[id].get(); in AttachEndpointClient()
317 Endpoint* endpoint = endpoints_[id].get(); in DetachEndpointClient()
350 class Endpoint;
352 friend class Endpoint;
396 class Endpoint : public base::RefCountedThreadSafe<Endpoint>, class in IPC::__anon75e303610111::ChannelAssociatedGroupController
399 Endpoint(ChannelAssociatedGroupController* controller, mojo::InterfaceId id) in Endpoint() function in IPC::__anon75e303610111::ChannelAssociatedGroupController::Endpoint
525 friend class base::RefCountedThreadSafe<Endpoint>;
527 ~Endpoint() override { in ~Endpoint()
538 scoped_refptr<Endpoint> keepalive(this); in OnSyncMessageEventReady()
581 base::BindRepeating(&Endpoint::OnSyncMessageEventReady, in EnsureSyncWatcherExists()
607 DISALLOW_COPY_AND_ASSIGN(Endpoint);
632 Endpoint* endpoint = iter->second.get(); in ~ChannelAssociatedGroupController()
695 std::vector<scoped_refptr<Endpoint>> endpoints_to_notify; in OnPipeError()
697 Endpoint* endpoint = iter->second.get(); in OnPipeError()
714 void NotifyEndpointOfError(Endpoint* endpoint, bool force_async) { in NotifyEndpointOfError()
734 Endpoint* endpoint) { in NotifyEndpointOfErrorOnEndpointThread()
746 void MarkClosedAndMaybeRemove(Endpoint* endpoint) { in MarkClosedAndMaybeRemove()
753 void MarkPeerClosedAndMaybeRemove(Endpoint* endpoint) { in MarkPeerClosedAndMaybeRemove()
761 Endpoint* FindOrInsertEndpoint(mojo::InterfaceId id, bool* inserted) { in FindOrInsertEndpoint()
765 Endpoint* endpoint = FindEndpoint(id); in FindOrInsertEndpoint()
767 endpoint = new Endpoint(this, id); in FindOrInsertEndpoint()
775 Endpoint* FindEndpoint(mojo::InterfaceId id) { in FindEndpoint()
795 Endpoint* endpoint = FindEndpoint(id); in Accept()
848 Endpoint* endpoint = FindEndpoint(id); in AcceptOnProxyThread()
875 Endpoint* endpoint = FindEndpoint(interface_id); in AcceptSyncMessage()
911 scoped_refptr<Endpoint> endpoint = FindOrInsertEndpoint(id, nullptr); in OnPeerAssociatedEndpointClosed()
956 std::map<uint32_t, scoped_refptr<Endpoint>> endpoints_;