Home
last modified time | relevance | path

Searched refs:notifier (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dtransaction_base.cc86 std::shared_ptr<TransactionNotifier> notifier) { in SetSnapshotOnNextOperation() argument
88 snapshot_notifier_ = notifier; in SetSnapshotOnNextOperation()
93 std::shared_ptr<TransactionNotifier> notifier = snapshot_notifier_; in SetSnapshotIfNeeded() local
95 if (notifier != nullptr) { in SetSnapshotIfNeeded()
96 notifier->SnapshotCreated(GetSnapshot()); in SetSnapshotIfNeeded()
Dtransaction_base.h208 std::shared_ptr<TransactionNotifier> notifier = nullptr) override;
Dtransaction_test.cc5062 std::shared_ptr<Notifier> notifier = in TEST_P() local
5071 txn1->SetSnapshotOnNextOperation(notifier); in TEST_P()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DAbstractTransactionTest.java60 try(final TestTransactionNotifier notifier = new TestTransactionNotifier()) { in setSnapshotOnNextOperation_transactionNotifier() argument
61 txn.setSnapshotOnNextOperation(notifier); in setSnapshotOnNextOperation_transactionNotifier()
64 txn.setSnapshotOnNextOperation(notifier); in setSnapshotOnNextOperation_transactionNotifier()
67 assertThat(notifier.getCreatedSnapshots().size()).isEqualTo(2); in setSnapshotOnNextOperation_transactionNotifier()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h104 std::shared_ptr<TransactionNotifier> notifier = nullptr) = 0;