Home
last modified time | relevance | path

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

/external/perfetto/src/traced/probes/
Dprobes_producer.cc377 void ProbesProducer::Flush(FlushRequestID flush_request_id, in Flush() argument
380 PERFETTO_DCHECK(flush_request_id); in Flush()
390 pending_flushes_.emplace(flush_request_id, ds_id); in Flush()
392 auto flush_callback = [weak_this, flush_request_id, ds_id] { in Flush()
394 weak_this->OnDataSourceFlushComplete(flush_request_id, ds_id); in Flush()
396 it->second->Flush(flush_request_id, flush_callback); in Flush()
401 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
407 [weak_this, flush_request_id] { in Flush()
409 weak_this->OnFlushTimeout(flush_request_id); in Flush()
414 void ProbesProducer::OnDataSourceFlushComplete(FlushRequestID flush_request_id, in OnDataSourceFlushComplete() argument
[all …]
/external/perfetto/src/traced/probes/ftrace/
Dftrace_data_source.cc72 void FtraceDataSource::Flush(FlushRequestID flush_request_id, in Flush() argument
77 pending_flushes_[flush_request_id] = std::move(callback); in Flush()
82 controller_weak_->Flush(flush_request_id); in Flush()
86 void FtraceDataSource::OnFtraceFlushComplete(FlushRequestID flush_request_id) { in OnFtraceFlushComplete() argument
87 auto it = pending_flushes_.find(flush_request_id); in OnFtraceFlushComplete()
/external/perfetto/test/
Dfake_producer.cc156 void FakeProducer::Flush(FlushRequestID flush_request_id, in Flush() argument
162 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
/external/perfetto/src/tracing/core/
Dtracing_service_impl.cc165 uint32_t has_flush_id = req_untrusted.flush_request_id() != 0; in EncodeCommitDataRequest()
1592 FlushRequestID flush_request_id = ++last_flush_request_id_; in Flush() local
1596 flush_request_id, PendingFlush(std::move(callback))) in Flush()
1613 producer->Flush(flush_request_id, data_sources); in Flush()
1624 [weak_this, tsid, flush_request_id] { in Flush()
1626 weak_this->OnFlushTimeout(tsid, flush_request_id); in Flush()
1633 FlushRequestID flush_request_id) { in NotifyFlushDoneForProducer() argument
1637 auto end_it = pending_flushes.upper_bound(flush_request_id); in NotifyFlushDoneForProducer()
1660 FlushRequestID flush_request_id) { in OnFlushTimeout() argument
1664 auto it = tracing_session->pending_flushes.find(flush_request_id); in OnFlushTimeout()
[all …]
Dshared_memory_arbiter_impl.cc770 req_id = std::max(req_id, commit_data_req_->flush_request_id()); in NotifyFlushComplete()
/external/perfetto/src/tracing/ipc/service/
Dproducer_ipc_service.cc468 FlushRequestID flush_request_id, in Flush() argument
481 cmd->mutable_flush()->set_request_id(flush_request_id); in Flush()
/external/perfetto/protos/perfetto/common/
Dcommit_data_request.proto76 optional uint64 flush_request_id = 3; field