Home
last modified time | relevance | path

Searched refs:WriteBatch (Results 1 – 25 of 129) sorted by relevance

123456

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchTest.java44 try (final WriteBatch batch = new WriteBatch()) { in emptyWriteBatch()
61 try (final WriteBatch batch = new WriteBatch()) { in multipleBatchOperations()
90 try (WriteBatch batch = new WriteBatch()) { in multipleBatchOperationsDirect()
122 try (final WriteBatch b1 = new WriteBatch(); in testAppendOperation()
123 final WriteBatch b2 = new WriteBatch()) { in testAppendOperation()
155 try (final WriteBatch batch = new WriteBatch()) { in blobOperation()
176 try (final WriteBatch batch = new WriteBatch()) { in savePoints()
222 final WriteBatch batch = new WriteBatch(); in deleteRange()
245 try (final WriteBatch batch = new WriteBatch()) { in restorePoints()
269 try (final WriteBatch batch = new WriteBatch()) { in restorePoints_withoutSavePoints()
[all …]
DWalFilterTest.java67 final WriteBatch batch = new WriteBatch(); in walFilter()
141 final long logNumber, final String logFileName, final WriteBatch batch, in logRecordFound()
142 final WriteBatch newBatch) { in logRecordFound()
DReadOnlyTest.java257 final WriteBatch wb = new WriteBatch(); in failToWriteBatchReadOnly()
290 final WriteBatch wb = new WriteBatch(); in failToCFWriteBatchReadOnly()
/rocksdb-6.9/db/
Dwrite_batch_internal.h115 static Status InsertNoop(WriteBatch* batch);
118 static uint32_t Count(const WriteBatch* batch);
121 static void SetCount(WriteBatch* batch, uint32_t n);
124 static SequenceNumber Sequence(const WriteBatch* batch);
132 static size_t GetFirstOffset(WriteBatch* batch);
134 static Slice Contents(const WriteBatch* batch) { in Contents()
138 static size_t ByteSize(const WriteBatch* batch) { in ByteSize()
194 static Status Append(WriteBatch* dst, const WriteBatch* src,
202 static Status Iterate(const WriteBatch* wb, WriteBatch::Handler* handler,
214 explicit LocalSavePoint(WriteBatch* batch) in LocalSavePoint()
[all …]
Dwrite_batch.cc246 WriteBatch::WriteBatch(size_t reserved_bytes, size_t max_bytes) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
254 WriteBatch::WriteBatch(size_t reserved_bytes, size_t max_bytes, size_t ts_sz) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
261 WriteBatch::WriteBatch(const std::string& rep) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
267 WriteBatch::WriteBatch(std::string&& rep) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
273 WriteBatch::WriteBatch(const WriteBatch& src) in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
285 WriteBatch::WriteBatch(WriteBatch&& src) noexcept in WriteBatch() function in ROCKSDB_NAMESPACE::WriteBatch
293 WriteBatch& WriteBatch::operator=(const WriteBatch& src) { in operator =()
295 this->~WriteBatch(); in operator =()
301 WriteBatch& WriteBatch::operator=(WriteBatch&& src) { in operator =()
303 this->~WriteBatch(); in operator =()
[all …]
Dwrite_batch_test.cc133 WriteBatch batch; in TEST_F()
140 WriteBatch batch; in TEST_F()
158 WriteBatch batch; in TEST_F()
171 WriteBatch b1, b2; in TEST_F()
222 WriteBatch batch; in TEST_F()
318 WriteBatch batch; in TEST_F()
328 WriteBatch batch; in TEST_F()
338 WriteBatch batch; in TEST_F()
348 WriteBatch batch; in TEST_F()
358 WriteBatch batch; in TEST_F()
[all …]
Dtransaction_log_impl.cc208 const WriteBatch* batch, const SequenceNumber expected_seq) { in IsBatchExpected()
225 std::unique_ptr<WriteBatch> batch(new WriteBatch()); in UpdateCurrentWriteBatch()
249 struct BatchCounter : public WriteBatch::Handler { in UpdateCurrentWriteBatch()
/rocksdb-6.9/java/rocksjni/
Dwrite_batch.cc34 new ROCKSDB_NAMESPACE::WriteBatch(static_cast<size_t>(jreserved_bytes)); in Java_org_rocksdb_WriteBatch_newWriteBatch__I()
57 auto* wb = new ROCKSDB_NAMESPACE::WriteBatch(serialized); in Java_org_rocksdb_WriteBatch_newWriteBatch___3BI()
68 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_count0()
81 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_clear0()
95 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_setSavePoint0()
109 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_rollbackToSavePoint0()
127 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_popSavePoint()
146 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_setMaxBytes()
162 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_put__J_3BI_3BI()
184 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatch_put__J_3BI_3BIJ()
[all …]
Dwrite_batch_test.cc36 auto* b = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTest_getContents()
161 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTestInternalHelper_setSequence()
176 auto* wb = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle); in Java_org_rocksdb_WriteBatchTestInternalHelper_sequence()
192 auto* wb1 = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle_1); in Java_org_rocksdb_WriteBatchTestInternalHelper_append()
194 auto* wb2 = reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatch*>(jwb_handle_2); in Java_org_rocksdb_WriteBatchTestInternalHelper_append()
/rocksdb-6.9/include/rocksdb/
Dwrite_batch.h61 class WriteBatch : public WriteBatchBase {
63 explicit WriteBatch(size_t reserved_bytes = 0, size_t max_bytes = 0);
64 explicit WriteBatch(size_t reserved_bytes, size_t max_bytes, size_t ts_sz);
65 ~WriteBatch() override;
323 WriteBatch* GetWriteBatch() override { return this; } in GetWriteBatch()
326 explicit WriteBatch(const std::string& rep);
327 explicit WriteBatch(std::string&& rep);
329 WriteBatch(const WriteBatch& src);
330 WriteBatch(WriteBatch&& src) noexcept;
331 WriteBatch& operator=(const WriteBatch& src);
[all …]
Dwal_filter.h15 class WriteBatch; variable
83 const WriteBatch& batch, WriteBatch* new_batch, bool* batch_changed) { in LogRecordFound()
91 virtual WalProcessingOption LogRecord(const WriteBatch& /*batch*/, in LogRecord() argument
92 WriteBatch* /*new_batch*/, in LogRecord() argument
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DWriteBatch.java27 public class WriteBatch extends AbstractWriteBatch { class
31 public WriteBatch() { in WriteBatch() method in WriteBatch
40 public WriteBatch(final int reserved_bytes) { in WriteBatch() method in WriteBatch
50 public WriteBatch(final byte[] serialized) { in WriteBatch() method in WriteBatch
169 public WriteBatch getWriteBatch() { in getWriteBatch()
193 WriteBatch getWriteBatch(final long handle) { in getWriteBatch()
204 WriteBatch(final long nativeHandle) { in WriteBatch() method in WriteBatch
215 WriteBatch(final long nativeHandle, final boolean owningNativeHandle) { in WriteBatch() method in WriteBatch
DTransactionLogIterator.java80 writeBatch_ = new WriteBatch(nativeHandle, true); in BatchResult()
98 public WriteBatch writeBatch() { in writeBatch()
103 private final WriteBatch writeBatch_;
DAbstractWalFilter.java37 logNumber, logFileName, new WriteBatch(batchHandle), in logRecordFoundProxy()
38 new WriteBatch(newBatchHandle)); in logRecordFoundProxy()
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc135 Status WritePreparedTxn::CommitBatchInternal(WriteBatch* batch, in CommitBatchInternal()
145 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal()
219 WriteBatch empty_batch; in CommitInternal()
244 WriteBatch rollback_batch; in RollbackInternal()
253 struct RollbackWriteBatchBuilder : public WriteBatch::Handler { in RollbackInternal()
256 WriteBatch* rollback_batch_; in RollbackInternal()
265 WriteBatch* dst_batch, in RollbackInternal()
404 WriteBatch empty_batch; in RollbackInternal()
465 Status WritePreparedTxn::RebuildFromWriteBatch(WriteBatch* src_batch) { in RebuildFromWriteBatch()
Dpessimistic_transaction.h59 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;
Dpessimistic_transaction_db.h70 virtual Status Write(const WriteOptions& opts, WriteBatch* updates) override;
72 WriteBatch* updates) { in WriteWithConcurrencyControl()
215 WriteBatch* updates) override;
216 virtual Status Write(const WriteOptions& opts, WriteBatch* updates) override;
Dpessimistic_transaction.cc134 Status PessimisticTransaction::CommitBatch(WriteBatch* batch) { in CommitBatch()
360 Status WriteCommittedTxn::CommitBatchInternal(WriteBatch* batch, size_t) { in CommitBatchInternal()
375 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal()
437 WriteBatch rollback_marker; in RollbackInternal()
461 Status PessimisticTransaction::LockBatch(WriteBatch* batch, in LockBatch()
463 class Handler : public WriteBatch::Handler { in LockBatch()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc57 WriteBatch* my_batch, in WriteWithCallback()
956 WriteBatch* merged_batch = nullptr; in MergeBatch()
1033 WriteBatch* to_be_cached_state = nullptr; in WriteToWAL()
1101 WriteBatch tmp_batch; in ConcurrentWriteToWAL()
1103 WriteBatch* to_be_cached_state = nullptr; in ConcurrentWriteToWAL()
1104 WriteBatch* merged_batch = in ConcurrentWriteToWAL()
1813 WriteBatch batch(key.size() + value.size() + 24); in Put()
1838 WriteBatch batch; in Delete()
1845 WriteBatch batch; in SingleDelete()
1853 WriteBatch batch; in DeleteRange()
[all …]
Ddb_impl.h160 WriteBatch* updates) override;
507 WriteBatch* my_batch,
726 WriteBatch* batch_;
741 WriteBatch* batch, SequenceNumber seq, in RecoveredTransaction()
1083 Status WriteImpl(const WriteOptions& options, WriteBatch* updates,
1118 WriteBatch* updates, WriteCallback* callback, uint64_t* log_used,
1416 WriteBatch* my_batch);
1500 WriteBatch* MergeBatch(const WriteThread::WriteGroup& write_group,
1502 WriteBatch** to_be_cached_state);
1854 WriteBatch cached_recoverable_state_;
[all …]
/rocksdb-6.9/tools/rdb/
Ddb_wrapper.h29 static bool AddToBatch(ROCKSDB_NAMESPACE::WriteBatch& batch, bool del,
31 static bool AddToBatch(ROCKSDB_NAMESPACE::WriteBatch& batch, bool del,
47 static Handle<Value> WriteBatch(const Arguments& args);
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc52 Status PutBlobIndex(WriteBatch* batch, const Slice& key, in PutBlobIndex()
58 Status Write(WriteBatch* batch) { in Write()
143 WriteBatch batch; in TEST_F()
160 WriteBatch batch; in TEST_F()
185 WriteBatch batch; in TEST_F()
336 WriteBatch batch; in TEST_F()
/rocksdb-6.9/docs/_posts/
D2015-02-27-write-batch-with-index.markdown16 …WriteBatch`, is a RocksDB data structure for atomic writes of multiple keys. Users can buffer thei…
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc212 WriteBatch batch; in Put()
265 WriteBatch batch; in Merge()
270 Status DBWithTTLImpl::Write(const WriteOptions& opts, WriteBatch* updates) { in Write()
271 class Handler : public WriteBatch::Handler { in Write()
274 WriteBatch updates_ttl; in Write()
/rocksdb-6.9/utilities/
Denv_librados_test.cc357 WriteBatch batch; in TEST_F()
475 WriteBatch batch; in TEST_F()
514 WriteBatch batch; in TEST_F()
559 WriteBatch batch; in TEST_F()
598 WriteBatch batch; in TEST_F()
643 WriteBatch batch; in TEST_F()
694 WriteBatch batch; in TEST_F()
900 WriteBatch batch; in TEST_F()
942 WriteBatch batch; in TEST_F()
985 WriteBatch batch; in TEST_F()

123456