Home
last modified time | relevance | path

Searched refs:thread_sync_ (Results 1 – 6 of 6) sorted by relevance

/external/perfetto/src/traced/probes/ftrace/
Dftrace_controller.cc138 thread_sync_(task_runner), in FtraceController()
143 thread_sync_.trace_controller_weak = GetWeakPtr(); in FtraceController()
232 std::lock_guard<std::mutex> lock(thread_sync_.mutex); in DrainCPUs()
233 std::swap(cpus_to_drain, thread_sync_.cpus_to_drain); in DrainCPUs()
237 if (cur_flush_request_id_ && thread_sync_.flush_acks.count() >= num_cpus) { in DrainCPUs()
238 thread_sync_.flush_acks.reset(); in DrainCPUs()
284 std::unique_lock<std::mutex> lock(thread_sync_.mutex); in UnblockReaders()
285 if (thread_sync_.cmd != FtraceThreadSync::kRun) in UnblockReaders()
301 std::lock_guard<std::mutex> lock(thread_sync_.mutex); in StartIfNeeded()
302 thread_sync_.cpus_to_drain.reset(); in StartIfNeeded()
[all …]
Dcpu_reader.cc157 thread_sync_(thread_sync), in CpuReader()
182 *trace_fd_, &pool_, thread_sync_, in CpuReader()
191 std::lock_guard<std::mutex> lock(thread_sync_->mutex); in ~CpuReader()
192 PERFETTO_DCHECK(thread_sync_->cmd == FtraceThreadSync::kQuit); in ~CpuReader()
Dftrace_controller.h122 FtraceThreadSync thread_sync_; variable
Dftrace_controller_unittest.cc229 auto* thread_sync = &thread_sync_; in GetDataAvailableCallback()
238 std::unique_lock<std::mutex> lock(thread_sync_.mutex); in WaitForData()
239 if (thread_sync_.cpus_to_drain[cpu]) in WaitForData()
Dcpu_reader.h194 FtraceThreadSync* const thread_sync_; variable
/external/libchrome/base/message_loop/
Dmessage_loop_task_runner_unittest.cc28 thread_sync_(WaitableEvent::ResetPolicy::MANUAL, in MessageLoopTaskRunnerTest()
49 thread_sync_.Signal(); in TearDown()
88 void UnblockTaskThread() { thread_sync_.Signal(); } in UnblockTaskThread()
90 void BlockTaskThreadHelper() { thread_sync_.Wait(); } in BlockTaskThreadHelper()
98 base::WaitableEvent thread_sync_; member in base::MessageLoopTaskRunnerTest