Lines Matching refs:endpoint_id
75 for (uint64_t endpoint_id : delete_connections_) { in Cleanup() local
76 auto it = connections_.find(endpoint_id); in Cleanup()
90 uint64_t endpoint_id) { in CreateProtocolConnection() argument
94 auto connection_entry = connections_.find(endpoint_id); in CreateProtocolConnection()
100 connection_entry->second.delegate.get(), endpoint_id); in CreateProtocolConnection()
107 auto connection_entry = connections_.find(connection->endpoint_id()); in OnConnectionDestroyed()
124 uint64_t endpoint_id = next_endpoint_id_++; in OnCryptoHandshakeComplete() local
125 endpoint_map_[endpoint] = endpoint_id; in OnCryptoHandshakeComplete()
126 connections_.emplace(endpoint_id, std::move(connection_data)); in OnCryptoHandshakeComplete()
127 return endpoint_id; in OnCryptoHandshakeComplete()
136 void QuicServer::OnConnectionClosed(uint64_t endpoint_id, in OnConnectionClosed() argument
139 auto connection_entry = connections_.find(endpoint_id); in OnConnectionClosed()
142 delete_connections_.push_back(endpoint_id); in OnConnectionClosed()
147 endpoint_request_ids_.ResetRequestId(endpoint_id); in OnConnectionClosed()
150 void QuicServer::OnDataReceived(uint64_t endpoint_id, in OnDataReceived() argument
155 demuxer_->OnStreamData(endpoint_id, connection_id, data, data_size); in OnDataReceived()