785   auto* data_source = trace_config.add_data_sources();  in TEST_P()  local
788   auto* ds_cfg = data_source->mutable_config();  in TEST_P()
798   data_source->add_producer_name_filter("all_producers_excluded");  in TEST_P()
810   data_source->clear_producer_name_filter();  in TEST_P()
2567   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2588   data_source->on_setup.Wait();  in TEST_P()
2589   EXPECT_EQ(data_source->config.legacy_config(), "test config");  in TEST_P()
2590   data_source->on_start.Wait();  in TEST_P()
2614   data_source->on_stop.Wait();  in TEST_P()
2643   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2655   data_source->on_start.Wait();  in TEST_P()
2671   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2684   data_source->on_start.Wait();  in TEST_P()
2721   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2735   data_source->on_setup.Wait();  in TEST_P()
2736   data_source->on_start.Wait();  in TEST_P()
2777   data_source->on_stop.Wait();  in TEST_P()
2805   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2826   EXPECT_TRUE(data_source->on_setup.notified());  in TEST_P()
2827   EXPECT_TRUE(data_source->on_start.notified());  in TEST_P()
2830   EXPECT_TRUE(data_source->on_stop.notified());  in TEST_P()
2850   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
2851   data_source->handle_stop_asynchronously = true;  in TEST_P()
2867   data_source->on_stop.Wait();  in TEST_P()
2889   EXPECT_TRUE(data_source->async_stop_closure);  in TEST_P()
2890   data_source->async_stop_closure();  in TEST_P()
3042   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3054   data_source->on_start_callback = [] {  in TEST_P()
3063   data_source->on_stop_callback = [] {  in TEST_P()
3074   data_source->on_stop.Wait();  in TEST_P()