Home
last modified time | relevance | path

Searched refs:db_impl (Results 1 – 25 of 285) sorted by relevance

12345678910>>...12

/rocksdb-6.9/utilities/transactions/
Dtransaction_util.cc22 DBImpl* db_impl, ColumnFamilyHandle* column_family, const std::string& key, in CheckKeyForConflicts() argument
29 SuperVersion* sv = db_impl->GetAndRefSuperVersion(cfd); in CheckKeyForConflicts()
38 db_impl->GetEarliestMemTableSequenceNumber(sv, true); in CheckKeyForConflicts()
40 result = CheckKey(db_impl, sv, earliest_seq, snap_seq, key, cache_only, in CheckKeyForConflicts()
43 db_impl->ReturnAndCleanupSuperVersion(cfd, sv); in CheckKeyForConflicts()
49 Status TransactionUtil::CheckKey(DBImpl* db_impl, SuperVersion* sv, in CheckKey() argument
119 Status s = db_impl->GetLatestSequenceForKey(sv, key, !need_to_read_sst, in CheckKey()
138 Status TransactionUtil::CheckKeysForConflicts(DBImpl* db_impl, in CheckKeysForConflicts() argument
147 SuperVersion* sv = db_impl->GetAndRefSuperVersion(cf_id); in CheckKeysForConflicts()
155 db_impl->GetEarliestMemTableSequenceNumber(sv, true); in CheckKeysForConflicts()
[all …]
Doptimistic_transaction.cc79 DBImpl* db_impl = static_cast_with_check<DBImpl, DB>(db_->GetRootDB()); in CommitWithSerialValidate() local
81 Status s = db_impl->WriteWithCallback( in CommitWithSerialValidate()
95 DBImpl* db_impl = static_cast_with_check<DBImpl, DB>(db_->GetRootDB()); in CommitWithParallelValidate() local
96 assert(db_impl); in CommitWithParallelValidate()
112 Status s = TransactionUtil::CheckKeysForConflicts(db_impl, GetTrackedKeys(), in CommitWithParallelValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
171 auto db_impl = static_cast_with_check<DBImpl, DB>(db); in CheckTransactionForConflicts() local
177 return TransactionUtil::CheckKeysForConflicts(db_impl, GetTrackedKeys(), in CheckTransactionForConflicts()
Dtransaction_test.cc227 db_impl->TEST_FlushMemTable(true); in TEST_P()
900 db_impl->TEST_FlushMemTable(true); in TEST_P()
1021 db_impl->TEST_FlushMemTable(true); in TEST_P()
1263 db_impl->TEST_FlushMemTable(true); in TEST_P()
1319 db_impl->TEST_FlushMemTable(true); in TEST_P()
1410 db_impl->TEST_FlushMemTable(true); in TEST_P()
1891 s = db_impl->PauseBackgroundWork(); in TEST_P()
1935 db_impl->TEST_SwitchWAL(); in TEST_P()
1961 db_impl->TEST_SwitchWAL(); in TEST_P()
2407 db_impl->TEST_WaitForCompact(); in TEST_P()
[all …]
Dtransaction_util.h67 DBImpl* db_impl, ColumnFamilyHandle* column_family,
81 static Status CheckKeysForConflicts(DBImpl* db_impl,
94 static Status CheckKey(DBImpl* db_impl, SuperVersion* sv,
Dwrite_unprepared_transaction_test.cc498 auto db_impl = wup_db->db_impl_; in TEST_P() local
514 db_impl->TEST_SwitchWAL(); in TEST_P()
521 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
523 ASSERT_GT(db_impl->TEST_LogfileNumber(), txn1->GetLogNumber()); in TEST_P()
530 ASSERT_GE(db_impl->TEST_LogfileNumber(), txn1->GetLogNumber()); in TEST_P()
531 ASSERT_GE(db_impl->TEST_LogfileNumber(), txn2->GetLogNumber()); in TEST_P()
533 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
541 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), in TEST_P()
550 ASSERT_EQ(db_impl->TEST_FindMinLogContainingOutstandingPrep(), 0); in TEST_P()
/rocksdb-6.9/db/
Dwrite_callback_test.cc44 DBImpl* db_impl = dynamic_cast<DBImpl*> (db); in Callback() local
45 if (db_impl == nullptr) { in Callback()
158 DBImpl* db_impl; in TEST_F() local
175 db_impl = dynamic_cast<DBImpl*>(db); in TEST_F()
176 ASSERT_TRUE(db_impl); in TEST_F()
313 } publish_seq_callback(db_impl); in TEST_F()
317 s = db_impl->WriteImpl( in TEST_F()
322 s = db_impl->WriteWithCallback( in TEST_F()
381 DBImpl* db_impl; in TEST_F() local
389 db_impl = dynamic_cast<DBImpl*> (db); in TEST_F()
[all …]
Darena_wrapped_db_iter.cc39 ReadCallback* read_callback, DBImpl* db_impl, in Init() argument
46 read_callback, db_impl, cfd, allow_blob); in Init()
92 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd, in NewArenaWrappedDbIterator() argument
97 db_impl, cfd, allow_blob, allow_refresh); in NewArenaWrappedDbIterator()
98 if (db_impl != nullptr && cfd != nullptr && allow_refresh) { in NewArenaWrappedDbIterator()
99 iter->StoreRefreshInfo(read_options, db_impl, cfd, read_callback, in NewArenaWrappedDbIterator()
Darena_wrapped_db_iter.h77 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd,
82 void StoreRefreshInfo(const ReadOptions& read_options, DBImpl* db_impl, in StoreRefreshInfo() argument
86 db_impl_ = db_impl; in StoreRefreshInfo()
112 ReadCallback* read_callback, DBImpl* db_impl = nullptr,
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc.d1 db/db_impl/db_impl.cc.d db/db_impl/db_impl.o: db/db_impl/db_impl.cc \
2 db/db_impl/db_impl.h db/column_family.h db/memtable_list.h \
Ddb_impl_readonly.cc.d1 db/db_impl/db_impl_readonly.cc.d db/db_impl/db_impl_readonly.o: \
2 db/db_impl/db_impl_readonly.cc db/db_impl/db_impl_readonly.h \
3 db/db_impl/db_impl.h db/column_family.h db/memtable_list.h \
Ddb_impl_secondary.cc.d1 db/db_impl/db_impl_secondary.cc.d db/db_impl/db_impl_secondary.o: \
2 db/db_impl/db_impl_secondary.cc db/db_impl/db_impl_secondary.h \
3 db/db_impl/db_impl.h db/column_family.h db/memtable_list.h \
Ddb_secondary_test.cc.d1 db/db_impl/db_secondary_test.cc.d db/db_impl/db_secondary_test.o: \
2 db/db_impl/db_secondary_test.cc db/db_impl/db_impl_secondary.h \
3 db/db_impl/db_impl.h db/column_family.h db/memtable_list.h \
Ddb_impl_write.cc.d1 db/db_impl/db_impl_write.cc.d db/db_impl/db_impl_write.o: \
2 db/db_impl/db_impl_write.cc db/db_impl/db_impl.h db/column_family.h \
Ddb_impl_experimental.cc.d1 db/db_impl/db_impl_experimental.cc.d db/db_impl/db_impl_experimental.o: \
2 db/db_impl/db_impl_experimental.cc db/db_impl/db_impl.h \
Ddb_impl_debug.cc.d1 db/db_impl/db_impl_debug.cc.d db/db_impl/db_impl_debug.o: \
2 db/db_impl/db_impl_debug.cc db/column_family.h db/memtable_list.h \
53 db/db_impl/db_impl.h db/compaction/compaction_job.h \
Ddb_impl_compaction_flush.cc.d1 db/db_impl/db_impl_compaction_flush.cc.d \
2 db/db_impl/db_impl_compaction_flush.o: \
3 db/db_impl/db_impl_compaction_flush.cc db/db_impl/db_impl.h \
Ddb_impl_files.cc.d1 db/db_impl/db_impl_files.cc.d db/db_impl/db_impl_files.o: \
2 db/db_impl/db_impl_files.cc db/db_impl/db_impl.h db/column_family.h \
Ddb_impl_open.cc.d1 db/db_impl/db_impl_open.cc.d db/db_impl/db_impl_open.o: \
2 db/db_impl/db_impl_open.cc db/db_impl/db_impl.h db/column_family.h \
/rocksdb-6.9/tools/advisor/test/input_files/
DLOG-025 2018/05/25-14:34:21.048981 7f82bd676200 [db/db_impl.cc:398] Shutdown complete
26 2018/05/25-14:34:21.049000 7f82bd676200 [db/db_impl.cc:563] [col-fam-A] random log message for test…
27 2018/05/25-14:34:21.049010 7f82bd676200 [db/db_impl.cc:234] [col-fam-B] log continuing on next line
29 2018/05/25-14:34:21.049020 7f82bd676200 [db/db_impl.cc:653] [col-fam-A] another random log message
30 2018/05/25-14:34:21.049025 7f82bd676200 [db/db_impl.cc:331] [unknown] random log message no column …
/rocksdb-6.9/tools/
Dreduce_levels_test.cc50 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db_); in Flush() local
51 return db_impl->TEST_FlushMemTable(); in Flush()
55 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db_); in MoveL0FileToLevel() local
57 ASSERT_OK(db_impl->TEST_CompactRange(i, nullptr, nullptr)); in MoveL0FileToLevel()
/rocksdb-6.9/
Dsrc.mk23 db/db_impl/db_impl.cc \
24 db/db_impl/db_impl_compaction_flush.cc \
25 db/db_impl/db_impl_debug.cc \
26 db/db_impl/db_impl_experimental.cc \
27 db/db_impl/db_impl_files.cc \
28 db/db_impl/db_impl_open.cc \
29 db/db_impl/db_impl_readonly.cc \
30 db/db_impl/db_impl_secondary.cc \
31 db/db_impl/db_impl_write.cc \
344 db/db_impl/db_secondary_test.cc \
DMakefile1025 db/db_impl/db_impl.o: db/db_impl/db_impl.cc.o
1026 .PHONY : db/db_impl/db_impl.o
1029 db/db_impl/db_impl.cc.o:
1032 .PHONY : db/db_impl/db_impl.cc.o
1034 db/db_impl/db_impl.i: db/db_impl/db_impl.cc.i
1035 .PHONY : db/db_impl/db_impl.i
1038 db/db_impl/db_impl.cc.i:
1041 .PHONY : db/db_impl/db_impl.cc.i
1043 db/db_impl/db_impl.s: db/db_impl/db_impl.cc.s
1044 .PHONY : db/db_impl/db_impl.s
[all …]
/rocksdb-6.9/CMakeFiles/rocksdb.dir/
DDependInfo.cmake31 …rc/rocksdb-6.9/db/db_impl/db_impl.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl.cc.o" "gcc" "CMak…
32 …9/db/db_impl/db_impl_compaction_flush.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_compaction_fl…
33 …/rocksdb-6.9/db/db_impl/db_impl_debug.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_debug.cc.o" "…
34 …b-6.9/db/db_impl/db_impl_experimental.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_experimental.…
35 …/rocksdb-6.9/db/db_impl/db_impl_files.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_files.cc.o" "…
36 …c/rocksdb-6.9/db/db_impl/db_impl_open.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_open.cc.o" "g…
37 …cksdb-6.9/db/db_impl/db_impl_readonly.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_readonly.cc.o…
38 …ksdb-6.9/db/db_impl/db_impl_secondary.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_secondary.cc.…
39 …/rocksdb-6.9/db/db_impl/db_impl_write.cc" "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_write.cc.o" "…
Dcmake_clean.cmake42 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl.cc.o"
43 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl.cc.o.d"
46 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_debug.cc.o"
47 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_debug.cc.o.d"
50 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_files.cc.o"
51 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_files.cc.o.d"
52 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_open.cc.o"
53 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_open.cc.o.d"
54 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_readonly.cc.o"
58 "CMakeFiles/rocksdb.dir/db/db_impl/db_impl_write.cc.o"
[all …]
/rocksdb-6.9/utilities/memory/
Dmemory_test.cc64 DBImpl* db_impl = dynamic_cast<DBImpl*>(sdb ? sdb->GetBaseDB() : db); in GetCachePointers() local
65 if (db_impl != nullptr) { in GetCachePointers()
66 cache_set->insert(db_impl->TEST_table_cache()); in GetCachePointers()
74 if (db_impl != nullptr) { in GetCachePointers()
75 ASSERT_OK(db_impl->TEST_GetAllImmutableCFOptions(&iopts_map)); in GetCachePointers()

12345678910>>...12