mirror of https://github.com/grpc/grpc.git
Remove `include/grpcpp/impl/codegen/sync.h` (#31545)
* Remove `include/grpcpp/impl/codegen/sync.h` * Fix sanity testspull/31743/head
Cheng-Yu Chung
2 years ago
committed by
GitHub
parent
452d026b7d
commit
e9b287997a
32 changed files with 192 additions and 158 deletions
@ -0,0 +1,156 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2019 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#ifndef GRPCPP_IMPL_SYNC_H |
||||
#define GRPCPP_IMPL_SYNC_H |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#ifdef GPR_HAS_PTHREAD_H |
||||
#include <pthread.h> |
||||
#endif |
||||
|
||||
#include <mutex> |
||||
|
||||
#include "absl/synchronization/mutex.h" |
||||
|
||||
#include <grpc/support/log.h> |
||||
#include <grpc/support/sync.h> |
||||
#include <grpcpp/impl/codegen/core_codegen_interface.h> |
||||
|
||||
// The core library is not accessible in C++ codegen headers, and vice versa.
|
||||
// Thus, we need to have duplicate headers with similar functionality.
|
||||
// Make sure any change to this file is also reflected in
|
||||
// src/core/lib/gprpp/sync.h too.
|
||||
//
|
||||
// Whenever possible, prefer "src/core/lib/gprpp/sync.h" over this file,
|
||||
// since in core we do not rely on g_core_codegen_interface and hence do not
|
||||
// pay the costs of virtual function calls.
|
||||
|
||||
namespace grpc { |
||||
namespace internal { |
||||
|
||||
#ifdef GPR_ABSEIL_SYNC |
||||
|
||||
using Mutex = absl::Mutex; |
||||
using MutexLock = absl::MutexLock; |
||||
using ReleasableMutexLock = absl::ReleasableMutexLock; |
||||
using CondVar = absl::CondVar; |
||||
|
||||
#else |
||||
|
||||
class ABSL_LOCKABLE Mutex { |
||||
public: |
||||
Mutex() { g_core_codegen_interface->gpr_mu_init(&mu_); } |
||||
~Mutex() { g_core_codegen_interface->gpr_mu_destroy(&mu_); } |
||||
|
||||
Mutex(const Mutex&) = delete; |
||||
Mutex& operator=(const Mutex&) = delete; |
||||
|
||||
void Lock() ABSL_EXCLUSIVE_LOCK_FUNCTION() { |
||||
g_core_codegen_interface->gpr_mu_lock(&mu_); |
||||
} |
||||
void Unlock() ABSL_UNLOCK_FUNCTION() { |
||||
g_core_codegen_interface->gpr_mu_unlock(&mu_); |
||||
} |
||||
|
||||
private: |
||||
union { |
||||
gpr_mu mu_; |
||||
std::mutex do_not_use_sth_; |
||||
#ifdef GPR_HAS_PTHREAD_H |
||||
pthread_mutex_t do_not_use_pth_; |
||||
#endif |
||||
}; |
||||
|
||||
friend class CondVar; |
||||
}; |
||||
|
||||
class ABSL_SCOPED_LOCKABLE MutexLock { |
||||
public: |
||||
explicit MutexLock(Mutex* mu) ABSL_EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(mu) { |
||||
mu_->Lock(); |
||||
} |
||||
~MutexLock() ABSL_UNLOCK_FUNCTION() { mu_->Unlock(); } |
||||
|
||||
MutexLock(const MutexLock&) = delete; |
||||
MutexLock& operator=(const MutexLock&) = delete; |
||||
|
||||
private: |
||||
Mutex* const mu_; |
||||
}; |
||||
|
||||
class ABSL_SCOPED_LOCKABLE ReleasableMutexLock { |
||||
public: |
||||
explicit ReleasableMutexLock(Mutex* mu) ABSL_EXCLUSIVE_LOCK_FUNCTION(mu) |
||||
: mu_(mu) { |
||||
mu_->Lock(); |
||||
} |
||||
~ReleasableMutexLock() ABSL_UNLOCK_FUNCTION() { |
||||
if (!released_) mu_->Unlock(); |
||||
} |
||||
|
||||
ReleasableMutexLock(const ReleasableMutexLock&) = delete; |
||||
ReleasableMutexLock& operator=(const ReleasableMutexLock&) = delete; |
||||
|
||||
void Release() ABSL_UNLOCK_FUNCTION() { |
||||
GPR_DEBUG_ASSERT(!released_); |
||||
released_ = true; |
||||
mu_->Unlock(); |
||||
} |
||||
|
||||
private: |
||||
Mutex* const mu_; |
||||
bool released_ = false; |
||||
}; |
||||
|
||||
class CondVar { |
||||
public: |
||||
CondVar() { g_core_codegen_interface->gpr_cv_init(&cv_); } |
||||
~CondVar() { g_core_codegen_interface->gpr_cv_destroy(&cv_); } |
||||
|
||||
CondVar(const CondVar&) = delete; |
||||
CondVar& operator=(const CondVar&) = delete; |
||||
|
||||
void Signal() { g_core_codegen_interface->gpr_cv_signal(&cv_); } |
||||
void SignalAll() { g_core_codegen_interface->gpr_cv_broadcast(&cv_); } |
||||
|
||||
void Wait(Mutex* mu) { |
||||
g_core_codegen_interface->gpr_cv_wait( |
||||
&cv_, &mu->mu_, |
||||
g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME)); |
||||
} |
||||
|
||||
private: |
||||
gpr_cv cv_; |
||||
}; |
||||
|
||||
#endif // GPR_ABSEIL_SYNC
|
||||
|
||||
template <typename Predicate> |
||||
GRPC_DEPRECATED("incompatible with thread safety analysis") |
||||
static void WaitUntil(CondVar* cv, Mutex* mu, Predicate pred) { |
||||
while (!pred()) { |
||||
cv->Wait(mu); |
||||
} |
||||
} |
||||
|
||||
} // namespace internal
|
||||
} // namespace grpc
|
||||
|
||||
#endif // GRPCPP_IMPL_SYNC_H
|
||||
Loading…
Reference in new issue