Lines Matching refs:db_with_cfh
1967 void FinishedOps(DBWithColumnFamilies* db_with_cfh, DB* db, int64_t num_ops, in FinishedOps() argument
2030 if (db_with_cfh && db_with_cfh->num_created.load()) { in FinishedOps()
2031 for (size_t i = 0; i < db_with_cfh->num_created.load(); ++i) { in FinishedOps()
2032 if (db->GetProperty(db_with_cfh->cfh[i], "rocksdb.cfstats", in FinishedOps()
2038 db_with_cfh->cfh[i], in FinishedOps()
4405 DBWithColumnFamilies* db_with_cfh = SelectDBWithCfh(id); in DoWrite() local
4416 static_cast<blob_db::BlobDB*>(db_with_cfh->db); in DoWrite()
4430 batch.Put(db_with_cfh->GetCfh(rand_num), key, in DoWrite()
4452 s = db_with_cfh->db->Delete(write_options_, in DoWrite()
4458 batch.Delete(db_with_cfh->GetCfh(rand_num), in DoWrite()
4468 s = db_with_cfh->db->DeleteRange( in DoWrite()
4469 write_options_, db_with_cfh->db->DefaultColumnFamily(), in DoWrite()
4475 batch.DeleteRange(db_with_cfh->GetCfh(rand_num), begin_key, in DoWrite()
4491 s = db_with_cfh->db->Write(write_options_, &batch); in DoWrite()
4493 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, in DoWrite()
4837 for (const auto& db_with_cfh : multi_dbs_) { in ReadSequential() local
4838 ReadSequential(thread, db_with_cfh.db); in ReadSequential()
4882 DBWithColumnFamilies* db_with_cfh = SelectDBWithCfh(thread); in ReadToRowCache() local
4891 s = db_with_cfh->db->Get(options, db_with_cfh->GetCfh(key_rand), key, in ReadToRowCache()
4895 s = db_with_cfh->db->Get(options, in ReadToRowCache()
4896 db_with_cfh->db->DefaultColumnFamily(), key, in ReadToRowCache()
4914 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, 1, kRead); in ReadToRowCache()
4934 for (const auto& db_with_cfh : multi_dbs_) { in ReadReverse() local
4935 ReadReverse(thread, db_with_cfh.db); in ReadReverse()
5047 DBWithColumnFamilies* db_with_cfh = SelectDBWithCfh(thread); in ReadRandom() local
5069 s = db_with_cfh->db->Get(options, db_with_cfh->GetCfh(key_rand), key, in ReadRandom()
5073 s = db_with_cfh->db->Get(options, in ReadRandom()
5074 db_with_cfh->db->DefaultColumnFamily(), key, in ReadRandom()
5091 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, 1, kRead); in ReadRandom()
5465 DBWithColumnFamilies* db_with_cfh = SelectDBWithCfh(thread); in MixGraph() local
5516 s = db_with_cfh->db->Get(options, db_with_cfh->GetCfh(key_rand), key, in MixGraph()
5520 s = db_with_cfh->db->Get(options, in MixGraph()
5521 db_with_cfh->db->DefaultColumnFamily(), key, in MixGraph()
5539 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, 1, kRead); in MixGraph()
5550 s = db_with_cfh->db->Put( in MixGraph()
5563 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, 1, kWrite); in MixGraph()
5566 if (db_with_cfh->db != nullptr) { in MixGraph()
5568 single_iter = db_with_cfh->db->NewIterator(options); in MixGraph()
5591 thread->stats.FinishedOps(db_with_cfh, db_with_cfh->db, 1, kSeek); in MixGraph()
5643 for (const auto& db_with_cfh : multi_dbs_) { in SeekRandom() local
5644 multi_iters.push_back(db_with_cfh.db->NewIterator(options)); in SeekRandom()
5687 for (const auto& db_with_cfh : multi_dbs_) { in SeekRandom() local
5688 multi_iters.push_back(db_with_cfh.db->NewIterator(options)); in SeekRandom()
6303 DBWithColumnFamilies* db_with_cfh = SelectDBWithCfh(thread); in MergeRandom() local
6310 s = db_with_cfh->db->Merge(write_options_, in MergeRandom()
6311 db_with_cfh->GetCfh(key_rand), key, in MergeRandom()
6314 s = db_with_cfh->db->Merge(write_options_, in MergeRandom()
6315 db_with_cfh->db->DefaultColumnFamily(), key, in MergeRandom()
6324 thread->stats.FinishedOps(nullptr, db_with_cfh->db, 1, kMerge); in MergeRandom()
6847 for (const auto& db_with_cfh : multi_dbs_) { in CompactAll() local
6848 db_with_cfh.db->CompactRange(CompactRangeOptions(), nullptr, nullptr); in CompactAll()
6856 for (const auto& db_with_cfh : multi_dbs_) { in ResetStats() local
6857 db_with_cfh.db->ResetStats(); in ResetStats()
6865 for (const auto& db_with_cfh : multi_dbs_) { in PrintStatsHistory() local
6866 PrintStatsHistoryImpl(db_with_cfh.db, true); in PrintStatsHistory()
6898 for (const auto& db_with_cfh : multi_dbs_) { in PrintStats() local
6899 PrintStats(db_with_cfh.db, key, true); in PrintStats()
6920 void Replay(ThreadState* /*thread*/, DBWithColumnFamilies* db_with_cfh) { in Replay() argument
6933 Replayer replayer(db_with_cfh->db, db_with_cfh->cfh, in Replay()