0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-29 04:08:54 +02:00

ircd::db: Simplify port entry checks.

This commit is contained in:
Jason Volk 2018-08-28 15:57:49 -07:00
parent 3833aa70cb
commit d70ef25711

View file

@ -4916,7 +4916,7 @@ static_assert
rocksdb::port::Mutex::Mutex() rocksdb::port::Mutex::Mutex()
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current || !is_main_thread())) if(unlikely(!ctx::current))
return; return;
log::debug log::debug
@ -4934,7 +4934,7 @@ rocksdb::port::Mutex::Mutex(bool adaptive)
rocksdb::port::Mutex::~Mutex() rocksdb::port::Mutex::~Mutex()
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current || !is_main_thread())) if(unlikely(!ctx::current))
return; return;
log::debug log::debug
@ -4947,7 +4947,7 @@ rocksdb::port::Mutex::~Mutex()
void void
rocksdb::port::Mutex::Lock() rocksdb::port::Mutex::Lock()
{ {
if(unlikely(!is_main_thread() || !ctx::current)) if(unlikely(!ctx::current))
return; return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
@ -4963,7 +4963,7 @@ rocksdb::port::Mutex::Lock()
void void
rocksdb::port::Mutex::Unlock() rocksdb::port::Mutex::Unlock()
{ {
if(unlikely(!is_main_thread() || !ctx::current)) if(unlikely(!ctx::current))
return; return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
@ -4980,7 +4980,7 @@ rocksdb::port::Mutex::Unlock()
void void
rocksdb::port::Mutex::AssertHeld() rocksdb::port::Mutex::AssertHeld()
{ {
if(unlikely(!is_main_thread() || !ctx::current)) if(unlikely(!ctx::current))
return; return;
assert(mu.locked()); assert(mu.locked());
@ -5000,6 +5000,9 @@ static_assert
rocksdb::port::RWMutex::RWMutex() rocksdb::port::RWMutex::RWMutex()
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current))
return;
log::debug log::debug
{ {
db::log, "shared_mutex %lu %p CTOR", ctx::id(), this db::log, "shared_mutex %lu %p CTOR", ctx::id(), this
@ -5010,6 +5013,9 @@ rocksdb::port::RWMutex::RWMutex()
rocksdb::port::RWMutex::~RWMutex() rocksdb::port::RWMutex::~RWMutex()
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current))
return;
log::debug log::debug
{ {
db::log, "shared_mutex %lu %p DTOR", ctx::id(), this db::log, "shared_mutex %lu %p DTOR", ctx::id(), this
@ -5020,6 +5026,9 @@ rocksdb::port::RWMutex::~RWMutex()
void void
rocksdb::port::RWMutex::ReadLock() rocksdb::port::RWMutex::ReadLock()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5034,6 +5043,9 @@ rocksdb::port::RWMutex::ReadLock()
void void
rocksdb::port::RWMutex::WriteLock() rocksdb::port::RWMutex::WriteLock()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5048,6 +5060,9 @@ rocksdb::port::RWMutex::WriteLock()
void void
rocksdb::port::RWMutex::ReadUnlock() rocksdb::port::RWMutex::ReadUnlock()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5062,6 +5077,9 @@ rocksdb::port::RWMutex::ReadUnlock()
void void
rocksdb::port::RWMutex::WriteUnlock() rocksdb::port::RWMutex::WriteUnlock()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5088,6 +5106,9 @@ rocksdb::port::CondVar::CondVar(Mutex *mu)
:mu{mu} :mu{mu}
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current))
return;
log::debug log::debug
{ {
db::log, "cond %lu %p %p CTOR", ctx::id(), this, mu db::log, "cond %lu %p %p CTOR", ctx::id(), this, mu
@ -5098,6 +5119,9 @@ rocksdb::port::CondVar::CondVar(Mutex *mu)
rocksdb::port::CondVar::~CondVar() rocksdb::port::CondVar::~CondVar()
{ {
#ifdef RB_DEBUG_DB_PORT_ #ifdef RB_DEBUG_DB_PORT_
if(unlikely(!ctx::current))
return;
log::debug log::debug
{ {
db::log, "cond %lu %p %p DTOR", ctx::id(), this, mu db::log, "cond %lu %p %p DTOR", ctx::id(), this, mu
@ -5108,6 +5132,9 @@ rocksdb::port::CondVar::~CondVar()
void void
rocksdb::port::CondVar::Wait() rocksdb::port::CondVar::Wait()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5125,6 +5152,8 @@ rocksdb::port::CondVar::Wait()
bool bool
rocksdb::port::CondVar::TimedWait(uint64_t abs_time_us) rocksdb::port::CondVar::TimedWait(uint64_t abs_time_us)
{ {
assert(ctx::current);
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5143,6 +5172,9 @@ rocksdb::port::CondVar::TimedWait(uint64_t abs_time_us)
void void
rocksdb::port::CondVar::Signal() rocksdb::port::CondVar::Signal()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {
@ -5157,6 +5189,9 @@ rocksdb::port::CondVar::Signal()
void void
rocksdb::port::CondVar::SignalAll() rocksdb::port::CondVar::SignalAll()
{ {
if(unlikely(!ctx::current))
return;
#ifdef RB_DEBUG_DB_PORT #ifdef RB_DEBUG_DB_PORT
log::debug log::debug
{ {