Searched refs:service_endpoint (Results 1 – 4 of 4) sorted by relevance
113 producer->service_endpoint = core_service_->ConnectProducer( in InitializeConnection()121 if (!producer->service_endpoint) { in InitializeConnection()127 producer->service_endpoint->IsShmemProvidedByProducer(); in InitializeConnection()153 GetProducerForCurrentRequest()->service_endpoint->RegisterDataSource(dsd); in RegisterDataSource()186 producer->service_endpoint->UnregisterDataSource(req.data_source_name()); in UnregisterDataSource()207 producer->service_endpoint->RegisterTraceWriter(req.trace_writer_id(), in RegisterTraceWriter()229 producer->service_endpoint->UnregisterTraceWriter(req.trace_writer_id()); in UnregisterTraceWriter()263 producer->service_endpoint->CommitData(req, callback); in CommitData()278 producer->service_endpoint->NotifyDataSourceStarted(request.data_source_id()); in NotifyDataSourceStarted()300 producer->service_endpoint->NotifyDataSourceStopped(request.data_source_id()); in NotifyDataSourceStopped()[all …]
51 remote_consumer->service_endpoint = in GetConsumerForCurrentRequest()77 remote_consumer->service_endpoint->EnableTracing(trace_config, std::move(fd)); in EnableTracing()85 remote_consumer->service_endpoint->StartTracing(); in StartTracing()94 remote_consumer->service_endpoint->ChangeTraceConfig(req.trace_config()); in ChangeTraceConfig()103 GetConsumerForCurrentRequest()->service_endpoint->DisableTracing(); in DisableTracing()112 remote_consumer->service_endpoint->ReadBuffers(); in ReadBuffers()118 GetConsumerForCurrentRequest()->service_endpoint->FreeBuffers(); in FreeBuffers()132 GetConsumerForCurrentRequest()->service_endpoint->Flush(req.timeout_ms(), in Flush()142 remote_consumer->service_endpoint->Detach(req.key()); in Detach()151 remote_consumer->service_endpoint->Attach(req.key()); in Attach()[all …]
104 std::unique_ptr<TracingService::ProducerEndpoint> service_endpoint; variable
101 std::unique_ptr<TracingService::ConsumerEndpoint> service_endpoint; variable