Home
last modified time | relevance | path

Searched refs:write_options (Results 1 – 25 of 53) sorted by relevance

123

/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_test.cc78 WriteOptions write_options; in TEST_P() local
107 WriteOptions write_options; in TEST_P() local
141 WriteOptions write_options; in TEST_P() local
176 WriteOptions write_options; in TEST_P() local
218 WriteOptions write_options; in TEST_P() local
235 WriteOptions write_options; in TEST_P() local
275 WriteOptions write_options; in TEST_P() local
444 WriteOptions write_options; in TEST_P() local
473 WriteOptions write_options; in TEST_P() local
580 WriteOptions write_options; in TEST_P() local
[all …]
Dtransaction_test.cc86 WriteOptions write_options; in TEST_P() local
87 write_options.sync = true; in TEST_P()
120 WriteOptions write_options; in TEST_P() local
154 WriteOptions write_options; in TEST_P() local
261 WriteOptions write_options; in TEST_P() local
355 WriteOptions write_options; in TEST_P() local
480 WriteOptions write_options; in TEST_P() local
1287 write_options.sync = true; in TEST_P()
1507 write_options.sync = true; in TEST_P()
1572 write_options.sync = true; in TEST_P()
[all …]
Doptimistic_transaction_db_impl.cc22 const WriteOptions& write_options, in BeginTransaction() argument
25 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
28 return new OptimisticTransaction(this, write_options, txn_options); in BeginTransaction()
102 Transaction* txn, const WriteOptions& write_options, in ReinitializeTransaction() argument
107 txn_impl->Reinitialize(this, write_options, txn_options); in ReinitializeTransaction()
Dtransaction_test.h267 WriteOptions write_options; variable
268 Transaction* txn = db->BeginTransaction(write_options, txn_options);
300 WriteOptions write_options; variable
301 Transaction* txn = db->BeginTransaction(write_options, txn_options);
333 WriteOptions write_options; variable
334 Transaction* txn = db->BeginTransaction(write_options, txn_options);
378 WriteOptions write_options; in CrossCompatibilityTest() local
401 ASSERT_OK(db->Put(write_options, k, v)); in CrossCompatibilityTest()
403 ASSERT_OK(db->Put(write_options, k, v2)); in CrossCompatibilityTest()
411 ASSERT_OK(db->Write(write_options, &wb)); in CrossCompatibilityTest()
[all …]
Dpessimistic_transaction.cc39 TransactionDB* txn_db, const WriteOptions& write_options, in PessimisticTransaction() argument
41 : TransactionBaseImpl(txn_db->GetRootDB(), write_options), in PessimisticTransaction()
109 TransactionDB* txn_db, const WriteOptions& write_options, in Reinitialize() argument
114 TransactionBaseImpl::Reinitialize(txn_db->GetRootDB(), write_options); in Reinitialize()
130 const WriteOptions& write_options, in WriteCommittedTxn() argument
132 : PessimisticTransaction(txn_db, write_options, txn_options){}; in WriteCommittedTxn()
224 WriteOptions write_options = write_options_; in PrepareInternal() local
225 write_options.disableWAL = false; in PrepareInternal()
257 write_options, GetWriteBatch()->GetWriteBatch(), kNoWriteCallback, in PrepareInternal()
Doptimistic_transaction.cc29 OptimisticTransactionDB* txn_db, const WriteOptions& write_options, in OptimisticTransaction() argument
31 : TransactionBaseImpl(txn_db->GetBaseDB(), write_options), txn_db_(txn_db) { in OptimisticTransaction()
43 OptimisticTransactionDB* txn_db, const WriteOptions& write_options, in Reinitialize() argument
45 TransactionBaseImpl::Reinitialize(txn_db->GetBaseDB(), write_options); in Reinitialize()
Dwrite_unprepared_transaction_test.cc158 WriteOptions write_options; in TEST_P() local
193 txn = db->BeginTransaction(write_options, txn_options); in TEST_P()
323 WriteOptions write_options; in TEST_P() local
324 write_options.disableWAL = false; in TEST_P()
350 Transaction* txn = db->BeginTransaction(write_options, txn_options); in TEST_P()
419 WriteOptions write_options; in TEST_P() local
429 Transaction* txn = db->BeginTransaction(write_options, txn_options); in TEST_P()
485 WriteOptions write_options; in TEST_P() local
500 Transaction* txn1 = db->BeginTransaction(write_options, txn_options); in TEST_P()
503 Transaction* txn2 = db->BeginTransaction(write_options, txn_options); in TEST_P()
Dpessimistic_transaction.h40 PessimisticTransaction(TransactionDB* db, const WriteOptions& write_options,
49 void Reinitialize(TransactionDB* txn_db, const WriteOptions& write_options,
203 WriteCommittedTxn(TransactionDB* db, const WriteOptions& write_options,
Dwrite_prepared_txn.cc28 const WriteOptions& write_options, in WritePreparedTxn() argument
30 : PessimisticTransaction(txn_db, write_options, txn_options, false), in WritePreparedTxn()
103 WriteOptions write_options = write_options_; in PrepareInternal() local
104 write_options.disableWAL = false; in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
Doptimistic_transaction_db_impl.h45 Transaction* BeginTransaction(const WriteOptions& write_options,
65 const WriteOptions& write_options,
Dpessimistic_transaction_db.h45 Transaction* BeginTransaction(const WriteOptions& write_options,
152 Transaction* txn, const WriteOptions& write_options,
206 Transaction* BeginTransaction(const WriteOptions& write_options,
Dwrite_prepared_txn_db.cc105 const WriteOptions& write_options, const TransactionOptions& txn_options, in BeginTransaction() argument
108 ReinitializeTransaction(old_txn, write_options, txn_options); in BeginTransaction()
111 return new WritePreparedTxn(this, write_options, txn_options); in BeginTransaction()
169 WriteOptions write_options(write_options_orig); in WriteInternal() local
192 auto s = db_impl_->WriteImpl(write_options, batch, nullptr, nullptr, in WriteInternal()
215 write_options.disableWAL = true; in WriteInternal()
216 write_options.sync = false; in WriteInternal()
218 s = db_impl_->WriteImpl(write_options, &empty_batch, nullptr, nullptr, in WriteInternal()
/rocksdb-6.9/db/
Dprefix_test.cc140 ASSERT_OK(db->Put(write_options, key, value)); in PutKey()
147 ASSERT_OK(db->Put(write_options, key, value)); in PutKey()
160 ASSERT_OK(db->Delete(write_options, key)); in DeleteKey()
305 WriteOptions write_options; in TEST() local
355 WriteOptions write_options; in TEST_F() local
528 WriteOptions write_options; in TEST_F() local
580 WriteOptions write_options; in TEST_F() local
687 WriteOptions write_options; in TEST_F() local
803 WriteOptions write_options; in TEST_F() local
836 WriteOptions write_options; in TEST_F() local
[all …]
Dfault_injection_test.cc196 ASSERT_OK(db_->Write(write_options, &batch)); in Build()
307 WriteOptions write_options; in PartialCompactTestPreFault() local
308 write_options.sync = sync_use_wal_; in PartialCompactTestPreFault()
310 Build(write_options, 0, num_pre_sync); in PartialCompactTestPreFault()
314 write_options.sync = false; in PartialCompactTestPreFault()
315 Build(write_options, num_pre_sync, num_post_sync); in PartialCompactTestPreFault()
399 WriteOptions write_options; in TEST_P() local
400 write_options.sync = false; in TEST_P()
408 write_options.sync = true; in TEST_P()
485 WriteOptions write_options; in TEST_P() local
[all …]
Ddb_write_test.cc34 WriteOptions write_options; in TEST_P() local
35 write_options.sync = true; in TEST_P()
36 write_options.disableWAL = true; in TEST_P()
37 ASSERT_TRUE(dbfull()->Put(write_options, "foo", "bar").IsInvalidArgument()); in TEST_P()
40 ASSERT_TRUE(dbfull()->Write(write_options, &batch).IsInvalidArgument()); in TEST_P()
Dwrite_thread.h156 Writer(const WriteOptions& write_options, WriteBatch* _batch,
161 sync(write_options.sync), in batch()
162 no_slowdown(write_options.no_slowdown), in batch()
163 disable_wal(write_options.disableWAL), in batch()
Dperf_context_test.cc72 WriteOptions write_options; in TEST_F() local
79 db->Put(write_options, key, value); in TEST_F()
84 db->Delete(write_options, key); in TEST_F()
211 WriteOptions write_options; in ProfileQueries() local
273 db->Put(write_options, key, value); in ProfileQueries()
514 WriteOptions write_options; in TEST_F() local
542 db->Put(write_options, key, value); in TEST_F()
822 WriteOptions write_options; in TEST_F() local
833 db->Put(write_options, key, value); in TEST_F()
Dwrite_callback_test.cc377 WriteOptions write_options; in TEST_F() local
398 s = db->Write(write_options, &wb); in TEST_F()
411 s = db_impl->WriteWithCallback(write_options, &wb2, &callback1); in TEST_F()
425 s = db_impl->WriteWithCallback(write_options, &wb3, &callback2); in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc82 if (write_options.sync && write_options.disableWAL) { in WriteImpl()
105 if (write_options.low_pri) { in WriteImpl()
159 if (!write_options.disableWAL) { in WriteImpl()
317 if (write_options.disableWAL) { in WriteImpl()
478 bool need_log_sync = !write_options.disableWAL && write_options.sync; in PipelinedWriteImpl()
627 if (write_options.disableWAL) { in UnorderedWriteMemtable()
756 if (!write_options.disableWAL) { in WriteImplWALOnly()
781 assert(!write_options.disableWAL); in WriteImplWALOnly()
1407 if (write_options.no_slowdown) { in DelayWrite()
1477 assert(write_options.low_pri); in ThrottleLowPriWritesIfNeeded()
[all …]
/rocksdb-6.9/examples/
Dtransaction_example.cc28 WriteOptions write_options; in main() local
40 Transaction* txn = txn_db->BeginTransaction(write_options); in main()
57 s = txn_db->Put(write_options, "xyz", "zzz"); in main()
62 s = txn_db->Put(write_options, "abc", "def"); in main()
89 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
94 s = txn_db->Put(write_options, "abc", "xyz"); in main()
134 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
144 s = txn_db->Put(write_options, "y", "y1"); in main()
Doptimistic_transaction_example.cc29 WriteOptions write_options; in main() local
41 Transaction* txn = txn_db->BeginTransaction(write_options); in main()
59 s = db->Put(write_options, "xyz", "zzz"); in main()
61 s = db->Put(write_options, "abc", "def"); in main()
86 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
91 s = db->Put(write_options, "abc", "xyz"); in main()
129 txn = txn_db->BeginTransaction(write_options, txn_options); in main()
144 s = db->Put(write_options, "y", "z"); in main()
/rocksdb-6.9/java/rocksjni/
Doptimistic_transaction_db.cc193 auto* write_options = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJ() local
196 optimistic_txn_db->BeginTransaction(*write_options); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJ()
210 auto* write_options = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJJ() local
216 *write_options, *optimistic_txn_options); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction__JJJ()
230 auto* write_options = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ() local
236 *write_options, optimistic_txn_options, old_txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJ()
256 auto* write_options = in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ() local
264 *write_options, *optimistic_txn_options, old_txn); in Java_org_rocksdb_OptimisticTransactionDB_beginTransaction_1withOld__JJJJ()
Drocksjni.cc564 auto* write_options = in Java_org_rocksdb_RocksDB_put__JJ_3BII_3BII() local
581 auto* write_options = in Java_org_rocksdb_RocksDB_put__JJ_3BII_3BIIJ() local
605 auto* write_options = in Java_org_rocksdb_RocksDB_putDirect() local
715 auto* write_options = in Java_org_rocksdb_RocksDB_delete__JJ_3BII() local
730 auto* write_options = in Java_org_rocksdb_RocksDB_delete__JJ_3BIIJ() local
834 auto* write_options = in Java_org_rocksdb_RocksDB_singleDelete__JJ_3BI() local
849 auto* write_options = in Java_org_rocksdb_RocksDB_singleDelete__JJ_3BIJ() local
1052 auto* write_options = in Java_org_rocksdb_RocksDB_deleteRange__JJ_3BII_3BII() local
1070 auto* write_options = in Java_org_rocksdb_RocksDB_deleteRange__JJ_3BII_3BIIJ() local
1209 auto* write_options = in Java_org_rocksdb_RocksDB_merge__JJ_3BII_3BII() local
[all …]
Dtransaction_db.cc191 auto* write_options = in Java_org_rocksdb_TransactionDB_beginTransaction__JJ() local
194 txn_db->BeginTransaction(*write_options); in Java_org_rocksdb_TransactionDB_beginTransaction__JJ()
207 auto* write_options = in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ() local
212 txn_db->BeginTransaction(*write_options, *txn_options); in Java_org_rocksdb_TransactionDB_beginTransaction__JJJ()
225 auto* write_options = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ() local
231 txn_db->BeginTransaction(*write_options, txn_options, old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJ()
250 auto* write_options = in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ() local
257 txn_db->BeginTransaction(*write_options, *txn_options, old_txn); in Java_org_rocksdb_TransactionDB_beginTransaction_1withOld__JJJJ()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc1099 WriteOptions write_options; in TEST_F() local
1102 s = db->Put(write_options, "a", "a"); in TEST_F()
1105 s = db->Put(write_options, "b", "b"); in TEST_F()
1108 s = db->Put(write_options, "c", "c"); in TEST_F()
1128 db->Delete(write_options, "x"); in TEST_F()
1152 WriteOptions write_options; in TEST_F() local
1196 s = db->Delete(write_options, "x"); in TEST_F()
1206 s = db->Delete(write_options, "a"); in TEST_F()
1247 s = db->Delete(write_options, "e"); in TEST_F()
1280 WriteOptions write_options; in TEST_F() local
[all …]

123