Searched refs:service_endpoint (Results 1 – 4 of 4) sorted by relevance
82 producer->service_endpoint = core_service_->ConnectProducer( in InitializeConnection()88 if (!producer->service_endpoint) in InitializeConnection()114 GetProducerForCurrentRequest()->service_endpoint->RegisterDataSource(dsd); in RegisterDataSource()147 producer->service_endpoint->UnregisterDataSource(req.data_source_name()); in UnregisterDataSource()168 producer->service_endpoint->RegisterTraceWriter(req.trace_writer_id(), in RegisterTraceWriter()190 producer->service_endpoint->UnregisterTraceWriter(req.trace_writer_id()); in UnregisterTraceWriter()226 producer->service_endpoint->CommitData(req, callback); in CommitData()241 producer->service_endpoint->NotifyDataSourceStarted(request.data_source_id()); in NotifyDataSourceStarted()263 producer->service_endpoint->NotifyDataSourceStopped(request.data_source_id()); in NotifyDataSourceStopped()288 producer->service_endpoint->ActivateTriggers(triggers); in ActivateTriggers()[all …]
49 remote_consumer->service_endpoint = in GetConsumerForCurrentRequest()75 remote_consumer->service_endpoint->EnableTracing(trace_config, std::move(fd)); in EnableTracing()83 remote_consumer->service_endpoint->StartTracing(); in StartTracing()94 remote_consumer->service_endpoint->ChangeTraceConfig(trace_config); in ChangeTraceConfig()101 GetConsumerForCurrentRequest()->service_endpoint->DisableTracing(); in DisableTracing()110 remote_consumer->service_endpoint->ReadBuffers(); in ReadBuffers()116 GetConsumerForCurrentRequest()->service_endpoint->FreeBuffers(); in FreeBuffers()130 GetConsumerForCurrentRequest()->service_endpoint->Flush(req.timeout_ms(), in Flush()140 remote_consumer->service_endpoint->Detach(req.key()); in Detach()149 remote_consumer->service_endpoint->Attach(req.key()); in Attach()[all …]
101 std::unique_ptr<TracingService::ProducerEndpoint> service_endpoint; variable
93 std::unique_ptr<TracingService::ConsumerEndpoint> service_endpoint; variable