| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteBatchTest.java | 62 batch.put(foo, bar); in multipleBatchOperations()
63 batch.delete(box); in multipleBatchOperations()
64 batch.put(baz, boo); in multipleBatchOperations()
65 batch.merge(baz, hoo); in multipleBatchOperations()
95 batch.put(key, value); in multipleBatchOperationsDirect()
103 batch.remove(key); in multipleBatchOperationsDirect()
185 batch.setSavePoint(); in savePoints()
194 batch.setSavePoint(); in savePoints()
250 batch.setSavePoint(); in restorePoints()
278 batch.setSavePoint(); in restorePoints_withoutSavePoints_nested()
[all …]
|
| D | WriteBatchHandlerTest.java | 39 try (final WriteBatch batch = new WriteBatch()) { in writeBatchHandler() argument
44 batch.put(testEvent.key, testEvent.value); in writeBatchHandler()
48 batch.merge(testEvent.key, testEvent.value); in writeBatchHandler()
52 batch.delete(testEvent.key); in writeBatchHandler()
56 batch.putLogData(testEvent.value); in writeBatchHandler()
65 batch.iterate(handler); in writeBatchHandler()
|
| D | WalFilterTest.java | 67 final WriteBatch batch = new WriteBatch(); in walFilter() local
69 batch.put(cfHandles.get(0), batchKeys[i][j], dummyString(1024)); in walFilter()
71 db.write(writeOptions, batch); in walFilter()
141 final long logNumber, final String logFileName, final WriteBatch batch, in logRecordFound() argument
|
| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 133 WriteBatch batch; in TEST_F() local
140 WriteBatch batch; in TEST_F() local
158 WriteBatch batch; in TEST_F() local
222 WriteBatch batch; in TEST_F() local
318 WriteBatch batch; in TEST_F() local
328 WriteBatch batch; in TEST_F() local
338 WriteBatch batch; in TEST_F() local
348 WriteBatch batch; in TEST_F() local
358 WriteBatch batch; in TEST_F() local
392 WriteBatch batch; in TEST_F() local
[all …]
|
| D | write_batch_internal.h | 115 static Status InsertNoop(WriteBatch* batch);
118 static uint32_t Count(const WriteBatch* batch);
121 static void SetCount(WriteBatch* batch, uint32_t n);
132 static size_t GetFirstOffset(WriteBatch* batch);
134 static Slice Contents(const WriteBatch* batch) { in Contents() argument
135 return Slice(batch->rep_); in Contents()
138 static size_t ByteSize(const WriteBatch* batch) { in ByteSize() argument
139 return batch->rep_.size(); in ByteSize()
214 explicit LocalSavePoint(WriteBatch* batch) in LocalSavePoint() argument
215 : batch_(batch), in LocalSavePoint()
[all …]
|
| D | db_log_iter_test.cc | 218 WriteBatch batch; in TEST_F() local
219 batch.Put(handles_[1], "key1", DummyString(1024)); in TEST_F()
220 batch.Put(handles_[0], "key2", DummyString(1024)); in TEST_F()
221 batch.Put(handles_[1], "key3", DummyString(1024)); in TEST_F()
222 batch.Delete(handles_[0], "key2"); in TEST_F()
223 dbfull()->Write(WriteOptions(), &batch); in TEST_F()
238 WriteBatch batch; in TEST_F() local
241 batch.PutLogData(Slice("blob1")); in TEST_F()
243 batch.PutLogData(Slice("blob2")); in TEST_F()
244 batch.Delete(handles_[0], "key2"); in TEST_F()
[all …]
|
| D | error_handler_fs_test.cc | 725 WriteBatch batch; in TEST_F() local
737 WriteBatch batch; in TEST_F() local
801 WriteBatch batch; in TEST_F() local
815 WriteBatch batch; in TEST_F() local
852 WriteBatch batch; in TEST_F() local
892 WriteBatch batch; in TEST_F() local
906 WriteBatch batch; in TEST_F() local
997 WriteBatch batch; in TEST_F() local
1011 WriteBatch batch; in TEST_F() local
1110 WriteBatch batch; in TEST_F() local
[all …]
|
| D | transaction_log_impl.cc | 208 const WriteBatch* batch, const SequenceNumber expected_seq) { in IsBatchExpected() argument
209 assert(batch); in IsBatchExpected()
210 SequenceNumber batchSeq = WriteBatchInternal::Sequence(batch); in IsBatchExpected()
225 std::unique_ptr<WriteBatch> batch(new WriteBatch()); in UpdateCurrentWriteBatch() local
226 WriteBatchInternal::SetContents(batch.get(), record); in UpdateCurrentWriteBatch()
230 if (started_ && !IsBatchExpected(batch.get(), expected_seq)) { in UpdateCurrentWriteBatch()
285 current_batch_seq_ = WriteBatchInternal::Sequence(batch.get()); in UpdateCurrentWriteBatch()
288 batch->Iterate(&counter); in UpdateCurrentWriteBatch()
292 current_batch_seq_ + WriteBatchInternal::Count(batch.get()) - 1; in UpdateCurrentWriteBatch()
297 current_batch_ = std::move(batch); in UpdateCurrentWriteBatch()
|
| D | manual_compaction_test.cc | 136 WriteBatch batch; in TEST_F() local
138 batch.Put(Key1(i), "value for range 1 key"); in TEST_F()
140 ASSERT_OK(db->Write(WriteOptions(), &batch)); in TEST_F()
143 batch.Clear(); in TEST_F()
145 batch.Put(Key2(i), "value for range 2 key"); in TEST_F()
147 ASSERT_OK(db->Write(WriteOptions(), &batch)); in TEST_F()
150 batch.Clear(); in TEST_F()
152 batch.Delete(Key2(i)); in TEST_F()
154 ASSERT_OK(db->Write(WriteOptions(), &batch)); in TEST_F()
|
| D | wal_manager_test.cc | 69 WriteBatch batch; in Put() local
70 batch.Put(key, value); in Put()
71 WriteBatchInternal::SetSequence(&batch, seq); in Put()
72 current_log_writer_->AddRecord(WriteBatchInternal::Contents(&batch)); in Put()
140 WriteBatch batch; in TEST_F() local
141 batch.Put("foo", "bar"); in TEST_F()
142 WriteBatchInternal::SetSequence(&batch, 10); in TEST_F()
143 writer.AddRecord(WriteBatchInternal::Contents(&batch)); in TEST_F()
|
| D | write_thread.cc | 375 assert(w->batch != nullptr); in JoinBatchGroup()
410 assert(leader->batch != nullptr); in EnterAsBatchGroupLeader()
413 size_t size = WriteBatchInternal::ByteSize(leader->batch); in EnterAsBatchGroupLeader()
460 if (w->batch == nullptr) { in EnterAsBatchGroupLeader()
471 auto batch_size = WriteBatchInternal::ByteSize(w->batch); in EnterAsBatchGroupLeader()
490 assert(leader->batch != nullptr); in EnterAsMemTableWriter()
493 size_t size = WriteBatchInternal::ByteSize(leader->batch); in EnterAsMemTableWriter()
517 if (w->batch == nullptr) { in EnterAsMemTableWriter()
521 if (w->batch->HasMerge()) { in EnterAsMemTableWriter()
526 auto batch_size = WriteBatchInternal::ByteSize(w->batch); in EnterAsMemTableWriter()
[all …]
|
| D | fault_injection_test.cc | 191 WriteBatch batch; in Build() local
194 batch.Clear(); in Build()
195 batch.Put(key, Value(i, &value_space)); in Build()
196 ASSERT_OK(db_->Write(write_options, &batch)); in Build()
522 WriteBatch batch; in TEST_P() local
523 batch.Put("cats", "dogs"); in TEST_P()
524 batch.MarkWalTerminationPoint(); in TEST_P()
525 batch.Put("boys", "girls"); in TEST_P()
526 ASSERT_OK(db_->Write(wo, &batch)); in TEST_P()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_test.cc | 294 batch.Clear(); in TEST_F()
943 batch.Delete("c"); in TEST_F()
944 batch.Delete("d"); in TEST_F()
945 batch.Delete("e"); in TEST_F()
1112 batch.Delete("b"); in TEST_F()
1217 batch.Delete("a"); in TEST_F()
1302 batch.Delete("A"); in TEST_F()
1382 batch.Delete("x"); in TEST_F()
1445 batch.Delete("x"); in TEST_F()
1704 batch.Clear(); in TEST_F()
[all …]
|
| /rocksdb-6.9/db/blob/ |
| D | db_blob_index_test.cc | 58 Status Write(WriteBatch* batch) { in Write() argument
59 return dbfull()->Write(WriteOptions(), batch); in Write()
143 WriteBatch batch; in TEST_F() local
145 ASSERT_OK(Write(&batch)); in TEST_F()
160 WriteBatch batch; in TEST_F() local
161 ASSERT_OK(batch.Put("key", "value")); in TEST_F()
163 ASSERT_OK(Write(&batch)); in TEST_F()
185 WriteBatch batch; in TEST_F() local
189 ASSERT_OK(Write(&batch)); in TEST_F()
336 WriteBatch batch; in TEST_F() local
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | env_librados_test.cc | 357 WriteBatch batch; in TEST_F() local
358 batch.Delete("key1"); in TEST_F()
475 WriteBatch batch; in TEST_F() local
514 WriteBatch batch; in TEST_F() local
559 WriteBatch batch; in TEST_F() local
598 WriteBatch batch; in TEST_F() local
643 WriteBatch batch; in TEST_F() local
694 WriteBatch batch; in TEST_F() local
900 WriteBatch batch; in TEST_F() local
942 WriteBatch batch; in TEST_F() local
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 965 merged_batch = leader->batch; in MergeBatch()
1818 return Write(opt, &batch); in Put()
1833 return Write(opt, &batch); in Put()
1838 WriteBatch batch; in Delete() local
1840 return Write(opt, &batch); in Delete()
1845 WriteBatch batch; in SingleDelete() local
1847 return Write(opt, &batch); in SingleDelete()
1853 WriteBatch batch; in DeleteRange() local
1855 return Write(opt, &batch); in DeleteRange()
1860 WriteBatch batch; in Merge() local
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-02-27-write-batch-with-index.markdown | 7 - /blog/1901/write-batch-with-index/
10 …ty can be implemented by committing a transaction's writes with one write batch to RocksDB in the …
14 …batch, you cannot get the updated value from RocksDB previously written by the same transaction (r…
16 Before talking about the index part, let me introduce write batch first. The write batch class, `Wr…
18 …batch to RocksDB. When the user wants to call `Get()`, we first check if the value exists in the `…
|
| /rocksdb-6.9/examples/ |
| D | column_families_example.cc | 55 WriteBatch batch; in main() local
56 batch.Put(handles[0], Slice("key2"), Slice("value2")); in main()
57 batch.Put(handles[1], Slice("key3"), Slice("value3")); in main()
58 batch.Delete(handles[0], Slice("key")); in main()
59 s = db->Write(WriteOptions(), &batch); in main()
|
| D | simple_example.cc | 41 WriteBatch batch; in main() local
42 batch.Delete("key1"); in main()
43 batch.Put("key2", value); in main()
44 s = db->Write(WriteOptions(), &batch); in main()
|
| /rocksdb-6.9/tools/rdb/ |
| D | db_wrapper.cc | 290 bool DBWrapper::AddToBatch(ROCKSDB_NAMESPACE::WriteBatch& batch, bool del, in AddToBatch() argument
299 batch.Delete(*v8::String::Utf8Value(array->Get(i)->ToString())); in AddToBatch()
313 batch.Put( in AddToBatch()
331 batch.Delete( in AddToBatch()
347 batch.Put( in AddToBatch()
366 ROCKSDB_NAMESPACE::WriteBatch batch; in WriteBatch() local
382 batch, false, in WriteBatch()
388 batch, true, in WriteBatch()
394 batch, false, in WriteBatch()
397 batch, true, in WriteBatch()
[all …]
|
| /rocksdb-6.9/db_stress_tool/ |
| D | cf_consistency_stress.cc | 31 WriteBatch batch; in TestPut() local
35 batch.Merge(cfh, key, v); in TestPut()
37 batch.Put(cfh, key, v); in TestPut()
40 Status s = db_->Write(write_opts, &batch); in TestPut()
58 WriteBatch batch; in TestDelete() local
61 batch.Delete(cfh, key); in TestDelete()
63 Status s = db_->Write(write_opts, &batch); in TestDelete()
88 WriteBatch batch; in TestDeleteRange() local
91 batch.DeleteRange(cfh, key, end_key); in TestDeleteRange()
93 Status s = db_->Write(write_opts, &batch); in TestDeleteRange()
|
| D | batched_ops_stress.cc | 34 WriteBatch batch; in TestPut() local
43 batch.Merge(cfh, keys[i], value_slices[i]); in TestPut()
45 batch.Put(cfh, keys[i], value_slices[i]); in TestPut()
49 s = db_->Write(write_opts, &batch); in TestPut()
69 WriteBatch batch; in TestDelete() local
75 batch.Delete(cfh, keys[i]); in TestDelete()
78 s = db_->Write(writeoptions, &batch); in TestDelete()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction.h | 59 Status CommitBatch(WriteBatch* batch);
130 virtual Status CommitBatchInternal(WriteBatch* batch,
139 Status LockBatch(WriteBatch* batch, TransactionKeyMap* keys_to_unlock);
216 Status CommitBatchInternal(WriteBatch* batch, size_t batch_cnt) override;
|
| D | pessimistic_transaction.cc | 134 Status PessimisticTransaction::CommitBatch(WriteBatch* batch) { in CommitBatch() argument
136 Status s = LockBatch(batch, &keys_to_unlock); in CommitBatch()
157 s = CommitBatchInternal(batch); in CommitBatch()
360 Status WriteCommittedTxn::CommitBatchInternal(WriteBatch* batch, size_t) { in CommitBatchInternal() argument
362 auto s = db_impl_->WriteImpl(write_options_, batch, /*callback*/ nullptr, in CommitBatchInternal()
461 Status PessimisticTransaction::LockBatch(WriteBatch* batch, in LockBatch() argument
502 batch->Iterate(&handler); in LockBatch()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 212 WriteBatch batch; in Put() local
213 batch.Put(column_family, key, val); in Put()
214 return Write(options, &batch); in Put()
265 WriteBatch batch; in Merge() local
266 batch.Merge(column_family, key, value); in Merge()
267 return Write(options, &batch); in Merge()
|