379   DataSource data_source(endpoint_->CreateTraceWriter(buffer_id));  in SetupDataSource()
405     const DataSource& ds = pair.second;  in IsPidProfiled()
426 void HeapprofdProducer::SetStartupProperties(DataSource* data_source) {  in SetStartupProperties()
436 void HeapprofdProducer::SignalRunningProcesses(DataSource* data_source) {  in SignalRunningProcesses()
488   DataSource& data_source = it->second;  in StartDataSource()
535   DataSource& data_source = it->second;  in StopDataSource()
540 void HeapprofdProducer::ShutdownDataSource(DataSource* data_source) {  in ShutdownDataSource()
577           DataSource& ds = ds_it->second;  in ShutdownDataSource()
602 void HeapprofdProducer::DumpProcessState(DataSource* data_source,  in DumpProcessState()
677   DataSource& data_source = it->second;  in DumpProcessesInDataSource()
710     DataSource& data_source = it->second;  in Flush()
790     DataSource& data_source = ds_it->second;  in OnDataAvailable()
848 HeapprofdProducer::DataSource* HeapprofdProducer::GetDataSourceForProcess(  in GetDataSourceForProcess()
851     DataSource& ds = ds_id_and_datasource.second;  in GetDataSourceForProcess()
858 void HeapprofdProducer::RecordOtherSourcesAsRejected(DataSource* active_ds,  in RecordOtherSourcesAsRejected()
861     DataSource& ds = ds_id_and_datasource.second;  in RecordOtherSourcesAsRejected()
871   DataSource* data_source = GetDataSourceForProcess(process);  in HandleClientConnection()
943   DataSource& ds = it->second;  in HandleAllocRecord()
994   DataSource& ds = it->second;  in HandleFreeRecord()
1017 bool HeapprofdProducer::MaybeFinishDataSource(DataSource* ds) {  in MaybeFinishDataSource()
1054   DataSource& ds = it->second;  in HandleSocketDisconnected()
1083     DataSource& ds = id_and_ds.second;  in CheckDataSourceCpu()
1098     DataSource& ds = id_and_ds.second;  in CheckDataSourceCpu()
1129     DataSource& ds = id_and_ds.second;  in CheckDataSourceMemory()
1148     DataSource& ds = id_and_ds.second;  in CheckDataSourceMemory()