| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | bwe_test_framework.cc | 104 Packet::Packet(int flow_id, int64_t send_time_us, size_t payload_size) in Packet() argument
105 : flow_id_(flow_id), in Packet()
129 MediaPacket::MediaPacket(int flow_id, in MediaPacket() argument
133 : Packet(flow_id, send_time_us, payload_size) { in MediaPacket()
138 MediaPacket::MediaPacket(int flow_id, in MediaPacket() argument
142 : Packet(flow_id, send_time_us, payload_size), header_(header) { in MediaPacket()
157 RembFeedback::RembFeedback(int flow_id, in RembFeedback() argument
162 : FeedbackPacket(flow_id, send_time_us, last_send_time_ms), in RembFeedback()
168 int flow_id, in SendSideBweFeedback() argument
172 : FeedbackPacket(flow_id, send_time_us, last_send_time_ms), in SendSideBweFeedback()
[all …]
|
| D | packet.h | 31 Packet(int flow_id, int64_t send_time_us, size_t payload_size);
36 virtual int flow_id() const { return flow_id_; } in flow_id() function
67 MediaPacket(int flow_id,
71 MediaPacket(int flow_id,
100 FeedbackPacket(int flow_id, in FeedbackPacket() argument
103 : Packet(flow_id, this_send_time_us, 0), in FeedbackPacket()
116 RembFeedback(int flow_id,
134 SendSideBweFeedback(int flow_id,
150 NadaFeedback(int flow_id, in NadaFeedback() argument
158 : FeedbackPacket(flow_id, this_send_time_us, latest_send_time_ms), in NadaFeedback()
[all …]
|
| D | bwe_test_logging.h | 107 #define BWE_TEST_LOGGING_BAR(figure, name, value, flow_id) argument
109 error_title, flow_id) argument
111 figure, name, value, ylow, yhigh, error_title, ymax, limit_title, flow_id) argument
113 #define BWE_TEST_LOGGING_BASELINEBAR(figure, name, value, flow_id) argument
197 #define BWE_TEST_LOGGING_BAR(figure, name, value, flow_id) \ argument
201 flow_id); \
204 #define BWE_TEST_LOGGING_BASELINEBAR(figure, name, value, flow_id) \ argument
208 figure, name, value, flow_id); \
212 flow_id) \ argument
216 figure, name, value, ylow, yhigh, title, flow_id); \
[all …]
|
| D | bwe.cc | 31 BweReceiver::BweReceiver(int flow_id) in BweReceiver() argument
32 : flow_id_(flow_id), in BweReceiver()
38 BweReceiver::BweReceiver(int flow_id, int64_t window_size_ms) in BweReceiver() argument
39 : flow_id_(flow_id), in BweReceiver()
106 int flow_id, in CreateBweReceiver() argument
110 return new RembReceiver(flow_id, plot); in CreateBweReceiver()
112 return new SendSideBweReceiver(flow_id); in CreateBweReceiver()
114 return new NadaBweReceiver(flow_id); in CreateBweReceiver()
116 return new TcpBweReceiver(flow_id); in CreateBweReceiver()
118 return new BweReceiver(flow_id); in CreateBweReceiver()
|
| D | packet_receiver.cc | 28 int flow_id, in PacketReceiver() argument
33 : PacketProcessor(listener, flow_id, kReceiver), in PacketReceiver()
34 bwe_receiver_(CreateBweReceiver(bwe_type, flow_id, plot_bwe)), in PacketReceiver()
63 int flow_id, in PacketReceiver() argument
68 flow_id, in PacketReceiver()
87 (*it)->flow_id() == *flow_ids().begin()) { in RunFor()
|
| D | bwe_test_framework.h | 196 int flow_id,
230 int flow_id,
262 LossFilter(PacketProcessorListener* listener, int flow_id);
278 DelayFilter(PacketProcessorListener* listener, int flow_id);
294 JitterFilter(PacketProcessorListener* listener, int flow_id);
315 ReorderFilter(PacketProcessorListener* listener, int flow_id);
332 ChokeFilter(PacketProcessorListener* listener, int flow_id);
355 TraceBasedDeliveryFilter(PacketProcessorListener* listener, int flow_id);
359 int flow_id,
393 VideoSource(int flow_id,
[all …]
|
| D | bwe_test_logging.cc | 120 int flow_id) { in PlotBar() argument
126 printf("BAR\t%d\t%s_%d\t%f\n", figure, name.c_str(), flow_id, value); in PlotBar()
133 int flow_id) { in PlotBaselineBar() argument
139 printf("BASELINE\t%d\t%s_%d\t%f\n", figure, name.c_str(), flow_id, value); in PlotBaselineBar()
149 int flow_id) { in PlotErrorBar() argument
156 flow_id, value, ylow, yhigh, error_title.c_str()); in PlotErrorBar()
168 int flow_id) { in PlotLimitErrorBar() argument
175 name.c_str(), flow_id, value, ylow, yhigh, error_title.c_str(), ymax, in PlotLimitErrorBar()
|
| D | packet_sender.cc | 55 int flow_id) { in GetFeedbackPackets() argument
61 flow_id == (*it)->flow_id()) { in GetFeedbackPackets()
74 : PacketSender(listener, source->flow_id()), in VideoSender()
99 in_out, clock_.TimeInMilliseconds() + time_ms, source_->flow_id()); in RunFor()
180 GetFeedbackPackets(in_out, end_time_ms, source_->flow_id()); in RunFor()
183 BWE_TEST_LOGGING_CONTEXT(source_->flow_id()); in RunFor()
322 int flow_id, in TcpSender() argument
324 : TcpSender(listener, flow_id, offset_ms, kNoLimit) { in TcpSender()
328 int flow_id, in TcpSender() argument
331 : PacketSender(listener, flow_id), in TcpSender()
|
| D | bwe_test.h | 122 int flow_id,
164 DefaultEvaluationFilter(PacketProcessorListener* listener, int flow_id) in DefaultEvaluationFilter()
165 : choke(listener, flow_id), in DefaultEvaluationFilter()
166 delay(listener, flow_id), in DefaultEvaluationFilter()
167 jitter(listener, flow_id) { in DefaultEvaluationFilter()
|
| D | metric_recorder.cc | 35 void LinkShare::PauseFlow(int flow_id) { in PauseFlow() argument
36 running_flows_.erase(flow_id); in PauseFlow()
39 void LinkShare::ResumeFlow(int flow_id) { in ResumeFlow() argument
40 running_flows_.insert(flow_id); in ResumeFlow()
47 uint32_t LinkShare::AvailablePerFlowKbps(int flow_id) { in AvailablePerFlowKbps() argument
49 if (running_flows_.find(flow_id) != running_flows_.end()) { in AvailablePerFlowKbps()
57 int flow_id, in MetricRecorder() argument
61 flow_id_(flow_id), in MetricRecorder()
|
| D | metric_recorder.h | 33 void PauseFlow(int flow_id); // Increases available capacity per flow.
34 void ResumeFlow(int flow_id); // Decreases available capacity per flow.
38 uint32_t AvailablePerFlowKbps(int flow_id);
68 int flow_id,
|
| D | packet_sender.h | 33 PacketSender(PacketProcessorListener* listener, int flow_id) in PacketSender() argument
34 : PacketProcessor(listener, flow_id, kSender), in PacketSender()
138 TcpSender(PacketProcessorListener* listener, int flow_id, int64_t offset_ms);
140 int flow_id,
|
| D | packet_receiver.h | 29 int flow_id,
34 int flow_id,
|
| D | bwe.h | 133 explicit BweReceiver(int flow_id);
134 BweReceiver(int flow_id, int64_t window_size_ms);
192 int flow_id,
|
| D | bwe_test.cc | 68 if (flow_ids.find((*it)->flow_id()) != flow_ids.end()) { in FindPacketsToProcess()
193 int flow_id, in PrintResults() argument
197 flow_delays_ms[flow_id] = flow_delay_ms; in PrintResults()
199 flow_throughputs_kbps[flow_id] = flow_throughput_kbps; in PrintResults()
361 int flow_id = *rate_counter->flow_ids().begin(); in RunFairnessTest() local
362 flow_throughput_kbps[flow_id] = rate_counter->GetBitrateStats(); in RunFairnessTest()
367 int flow_id = *receiver->flow_ids().begin(); in RunFairnessTest() local
368 flow_delay_ms[flow_id] = receiver->GetDelayStats(); in RunFairnessTest()
405 int flow_id = bwe_type; in RunChoke() local
406 AdaptiveVideoSource source(flow_id, 30, 300, 0, 0); in RunChoke()
[all …]
|
| D | plot_dynamics.py | 100 flow_id = re.search(r'(\d+(,\d+)*)', series) # One or multiple ids.
101 key = alg + flow_id.group(1)
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/ |
| D | tcp.cc | 25 TcpBweReceiver::TcpBweReceiver(int flow_id) in TcpBweReceiver() argument
26 : BweReceiver(flow_id), in TcpBweReceiver()
|
| D | send_side.cc | 119 SendSideBweReceiver::SendSideBweReceiver(int flow_id) in SendSideBweReceiver() argument
120 : BweReceiver(flow_id), last_feedback_ms_(0) { in SendSideBweReceiver()
|
| D | remb.cc | 64 RembReceiver::RembReceiver(int flow_id, bool plot) in RembReceiver() argument
65 : BweReceiver(flow_id), in RembReceiver()
|
| D | tcp.h | 23 explicit TcpBweReceiver(int flow_id);
|
| D | nada.cc | 33 NadaBweReceiver::NadaBweReceiver(int flow_id) in NadaBweReceiver() argument
34 : BweReceiver(flow_id, kReceivingRateTimeWindowMs), in NadaBweReceiver()
|
| D | send_side.h | 53 explicit SendSideBweReceiver(int flow_id);
|
| D | remb.h | 54 RembReceiver(int flow_id, bool plot);
|
| D | nada.h | 36 explicit NadaBweReceiver(int flow_id);
|
| /external/fio/ |
| D | flow.c | 95 td->flow = flow_get(td->o.flow_id); in flow_init_job()
|