Searched refs:flush_request_id (Results 1 – 10 of 10) sorted by relevance
/external/perfetto/src/traced/probes/ |
D | probes_producer.cc | 336 void ProbesProducer::Flush(FlushRequestID flush_request_id, in Flush() argument 339 PERFETTO_DCHECK(flush_request_id); in Flush() 349 pending_flushes_.emplace(flush_request_id, ds_id); in Flush() 351 auto flush_callback = [weak_this, flush_request_id, ds_id] { in Flush() 353 weak_this->OnDataSourceFlushComplete(flush_request_id, ds_id); in Flush() 355 it->second->Flush(flush_request_id, flush_callback); in Flush() 360 endpoint_->NotifyFlushComplete(flush_request_id); in Flush() 366 [weak_this, flush_request_id] { in Flush() 368 weak_this->OnFlushTimeout(flush_request_id); in Flush() 373 void ProbesProducer::OnDataSourceFlushComplete(FlushRequestID flush_request_id, in OnDataSourceFlushComplete() argument [all …]
|
/external/perfetto/src/traced/probes/ftrace/ |
D | ftrace_data_source.cc | 68 void FtraceDataSource::Flush(FlushRequestID flush_request_id, in Flush() argument 73 pending_flushes_[flush_request_id] = std::move(callback); in Flush() 78 controller_weak_->Flush(flush_request_id); in Flush() 82 void FtraceDataSource::OnFtraceFlushComplete(FlushRequestID flush_request_id) { in OnFtraceFlushComplete() argument 83 auto it = pending_flushes_.find(flush_request_id); in OnFtraceFlushComplete()
|
D | ftrace_controller.cc | 362 void FtraceController::OnFlushTimeout(FlushRequestID flush_request_id) { in OnFlushTimeout() argument 363 if (flush_request_id != cur_flush_request_id_) in OnFlushTimeout() 377 flush_request_id, acks.c_str()); in OnFlushTimeout() 379 NotifyFlushCompleteToStartedDataSources(flush_request_id); in OnFlushTimeout() 473 FlushRequestID flush_request_id) { in NotifyFlushCompleteToStartedDataSources() argument 476 data_source->OnFtraceFlushComplete(flush_request_id); in NotifyFlushCompleteToStartedDataSources()
|
/external/perfetto/src/tracing/core/ |
D | commit_data_request.cc | 65 static_assert(sizeof(flush_request_id_) == sizeof(proto.flush_request_id()), in FromProto() 68 static_cast<decltype(flush_request_id_)>(proto.flush_request_id()); in FromProto() 86 static_assert(sizeof(flush_request_id_) == sizeof(proto->flush_request_id()), in ToProto() 89 static_cast<decltype(proto->flush_request_id())>(flush_request_id_)); in ToProto()
|
D | tracing_service_impl.cc | 1061 FlushRequestID flush_request_id = ++last_flush_request_id_; in Flush() local 1065 flush_request_id, PendingFlush(std::move(callback))) in Flush() 1082 producer->Flush(flush_request_id, data_sources); in Flush() 1093 [weak_this, tsid, flush_request_id] { in Flush() 1095 weak_this->OnFlushTimeout(tsid, flush_request_id); in Flush() 1102 FlushRequestID flush_request_id) { in NotifyFlushDoneForProducer() argument 1106 auto end_it = pending_flushes.upper_bound(flush_request_id); in NotifyFlushDoneForProducer() 1129 FlushRequestID flush_request_id) { in OnFlushTimeout() argument 1133 auto it = tracing_session->pending_flushes.find(flush_request_id); in OnFlushTimeout() 2594 if (req_untrusted.flush_request_id()) { in CommitData() [all …]
|
D | shared_memory_arbiter_impl.cc | 371 req_id = std::max(req_id, commit_data_req_->flush_request_id()); in NotifyFlushComplete()
|
/external/perfetto/test/ |
D | fake_producer.cc | 136 void FakeProducer::Flush(FlushRequestID flush_request_id, in Flush() argument 142 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
|
/external/perfetto/src/tracing/ipc/service/ |
D | producer_ipc_service.cc | 397 FlushRequestID flush_request_id, in Flush() argument 410 cmd->mutable_flush()->set_request_id(flush_request_id); in Flush()
|
/external/perfetto/include/perfetto/tracing/core/ |
D | commit_data_request.h | 218 uint64_t flush_request_id() const { return flush_request_id_; } in flush_request_id() function
|
/external/perfetto/protos/perfetto/common/ |
D | commit_data_request.proto | 77 optional uint64 flush_request_id = 3; field
|