Home
last modified time | relevance | path

Searched refs:db_impl_ (Results 1 – 24 of 24) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc115 wpt_db_, db_impl_, prepare_batch_cnt_, in PrepareInternal()
119 Status s = db_impl_->WriteImpl( in PrepareInternal()
141 ROCKS_LOG_DETAILS(db_impl_->immutable_db_options().info_log, in CommitInternal()
162 ROCKS_LOG_WARN(db_impl_->immutable_db_options().info_log, in CommitInternal()
177 wpt_db_, db_impl_, commit_batch_cnt, in CommitInternal()
242 ROCKS_LOG_WARN(db_impl_->immutable_db_options().info_log, in RollbackInternal()
370 wpt_db_, db_impl_, ONE_BATCH, in RollbackInternal()
373 wpt_db_, db_impl_, GetId(), prepare_batch_cnt_, ONE_BATCH); in RollbackInternal()
392 assert(!db_impl_->immutable_db_options().two_write_queues); in RollbackInternal()
397 ROCKS_LOG_DETAILS(db_impl_->immutable_db_options().info_log, in RollbackInternal()
[all …]
Dwrite_prepared_txn_db.cc61 db_impl_->versions_->SetLastSequence(last_seq + 1); in Initialize()
82 db_impl_->SetRecoverableStatePreReleaseCallback( in Initialize()
181 this, db_impl_, batch_cnt, in WriteInternal()
182 db_impl_->immutable_db_options().two_write_queues, in WriteInternal()
213 this, db_impl_, prepare_seq, batch_cnt, ZERO_COMMITS); in WriteInternal()
715 db_impl_->immutable_db_options().info_log, in GetSnapshotInternal()
750 InstrumentedMutexLock dblock(db_impl_->mutex()); in GetSnapshotListFromDB()
751 db_impl_->mutex()->AssertHeld(); in GetSnapshotListFromDB()
752 return db_impl_->snapshots().GetAll(nullptr, max); in GetSnapshotListFromDB()
973 if (!db_impl_->shutting_down_) { in ~WritePreparedTxnDB()
[all …]
Dwrite_unprepared_txn.cc118 largest_validated_seq_ = db_impl_->GetLastPublishedSequence(); in HandleWrite()
366 wpt_db_, db_impl_, prepare_batch_cnt_, in FlushWriteBatchToDBInternal()
374 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in FlushWriteBatchToDBInternal()
555 ROCKS_LOG_WARN(db_impl_->immutable_db_options().info_log, in CommitInternal()
567 wpt_db_, db_impl_, unprep_seqs_, commit_batch_cnt); in CommitInternal()
570 wpt_db_, db_impl_, commit_batch_cnt, in CommitInternal()
626 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in CommitInternal()
654 auto s = db_impl_->GetImpl(roptions, key, get_impl_options); in WriteRollbackKeys()
735 wpt_db_, db_impl_, unprep_seqs_, rollback_batch_cnt); in RollbackInternal()
766 ROCKS_LOG_DETAILS(db_impl_->immutable_db_options().info_log, in RollbackInternal()
[all …]
Dwrite_unprepared_txn_db.cc160 } rollback_handler(db_impl_, last_visible_txn, &rollback_batch, in RollbackRecoveredTransaction()
176 s = db_impl_->WriteImpl(w_options, &rollback_batch, nullptr, nullptr, in RollbackRecoveredTransaction()
184 if (db_impl_->immutable_db_options().two_write_queues) { in RollbackRecoveredTransaction()
185 db_impl_->SetLastPublishedSequence(seq_used); in RollbackRecoveredTransaction()
199 db_impl_->SetSnapshotChecker(new WritePreparedSnapshotChecker(this)); in Initialize()
216 db_impl_->SetRecoverableStatePreReleaseCallback( in Initialize()
318 SequenceNumber last_seq = db_impl_->GetLatestSequenceNumber(); in Initialize()
324 db_impl_->versions_->SetLastAllocatedSequence(last_seq + 1); in Initialize()
325 db_impl_->versions_->SetLastSequence(last_seq + 1); in Initialize()
326 db_impl_->versions_->SetLastPublishedSequence(last_seq + 1); in Initialize()
[all …]
Dpessimistic_transaction.cc53 db_impl_ = static_cast_with_check<DBImpl, DB>(db_); in PessimisticTransaction()
248 } mark_log_callback(db_impl_, in PrepareInternal()
249 db_impl_->immutable_db_options().two_write_queues); in PrepareInternal()
256 Status s = db_impl_->WriteImpl( in PrepareInternal()
319 ROCKS_LOG_WARN(db_impl_->immutable_db_options().info_log, in Commit()
350 db_impl_->WriteImpl(write_options_, GetWriteBatch()->GetWriteBatch(), in CommitWithoutPrepareInternal()
362 auto s = db_impl_->WriteImpl(write_options_, batch, /*callback*/ nullptr, in CommitBatchInternal()
388 db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
439 auto s = db_impl_->WriteImpl(write_options_, &rollback_marker); in RollbackInternal()
683 column_family ? column_family : db_impl_->DefaultColumnFamily(); in ValidateSnapshot()
[all …]
Dwrite_prepared_txn_db.h640 auto next_prepare = db_impl_->GetLatestSequenceNumber() + 1; in SmallestUnCommittedSeq()
854 db_impl_(db_impl), in AddPreparedCallback()
894 DBImpl* db_impl_; variable
911 db_impl_(db_impl), in db_()
957 if (db_impl_->immutable_db_options().two_write_queues) { in Callback()
963 db_impl_->SetLastPublishedSequence(last_commit_seq); in Callback()
980 DBImpl* db_impl_; variable
1007 db_impl_(db_impl), in WritePreparedRollbackPreReleaseCallback()
1020 assert(db_impl_->immutable_db_options().two_write_queues); in Callback()
1029 db_impl_->SetLastPublishedSequence(last_commit_seq); in Callback()
[all …]
Dwrite_unprepared_txn_db.h50 db_impl_(db_impl), in db_()
82 if (db_impl_->immutable_db_options().two_write_queues && publish_seq_) { in Callback()
88 db_impl_->SetLastPublishedSequence(last_commit_seq); in Callback()
97 DBImpl* db_impl_; variable
Dpessimistic_transaction_db.cc32 db_impl_(static_cast_with_check<DBImpl, DB>(db)), in PessimisticTransactionDB()
40 assert(db_impl_ != nullptr); in PessimisticTransactionDB()
41 info_log_ = db_impl_->GetDBOptions().info_log; in PessimisticTransactionDB()
63 db_impl_(static_cast_with_check<DBImpl, DB>(db->GetRootDB())), in PessimisticTransactionDB()
71 assert(db_impl_ != nullptr); in PessimisticTransactionDB()
529 return db_impl_->Write(opts, updates); in Write()
539 return db_impl_->Write(opts, updates); in Write()
Dpessimistic_transaction.h148 DBImpl* db_impl_; variable
Dpessimistic_transaction_db.h147 DBImpl* db_impl_;
Dwrite_unprepared_transaction_test.cc376 wup_db->db_impl_->FlushWAL(true); in TEST_P()
498 auto db_impl = wup_db->db_impl_; in TEST_P()
Dwrite_prepared_transaction_test.cc706 assert(wp_db->db_impl_); in TEST_P()
1572 wp_db->db_impl_->FlushWAL(true); in TEST_P()
1835 wp_db->db_impl_->FlushWAL(true); in TEST_P()
1880 wp_db->db_impl_->FlushWAL(true); in TEST_P()
1916 wp_db->db_impl_->FlushWAL(true); in TEST_P()
/rocksdb-6.9/db/
Darena_wrapped_db_iter.cc52 if (cfd_ == nullptr || db_impl_ == nullptr || !allow_refresh_) { in Refresh()
59 SequenceNumber latest_seq = db_impl_->GetLatestSequenceNumber(); in Refresh()
67 SuperVersion* sv = cfd_->GetReferencedSuperVersion(db_impl_); in Refresh()
73 cur_sv_number, read_callback_, db_impl_, cfd_, allow_blob_, in Refresh()
76 InternalIterator* internal_iter = db_impl_->NewInternalIterator( in Refresh()
Darena_wrapped_db_iter.h86 db_impl_ = db_impl; in StoreRefreshInfo()
97 DBImpl* db_impl_ = nullptr; variable
Dwrite_callback_test.cc305 : db_impl_(db_impl_in) {} in TEST_F()
309 db_impl_->SetLastPublishedSequence(last_seq); in TEST_F()
312 DBImpl* db_impl_; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::__anon7a445e9b0402::PublishSeqCallback
Ddb_iter.cc72 db_impl_(db_impl), in DBIter()
1157 if (db_impl_ != nullptr && cfd_ != nullptr) { in Seek()
1158 db_impl_->TraceIteratorSeek(cfd_->GetID(), target); in Seek()
1218 if (db_impl_ != nullptr && cfd_ != nullptr) { in SeekForPrev()
1219 db_impl_->TraceIteratorSeekForPrev(cfd_->GetID(), target); in SeekForPrev()
Ddb_iter.h332 DBImpl* db_impl_; variable
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc124 if (db_impl_ != nullptr) { in AdvanceIteratorByTime()
127 db_impl_->NewIterator(ro, db_impl_->PersistentStatsColumnFamily()); in AdvanceIteratorByTime()
Din_memory_stats_history.cc41 if (db_impl_ != nullptr) { in AdvanceIteratorByTime()
43 db_impl_->FindStatsByTime(start_time, end_time, &time_, &stats_map_); in AdvanceIteratorByTime()
Din_memory_stats_history.h34 db_impl_(db_impl) { in InMemoryStatsHistoryIterator()
71 DBImpl* db_impl_; variable
Dpersistent_stats_history.h49 db_impl_(db_impl) { in PersistentStatsHistoryIterator()
80 DBImpl* db_impl_; variable
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl_filesnapshot.cc21 Status s = db_impl_->DisableFileDeletions(); in DisableFileDeletions()
41 Status s = db_impl_->EnableFileDeletions(force); in EnableFileDeletions()
Dblob_db_impl.cc79 db_impl_(nullptr), in BlobDBImpl()
121 db_impl_ = nullptr; in Close()
212 db_impl_ = static_cast_with_check<DBImpl, DB>(db_->GetRootDB()); in Open()
238 db_impl_->immutable_db_options().sst_file_manager.get()); in Open()
1594 s = db_impl_->GetImpl(ro, key, get_impl_options); in GetImpl()
1775 InstrumentedMutexLock l(db_impl_->mutex()); in VisibleToActiveSnapshot()
1776 auto& snapshots = db_impl_->snapshots(); in VisibleToActiveSnapshot()
1939 Status s = DeleteDBFile(&(db_impl_->immutable_db_options()), in DeleteObsoleteFiles()
1998 auto* iter = db_impl_->NewIteratorImpl( in NewIterator()
Dblob_db_impl.h396 DBImpl* db_impl_; variable