Home
last modified time | relevance | path

Searched refs:batch_ (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/db/
Dwrite_batch_internal.h215 : batch_(batch), in LocalSavePoint()
232 if (batch_->max_bytes_ && batch_->rep_.size() > batch_->max_bytes_) { in commit()
233 batch_->rep_.resize(savepoint_.size); in commit()
234 WriteBatchInternal::SetCount(batch_, savepoint_.count); in commit()
235 batch_->content_flags_.store(savepoint_.content_flags, in commit()
243 WriteBatch* batch_;
Dwrite_batch.cc1906 s = batch_info.batch_->Iterate(this); in MarkCommit()
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn_db.cc61 const auto& batch = it->second.batch_; in RollbackRecoveredTransaction()
293 s = wupt->RebuildFromWriteBatch(batch_info.batch_); in Initialize()
Dpessimistic_transaction_db.cc154 s = real_trx->RebuildFromWriteBatch(batch_info.batch_); in Initialize()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc906 WriteBatch batch_; member in ROCKSDB_NAMESPACE::blob_db::BlobDBImpl::BlobInserter
915 WriteBatch* batch() { return &batch_; } in batch()
924 &batch_); in PutCF()
933 Status s = WriteBatchInternal::Delete(&batch_, column_family_id, key); in DeleteCF()
943 Status s = WriteBatchInternal::DeleteRange(&batch_, column_family_id, in DeleteRange()
958 void LogData(const Slice& blob) override { batch_.PutLogData(blob); } in LogData()
/rocksdb-6.9/db/db_impl/
Ddb_impl.h726 WriteBatch* batch_; member
749 delete it.second.batch_; in ~RecoveredTransaction()