Lines Matching refs:endpoint_id
58 for (uint64_t endpoint_id : delete_connections_) { in Cleanup() local
59 auto it = connections_.find(endpoint_id); in Cleanup()
89 uint64_t endpoint_id) { in CreateProtocolConnection() argument
92 auto connection_entry = connections_.find(endpoint_id); in CreateProtocolConnection()
97 connection_entry->second.delegate.get(), endpoint_id); in CreateProtocolConnection()
104 auto connection_entry = connections_.find(connection->endpoint_id()); in OnConnectionDestroyed()
121 uint64_t endpoint_id = next_endpoint_id_++; in OnCryptoHandshakeComplete() local
122 endpoint_map_[endpoint] = endpoint_id; in OnCryptoHandshakeComplete()
123 connections_.emplace(endpoint_id, std::move(connection_data)); in OnCryptoHandshakeComplete()
129 endpoint_id); in OnCryptoHandshakeComplete()
134 return endpoint_id; in OnCryptoHandshakeComplete()
145 void QuicClient::OnConnectionClosed(uint64_t endpoint_id, in OnConnectionClosed() argument
149 auto connection_entry = connections_.find(endpoint_id); in OnConnectionClosed()
152 delete_connections_.push_back(endpoint_id); in OnConnectionClosed()
157 endpoint_request_ids_.ResetRequestId(endpoint_id); in OnConnectionClosed()
160 void QuicClient::OnDataReceived(uint64_t endpoint_id, in OnDataReceived() argument
164 demuxer_->OnStreamData(endpoint_id, connection_id, data, data_size); in OnDataReceived()