| /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 | 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 | 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_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 | 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 | bwe.h | 133 explicit BweReceiver(int flow_id);
134 BweReceiver(int flow_id, int64_t window_size_ms);
192 int flow_id,
|
| D | packet_receiver.h | 29 int flow_id,
34 int flow_id,
|
| 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/adhd/cras/src/tests/ |
| D | dsp_ini_unittest.cc | 110 EXPECT_EQ(INVALID_FLOW_ID, port->flow_id); in TEST_F()
142 EXPECT_EQ(0, foo0->flow_id); in TEST_F()
143 EXPECT_EQ(1, foo1->flow_id); in TEST_F()
151 EXPECT_EQ(1, bar0->flow_id); in TEST_F()
152 EXPECT_EQ(0, bar1->flow_id); in TEST_F()
251 EXPECT_EQ(0, m0_0->flow_id); in TEST_F()
252 EXPECT_EQ(1, m0_1->flow_id); in TEST_F()
253 EXPECT_EQ(0, m1_0->flow_id); in TEST_F()
254 EXPECT_EQ(1, m1_1->flow_id); in TEST_F()
255 EXPECT_EQ(2, m1_2->flow_id); in TEST_F()
[all …]
|
| /external/adhd/cras/src/server/ |
| D | cras_dsp_ini.c | 125 p->flow_id = lookup_or_add_flow(ini, str); in parse_ports()
136 p->flow_id = INVALID_FLOW_ID; in parse_ports()
180 int flow_id = port->flow_id; in fill_flow_info() local
181 if (flow_id == INVALID_FLOW_ID) in fill_flow_info()
183 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in fill_flow_info()
201 int flow_id, in add_audio_port() argument
207 p->flow_id = flow_id; in add_audio_port()
284 sink_input_flowid_0 = ARRAY_ELEMENT(&sink->ports, 0)->flow_id; in insert_swap_lr_plugin()
285 sink_input_flowid_1 = ARRAY_ELEMENT(&sink->ports, 1)->flow_id; in insert_swap_lr_plugin()
311 ARRAY_ELEMENT(&sink->ports, 0)->flow_id = swap_lr_output_flowid_0; in insert_swap_lr_plugin()
[all …]
|
| D | cras_dsp_pipeline.c | 170 int flow_id; in find_origin_port() local
177 flow_id = port->flow_id; in find_origin_port()
178 if (flow_id == INVALID_FLOW_ID) in find_origin_port()
180 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in find_origin_port()
285 int flow_id; in topological_sort() local
295 if (port->flow_id == INVALID_FLOW_ID) in topological_sort()
297 flow_id = port->flow_id; in topological_sort()
298 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in topological_sort()
317 int need_connect = (port->flow_id != INVALID_FLOW_ID && in topological_sort()
|
| /external/tensorflow/tensorflow/python/client/ |
| D | timeline.py | 185 def emit_flow_start(self, name, timestamp, pid, tid, flow_id): argument
199 event['id'] = flow_id
202 def emit_flow_end(self, name, timestamp, pid, tid, flow_id): argument
216 event['id'] = flow_id
382 flow_id = self._next_flow_id
384 return flow_id
554 flow_id = self._alloc_flow_id()
557 flow_id)
559 device_pid, tid, flow_id)
|
| /external/tensorflow/tensorflow/core/profiler/internal/ |
| D | tfprof_timeline.cc | 77 int64 pid, int64 tid, int64 flow_id) { in EmitFlowStart() argument
79 event["id"] = Json::Int64(flow_id); in EmitFlowStart()
84 int64 tid, int64 flow_id) { in EmitFlowEnd() argument
86 event["id"] = Json::Int64(flow_id); in EmitFlowEnd()
239 int64 flow_id = 1; in GenerateGraphTimeline() local
256 process.first, lane.first, flow_id); in GenerateGraphTimeline()
259 next_tnode->process->pid, next_tnode->tid, flow_id); in GenerateGraphTimeline()
260 flow_id += 1; in GenerateGraphTimeline()
|
| /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);
|