310   std::map<DataSourceInstanceID, DataSourceState>::iterator ds_it;  in StartDataSource()
317   DataSourceState& ds = ds_it->second;  in StartDataSource()
410   DataSourceState& ds = ds_it->second;  in StopDataSource()
452     DataSourceState& ds = ds_it->second;  in ClearIncrementalState()
481   DataSourceState& ds = it->second;  in TickDataSourceRead()
497   if (PERFETTO_UNLIKELY(ds.status == DataSourceState::Status::kShuttingDown) &&  in TickDataSourceRead()
516                                             DataSourceState* ds) {  in ReadAndParsePerCpuBuffer()
634     DataSourceState& ds = it.second;  in OnProcDescriptors()
705   DataSourceState& ds = ds_it->second;  in EvaluateDescriptorLookupTimeout()
744   DataSourceState& ds = ds_it->second;  in EmitSample()
779   DataSourceState& ds = ds_it->second;  in EmitRingBufferLoss()
824   DataSourceState& ds = ds_it->second;  in EmitSkippedSample()
853 void PerfProducer::InitiateReaderStop(DataSourceState* ds) {  in InitiateReaderStop()
855   PERFETTO_CHECK(ds->status != DataSourceState::Status::kShuttingDown);  in InitiateReaderStop()
857   ds->status = DataSourceState::Status::kShuttingDown;  in InitiateReaderStop()
879   DataSourceState& ds = ds_it->second;  in FinishDataSourceStop()
880   PERFETTO_CHECK(ds.status == DataSourceState::Status::kShuttingDown);  in FinishDataSourceStop()
907   DataSourceState& ds = ds_it->second;  in PurgeDataSource()