Searched refs:clusters_ (Results 1 – 6 of 6) sorted by relevance
84 if (probing_state_ == ProbingState::kInactive && !clusters_.empty() && in OnIncomingPacket()99 while (!clusters_.empty() && in CreateProbeCluster()100 now - clusters_.front().created_at > kProbeClusterTimeout) { in CreateProbeCluster()101 clusters_.pop(); in CreateProbeCluster()113 clusters_.push(cluster); in CreateProbeCluster()127 if (probing_state_ != ProbingState::kActive || clusters_.empty()) { in NextProbeTime()145 if (clusters_.empty() || probing_state_ != ProbingState::kActive) { in CurrentCluster()155 clusters_.pop(); in CurrentCluster()156 if (clusters_.empty()) { in CurrentCluster()162 PacedPacketInfo info = clusters_.front().pace_info; in CurrentCluster()[all …]
119 std::queue<ProbeCluster> clusters_; variable
69 AggregatedCluster* cluster = &clusters_[cluster_id]; in HandleProbeAndEstimateBitrate()193 for (auto it = clusters_.begin(); it != clusters_.end();) { in EraseOldClusters()195 it = clusters_.erase(it); in EraseOldClusters()
51 std::map<int, AggregatedCluster> clusters_; variable
138 std::vector<std::unique_ptr<Cluster>> clusters_; member in toco::ResolveSvdfTest167 &clusters_)); in TEST_F()169 for (const std::unique_ptr<Cluster>& cluster : clusters_) { in TEST_F()179 for (const std::unique_ptr<Cluster>& cluster : clusters_) { in TEST_F()
149 clusters_ == other_xds->clusters_; in Equals()173 std::map<absl::string_view, RefCountedPtr<ClusterState>> clusters_; member in grpc_core::__anonead745500111::XdsResolver::XdsConfigSelector345 clusters_.clear(); in ~XdsConfigSelector()350 if (clusters_.find(name) == clusters_.end()) { in MaybeAddCluster()355 clusters_[new_cluster_state->cluster()] = std::move(new_cluster_state); in MaybeAddCluster()357 clusters_[it->second->cluster()] = it->second->Ref(); in MaybeAddCluster()519 auto it = clusters_.find(cluster_name); in GetCallConfig()520 GPR_ASSERT(it != clusters_.end()); in GetCallConfig()