Lines Matching refs:db_impl
226 auto db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
227 db_impl->TEST_FlushMemTable(true); in TEST_P()
237 db_impl->TEST_FlushMemTable(true); in TEST_P()
885 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
887 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
893 ASSERT_GT(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
900 db_impl->TEST_FlushMemTable(true); in TEST_P()
907 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
910 ASSERT_EQ(db_impl->TEST_PreparedSectionCompletedSize(), 0); in TEST_P()
911 ASSERT_EQ(db_impl->TEST_LogsWithPrepSize(), 0); in TEST_P()
926 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
953 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
971 db_impl->TEST_FindMinLogContainingOutstandingPrep(); in TEST_P()
1003 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
1008 ASSERT_GE(log_containing_prep, db_impl->MinLogNumberToKeep()); in TEST_P()
1010 db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1015 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1021 db_impl->TEST_FlushMemTable(true); in TEST_P()
1034 ASSERT_GT(db_impl->MinLogNumberToKeep(), log_containing_prep); in TEST_P()
1035 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1163 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
1164 db_impl->TEST_FlushMemTable(true); in TEST_P()
1225 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
1263 db_impl->TEST_FlushMemTable(true); in TEST_P()
1296 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
1319 db_impl->TEST_FlushMemTable(true); in TEST_P()
1326 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
1343 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
1357 db_impl->TEST_FindMinLogContainingOutstandingPrep(); in TEST_P()
1386 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
1392 db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1393 ASSERT_GE(log_containing_prep, db_impl->MinLogNumberToKeep()); in TEST_P()
1399 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1410 db_impl->TEST_FlushMemTable(true); in TEST_P()
1413 ASSERT_GT(db_impl->MinLogNumberToKeep(), log_containing_prep); in TEST_P()
1414 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1688 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
1730 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
1732 ASSERT_EQ(db_impl->TEST_LogfileNumber(), txn1->GetLastLogNumber()); in TEST_P()
1737 s = db_impl->TEST_FlushMemTable(true); in TEST_P()
1741 ASSERT_GT(db_impl->TEST_LogfileNumber(), txn1->GetLastLogNumber()); in TEST_P()
1746 ASSERT_EQ(db_impl->TEST_LogfileNumber(), txn2->GetLastLogNumber()); in TEST_P()
1749 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
1757 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
1764 db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1769 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1778 s = db_impl->TEST_FlushMemTable(true); in TEST_P()
1782 ASSERT_GT(db_impl->TEST_LogfileNumber(), txn2->GetLastLogNumber()); in TEST_P()
1789 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
1795 db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1800 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1807 s = db_impl->TEST_FlushMemTable(true, false, cfa); in TEST_P()
1814 db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1819 ASSERT_EQ(0, db_impl->TEST_FindMinPrepLogReferencedByMemTable()); in TEST_P()
1826 s = db_impl->TEST_FlushMemTable(true, false, cfb); in TEST_P()
1830 ASSERT_EQ(db_impl->TEST_FindMinPrepLogReferencedByMemTable(), 0); in TEST_P()
1831 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
1840 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
1886 s = db_impl->TEST_FlushMemTable(true); in TEST_P()
1891 s = db_impl->PauseBackgroundWork(); in TEST_P()
1894 ASSERT_GT(db_impl->TEST_LogfileNumber(), prepare_log_no); in TEST_P()
1899 ASSERT_EQ(cfh_a->cfd()->GetLogNumber(), db_impl->TEST_LogfileNumber()); in TEST_P()
1909 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
1911 ASSERT_EQ(db_impl->TEST_FindMinPrepLogReferencedByMemTable(), 0); in TEST_P()
1919 ASSERT_EQ(db_impl->TEST_FindMinPrepLogReferencedByMemTable(), in TEST_P()
1925 ASSERT_EQ(db_impl->TEST_FindMinPrepLogReferencedByMemTable(), 0); in TEST_P()
1931 ASSERT_TRUE(!db_impl->TEST_UnableToReleaseOldestLog()); in TEST_P()
1935 db_impl->TEST_SwitchWAL(); in TEST_P()
1937 ASSERT_TRUE(!db_impl->TEST_IsLogGettingFlushed()); in TEST_P()
1938 ASSERT_TRUE(db_impl->TEST_UnableToReleaseOldestLog()); in TEST_P()
1961 db_impl->TEST_SwitchWAL(); in TEST_P()
1962 ASSERT_TRUE(!db_impl->TEST_UnableToReleaseOldestLog()); in TEST_P()
1969 ASSERT_TRUE(db_impl->TEST_IsLogGettingFlushed()); in TEST_P()
1985 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
2016 s = db_impl->TEST_FlushMemTable(true); in TEST_P()
2304 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
2343 s = db_impl->TEST_FlushMemTable(true); in TEST_P()
2351 ASSERT_OK(db_impl->TEST_FlushMemTable(true)); in TEST_P()
2359 ASSERT_OK(db_impl->TEST_FlushMemTable(true)); in TEST_P()
2407 db_impl->TEST_WaitForCompact(); in TEST_P()
5444 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
5446 auto seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
5449 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5453 ASSERT_OK(db_impl->Flush(fopt)); in TEST_P()
5454 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5458 ASSERT_OK(db_impl->FlushWAL(true)); in TEST_P()
5460 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
5461 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
5467 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5471 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5475 ASSERT_OK(db_impl->Flush(fopt)); in TEST_P()
5476 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5480 ASSERT_OK(db_impl->FlushWAL(true)); in TEST_P()
5482 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
5483 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
5488 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5492 ASSERT_OK(db_impl->Flush(fopt)); in TEST_P()
5493 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5497 ASSERT_OK(db_impl->FlushWAL(true)); in TEST_P()
5499 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
5500 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
5505 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5510 ASSERT_OK(db_impl->Flush(fopt)); in TEST_P()
5511 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5515 ASSERT_OK(db_impl->FlushWAL(true)); in TEST_P()
5517 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
5518 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
5523 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5527 ASSERT_OK(db_impl->Flush(fopt)); in TEST_P()
5528 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
5532 ASSERT_OK(db_impl->FlushWAL(true)); in TEST_P()
5534 db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P()
5535 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
6160 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db->GetRootDB()); in TEST_P() local
6161 uint64_t wal_file_id = db_impl->TEST_LogfileNumber(); in TEST_P()