Searched refs:flow_ids (Results 1 – 7 of 7) sorted by relevance
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | bwe_test_framework.cc | 51 FlowIds flow_ids(&flow_ids_array[0], flow_ids_array + num_flow_ids); in CreateFlowIds() local
52 return flow_ids; in CreateFlowIds()
197 const FlowIds& flow_ids, in PacketProcessor() argument
199 : listener_(listener), flow_ids_(flow_ids) { in PacketProcessor()
234 const FlowIds& flow_ids, in RateCounterFilter() argument
237 : PacketProcessor(listener, flow_ids, kRegular), in RateCounterFilter()
245 for (int flow_id : flow_ids) { in RateCounterFilter()
253 const FlowIds& flow_ids, in RateCounterFilter() argument
257 : RateCounterFilter(listener, flow_ids, name, plot_name) { in RateCounterFilter()
309 const FlowIds& flow_ids) in LossFilter() argument
[all …]
|
| D | bwe_test.h | 41 void FindPacketsToProcess(const FlowIds& flow_ids, Packets* in, Packets* out);
135 void FindPacketsToProcess(const FlowIds& flow_ids, Packets* in,
172 const FlowIds& flow_ids) in DefaultEvaluationFilter()
173 : choke(listener, flow_ids), in DefaultEvaluationFilter()
174 delay(listener, flow_ids), in DefaultEvaluationFilter()
175 jitter(listener, flow_ids) { in DefaultEvaluationFilter()
|
| D | bwe_test_framework.h | 199 const FlowIds& flow_ids,
212 const FlowIds& flow_ids() const { return flow_ids_; } in flow_ids() function
234 const FlowIds& flow_ids,
238 const FlowIds& flow_ids,
263 LossFilter(PacketProcessorListener* listener, const FlowIds& flow_ids);
279 DelayFilter(PacketProcessorListener* listener, const FlowIds& flow_ids);
295 JitterFilter(PacketProcessorListener* listener, const FlowIds& flow_ids);
316 ReorderFilter(PacketProcessorListener* listener, const FlowIds& flow_ids);
333 ChokeFilter(PacketProcessorListener* listener, const FlowIds& flow_ids);
357 const FlowIds& flow_ids);
|
| D | bwe_test.cc | 51 FindPacketsToProcess(processor_->flow_ids(), in_out, &to_process); in RunFor()
60 void PacketProcessorRunner::FindPacketsToProcess(const FlowIds& flow_ids, in FindPacketsToProcess() argument
68 if (flow_ids.find((*it)->flow_id()) != flow_ids.end()) { in FindPacketsToProcess()
361 int flow_id = *rate_counter->flow_ids().begin(); in RunFairnessTest()
367 int flow_id = *receiver->flow_ids().begin(); in RunFairnessTest()
494 FlowIds flow_ids = CreateFlowIdRange(0, static_cast<int>(num_flows - 1)); in RunVariableCapacity2MultipleFlows() local
496 DefaultEvaluationFilter up_filter(&uplink_, flow_ids); in RunVariableCapacity2MultipleFlows()
499 RateCounterFilter total_utilization(&uplink_, flow_ids, "Total_utilization", in RunVariableCapacity2MultipleFlows()
515 DelayFilter down_filter(&downlink_, flow_ids); in RunVariableCapacity2MultipleFlows()
802 FlowIds flow_ids = CreateFlowIdRange(0, static_cast<int>(kNumTotalFlows - 1)); in RunMultipleShortTcpFairness() local
[all …]
|
| D | packet_receiver.cc | 87 (*it)->flow_id() == *flow_ids().begin()) { in RunFor()
88 BWE_TEST_LOGGING_CONTEXT(*flow_ids().begin()); in RunFor()
|
| D | packet_sender.cc | 47 BWE_TEST_LOGGING_CONTEXT(*flow_ids().begin()); in RecordBitrate()
363 in_out, clock_.TimeInMilliseconds() + time_ms, *flow_ids().begin()); in RunFor()
461 new MediaPacket(*flow_ids().begin(), 1000 * clock_.TimeInMilliseconds(), in GeneratePackets()
|
| D | metric_recorder.cc | 32 : choke_filter_(choke_filter), running_flows_(choke_filter->flow_ids()) { in LinkShare()
|