| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 434 struct WriteBatchWithIndex::Rep {
515 void WriteBatchWithIndex::Rep::AddOrUpdateIndex( in AddOrUpdateIndex()
551 void WriteBatchWithIndex::Rep::Clear() { in Clear()
556 void WriteBatchWithIndex::Rep::ClearIndex() { in ClearIndex()
633 WriteBatchWithIndex::WriteBatchWithIndex( in WriteBatchWithIndex() function in ROCKSDB_NAMESPACE::WriteBatchWithIndex
639 WriteBatchWithIndex::~WriteBatchWithIndex() {} in ~WriteBatchWithIndex()
641 WriteBatchWithIndex::WriteBatchWithIndex(WriteBatchWithIndex&&) = default;
643 WriteBatchWithIndex& WriteBatchWithIndex::operator=(WriteBatchWithIndex&&) =
654 WBWIIterator* WriteBatchWithIndex::NewIterator( in NewIterator()
843 Status WriteBatchWithIndex::GetFromBatchAndDB( in GetFromBatchAndDB()
[all …]
|
| D | write_batch_with_index_test.cc | 289 WriteBatchWithIndex batch(nullptr, 20); in TEST_F()
316 WriteBatchWithIndex batch(BytewiseComparator(), 20); in TEST_F()
403 WriteBatchWithIndex batch(BytewiseComparator(), 20, true); in TEST_F()
932 WriteBatchWithIndex batch; in TEST_F()
992 WriteBatchWithIndex batch; in TEST_F()
1042 WriteBatchWithIndex batch(BytewiseComparator(), 0, true); in TEST_F()
1097 WriteBatchWithIndex batch; in TEST_F()
1150 WriteBatchWithIndex batch; in TEST_F()
1329 WriteBatchWithIndex batch; in TEST_F()
1597 WriteBatchWithIndex batch; in TEST_F()
[all …]
|
| D | write_batch_with_index_internal.h | 138 const ImmutableDBOptions& ioptions, WriteBatchWithIndex* batch,
|
| D | write_batch_with_index_internal.cc | 155 const ImmutableDBOptions& immuable_db_options, WriteBatchWithIndex* batch, in GetFromBatch()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteBatchWithIndexTest.java | 45 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex(true); in readYourOwnWrites()
115 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex(); in writeBatchWithIndex()
141 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in write_writeBatchWithIndexDirect()
340 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in restorePoints()
361 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in restorePoints_withoutSavePoints()
368 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in restorePoints_withoutSavePoints_nested()
380 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in popSavePoint()
405 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in popSavePoint_withoutSavePoints()
412 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in popSavePoint_withoutSavePoints_nested()
424 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in maxBytes()
[all …]
|
| D | AbstractTransactionTest.java | 709 final WriteBatchWithIndex writeBatch = txn.getWriteBatch(); in getWriteBatch()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_with_index.cc | 22 auto* wbwi = new ROCKSDB_NAMESPACE::WriteBatchWithIndex(); in Java_org_rocksdb_WriteBatchWithIndex_newWriteBatchWithIndex__()
33 auto* wbwi = new ROCKSDB_NAMESPACE::WriteBatchWithIndex( in Java_org_rocksdb_WriteBatchWithIndex_newWriteBatchWithIndex__Z()
62 auto* wbwi = new ROCKSDB_NAMESPACE::WriteBatchWithIndex( in Java_org_rocksdb_WriteBatchWithIndex_newWriteBatchWithIndex__JBIZ()
77 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_count0()
92 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_put__J_3BI_3BI()
116 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_put__J_3BI_3BIJ()
167 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_merge__J_3BI_3BI()
191 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_merge__J_3BI_3BIJ()
219 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_delete__J_3BI()
240 reinterpret_cast<ROCKSDB_NAMESPACE::WriteBatchWithIndex*>(jwbwi_handle); in Java_org_rocksdb_WriteBatchWithIndex_delete__J_3BIJ()
[all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-02-27-write-batch-with-index.markdown | 2 title: 'WriteBatchWithIndex: Utility for Implementing Read-Your-Own-Writes'
14 …orage engine in MongoDB. We solved it by creating a utility class, WriteBatchWithIndex (a write ba…
16 …WriteBatchWithIndex`. Users can put updates to WriteBatchIndex in the same way as to `WriteBatch`.…
18 …WriteBatchWithIndex`, every time the user creates a transaction, we create a `WriteBatchWithIndex`…
20 …WriteBatchWithIndex`, we successfully implemented read-your-own-writes in the RocksDB storage engi…
|
| D | 2017-05-26-rocksdb-5-4-5-released.markdown | 26 * Fix WriteBatchWithIndex address use after scope error.
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 86 class WriteBatchWithIndex : public WriteBatchBase {
97 explicit WriteBatchWithIndex(
102 ~WriteBatchWithIndex() override;
103 WriteBatchWithIndex(WriteBatchWithIndex&&);
104 WriteBatchWithIndex& operator=(WriteBatchWithIndex&&);
|
| D | transaction.h | 21 class WriteBatchWithIndex; variable
432 virtual WriteBatchWithIndex* GetWriteBatch() = 0;
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | WriteBatchWithIndex.java | 22 public class WriteBatchWithIndex extends AbstractWriteBatch { class
29 public WriteBatchWithIndex() { in WriteBatchWithIndex() method in WriteBatchWithIndex
44 public WriteBatchWithIndex(final boolean overwriteKey) { in WriteBatchWithIndex() method in WriteBatchWithIndex
61 public WriteBatchWithIndex( in WriteBatchWithIndex() method in WriteBatchWithIndex
77 WriteBatchWithIndex(final long nativeHandle) { in WriteBatchWithIndex() method in WriteBatchWithIndex
|
| D | WBWIRocksIterator.java | 11 extends AbstractRocksIterator<WriteBatchWithIndex> {
14 protected WBWIRocksIterator(final WriteBatchWithIndex wbwi, in WBWIRocksIterator()
|
| D | Transaction.java | 1542 public WriteBatchWithIndex getWriteBatch() { in getWriteBatch()
1544 final WriteBatchWithIndex writeBatchWithIndex = in getWriteBatch()
1545 new WriteBatchWithIndex(getWriteBatch(nativeHandle_)); in getWriteBatch()
|
| /rocksdb-6.9/java/ |
| D | HISTORY-JAVA.md | 22 * WriteBatchWithIndex support.
23 * Iterator support for WriteBatch and WriteBatchWithIndex
|
| D | CMakeLists.txt | 237 src/main/java/org/rocksdb/WriteBatchWithIndex.java
468 org.rocksdb.WriteBatchWithIndex
|
| D | Makefile | 81 org.rocksdb.WriteBatchWithIndex\
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_txn.cc | 411 WriteBatchWithIndex* wb_; in FlushWriteBatchWithSavePointToDB()
415 WriteBatchWithIndex* wb, in FlushWriteBatchWithSavePointToDB()
459 WriteBatchWithIndex wb(wpt_db_->DefaultColumnFamily()->GetComparator(), 0, in FlushWriteBatchWithSavePointToDB()
642 const TransactionKeyMap& tracked_keys, WriteBatchWithIndex* rollback_batch, in WriteRollbackKeys()
696 WriteBatchWithIndex rollback_batch( in RollbackInternal()
|
| D | transaction_util.h | 50 class WriteBatchWithIndex; variable
|
| D | transaction_base.h | 197 WriteBatchWithIndex* GetWriteBatch() override;
330 WriteBatchWithIndex write_batch_;
|
| D | write_unprepared_txn.h | 216 WriteBatchWithIndex* rollback_batch,
|
| D | transaction_base.cc | 591 WriteBatchWithIndex* TransactionBaseImpl::GetWriteBatch() { in GetWriteBatch()
|
| D | write_prepared_transaction_test.cc | 199 TEST(WriteBatchWithIndex, SubBatchCnt) { in TEST() argument
214 WriteBatchWithIndex batch(db->DefaultColumnFamily()->GetComparator(), 0, true, in TEST()
275 WriteBatchWithIndex rndbatch(db->DefaultColumnFamily()->GetComparator(), in TEST()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 347 friend class WriteBatchWithIndex; variable
|
| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 651 WriteBatchWithIndex batch; in TEST_F()
|