/external/perfetto/src/trace_processor/importers/common/ |
D | flow_tracker.cc | 42 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 …]
|
D | flow_tracker_unittest.cc | 42 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 …]
|
D | flow_tracker.h | 40 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/ |
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() 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/ |
D | bwe_test_logging.h | 111 #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 …]
|
D | bwe_test_logging.cc | 134 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/ |
D | cras_dsp_ini.c | 124 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 …]
|
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() 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()
|
D | cras_dsp_ini.h | 37 int flow_id; member
|
/external/perfetto/src/trace_processor/importers/json/ |
D | json_trace_parser.cc | 156 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/ |
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 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/ |
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()
|
D | tfprof_timeline.h | 46 int64 flow_id); 49 int64 flow_id);
|
/external/rust/crates/quiche/src/h3/ |
D | ffi.rs | 268 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()
|
D | mod.rs | 929 &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/ |
D | xplane_schema.h | 264 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/ |
D | track_event_parser.cc | 727 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 …]
|
D | proto_trace_parser_unittest.cc | 223 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/ |
D | quiche.h | 527 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/ |
D | synth_common.py | 629 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/ |
D | steps_db.proto | 41 uint64 flow_id = 1; field
|
/external/perfetto/src/trace_processor/ |
D | export_json.cc | 1056 base::Optional<Json::Value> CreateFlowEventV1(uint32_t flow_id, in CreateFlowEventV1() argument 1079 event["id"] = flow_id; in CreateFlowEventV1()
|
/external/perfetto/src/tracing/test/ |
D | api_integrationtest.cc | 3394 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/ |
D | PR25409-librte_bus_dpaa.so.20.0.abi | 2190 …<var-decl name='flow_id' type-id='type-id-7' visibility='default' filepath='../../dpdk/lib/librte_…
|