Searched refs:flush_request_id (Results 1 – 7 of 7) sorted by relevance
| /external/perfetto/src/traced/probes/ |
| D | probes_producer.cc | 366 void ProbesProducer::Flush(FlushRequestID flush_request_id, in Flush() argument
369 PERFETTO_DCHECK(flush_request_id); in Flush()
379 pending_flushes_.emplace(flush_request_id, ds_id); in Flush()
381 auto flush_callback = [weak_this, flush_request_id, ds_id] { in Flush()
383 weak_this->OnDataSourceFlushComplete(flush_request_id, ds_id); in Flush()
385 it->second->Flush(flush_request_id, flush_callback); in Flush()
390 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
396 [weak_this, flush_request_id] { in Flush()
398 weak_this->OnFlushTimeout(flush_request_id); in Flush()
403 void ProbesProducer::OnDataSourceFlushComplete(FlushRequestID flush_request_id, in OnDataSourceFlushComplete() argument
[all …]
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_data_source.cc | 72 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/ |
| D | fake_producer.cc | 154 void FakeProducer::Flush(FlushRequestID flush_request_id, in Flush() argument
160 endpoint_->NotifyFlushComplete(flush_request_id); in Flush()
|
| /external/perfetto/src/tracing/core/ |
| D | tracing_service_impl.cc | 147 uint32_t has_flush_id = req_untrusted.flush_request_id() != 0; in EncodeCommitDataRequest()
1329 FlushRequestID flush_request_id = ++last_flush_request_id_; in Flush() local
1333 flush_request_id, PendingFlush(std::move(callback))) in Flush()
1350 producer->Flush(flush_request_id, data_sources); in Flush()
1361 [weak_this, tsid, flush_request_id] { in Flush()
1363 weak_this->OnFlushTimeout(tsid, flush_request_id); in Flush()
1370 FlushRequestID flush_request_id) { in NotifyFlushDoneForProducer() argument
1374 auto end_it = pending_flushes.upper_bound(flush_request_id); in NotifyFlushDoneForProducer()
1397 FlushRequestID flush_request_id) { in OnFlushTimeout() argument
1401 auto it = tracing_session->pending_flushes.find(flush_request_id); in OnFlushTimeout()
[all …]
|
| D | shared_memory_arbiter_impl.cc | 588 req_id = std::max(req_id, commit_data_req_->flush_request_id()); in NotifyFlushComplete()
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | producer_ipc_service.cc | 471 FlushRequestID flush_request_id, in Flush() argument
484 cmd->mutable_flush()->set_request_id(flush_request_id); in Flush()
|
| /external/perfetto/protos/perfetto/common/ |
| D | commit_data_request.proto | 76 optional uint64 flush_request_id = 3; field
|