Lines Matching refs:producer
29 #include "perfetto/tracing/core/producer.h"
131 std::unique_ptr<MockProducer> producer = CreateMockProducer();
132 producer->Connect(svc.get(), "mock_producer");
133 producer->RegisterDataSource("data_source");
141 producer->WaitForTracingSetup();
142 producer->WaitForDataSourceStart("data_source");
145 producer->WaitForDataSourceStop("data_source");
153 std::unique_ptr<MockProducer> producer = CreateMockProducer();
154 producer->Connect(svc.get(), "mock_producer_sameuid", geteuid());
155 producer->RegisterDataSource("data_source");
165 producer->WaitForTracingSetup();
166 producer->WaitForDataSourceStart("data_source");
177 producer->WaitForDataSourceStop("data_source");
183 producer->WaitForDataSourceStart("data_source");
189 producer->WaitForDataSourceStop("data_source");
197 std::unique_ptr<MockProducer> producer = CreateMockProducer();
198 producer->Connect(svc.get(), "mock_producer");
199 producer->RegisterDataSource("data_source");
207 producer->WaitForTracingSetup();
208 producer->WaitForDataSourceStart("data_source");
213 producer->WaitForDataSourceStop("data_source");
220 std::unique_ptr<MockProducer> producer = CreateMockProducer();
221 producer->Connect(svc.get(), "mock_producer");
222 producer->RegisterDataSource("data_source");
230 producer->WaitForTracingSetup();
231 producer->WaitForDataSourceStart("data_source");
233 // Disconnecting and reconnecting a producer with a matching data source.
234 // The Producer should see that data source getting enabled again.
235 producer.reset();
236 producer = CreateMockProducer();
237 producer->Connect(svc.get(), "mock_producer_2");
238 producer->RegisterDataSource("data_source");
239 producer->WaitForTracingSetup();
240 producer->WaitForDataSourceStart("data_source");
274 std::unique_ptr<MockProducer> producer = CreateMockProducer();
275 producer->Connect(svc.get(), "mock_producer");
276 producer->RegisterDataSource("data_source");
290 producer->WaitForTracingSetup();
291 producer->WaitForDataSourceStart("data_source");
297 producer->CreateTraceWriter("data_source");
317 producer->WaitForDataSourceStop("data_source");
338 // specify a value we fall back on the hint provided by the producer.
360 std::unique_ptr<MockProducer> producer[kNumProducers];
363 producer[i] = CreateMockProducer();
364 producer[i]->Connect(svc.get(), name, geteuid(), kHintSizesKb[i] * 1024);
365 producer[i]->RegisterDataSource("data_source");
384 producer[i]->WaitForTracingSetup();
385 producer[i]->WaitForDataSourceStart("data_source");
387 producer[i]->endpoint()->shared_memory()->size() / 1024;
389 producer[i]->endpoint()->shared_buffer_page_size_kb();
399 std::unique_ptr<MockProducer> producer = CreateMockProducer();
400 producer->Connect(svc.get(), "mock_producer");
401 producer->RegisterDataSource("data_source");
409 producer->WaitForTracingSetup();
410 producer->WaitForDataSourceStart("data_source");
413 producer->CreateTraceWriter("data_source");
420 producer->WaitForFlush(writer.get());
424 producer->WaitForDataSourceStop("data_source");
436 std::unique_ptr<MockProducer> producer = CreateMockProducer();
437 producer->Connect(svc.get(), "mock_producer");
438 producer->RegisterDataSource("data_source");
447 producer->WaitForTracingSetup();
448 producer->WaitForDataSourceStart("data_source");
451 producer->CreateTraceWriter("data_source");
457 producer->WaitForFlush(writer.get());
459 producer->WaitForDataSourceStop("data_source");
468 // Tests the monotonic semantic of flush request IDs, i.e., once a producer
475 std::unique_ptr<MockProducer> producer = CreateMockProducer();
476 producer->Connect(svc.get(), "mock_producer");
477 producer->RegisterDataSource("data_source");
485 producer->WaitForTracingSetup();
486 producer->WaitForDataSourceStart("data_source");
489 producer->CreateTraceWriter("data_source");
504 // Make the producer reply only to the 3rd flush request.
506 producer->WaitForFlush(nullptr); // Will NOT reply to flush id == 1.
507 producer->WaitForFlush(nullptr); // Will NOT reply to flush id == 2.
508 producer->WaitForFlush(writer.get()); // Will reply only to flush id == 3.
509 producer->WaitForFlush(nullptr); // Will NOT reply to flush id == 4.
511 // Even if the producer explicily replied only to flush ID == 3, all the
522 producer->WaitForDataSourceStop("data_source");
