blob: e358c2bec3eff5ca05d31cb9b841c8a87a2b31f2 [file] [log] [blame]
#ifndef QUICHE_COMMON_PLATFORM_DEFAULT_QUICHE_PLATFORM_IMPL_QUICHE_MUTEX_IMPL_H_
#define QUICHE_COMMON_PLATFORM_DEFAULT_QUICHE_PLATFORM_IMPL_QUICHE_MUTEX_IMPL_H_
#include "absl/synchronization/mutex.h"
#include "absl/synchronization/notification.h"
#include "quiche/common/platform/api/quiche_export.h"
#define QUICHE_EXCLUSIVE_LOCKS_REQUIRED_IMPL ABSL_EXCLUSIVE_LOCKS_REQUIRED
#define QUICHE_GUARDED_BY_IMPL ABSL_GUARDED_BY
#define QUICHE_LOCKABLE_IMPL ABSL_LOCKABLE
#define QUICHE_LOCKS_EXCLUDED_IMPL ABSL_LOCKS_EXCLUDED
#define QUICHE_SHARED_LOCKS_REQUIRED_IMPL ABSL_SHARED_LOCKS_REQUIRED
#define QUICHE_EXCLUSIVE_LOCK_FUNCTION_IMPL ABSL_EXCLUSIVE_LOCK_FUNCTION
#define QUICHE_UNLOCK_FUNCTION_IMPL ABSL_UNLOCK_FUNCTION
#define QUICHE_SHARED_LOCK_FUNCTION_IMPL ABSL_SHARED_LOCK_FUNCTION
#define QUICHE_SCOPED_LOCKABLE_IMPL ABSL_SCOPED_LOCKABLE
#define QUICHE_ASSERT_SHARED_LOCK_IMPL ABSL_ASSERT_SHARED_LOCK
namespace quiche {
// A class wrapping a non-reentrant mutex.
class ABSL_LOCKABLE QUICHE_EXPORT_PRIVATE QuicheLockImpl {
public:
QuicheLockImpl() = default;
QuicheLockImpl(const QuicheLockImpl&) = delete;
QuicheLockImpl& operator=(const QuicheLockImpl&) = delete;
// Block until mu_ is free, then acquire it exclusively.
void WriterLock() ABSL_EXCLUSIVE_LOCK_FUNCTION();
// Release mu_. Caller must hold it exclusively.
void WriterUnlock() ABSL_UNLOCK_FUNCTION();
// Block until mu_ is free or shared, then acquire a share of it.
void ReaderLock() ABSL_SHARED_LOCK_FUNCTION();
// Release mu_. Caller could hold it in shared mode.
void ReaderUnlock() ABSL_UNLOCK_FUNCTION();
// Returns immediately if current thread holds mu_ in at least shared
// mode. Otherwise, reports an error by crashing with a diagnostic.
void AssertReaderHeld() const ABSL_ASSERT_SHARED_LOCK();
private:
absl::Mutex mu_;
};
// A Notification allows threads to receive notification of a single occurrence
// of a single event.
class QUICHE_EXPORT_PRIVATE QuicheNotificationImpl {
public:
QuicheNotificationImpl() = default;
QuicheNotificationImpl(const QuicheNotificationImpl&) = delete;
QuicheNotificationImpl& operator=(const QuicheNotificationImpl&) = delete;
bool HasBeenNotified() { return notification_.HasBeenNotified(); }
void Notify() { notification_.Notify(); }
void WaitForNotification() { notification_.WaitForNotification(); }
private:
absl::Notification notification_;
};
} // namespace quiche
#endif // QUICHE_COMMON_PLATFORM_DEFAULT_QUICHE_PLATFORM_IMPL_QUICHE_MUTEX_IMPL_H_