Lines Matching refs:mutex_

220   mutex_.Lock();  in WriteImpl()
243 mutex_.Unlock(); in WriteImpl()
424 mutex_.Lock(); in WriteImpl()
426 mutex_.Unlock(); in WriteImpl()
477 mutex_.Lock(); in PipelinedWriteImpl()
485 mutex_.Unlock(); in PipelinedWriteImpl()
548 mutex_.Lock(); in PipelinedWriteImpl()
550 mutex_.Unlock(); in PipelinedWriteImpl()
688 InstrumentedMutexLock l(&mutex_); in WriteImplWALOnly()
837 mutex_.Lock(); in WriteStatusCheck()
839 mutex_.Unlock(); in WriteStatusCheck()
848 mutex_.Lock(); in IOStatusCheck()
850 mutex_.Unlock(); in IOStatusCheck()
861 mutex_.Lock(); in MemTableInsertStatusCheck()
864 mutex_.Unlock(); in MemTableInsertStatusCheck()
871 mutex_.AssertHeld(); in PreprocessWrite()
1144 mutex_.AssertHeld(); in WriteRecoverableState()
1179 mutex_.Unlock(); in WriteRecoverableState()
1182 mutex_.Lock(); in WriteRecoverableState()
1217 mutex_.AssertHeld(); in SwitchWAL()
1281 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in SwitchWAL()
1312 mutex_.AssertHeld(); in HandleWriteBufferFull()
1358 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in HandleWriteBufferFull()
1391 mutex_.AssertHeld(); in GetMaxTotalWalSize()
1416 mutex_.Unlock(); in DelayWrite()
1431 mutex_.Lock(); in DelayWrite()
1555 cfd->InstallSuperVersion(&context->superversion_context, &mutex_); in TrimMemtableHistory()
1583 nonmem_write_thread_.EnterUnbatched(&nonmem_w, &mutex_); in ScheduleFlushes()
1635 mutex_.AssertHeld(); in SwitchMemtable()
1681 mutex_.Unlock(); in SwitchMemtable()
1697 mutex_.Lock(); in SwitchMemtable()
1774 mutex_.Unlock(); in SwitchMemtable()
1778 mutex_.Lock(); in SwitchMemtable()
1784 mutex_.AssertHeld(); in GetWalPreallocateBlockSize()