101 lines
2.4 KiB
C++
101 lines
2.4 KiB
C++
// Matrix Construct
|
|
//
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2019 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
|
|
#pragma once
|
|
#define HAVE_IRCD_DB_PORT_H
|
|
|
|
// !!! EXPERIMENTAL !!!
|
|
//
|
|
// This file is special; even within the context of embedding RocksDB through
|
|
// its env interface. The functionality provided here is NOT done via
|
|
// overriding virtual interfaces called by RocksDB like with the rest of env.
|
|
// This functionality is deemed too critical for runtime virtual interfaces.
|
|
//
|
|
// Instead, the definitions we provide override those that RocksDB uses at
|
|
// link-time during the compilation of libircd. Interface declarations are not
|
|
// provided by RocksDB in its include path either, thus our interface here must
|
|
// match the rocksdb::port interface.
|
|
//
|
|
// Unfortunately if the rocksdb::port interface partially changes and we leave
|
|
// unresolved symbols at link time that may be bad, and go silently unnoticed.
|
|
//
|
|
// !!! EXPERIMENTAL !!!
|
|
|
|
namespace rocksdb::port
|
|
{
|
|
using namespace ircd;
|
|
|
|
struct Mutex;
|
|
struct CondVar;
|
|
struct RWMutex;
|
|
}
|
|
|
|
class rocksdb::port::Mutex
|
|
{
|
|
friend class CondVar;
|
|
|
|
union
|
|
{
|
|
ctx::mutex mu;
|
|
pthread_mutex_t mu_;
|
|
};
|
|
|
|
public:
|
|
void Lock() noexcept;
|
|
void Unlock() noexcept;
|
|
void AssertHeld() noexcept;
|
|
|
|
Mutex() noexcept;
|
|
Mutex(bool adaptive) noexcept;
|
|
Mutex(const Mutex &) = delete;
|
|
Mutex &operator=(const Mutex &) = delete;
|
|
~Mutex() noexcept;
|
|
};
|
|
|
|
class rocksdb::port::CondVar
|
|
{
|
|
union
|
|
{
|
|
ctx::condition_variable cv;
|
|
pthread_cond_t cv_;
|
|
};
|
|
|
|
Mutex *mu;
|
|
|
|
public:
|
|
void Wait() noexcept;
|
|
bool TimedWait(uint64_t abs_time_us) noexcept; // Returns true if timeout occurred
|
|
void Signal() noexcept;
|
|
void SignalAll() noexcept;
|
|
|
|
CondVar(Mutex *mu) noexcept;
|
|
~CondVar() noexcept;
|
|
};
|
|
|
|
class rocksdb::port::RWMutex
|
|
{
|
|
union
|
|
{
|
|
ctx::shared_mutex mu;
|
|
pthread_rwlock_t mu_;
|
|
};
|
|
|
|
public:
|
|
void ReadLock() noexcept;
|
|
void WriteLock() noexcept;
|
|
void ReadUnlock() noexcept;
|
|
void WriteUnlock() noexcept;
|
|
|
|
RWMutex() noexcept;
|
|
RWMutex(const RWMutex &) = delete;
|
|
RWMutex &operator=(const RWMutex &) = delete;
|
|
~RWMutex() noexcept;
|
|
};
|