Lines Matching refs:clusters_
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()
163 info.probe_cluster_bytes_sent = clusters_.front().sent_bytes; in CurrentCluster()
171 if (clusters_.empty()) { in RecommendedMinProbeSize()
175 DataRate::BitsPerSec(clusters_.front().pace_info.send_bitrate_bps); in RecommendedMinProbeSize()
183 if (!clusters_.empty()) { in ProbeSent()
184 ProbeCluster* cluster = &clusters_.front(); in ProbeSent()
201 clusters_.pop(); in ProbeSent()
203 if (clusters_.empty()) { in ProbeSent()