Lines Matching refs:ds_id
131 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()
347 TimeToNextReadTickMs(ds_id, tick_period_ms)); in StartDataSource()
353 [weak_this, ds_id, max_daemon_memory_kb] { in StartDataSource()
355 weak_this->CheckMemoryFootprintPeriodic(ds_id, in StartDataSource()
362 void PerfProducer::CheckMemoryFootprintPeriodic(DataSourceInstanceID ds_id, in CheckMemoryFootprintPeriodic() argument
364 auto ds_it = data_sources_.find(ds_id); in CheckMemoryFootprintPeriodic()
373 PurgeDataSource(ds_id); in CheckMemoryFootprintPeriodic()
380 [weak_this, ds_id, max_daemon_memory_kb] { in CheckMemoryFootprintPeriodic()
382 weak_this->CheckMemoryFootprintPeriodic(ds_id, max_daemon_memory_kb); in CheckMemoryFootprintPeriodic()
387 void PerfProducer::StopDataSource(DataSourceInstanceID ds_id) { in StopDataSource() argument
388 PERFETTO_LOG("StopDataSource(%zu)", static_cast<size_t>(ds_id)); in StopDataSource()
392 auto meta_it = metatrace_writers_.find(ds_id); in StopDataSource()
399 auto ds_it = data_sources_.find(ds_id); in StopDataSource()
404 endpoint_->NotifyDataSourceStopped(ds_id); in StopDataSource()
424 auto ds_id = data_source_ids[i]; in Flush() local
425 PERFETTO_DLOG("Flush(%zu)", static_cast<size_t>(ds_id)); in Flush()
427 auto meta_it = metatrace_writers_.find(ds_id); in Flush()
440 auto ds_id = data_source_ids[i]; in ClearIncrementalState() local
441 PERFETTO_DLOG("ClearIncrementalState(%zu)", static_cast<size_t>(ds_id)); in ClearIncrementalState()
443 if (metatrace_writers_.find(ds_id) != metatrace_writers_.end()) in ClearIncrementalState()
446 auto ds_it = data_sources_.find(ds_id); in ClearIncrementalState()
449 static_cast<size_t>(ds_id)); in ClearIncrementalState()
474 void PerfProducer::TickDataSourceRead(DataSourceInstanceID ds_id) { in TickDataSourceRead() argument
475 auto it = data_sources_.find(ds_id); in TickDataSourceRead()
478 static_cast<size_t>(ds_id)); in TickDataSourceRead()
489 if (ReadAndParsePerCpuBuffer(&reader, max_samples, ds_id, &ds)) { in TickDataSourceRead()
499 unwinding_worker_->PostInitiateDataSourceStop(ds_id); in TickDataSourceRead()
505 [weak_this, ds_id] { in TickDataSourceRead()
507 weak_this->TickDataSourceRead(ds_id); in TickDataSourceRead()
509 TimeToNextReadTickMs(ds_id, tick_period_ms)); in TickDataSourceRead()
515 DataSourceInstanceID ds_id, in ReadAndParsePerCpuBuffer() argument
521 auto records_lost_callback = [this, ds_id, cpu](uint64_t records_lost) { in ReadAndParsePerCpuBuffer()
523 task_runner_->PostTask([weak_this, ds_id, cpu, records_lost] { in ReadAndParsePerCpuBuffer()
525 weak_this->EmitRingBufferLoss(ds_id, cpu, records_lost); in ReadAndParsePerCpuBuffer()
541 EmitSample(ds_id, std::move(output)); in ReadAndParsePerCpuBuffer()
557 EmitSkippedSample(ds_id, std::move(sample.value()), in ReadAndParsePerCpuBuffer()
584 InitiateDescriptorLookup(ds_id, pid, in ReadAndParsePerCpuBuffer()
600 EmitSkippedSample(ds_id, std::move(sample.value()), in ReadAndParsePerCpuBuffer()
611 UnwindEntry{ds_id, std::move(sample.value())}; in ReadAndParsePerCpuBuffer()
616 EmitSkippedSample(ds_id, std::move(sample.value()), in ReadAndParsePerCpuBuffer()
667 void PerfProducer::InitiateDescriptorLookup(DataSourceInstanceID ds_id, in InitiateDescriptorLookup() argument
671 StartDescriptorLookup(ds_id, pid, timeout_ms); in InitiateDescriptorLookup()
678 [weak_this, ds_id, pid, timeout_ms] { in InitiateDescriptorLookup()
680 weak_this->StartDescriptorLookup(ds_id, pid, timeout_ms); in InitiateDescriptorLookup()
685 void PerfProducer::StartDescriptorLookup(DataSourceInstanceID ds_id, in StartDescriptorLookup() argument
692 [weak_this, ds_id, pid] { in StartDescriptorLookup()
694 weak_this->EvaluateDescriptorLookupTimeout(ds_id, pid); in StartDescriptorLookup()
699 void PerfProducer::EvaluateDescriptorLookupTimeout(DataSourceInstanceID ds_id, in EvaluateDescriptorLookupTimeout() argument
701 auto ds_it = data_sources_.find(ds_id); in EvaluateDescriptorLookupTimeout()
720 unwinding_worker_->PostRecordTimedOutProcDescriptors(ds_id, pid); in EvaluateDescriptorLookupTimeout()
724 void PerfProducer::PostEmitSample(DataSourceInstanceID ds_id, in PostEmitSample() argument
729 task_runner_->PostTask([weak_this, ds_id, raw_sample] { in PostEmitSample()
731 weak_this->EmitSample(ds_id, std::move(*raw_sample)); in PostEmitSample()
736 void PerfProducer::EmitSample(DataSourceInstanceID ds_id, in EmitSample() argument
738 auto ds_it = data_sources_.find(ds_id); in EmitSample()
741 static_cast<size_t>(ds_id)); in EmitSample()
773 void PerfProducer::EmitRingBufferLoss(DataSourceInstanceID ds_id, in EmitRingBufferLoss() argument
776 auto ds_it = data_sources_.find(ds_id); in EmitRingBufferLoss()
781 static_cast<size_t>(ds_id), cpu, records_lost); in EmitRingBufferLoss()
799 void PerfProducer::PostEmitUnwinderSkippedSample(DataSourceInstanceID ds_id, in PostEmitUnwinderSkippedSample() argument
801 PostEmitSkippedSample(ds_id, std::move(sample), in PostEmitUnwinderSkippedSample()
805 void PerfProducer::PostEmitSkippedSample(DataSourceInstanceID ds_id, in PostEmitSkippedSample() argument
811 task_runner_->PostTask([weak_this, ds_id, raw_sample, reason] { in PostEmitSkippedSample()
813 weak_this->EmitSkippedSample(ds_id, std::move(*raw_sample), reason); in PostEmitSkippedSample()
818 void PerfProducer::EmitSkippedSample(DataSourceInstanceID ds_id, in EmitSkippedSample() argument
821 auto ds_it = data_sources_.find(ds_id); in EmitSkippedSample()
863 void PerfProducer::PostFinishDataSourceStop(DataSourceInstanceID ds_id) { in PostFinishDataSourceStop() argument
865 task_runner_->PostTask([weak_producer, ds_id] { in PostFinishDataSourceStop()
867 weak_producer->FinishDataSourceStop(ds_id); in PostFinishDataSourceStop()
871 void PerfProducer::FinishDataSourceStop(DataSourceInstanceID ds_id) { in FinishDataSourceStop() argument
872 PERFETTO_LOG("FinishDataSourceStop(%zu)", static_cast<size_t>(ds_id)); in FinishDataSourceStop()
873 auto ds_it = data_sources_.find(ds_id); in FinishDataSourceStop()
876 static_cast<size_t>(ds_id)); in FinishDataSourceStop()
885 endpoint_->NotifyDataSourceStopped(ds_id); in FinishDataSourceStop()
903 void PerfProducer::PurgeDataSource(DataSourceInstanceID ds_id) { in PurgeDataSource() argument
904 auto ds_it = data_sources_.find(ds_id); in PurgeDataSource()
910 static_cast<size_t>(ds_id)); in PurgeDataSource()
912 unwinding_worker_->PostPurgeDataSource(ds_id); in PurgeDataSource()
936 void PerfProducer::StartMetatraceSource(DataSourceInstanceID ds_id, in StartMetatraceSource() argument
941 std::piecewise_construct, std::make_tuple(ds_id), std::make_tuple()); in StartMetatraceSource()
944 metatrace_writers_[ds_id].Enable(task_runner_, std::move(writer), in StartMetatraceSource()