1027   auto* data_source = trace_config.add_data_sources();  in TEST_P()  local
1030   auto* ds_cfg = data_source->mutable_config();  in TEST_P()
1040   data_source->add_producer_name_filter("all_producers_excluded");  in TEST_P()
1052   data_source->clear_producer_name_filter();  in TEST_P()
3734   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3755   data_source->on_setup.Wait();  in TEST_P()
3756   EXPECT_EQ(data_source->config.legacy_config(), "test config");  in TEST_P()
3757   data_source->on_start.Wait();  in TEST_P()
3781   data_source->on_stop.Wait();  in TEST_P()
3810   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3822   data_source->on_start.Wait();  in TEST_P()
3838   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3851   data_source->on_start.Wait();  in TEST_P()
3880   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3894   data_source->on_setup.Wait();  in TEST_P()
3895   data_source->on_start.Wait();  in TEST_P()
3936   data_source->on_stop.Wait();  in TEST_P()
3964   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
3985   EXPECT_TRUE(data_source->on_setup.notified());  in TEST_P()
3986   EXPECT_TRUE(data_source->on_start.notified());  in TEST_P()
3989   EXPECT_TRUE(data_source->on_stop.notified());  in TEST_P()
4011   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
4012   data_source->handle_stop_asynchronously = true;  in TEST_P()
4028   data_source->on_stop.Wait();  in TEST_P()
4050   EXPECT_TRUE(data_source->async_stop_closure);  in TEST_P()
4051   data_source->async_stop_closure();  in TEST_P()
4203   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
4219   data_source->on_flush_callback = [&] {  in TEST_P()
4239   data_source->on_stop.Wait();  in TEST_P()
4254   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
4269   data_source->handle_flush_asynchronously = true;  in TEST_P()
4270   data_source->on_flush_callback = [&] {  in TEST_P()
4279   data_source->on_flush.Wait();  in TEST_P()
4288   data_source->async_flush_closure();  in TEST_P()
4294   data_source->on_stop.Wait();  in TEST_P()
4311   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
4323   data_source->on_start_callback = [] {  in TEST_P()
4332   data_source->on_stop_callback = [] {  in TEST_P()
4343   data_source->on_stop.Wait();  in TEST_P()
5809   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
5810   data_source->on_stop.Wait();  in TEST_P()
5829   auto* data_source = &data_sources_["my_data_source"];  in TEST_P()  local
5830   data_source->handle_stop_asynchronously = true;  in TEST_P()
5876   data_source->on_stop.Wait();  in TEST_P()
5888   data_source->async_stop_closure();  in TEST_P()
5919   data_source->handle_stop_asynchronously = false;  in TEST_P()