/src/abseil-cpp/absl/synchronization/internal/waiter_base.cc
Line  | Count  | Source  | 
1  |  | // Copyright 2023 The Abseil Authors.  | 
2  |  | //  | 
3  |  | // Licensed under the Apache License, Version 2.0 (the "License");  | 
4  |  | // you may not use this file except in compliance with the License.  | 
5  |  | // You may obtain a copy of the License at  | 
6  |  | //  | 
7  |  | //      https://www.apache.org/licenses/LICENSE-2.0  | 
8  |  | //  | 
9  |  | // Unless required by applicable law or agreed to in writing, software  | 
10  |  | // distributed under the License is distributed on an "AS IS" BASIS,  | 
11  |  | // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  | 
12  |  | // See the License for the specific language governing permissions and  | 
13  |  | // limitations under the License.  | 
14  |  |  | 
15  |  | #include "absl/synchronization/internal/waiter_base.h"  | 
16  |  |  | 
17  |  | #include "absl/base/config.h"  | 
18  |  | #include "absl/base/internal/thread_identity.h"  | 
19  |  |  | 
20  |  | namespace absl { | 
21  |  | ABSL_NAMESPACE_BEGIN  | 
22  |  | namespace synchronization_internal { | 
23  |  |  | 
24  | 0  | void WaiterBase::MaybeBecomeIdle() { | 
25  | 0  |   base_internal::ThreadIdentity *identity =  | 
26  | 0  |       base_internal::CurrentThreadIdentityIfPresent();  | 
27  | 0  |   assert(identity != nullptr);  | 
28  | 0  |   const bool is_idle = identity->is_idle.load(std::memory_order_relaxed);  | 
29  | 0  |   const int ticker = identity->ticker.load(std::memory_order_relaxed);  | 
30  | 0  |   const int wait_start = identity->wait_start.load(std::memory_order_relaxed);  | 
31  | 0  |   if (!is_idle && ticker - wait_start > kIdlePeriods) { | 
32  | 0  |     identity->is_idle.store(true, std::memory_order_relaxed);  | 
33  | 0  |   }  | 
34  | 0  | }  | 
35  |  |  | 
36  |  | }  // namespace synchronization_internal  | 
37  |  | ABSL_NAMESPACE_END  | 
38  |  | }  // namespace absl  |