Home
last modified time | relevance | path

Searched refs:flow_id (Results 1 – 25 of 25) 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 Begin(open_slice_id.value(), flow_id); in Begin()
52 void FlowTracker::Begin(SliceId slice_id, FlowId flow_id) { in Begin() argument
53 auto it_and_ins = flow_to_slice_map_.Insert(flow_id, slice_id); in Begin()
60 void FlowTracker::Step(TrackId track_id, FlowId flow_id) { in Step() argument
67 Step(open_slice_id.value(), flow_id); in Step()
70 void FlowTracker::Step(SliceId slice_id, FlowId flow_id) { in Step() argument
71 auto* it = flow_to_slice_map_.Find(flow_id); in Step()
77 InsertFlow(flow_id, slice_out_id, slice_id); in Step()
82 FlowId flow_id, in End() argument
[all …]
Dflow_tracker.h43 void Begin(SliceId slice_id, FlowId flow_id);
44 void Step(SliceId slice_id, FlowId flow_id);
45 void End(SliceId track_id, FlowId flow_id, bool close_flow);
50 void Begin(TrackId track_id, FlowId flow_id);
51 void Step(TrackId track_id, FlowId flow_id);
60 FlowId flow_id,
64 bool IsActive(FlowId flow_id) const;
94 void InsertFlow(FlowId flow_id,
Dflow_tracker_unittest.cc45 FlowId flow_id = 1; in TEST() local
51 tracker.Begin(track_1, flow_id); in TEST()
56 tracker.End(track_2, flow_id, /* bind_enclosing = */ true, in TEST()
79 FlowId flow_id = 1; in TEST() local
85 tracker.Begin(track_1, flow_id); in TEST()
88 tracker.End(track_2, flow_id, /* bind_enclosing = */ false, in TEST()
117 FlowId flow_id = 1; in TEST() local
123 tracker.Begin(track_1, flow_id); in TEST()
126 tracker.End(track_2, flow_id, /* bind_enclosing = */ false, in TEST()
258 FlowId flow_id = 1; in TEST() local
[all …]
/external/perfetto/include/perfetto/tracing/
Dtrack_event_args.h35 ProcessScoped(uint64_t flow_id) { in ProcessScoped() argument
36 return Global(flow_id ^ Track::process_uuid); in ProcessScoped()
54 Global(uint64_t flow_id) { in Global() argument
55 return [flow_id](perfetto::EventContext& ctx) { in Global()
56 ctx.event()->add_flow_ids(flow_id); in Global()
61 explicit constexpr Flow(uint64_t flow_id) : flow_id_(flow_id) {} in Flow() argument
75 ProcessScoped(uint64_t flow_id) { in ProcessScoped() argument
76 return Global(flow_id ^ Track::process_uuid); in ProcessScoped()
87 Global(uint64_t flow_id) { in Global() argument
88 return [flow_id](perfetto::EventContext& ctx) { in Global()
[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
216 #define BWE_TEST_LOGGING_BAR(figure, name, value, flow_id) \ argument
220 flow_id); \
223 #define BWE_TEST_LOGGING_BASELINEBAR(figure, name, value, flow_id) \ argument
227 figure, name, value, flow_id); \
231 flow_id) \ argument
235 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/tensorflow/tensorflow/python/client/
Dtimeline.py182 def emit_flow_start(self, name, timestamp, pid, tid, flow_id): argument
196 event['id'] = flow_id
199 def emit_flow_end(self, name, timestamp, pid, tid, flow_id): argument
213 event['id'] = flow_id
380 flow_id = self._next_flow_id
382 return flow_id
565 flow_id = self._alloc_flow_id()
568 flow_id)
570 device_pid, tid, flow_id)
/external/tensorflow/tensorflow/core/profiler/utils/
Dxplane_schema.h333 XFlow(uint64_t flow_id, FlowDirection direction,
337 encoded_.parts.flow_id = flow_id;
361 uint64_t Id() const { return encoded_.parts.flow_id; } in Id()
383 uint64_t flow_id : 56; member
/external/tensorflow/tensorflow/core/profiler/internal/
Dtfprof_timeline.cc78 int64_t flow_id) { in EmitFlowStart() argument
80 event["id"] = Json::Int64(flow_id); in EmitFlowStart()
86 int64_t flow_id) { in EmitFlowEnd() argument
88 event["id"] = Json::Int64(flow_id); in EmitFlowEnd()
242 int64_t flow_id = 1; in GenerateGraphTimeline() local
259 process.first, lane.first, flow_id); in GenerateGraphTimeline()
262 next_tnode->process->pid, next_tnode->tid, flow_id); in GenerateGraphTimeline()
263 flow_id += 1; in GenerateGraphTimeline()
Dtfprof_timeline.h44 int64_t flow_id);
47 int64_t flow_id);
/external/perfetto/src/trace_processor/importers/json/
Djson_trace_parser.cc289 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseJsonPacket() local
291 flow_tracker->Begin(track_id, flow_id); in ParseJsonPacket()
302 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseJsonPacket() local
304 flow_tracker->Step(track_id, flow_id); in ParseJsonPacket()
315 FlowId flow_id = flow_tracker->GetFlowIdForV1Event( in ParseJsonPacket() local
319 flow_tracker->End(track_id, flow_id, bind_enclosing_slice, in ParseJsonPacket()
/external/wpa_supplicant_8/wpa_supplicant/
Dtwt.c32 bool flow_type, u8 flow_id, bool protection, in wpas_twt_send_setup() argument
77 req_type |= (flow_id & 0x7) << 7; in wpas_twt_send_setup()
Dwpa_supplicant_i.h1690 bool flow_type, u8 flow_id, bool protection,
Dctrl_iface.c10336 int flow_id = 0; in wpas_ctrl_iface_send_twt_setup() local
10387 flow_id = atoi(tok_s + os_strlen(" flow_id=")); in wpas_ctrl_iface_send_twt_setup()
10403 flow_type, flow_id, protection, twt_channel, in wpas_ctrl_iface_send_twt_setup()
/external/rust/crates/quiche/src/h3/
Dffi.rs370 conn: &mut h3::Connection, quic_conn: &mut Connection, flow_id: u64, in quiche_h3_send_dgram()
379 match conn.send_dgram(quic_conn, flow_id, data) { in quiche_h3_send_dgram()
388 conn: &mut h3::Connection, quic_conn: &mut Connection, flow_id: *mut u64, in quiche_h3_recv_dgram()
399 unsafe { *flow_id = id }; in quiche_h3_recv_dgram()
Dmod.rs1339 &mut self, conn: &mut super::Connection, flow_id: u64, buf: &[u8], in send_dgram()
1341 let len = octets::varint_len(flow_id) + buf.len(); in send_dgram()
1345 b.put_varint(flow_id)?; in send_dgram()
1375 let flow_id = b.get_varint()?; in recv_dgram() localVariable
1376 Ok((len, flow_id, b.off())) in recv_dgram()
1381 &self, conn: &super::Connection, flow_id: u64, in dgram_max_writable_len()
1383 let flow_id_len = octets::varint_len(flow_id); in dgram_max_writable_len()
3065 pub fn send_dgram_client(&mut self, flow_id: u64) -> Result<Vec<u8>> { in send_dgram_client()
3069 .send_dgram(&mut self.pipe.client, flow_id, &bytes)?; in send_dgram_client()
3089 pub fn send_dgram_server(&mut self, flow_id: u64) -> Result<Vec<u8>> { in send_dgram_server()
[all …]
/external/cronet/net/socket/
Dudp_socket_win.h87 PQOS_FLOWID flow_id);
90 QOS_FLOWID flow_id,
93 QOS_FLOWID flow_id,
Dudp_socket_win.cc218 PQOS_FLOWID flow_id) { in AddSocketToFlow() argument
220 flow_id); in AddSocketToFlow()
225 QOS_FLOWID flow_id, in RemoveSocketFromFlow() argument
227 return remove_socket_from_flow_func_(handle, socket, flow_id, reserved); in RemoveSocketFromFlow()
231 QOS_FLOWID flow_id, in SetFlow() argument
237 return set_flow_func_(handle, flow_id, op, size, data, reserved, overlapped); in SetFlow()
Dudp_socket_unittest.cc1016 PQOS_FLOWID flow_id));
1020 BOOL(HANDLE handle, SOCKET socket, QOS_FLOWID flow_id, DWORD reserved));
1023 QOS_FLOWID flow_id,
/external/perfetto/src/trace_processor/importers/proto/
Dtrack_event_parser.cc820 FlowId flow_id = context_->flow_tracker->GetFlowIdForV1Event( in ParseFlowEventV1() local
824 context_->flow_tracker->Begin(track_id_, flow_id); in ParseFlowEventV1()
827 context_->flow_tracker->Step(track_id_, flow_id); in ParseFlowEventV1()
830 context_->flow_tracker->End(track_id_, flow_id, in ParseFlowEventV1()
843 FlowId flow_id = *it; in MaybeParseTrackEventFlows() local
844 if (!context_->flow_tracker->IsActive(flow_id)) { in MaybeParseTrackEventFlows()
845 context_->flow_tracker->Begin(slice_id, flow_id); in MaybeParseTrackEventFlows()
848 context_->flow_tracker->Step(slice_id, flow_id); in MaybeParseTrackEventFlows()
857 FlowId flow_id = *it; in MaybeParseTrackEventFlows() local
858 if (!context_->flow_tracker->IsActive(flow_id)) { in MaybeParseTrackEventFlows()
[all …]
/external/perfetto/test/
Dsynth_common.py674 for flow_id in flow_ids:
675 packet.track_event.flow_ids.append(flow_id)
676 for flow_id in terminating_flow_ids:
677 packet.track_event.terminating_flow_ids.append(flow_id)
/external/rust/crates/quiche/include/
Dquiche.h953 uint64_t flow_id, uint8_t *data, size_t data_len);
957 uint64_t *flow_id, size_t *flow_id_len,
/external/perfetto/src/trace_processor/
Dexport_json.cc1057 std::optional<Json::Value> CreateFlowEventV1(uint32_t flow_id, in CreateFlowEventV1() argument
1080 event["id"] = flow_id; in CreateFlowEventV1()
/external/perfetto/src/tracing/test/
Dapi_integrationtest.cc4884 const uint64_t flow_id = 1234; in TEST_P() local
4886 TRACE_EVENT_WITH_FLOW1("cat", "LatencyInfo.Flow", TRACE_ID_GLOBAL(flow_id), in TEST_P()
4891 TRACE_EVENT_WITH_FLOW2("cat", "LatencyInfo.Flow", TRACE_ID_GLOBAL(flow_id), in TEST_P()
4897 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.abi2324 …<var-decl name='flow_id' type-id='type-id-6' visibility='default' filepath='../../dpdk/lib/librte_…