Lines Matching refs:backend
38817 TracingBackend* backend = nullptr; member
39637 auto add_backend = [this, &args](TracingBackend* backend, BackendType type) { in Initialize() argument
39638 if (!backend) { in Initialize()
39647 rb.backend = backend; in Initialize()
39659 rb.producer->Initialize(rb.backend->ConnectProducer(rb.producer_conn_args)); in Initialize()
40006 for (auto& backend : backends_) { in SyncProducersForTesting() local
40007 auto* producer = backend.producer.get(); in SyncProducersForTesting()
40026 for (auto& backend : backends_) in SyncProducersForTesting() local
40027 all_producers_connected &= backend.producer->connected_; in SyncProducersForTesting()
40085 for (RegisteredBackend& backend : backends_) { in UpdateDataSourcesOnAllBackends()
40087 if (!backend.producer->connected_) in UpdateDataSourcesOnAllBackends()
40091 if (backend.producer->registered_data_sources_.test( in UpdateDataSourcesOnAllBackends()
40098 backend.producer->service_->RegisterDataSource(rds.descriptor); in UpdateDataSourcesOnAllBackends()
40099 backend.producer->registered_data_sources_.set(rds.static_state->index); in UpdateDataSourcesOnAllBackends()
40224 for (RegisteredBackend& backend : backends_) { in DestroyTracingSession()
40231 for (auto& con : backend.consumers) { in DestroyTracingSession()
40242 std::count_if(backend.consumers.begin(), backend.consumers.end(), in DestroyTracingSession()
40317 for (RegisteredBackend& backend : backends_) { in SetBatchCommitsDurationForTesting()
40318 if (backend.producer && backend.producer->connected_ && in SetBatchCommitsDurationForTesting()
40319 backend.type == backend_type) { in SetBatchCommitsDurationForTesting()
40320 backend.producer->service_->MaybeSharedMemoryArbiter() in SetBatchCommitsDurationForTesting()
40328 for (RegisteredBackend& backend : backends_) { in EnableDirectSMBPatchingForTesting()
40329 if (backend.producer && backend.producer->connected_ && in EnableDirectSMBPatchingForTesting()
40330 backend.type == backend_type && in EnableDirectSMBPatchingForTesting()
40331 !backend.producer->service_->MaybeSharedMemoryArbiter() in EnableDirectSMBPatchingForTesting()
40342 for (RegisteredBackend& backend : backends_) { in FindConsumer()
40343 for (auto& consumer : backend.consumers) { in FindConsumer()
40362 RegisteredBackend& backend = backends_[backend_id]; in InitializeConsumer() local
40367 consumer->Initialize(backend.backend->ConnectConsumer(conn_args)); in InitializeConsumer()
40372 for (RegisteredBackend& backend : backends_) { in OnConsumerDisconnected()
40376 backend.consumers.erase(std::remove_if(backend.consumers.begin(), in OnConsumerDisconnected()
40377 backend.consumers.end(), pred), in OnConsumerDisconnected()
40378 backend.consumers.end()); in OnConsumerDisconnected()
40388 for (RegisteredBackend& backend : backends_) { in OnProducerDisconnected()
40389 if (backend.producer.get() != producer) in OnProducerDisconnected()
40400 backend.producer->Initialize( in OnProducerDisconnected()
40401 backend.backend->ConnectProducer(backend.producer_conn_args)); in OnProducerDisconnected()
40478 for (RegisteredBackend& backend : backends_) { in CreateTracingSession()
40479 if (requested_backend_type && backend.type && in CreateTracingSession()
40480 backend.type != requested_backend_type) { in CreateTracingSession()
40484 TracingBackendId backend_id = backend.id; in CreateTracingSession()
40489 backend.consumers.emplace_back( in CreateTracingSession()
40490 new ConsumerImpl(this, backend.type, backend.id, session_id)); in CreateTracingSession()
40494 if (!backend.type) { in CreateTracingSession()
40510 args.backend_type = backend.type; in CreateTracingSession()
41503 std::unique_ptr<TracingSession> Tracing::NewTrace(BackendType backend) { in NewTrace() argument
41505 ->CreateTracingSession(backend); in NewTrace()