Home
last modified time | relevance | path

Searched refs:TransactionLogIterator (Results 1 – 22 of 22) sorted by relevance

/rocksdb-6.9/java/rocksjni/
Dtransaction_log.cc25 delete reinterpret_cast<ROCKSDB_NAMESPACE::TransactionLogIterator*>(handle); in Java_org_rocksdb_TransactionLogIterator_disposeInternal()
36 return reinterpret_cast<ROCKSDB_NAMESPACE::TransactionLogIterator*>(handle) in Java_org_rocksdb_TransactionLogIterator_isValid()
48 reinterpret_cast<ROCKSDB_NAMESPACE::TransactionLogIterator*>(handle)->Next(); in Java_org_rocksdb_TransactionLogIterator_next()
60 reinterpret_cast<ROCKSDB_NAMESPACE::TransactionLogIterator*>(handle) in Java_org_rocksdb_TransactionLogIterator_status()
76 reinterpret_cast<ROCKSDB_NAMESPACE::TransactionLogIterator*>(handle) in Java_org_rocksdb_TransactionLogIterator_getBatch()
Drocksjni.cc2933 std::unique_ptr<ROCKSDB_NAMESPACE::TransactionLogIterator> iter; in Java_org_rocksdb_RocksDB_getUpdatesSince()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTransactionLogIteratorTest.java25 final TransactionLogIterator transactionLogIterator = in transactionLogIterator()
65 try (final TransactionLogIterator transactionLogIterator = in getBatch()
71 final TransactionLogIterator.BatchResult batchResult = in getBatch()
91 try (final TransactionLogIterator transactionLogIterator = in transactionLogIteratorStallAtLastRecord()
128 try (final TransactionLogIterator transactionLogIterator = in transactionLogIteratorCheckAfterRestart()
/rocksdb-6.9/db/
Ddb_log_iter_test.cc24 std::unique_ptr<TransactionLogIterator> OpenTransactionLogIter( in OpenTransactionLogIter()
26 std::unique_ptr<TransactionLogIterator> iter; in OpenTransactionLogIter()
36 std::unique_ptr<TransactionLogIterator>& iter, in ReadRecords()
54 std::unique_ptr<TransactionLogIterator>& iter) { in ExpectRecords()
61 TEST_F(DBTestXactLogIterator, TransactionLogIterator) { in TEST_F() argument
Dtransaction_log_impl.h59 class TransactionLogIteratorImpl : public TransactionLogIterator {
63 const TransactionLogIterator::ReadOptions& read_options,
79 const TransactionLogIterator::ReadOptions read_options_;
Dwal_manager_test.cc98 std::unique_ptr<TransactionLogIterator> OpenTransactionLogIter( in OpenTransactionLogIter()
100 std::unique_ptr<TransactionLogIterator> iter; in OpenTransactionLogIter()
102 seq, &iter, TransactionLogIterator::ReadOptions(), versions_.get()); in OpenTransactionLogIter()
198 int CountRecords(TransactionLogIterator* iter) { in CountRecords()
Dwal_manager.h53 SequenceNumber seq_number, std::unique_ptr<TransactionLogIterator>* iter,
54 const TransactionLogIterator::ReadOptions& read_options,
Dwal_manager.cc105 SequenceNumber seq, std::unique_ptr<TransactionLogIterator>* iter, in GetUpdatesSince()
106 const TransactionLogIterator::ReadOptions& read_options, in GetUpdatesSince()
Dtransaction_log_impl.cc17 const TransactionLogIterator::ReadOptions& read_options, in TransactionLogIteratorImpl()
Dc.cc110 using ROCKSDB_NAMESPACE::TransactionLogIterator;
151 struct rocksdb_wal_iterator_t { TransactionLogIterator* rep; };
152 struct rocksdb_wal_readoptions_t { TransactionLogIterator::ReadOptions rep; };
1011 std::unique_ptr<TransactionLogIterator> iter; in rocksdb_get_updates_since()
1012 TransactionLogIterator::ReadOptions ro; in rocksdb_get_updates_since()
Ddb_test.cc2959 std::unique_ptr<ROCKSDB_NAMESPACE::TransactionLogIterator>*, in GetUpdatesSince() argument
2960 const TransactionLogIterator::ReadOptions& /*read_options*/ = in GetUpdatesSince()
2961 TransactionLogIterator::ReadOptions()) override { in GetUpdatesSince()
/rocksdb-6.9/include/rocksdb/
Dtransaction_log.h85 class TransactionLogIterator {
87 TransactionLogIterator() {} in TransactionLogIterator() function
88 virtual ~TransactionLogIterator() {} in ~TransactionLogIterator()
Ddb.h1323 SequenceNumber seq_number, std::unique_ptr<TransactionLogIterator>* iter,
1324 const TransactionLogIterator::ReadOptions& read_options =
1325 TransactionLogIterator::ReadOptions()) = 0;
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransactionLogIterator.java9 public class TransactionLogIterator extends RocksObject { class
60 TransactionLogIterator(final long nativeHandle) { in TransactionLogIterator() method in TransactionLogIterator
DRocksDB.java3871 public TransactionLogIterator getUpdatesSince(final long sequenceNumber) in getUpdatesSince()
3873 return new TransactionLogIterator( in getUpdatesSince()
/rocksdb-6.9/tools/
Ddb_repl_stress.cc70 std::unique_ptr<TransactionLogIterator> iter; in ReplicationThreadBody()
/rocksdb-6.9/include/rocksdb/utilities/
Dstackable_db.h434 SequenceNumber seq_number, std::unique_ptr<TransactionLogIterator>* iter, in GetUpdatesSince()
435 const TransactionLogIterator::ReadOptions& read_options) override { in GetUpdatesSince()
/rocksdb-6.9/db/db_impl/
Ddb_impl.h380 SequenceNumber seq_number, std::unique_ptr<TransactionLogIterator>* iter,
381 const TransactionLogIterator::ReadOptions& read_options =
382 TransactionLogIterator::ReadOptions()) override;
Ddb_impl.cc3149 SequenceNumber seq, std::unique_ptr<TransactionLogIterator>* iter, in GetUpdatesSince()
3150 const TransactionLogIterator::ReadOptions& read_options) { in GetUpdatesSince()
/rocksdb-6.9/java/
DCMakeLists.txt225 src/main/java/org/rocksdb/TransactionLogIterator.java
459 org.rocksdb.TransactionLogIterator
DMakefile72 org.rocksdb.TransactionLogIterator\
/rocksdb-6.9/
DHISTORY.md208 …turn TryAgain status in place of Corruption when new tail is not visible to TransactionLogIterator.