Home
last modified time | relevance | path

Searched refs:write_options_ (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc103 WriteOptions write_options = write_options_; in PrepareInternal()
137 return wpt_db_->WriteInternal(write_options_, batch, batch_cnt, this); in CommitBatchInternal()
191 auto s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
226 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in CommitInternal()
384 s = db_impl_->WriteImpl(write_options_, &rollback_batch, nullptr, nullptr, in RollbackInternal()
408 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in RollbackInternal()
Dpessimistic_transaction.cc224 WriteOptions write_options = write_options_; in PrepareInternal()
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()
Doptimistic_transaction.cc82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
Dtransaction_base.h240 WriteOptions* GetWriteOptions() override { return &write_options_; } in GetWriteOptions()
243 write_options_ = write_options; in SetWriteOptions()
289 WriteOptions write_options_; variable
Dwrite_unprepared_txn.cc350 WriteOptions write_options = write_options_; in FlushWriteBatchToDBInternal()
584 auto s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
626 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in CommitInternal()
740 s = db_impl_->WriteImpl(write_options_, rollback_batch.GetWriteBatch(), in RollbackInternal()
774 s = db_impl_->WriteImpl(write_options_, &empty_batch, nullptr, nullptr, in RollbackInternal()
Dtransaction_base.cc26 write_options_(write_options), in TransactionBaseImpl()
65 write_options_ = write_options; in Reinitialize()
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc34 write_options_(write_options), in RandomTransactionInserter()
52 txn_ = db->BeginTransaction(write_options_, txn_options, txn_); in TransactionDBInsert()
78 db->BeginTransaction(write_options_, txn_options, optimistic_txn_); in OptimisticTransactionDBInsert()
251 s = db->Write(write_options_, &batch); in DoInsert()
Dtransaction_test_util.h103 const WriteOptions write_options_; variable
/rocksdb-6.9/tools/
Ddb_bench_tool.cc2305 WriteOptions write_options_; member in ROCKSDB_NAMESPACE::Benchmark
2876 write_options_ = WriteOptions(); in Run()
2879 write_options_.sync = true; in Run()
2966 write_options_.sync = true; in Run()
5551 write_options_, key, in MixGraph()
5774 auto s = db->Write(write_options_, &batch); in DoDelete()
5856 s = db->Put(write_options_, key, val); in BGWriter()
5858 s = db->Merge(write_options_, key, val); in BGWriter()
6310 s = db_with_cfh->db->Merge(write_options_, in MergeRandom()
6314 s = db_with_cfh->db->Merge(write_options_, in MergeRandom()
[all …]