Home
last modified time | relevance | path

Searched refs:ds_id (Results 1 – 12 of 12) sorted by relevance

/external/perfetto/src/profiling/perf/
Dperf_producer.cc131 uint32_t TimeToNextReadTickMs(DataSourceInstanceID ds_id, uint32_t period_ms) { in TimeToNextReadTickMs() argument
136 std::minstd_rand prng(static_cast<std::minstd_rand::result_type>(ds_id)); in TimeToNextReadTickMs()
256 void PerfProducer::StartDataSource(DataSourceInstanceID ds_id, in StartDataSource() argument
258 PERFETTO_LOG("StartDataSource(%zu, %s)", static_cast<size_t>(ds_id), in StartDataSource()
262 StartMetatraceSource(ds_id, static_cast<BufferID>(config.target_buffer())); in StartDataSource()
313 std::piecewise_construct, std::forward_as_tuple(ds_id), in StartDataSource()
332 unwinding_worker_->PostStartDataSource(ds_id, in StartDataSource()
336 ds_id, ds.event_config.unwind_state_clear_period_ms()); in StartDataSource()
343 [weak_this, ds_id] { in StartDataSource()
345 weak_this->TickDataSourceRead(ds_id); in StartDataSource()
[all …]
Dunwinding.cc45 void Unwinder::PostStartDataSource(DataSourceInstanceID ds_id, in PostStartDataSource() argument
50 [this, ds_id, kernel_frames] { StartDataSource(ds_id, kernel_frames); }); in PostStartDataSource()
53 void Unwinder::StartDataSource(DataSourceInstanceID ds_id, bool kernel_frames) { in StartDataSource() argument
55 PERFETTO_DLOG("Unwinder::StartDataSource(%zu)", static_cast<size_t>(ds_id)); in StartDataSource()
57 auto it_and_inserted = data_sources_.emplace(ds_id, DataSourceState{}); in StartDataSource()
80 void Unwinder::PostAdoptProcDescriptors(DataSourceInstanceID ds_id, in PostAdoptProcDescriptors() argument
86 task_runner_->PostTask([this, ds_id, pid, shared_maps, shared_mem] { in PostAdoptProcDescriptors()
89 AdoptProcDescriptors(ds_id, pid, std::move(maps), std::move(mem)); in PostAdoptProcDescriptors()
93 void Unwinder::AdoptProcDescriptors(DataSourceInstanceID ds_id, in AdoptProcDescriptors() argument
99 static_cast<size_t>(ds_id), static_cast<int>(pid), in AdoptProcDescriptors()
[all …]
Dperf_producer.h94 void PostEmitSample(DataSourceInstanceID ds_id,
96 void PostEmitUnwinderSkippedSample(DataSourceInstanceID ds_id,
98 void PostFinishDataSourceStop(DataSourceInstanceID ds_id) override;
164 void TickDataSourceRead(DataSourceInstanceID ds_id);
172 DataSourceInstanceID ds_id,
175 void InitiateDescriptorLookup(DataSourceInstanceID ds_id,
179 void StartDescriptorLookup(DataSourceInstanceID ds_id,
182 void EvaluateDescriptorLookupTimeout(DataSourceInstanceID ds_id, pid_t pid);
184 void EmitSample(DataSourceInstanceID ds_id, CompletedSample sample);
185 void EmitRingBufferLoss(DataSourceInstanceID ds_id,
[all …]
Dunwinding.h80 virtual void PostEmitSample(DataSourceInstanceID ds_id,
82 virtual void PostEmitUnwinderSkippedSample(DataSourceInstanceID ds_id,
84 virtual void PostFinishDataSourceStop(DataSourceInstanceID ds_id) = 0;
91 void PostStartDataSource(DataSourceInstanceID ds_id, bool kernel_frames);
92 void PostAdoptProcDescriptors(DataSourceInstanceID ds_id,
96 void PostRecordTimedOutProcDescriptors(DataSourceInstanceID ds_id, pid_t pid);
98 void PostInitiateDataSourceStop(DataSourceInstanceID ds_id);
99 void PostPurgeDataSource(DataSourceInstanceID ds_id);
101 void PostClearCachedStatePeriodic(DataSourceInstanceID ds_id,
161 void StartDataSource(DataSourceInstanceID ds_id, bool kernel_frames);
[all …]
/external/perfetto/src/traced/service/
Dbuiltin_producer.cc93 void BuiltinProducer::SetupDataSource(DataSourceInstanceID ds_id, in SetupDataSource() argument
99 lazy_heapprofd_.instance_ids.emplace(ds_id); in SetupDataSource()
106 lazy_traced_perf_.instance_ids.emplace(ds_id); in SetupDataSource()
111 void BuiltinProducer::StartDataSource(DataSourceInstanceID ds_id, in StartDataSource() argument
120 std::piecewise_construct, std::make_tuple(ds_id), std::make_tuple()); in StartDataSource()
123 metatrace_.writers[ds_id].Enable(task_runner_, std::move(writer), in StartDataSource()
128 void BuiltinProducer::StopDataSource(DataSourceInstanceID ds_id) { in StopDataSource() argument
129 auto meta_it = metatrace_.writers.find(ds_id); in StopDataSource()
135 endpoint_->NotifyDataSourceStopped(ds_id); in StopDataSource()
139 MaybeInitiateLazyStop(ds_id, &lazy_heapprofd_, kLazyHeapprofdPropertyName); in StopDataSource()
[all …]
Dbuiltin_producer.h76 void MaybeInitiateLazyStop(DataSourceInstanceID ds_id,
/external/perfetto/src/tracing/test/
Dmock_producer.cc104 .WillOnce(Invoke([on_ds_start, this](DataSourceInstanceID ds_id, in WaitForDataSourceSetup()
111 cfg.name(), EnabledDataSource{ds_id, target_buffer, session_id}); in WaitForDataSourceSetup()
123 .WillOnce(Invoke([on_ds_start, this](DataSourceInstanceID ds_id, in WaitForDataSourceStart() argument
132 cfg.name(), EnabledDataSource{ds_id, target_buffer, session_id}); in WaitForDataSourceStart()
144 DataSourceInstanceID ds_id = data_source_instances_[name].id; in WaitForDataSourceStop() local
145 EXPECT_CALL(*this, StopDataSource(ds_id)) in WaitForDataSourceStop()
/external/perfetto/src/traced/probes/
Dprobes_producer.cc386 DataSourceInstanceID ds_id = data_source_ids[i]; in Flush() local
387 auto it = data_sources_.find(ds_id); in Flush()
390 pending_flushes_.emplace(flush_request_id, ds_id); in Flush()
392 auto flush_callback = [weak_this, flush_request_id, ds_id] { in Flush()
394 weak_this->OnDataSourceFlushComplete(flush_request_id, ds_id); in Flush()
415 DataSourceInstanceID ds_id) { in OnDataSourceFlushComplete() argument
417 flush_request_id, ds_id); in OnDataSourceFlushComplete()
420 if (it->second == ds_id) { in OnDataSourceFlushComplete()
445 DataSourceInstanceID ds_id = data_source_ids[i]; in ClearIncrementalState() local
446 auto it = data_sources_.find(ds_id); in ClearIncrementalState()
/external/deqp-deps/amber/src/
Dclspv_helper.cc92 auto ds_id = inst->words[inst->operands[6].offset]; in ParseExtendedInst() local
102 helper->constants[ds_id], in ParseExtendedInst()
116 auto ds_id = inst->words[inst->operands[6].offset]; in ParseExtendedInst() local
128 helper->constants[ds_id], in ParseExtendedInst()
199 auto ds_id = inst->words[inst->operands[4].offset]; in ParseExtendedInst() local
203 helper->constants[ds_id], in ParseExtendedInst()
/external/perfetto/src/profiling/memory/
Dheapprofd_producer.cc1028 DataSourceInstanceID ds_id, in PostSocketDisconnected() argument
1032 task_runner_->PostTask([weak_this, ds_id, pid, stats] { in PostSocketDisconnected()
1034 weak_this->HandleSocketDisconnected(ds_id, pid, stats); in PostSocketDisconnected()
1183 DataSourceInstanceID ds_id = ds->id; in MaybeFinishDataSource() local
1186 ds->trace_writer->Flush([weak_producer, exit_when_done, ds_id, was_stopped] { in MaybeFinishDataSource()
1191 weak_producer->endpoint_->NotifyDataSourceStopped(ds_id); in MaybeFinishDataSource()
1192 weak_producer->data_sources_.erase(ds_id); in MaybeFinishDataSource()
1208 DataSourceInstanceID ds_id, in HandleSocketDisconnected() argument
1211 auto it = data_sources_.find(ds_id); in HandleSocketDisconnected()
Dunwinding.cc228 DataSourceInstanceID ds_id = client_data.data_source_instance_id; in OnDisconnect() local
239 delegate_->PostSocketDisconnected(this, ds_id, peer_pid, stats); in OnDisconnect()
/external/perfetto/src/tracing/core/
Dtracing_service_impl.cc3791 DataSourceInstanceID ds_id, in SetupDataSource() argument
3796 task_runner_->PostTask([weak_this, ds_id, config] { in SetupDataSource()
3798 weak_this->producer_->SetupDataSource(ds_id, std::move(config)); in SetupDataSource()
3803 DataSourceInstanceID ds_id, in StartDataSource() argument
3807 task_runner_->PostTask([weak_this, ds_id, config] { in StartDataSource()
3809 weak_this->producer_->StartDataSource(ds_id, std::move(config)); in StartDataSource()