Home
last modified time | relevance | path

Searched refs:flush_request_id (Results 1 – 10 of 10) sorted by relevance

/external/perfetto/src/traced/probes/
Dprobes_producer.cc336 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/
Dftrace_data_source.cc68 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()
Dftrace_controller.cc362 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/
Dcommit_data_request.cc65 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()
Dtracing_service_impl.cc1061 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 …]
Dshared_memory_arbiter_impl.cc371 req_id = std::max(req_id, commit_data_req_->flush_request_id()); in NotifyFlushComplete()
/external/perfetto/test/
Dfake_producer.cc136 void FakeProducer::Flush(FlushRequestID flush_request_id, in Flush() argument
142 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
/external/perfetto/src/tracing/ipc/service/
Dproducer_ipc_service.cc397 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/
Dcommit_data_request.h218 uint64_t flush_request_id() const { return flush_request_id_; } in flush_request_id() function
/external/perfetto/protos/perfetto/common/
Dcommit_data_request.proto77 optional uint64 flush_request_id = 3; field