xref: /aosp_15_r20/external/perfetto/src/base/waitable_event.cc (revision 6dbdd20afdafa5e3ca9b8809fa73465d530080dc)
1*6dbdd20aSAndroid Build Coastguard Worker /*
2*6dbdd20aSAndroid Build Coastguard Worker  * Copyright (C) 2019 The Android Open Source Project
3*6dbdd20aSAndroid Build Coastguard Worker  *
4*6dbdd20aSAndroid Build Coastguard Worker  * Licensed under the Apache License, Version 2.0 (the "License");
5*6dbdd20aSAndroid Build Coastguard Worker  * you may not use this file except in compliance with the License.
6*6dbdd20aSAndroid Build Coastguard Worker  * You may obtain a copy of the License at
7*6dbdd20aSAndroid Build Coastguard Worker  *
8*6dbdd20aSAndroid Build Coastguard Worker  *      http://www.apache.org/licenses/LICENSE-2.0
9*6dbdd20aSAndroid Build Coastguard Worker  *
10*6dbdd20aSAndroid Build Coastguard Worker  * Unless required by applicable law or agreed to in writing, software
11*6dbdd20aSAndroid Build Coastguard Worker  * distributed under the License is distributed on an "AS IS" BASIS,
12*6dbdd20aSAndroid Build Coastguard Worker  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13*6dbdd20aSAndroid Build Coastguard Worker  * See the License for the specific language governing permissions and
14*6dbdd20aSAndroid Build Coastguard Worker  * limitations under the License.
15*6dbdd20aSAndroid Build Coastguard Worker  */
16*6dbdd20aSAndroid Build Coastguard Worker 
17*6dbdd20aSAndroid Build Coastguard Worker #include "perfetto/ext/base/waitable_event.h"
18*6dbdd20aSAndroid Build Coastguard Worker 
19*6dbdd20aSAndroid Build Coastguard Worker namespace perfetto {
20*6dbdd20aSAndroid Build Coastguard Worker namespace base {
21*6dbdd20aSAndroid Build Coastguard Worker 
22*6dbdd20aSAndroid Build Coastguard Worker WaitableEvent::WaitableEvent() = default;
23*6dbdd20aSAndroid Build Coastguard Worker WaitableEvent::~WaitableEvent() = default;
24*6dbdd20aSAndroid Build Coastguard Worker 
Wait(uint64_t notifications)25*6dbdd20aSAndroid Build Coastguard Worker void WaitableEvent::Wait(uint64_t notifications)
26*6dbdd20aSAndroid Build Coastguard Worker     PERFETTO_NO_THREAD_SAFETY_ANALYSIS {
27*6dbdd20aSAndroid Build Coastguard Worker   // 'std::unique_lock' lock doesn't work well with thread annotations
28*6dbdd20aSAndroid Build Coastguard Worker   // (see https://github.com/llvm/llvm-project/issues/63239),
29*6dbdd20aSAndroid Build Coastguard Worker   // so we suppress thread safety static analysis for this method.
30*6dbdd20aSAndroid Build Coastguard Worker   std::unique_lock<std::mutex> lock(mutex_);
31*6dbdd20aSAndroid Build Coastguard Worker   return event_.wait(lock, [&]() PERFETTO_EXCLUSIVE_LOCKS_REQUIRED(mutex_) {
32*6dbdd20aSAndroid Build Coastguard Worker     return notifications_ >= notifications;
33*6dbdd20aSAndroid Build Coastguard Worker   });
34*6dbdd20aSAndroid Build Coastguard Worker }
35*6dbdd20aSAndroid Build Coastguard Worker 
Notify()36*6dbdd20aSAndroid Build Coastguard Worker void WaitableEvent::Notify() {
37*6dbdd20aSAndroid Build Coastguard Worker   std::lock_guard<std::mutex> lock(mutex_);
38*6dbdd20aSAndroid Build Coastguard Worker   ++notifications_;
39*6dbdd20aSAndroid Build Coastguard Worker   event_.notify_all();
40*6dbdd20aSAndroid Build Coastguard Worker }
41*6dbdd20aSAndroid Build Coastguard Worker 
42*6dbdd20aSAndroid Build Coastguard Worker }  // namespace base
43*6dbdd20aSAndroid Build Coastguard Worker }  // namespace perfetto
44