Lines Matching full:helper
69 TestHelper helper(&task_runner); in TEST() local
70 helper.StartServiceIfRequired(); in TEST()
71 helper.ConnectFakeProducer(); in TEST()
72 helper.ConnectConsumer(); in TEST()
73 helper.WaitForConsumerConnect(); in TEST()
91 helper.StartTracing(trace_config); in TEST()
92 helper.WaitForTracingDisabled(); in TEST()
94 helper.ReadData(); in TEST()
95 helper.WaitForReadData(); in TEST()
97 const auto& packets = helper.trace(); in TEST()
110 TestHelper helper(&task_runner); in TEST() local
111 helper.StartServiceIfRequired(); in TEST()
112 helper.ConnectFakeProducer(); in TEST()
113 helper.ConnectConsumer(); in TEST()
114 helper.WaitForConsumerConnect(); in TEST()
132 helper.StartTracing(trace_config); in TEST()
133 helper.WaitForTracingDisabled(); in TEST()
135 helper.ReadData(); in TEST()
136 helper.WaitForReadData(/* read_count */ 0, /* timeout_ms */ 10000); in TEST()
138 const auto& packets = helper.trace(); in TEST()
161 TestHelper helper(&task_runner); in TEST() local
162 helper.StartServiceIfRequired(); in TEST()
163 auto* producer = helper.ConnectFakeProducer(); in TEST()
164 helper.ConnectConsumer(); in TEST()
165 helper.WaitForConsumerConnect(); in TEST()
190 helper.StartTracing(trace_config); in TEST()
191 helper.WaitForProducerEnabled(); in TEST()
192 helper.WaitForTracingDisabled(); in TEST()
194 helper.ReadData(); in TEST()
195 helper.WaitForReadData(/* read_count */ 0, /* timeout_ms */ 10000); in TEST()
197 const auto& packets = helper.trace(); in TEST()
201 helper.FreeBuffers(); in TEST()
206 helper.producer_thread()->get()->RemoveFileDescriptorWatch( in TEST()
211 helper.StartTracing(trace_config, base::ScopedFile()); in TEST()
212 helper.WaitForTracingDisabled(/* timeout_ms = */ 20000); in TEST()
213 helper.FreeBuffers(); in TEST()
217 helper.producer_thread()->get()->AddFileDescriptorWatch( in TEST()
234 TestHelper helper(&task_runner); in TEST() local
235 helper.StartServiceIfRequired(); in TEST()
236 auto* fake_producer = helper.ConnectFakeProducer(); in TEST()
237 helper.ConnectConsumer(); in TEST()
238 helper.WaitForConsumerConnect(); in TEST()
239 helper.StartTracing(trace_config); in TEST()
242 helper.DetachConsumer("key"); in TEST()
245 helper.WaitForProducerEnabled(); in TEST()
247 fake_producer->ProduceEventBatch(helper.WrapTask(on_data_written)); in TEST()
251 helper.ConnectConsumer(); in TEST()
252 helper.WaitForConsumerConnect(); in TEST()
253 helper.AttachConsumer("key"); in TEST()
255 helper.DisableTracing(); in TEST()
256 helper.WaitForTracingDisabled(); in TEST()
258 helper.ReadData(); in TEST()
259 helper.WaitForReadData(); in TEST()
260 const auto& packets = helper.trace(); in TEST()
281 TestHelper helper(&task_runner); in TEST() local
282 helper.StartServiceIfRequired(); in TEST()
283 helper.ConnectFakeProducer(); in TEST()
284 helper.ConnectConsumer(); in TEST()
285 helper.WaitForConsumerConnect(); in TEST()
288 helper.StartTracing(trace_config, std::move(pipe_pair.wr)); in TEST()
291 helper.DetachConsumer("key"); in TEST()
303 helper.ConnectConsumer(); in TEST()
304 helper.WaitForConsumerConnect(); in TEST()
305 EXPECT_FALSE(helper.AttachConsumer("key")); in TEST()
311 TestHelper helper(&task_runner); in TEST() local
312 helper.CreateProducerProvidedSmb(); in TEST()
321 helper.ProduceStartupEventBatch(test_config); in TEST()
323 helper.StartServiceIfRequired(); in TEST()
324 helper.ConnectFakeProducer(); in TEST()
325 helper.ConnectConsumer(); in TEST()
326 helper.WaitForConsumerConnect(); in TEST()
339 helper.StartTracing(trace_config); in TEST()
340 helper.WaitForTracingDisabled(); in TEST()
342 EXPECT_TRUE(helper.IsShmemProvidedByProducer()); in TEST()
344 helper.ReadData(); in TEST()
345 helper.WaitForReadData(); in TEST()
347 const auto& packets = helper.trace(); in TEST()
359 TestHelper helper(&task_runner); in TEST() local
360 helper.StartServiceIfRequired(); in TEST()
361 helper.ConnectConsumer(); in TEST()
362 helper.WaitForConsumerConnect(); in TEST()
364 FakeProducer* producer = helper.ConnectFakeProducer(); in TEST()
384 helper.SyncAndWaitProducer(); in TEST()
389 auto svc_state = helper.QueryServiceStateAndWait(); in TEST()
409 TestHelper helper(&task_runner); in TEST() local
411 helper.StartServiceIfRequired(); in TEST()
412 helper.ConnectFakeProducer(); in TEST()
413 helper.ConnectConsumer(); in TEST()
414 helper.WaitForConsumerConnect(); in TEST()
448 helper.StartTracing(trace_config); in TEST()
449 helper.WaitForTracingDisabled(); in TEST()
451 helper.ReadData(); in TEST()
452 helper.WaitForReadData(/* read_count */ 0, /* timeout_ms */ 10000); in TEST()
454 const std::vector<protos::gen::TracePacket>& packets = helper.trace(); in TEST()
477 TestHelper helper(&task_runner, TestHelper::Mode::kStartDaemons, in TEST() local
479 ASSERT_EQ(helper.num_producers(), 2u); in TEST()
480 helper.StartServiceIfRequired(); in TEST()
482 helper.ConnectFakeProducer(); in TEST()
484 helper.ConnectFakeProducer(1); in TEST()
485 helper.ConnectConsumer(); in TEST()
486 helper.WaitForConsumerConnect(); in TEST()
508 helper.StartTracing(trace_config); in TEST()
509 helper.WaitForTracingDisabled(); in TEST()
511 helper.ReadData(); in TEST()
512 helper.WaitForReadData(); in TEST()
514 const auto& packets = helper.trace(); in TEST()
542 TestHelper helper(&task_runner, TestHelper::Mode::kStartDaemons, in TEST() local
544 ASSERT_EQ(helper.num_producers(), 1u); in TEST()
545 helper.StartServiceIfRequired(); in TEST()
547 helper.ConnectFakeProducer(); in TEST()
548 helper.ConnectConsumer(); in TEST()
549 helper.WaitForConsumerConnect(); in TEST()
566 helper.StartTracing(trace_config); in TEST()
567 helper.WaitForTracingDisabled(); in TEST()
569 helper.ReadData(); in TEST()
570 helper.WaitForReadData(); in TEST()
572 const auto& packets = helper.trace(); in TEST()