Home
last modified time | relevance | path

Searched refs:flow_id (Results 1 – 24 of 24) sorted by relevance

/external/perfetto/src/trace_processor/importers/common/
Dflow_tracker.cc42 void FlowTracker::Begin(TrackId track_id, FlowId flow_id) { in Begin() argument
49 if (flow_to_slice_map_.count(flow_id) != 0) { in Begin()
53 flow_to_slice_map_[flow_id] = open_slice_id.value(); in Begin()
56 void FlowTracker::Step(TrackId track_id, FlowId flow_id) { in Step() argument
63 if (flow_to_slice_map_.count(flow_id) == 0) { in Step()
67 SliceId slice_out_id = flow_to_slice_map_[flow_id]; in Step()
68 InsertFlow(flow_id, slice_out_id, open_slice_id.value()); in Step()
69 flow_to_slice_map_[flow_id] = open_slice_id.value(); in Step()
73 FlowId flow_id, in End() argument
77 pending_flow_ids_map_[track_id].push_back(flow_id); in End()
[all …]
Dflow_tracker_unittest.cc42 FlowId flow_id = 1; in TEST() local
48 tracker.Begin(track_1, flow_id); in TEST()
53 tracker.End(track_2, flow_id, /* bind_enclosing = */ true, in TEST()
74 FlowId flow_id = 1; in TEST() local
80 tracker.Begin(track_1, flow_id); in TEST()
83 tracker.End(track_2, flow_id, /* bind_enclosing = */ false, in TEST()
110 FlowId flow_id = 1; in TEST() local
116 tracker.Begin(track_1, flow_id); in TEST()
119 tracker.End(track_2, flow_id, /* bind_enclosing = */ false, in TEST()
245 FlowId flow_id = 1; in TEST() local
[all …]
Dflow_tracker.h40 virtual void Begin(TrackId track_id, FlowId flow_id);
41 virtual void Step(TrackId track_id, FlowId flow_id);
50 FlowId flow_id,
54 bool IsActive(FlowId flow_id) const;
87 void InsertFlow(FlowId flow_id,
/external/adhd/cras/src/tests/
Ddsp_ini_unittest.cc110 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()
250 EXPECT_EQ(0, m0_0->flow_id); in TEST_F()
251 EXPECT_EQ(1, m0_1->flow_id); in TEST_F()
252 EXPECT_EQ(0, m1_0->flow_id); in TEST_F()
253 EXPECT_EQ(1, m1_1->flow_id); in TEST_F()
254 EXPECT_EQ(2, m1_2->flow_id); in TEST_F()
[all …]
/external/webrtc/modules/remote_bitrate_estimator/test/
Dbwe_test_logging.h111 #define BWE_TEST_LOGGING_BAR(figure, name, value, flow_id) argument
113 error_title, flow_id) argument
115 figure, name, value, ylow, yhigh, error_title, ymax, limit_title, flow_id) argument
117 #define BWE_TEST_LOGGING_BASELINEBAR(figure, name, value, flow_id) argument
217 #define BWE_TEST_LOGGING_BAR(figure, name, value, flow_id) \ argument
221 flow_id); \
224 #define BWE_TEST_LOGGING_BASELINEBAR(figure, name, value, flow_id) \ argument
228 figure, name, value, flow_id); \
232 flow_id) \ argument
236 figure, name, value, ylow, yhigh, title, flow_id); \
[all …]
Dbwe_test_logging.cc134 int flow_id) { in PlotBar() argument
140 printf("BAR\t%d\t%s_%d\t%f\n", figure, name.c_str(), flow_id, value); in PlotBar()
147 int flow_id) { in PlotBaselineBar() argument
153 printf("BASELINE\t%d\t%s_%d\t%f\n", figure, name.c_str(), flow_id, value); in PlotBaselineBar()
163 int flow_id) { in PlotErrorBar() argument
170 flow_id, value, ylow, yhigh, error_title.c_str()); in PlotErrorBar()
182 int flow_id) { in PlotLimitErrorBar() argument
189 name.c_str(), flow_id, value, ylow, yhigh, error_title.c_str(), ymax, in PlotLimitErrorBar()
/external/adhd/cras/src/server/
Dcras_dsp_ini.c124 p->flow_id = lookup_or_add_flow(ini, str); in parse_ports()
135 p->flow_id = INVALID_FLOW_ID; in parse_ports()
179 int flow_id = port->flow_id; in fill_flow_info() local
180 if (flow_id == INVALID_FLOW_ID) in fill_flow_info()
182 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in fill_flow_info()
198 static void add_audio_port(struct ini *ini, struct plugin *plugin, int flow_id, in add_audio_port() argument
204 p->flow_id = flow_id; in add_audio_port()
278 sink_input_flowid_0 = ARRAY_ELEMENT(&sink->ports, 0)->flow_id; in insert_swap_lr_plugin()
279 sink_input_flowid_1 = ARRAY_ELEMENT(&sink->ports, 1)->flow_id; in insert_swap_lr_plugin()
302 ARRAY_ELEMENT(&sink->ports, 0)->flow_id = swap_lr_output_flowid_0; in insert_swap_lr_plugin()
[all …]
Dcras_dsp_pipeline.c170 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()
286 int flow_id; in topological_sort() local
296 if (port->flow_id == INVALID_FLOW_ID) in topological_sort()
298 flow_id = port->flow_id; in topological_sort()
299 flow = ARRAY_ELEMENT(&ini->flows, flow_id); in topological_sort()
318 int need_connect = (port->flow_id != INVALID_FLOW_ID && in topological_sort()
Dcras_dsp_ini.h37 int flow_id; member
/external/perfetto/src/trace_processor/importers/json/
Djson_trace_parser.cc156 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseTracePacket() local
158 flow_tracker->Begin(track_id, flow_id); in ParseTracePacket()
169 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseTracePacket() local
171 flow_tracker->Step(track_id, flow_id); in ParseTracePacket()
182 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseTracePacket() local
186 flow_tracker->End(track_id, flow_id, bind_enclosing_slice, in ParseTracePacket()
/external/tensorflow/tensorflow/python/client/
Dtimeline.py185 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
383 flow_id = self._next_flow_id
385 return flow_id
566 flow_id = self._alloc_flow_id()
569 flow_id)
571 device_pid, tid, flow_id)
/external/tensorflow/tensorflow/core/profiler/internal/
Dtfprof_timeline.cc77 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()
Dtfprof_timeline.h46 int64 flow_id);
49 int64 flow_id);
/external/rust/crates/quiche/src/h3/
Dffi.rs268 conn: &mut h3::Connection, quic_conn: &mut Connection, flow_id: u64, in quiche_h3_send_dgram()
277 match conn.send_dgram(quic_conn, flow_id, data) { in quiche_h3_send_dgram()
286 conn: &mut h3::Connection, quic_conn: &mut Connection, flow_id: *mut u64, in quiche_h3_recv_dgram()
297 unsafe { *flow_id = id }; in quiche_h3_recv_dgram()
Dmod.rs929 &mut self, conn: &mut super::Connection, flow_id: u64, buf: &[u8], in send_dgram()
931 let len = octets::varint_len(flow_id) + buf.len(); in send_dgram()
935 b.put_varint(flow_id)?; in send_dgram()
965 let flow_id = b.get_varint()?; in recv_dgram() localVariable
966 Ok((len, flow_id, b.off())) in recv_dgram()
971 &self, conn: &super::Connection, flow_id: u64, in dgram_max_writable_len()
973 let flow_id_len = octets::varint_len(flow_id); in dgram_max_writable_len()
1089 let flow_id = b.get_varint()?; in poll() localVariable
1090 return Ok((flow_id, Event::Datagram)); in poll()
/external/tensorflow/tensorflow/core/profiler/utils/
Dxplane_schema.h264 XFlow(uint64 flow_id, FlowDirection direction) in XFlow() argument
265 : encoded_((flow_id << 2) | (direction & 0x3)) { in XFlow()
/external/perfetto/src/trace_processor/importers/proto/
Dtrack_event_parser.cc727 FlowId flow_id = context_->flow_tracker->GetFlowIdForV1Event( in ParseFlowEventV1() local
731 context_->flow_tracker->Begin(track_id_, flow_id); in ParseFlowEventV1()
734 context_->flow_tracker->Step(track_id_, flow_id); in ParseFlowEventV1()
737 context_->flow_tracker->End(track_id_, flow_id, in ParseFlowEventV1()
749 FlowId flow_id = *it; in MaybeParseTrackEventFlows() local
750 if (!context_->flow_tracker->IsActive(flow_id)) { in MaybeParseTrackEventFlows()
751 context_->flow_tracker->Begin(track_id_, flow_id); in MaybeParseTrackEventFlows()
754 context_->flow_tracker->Step(track_id_, flow_id); in MaybeParseTrackEventFlows()
760 FlowId flow_id = *it; in MaybeParseTrackEventFlows() local
761 if (!context_->flow_tracker->IsActive(flow_id)) { in MaybeParseTrackEventFlows()
[all …]
Dproto_trace_parser_unittest.cc223 MOCK_METHOD2(Begin, void(TrackId track_id, FlowId flow_id));
224 MOCK_METHOD2(Step, void(TrackId track_id, FlowId flow_id));
227 FlowId flow_id,
/external/rust/crates/quiche/include/
Dquiche.h527 uint64_t flow_id, uint8_t *data, size_t data_len);
531 uint64_t *flow_id, uint8_t *out, size_t out_len);
/external/perfetto/test/
Dsynth_common.py629 for flow_id in flow_ids:
630 packet.track_event.flow_ids.append(flow_id)
631 for flow_id in terminating_flow_ids:
632 packet.track_event.terminating_flow_ids.append(flow_id)
/external/tensorflow/tensorflow/core/profiler/protobuf/
Dsteps_db.proto41 uint64 flow_id = 1; field
/external/perfetto/src/trace_processor/
Dexport_json.cc1056 base::Optional<Json::Value> CreateFlowEventV1(uint32_t flow_id, in CreateFlowEventV1() argument
1079 event["id"] = flow_id; in CreateFlowEventV1()
/external/perfetto/src/tracing/test/
Dapi_integrationtest.cc3394 const uint64_t flow_id = 1234; in TEST_P() local
3396 TRACE_EVENT_WITH_FLOW1("cat", "LatencyInfo.Flow", TRACE_ID_GLOBAL(flow_id), in TEST_P()
3401 TRACE_EVENT_WITH_FLOW2("cat", "LatencyInfo.Flow", TRACE_ID_GLOBAL(flow_id), in TEST_P()
3407 TRACE_EVENT_WITH_FLOW1("cat", "LatencyInfo.Flow", TRACE_ID_GLOBAL(flow_id), in TEST_P()
/external/libabigail/tests/data/test-diff-dwarf-abixml/
DPR25409-librte_bus_dpaa.so.20.0.abi2190 …<var-decl name='flow_id' type-id='type-id-7' visibility='default' filepath='../../dpdk/lib/librte_…