Home
last modified time | relevance | path

Searched refs:ReadOptions (Results 1 – 25 of 230) sorted by relevance

12345678910

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DReadOptionsTest.java37 try (final ReadOptions opt = new ReadOptions()) { in copyConstructor()
53 try (final ReadOptions opt = new ReadOptions()) { in verifyChecksum()
63 try (final ReadOptions opt = new ReadOptions()) { in fillCache()
73 try (final ReadOptions opt = new ReadOptions()) { in tailing()
83 try (final ReadOptions opt = new ReadOptions()) { in snapshot()
91 try (final ReadOptions opt = new ReadOptions()) { in readTier()
100 try (final ReadOptions opt = new ReadOptions()) { in managed()
108 try (final ReadOptions opt = new ReadOptions()) { in totalOrderSeek()
116 try (final ReadOptions opt = new ReadOptions()) { in prefixSameAsStart()
124 try (final ReadOptions opt = new ReadOptions()) { in pinData()
[all …]
DAbstractTransactionTest.java118 try(final ReadOptions readOptions = new ReadOptions(); in commit()
135 try(final ReadOptions readOptions = new ReadOptions(); in rollback()
150 final ReadOptions readOptions = new ReadOptions()) { in savePoint()
185 final ReadOptions readOptions = new ReadOptions(); in getPut_cf()
199 final ReadOptions readOptions = new ReadOptions(); in getPut()
217 final ReadOptions readOptions = new ReadOptions(); in multiGetPut_cf()
240 final ReadOptions readOptions = new ReadOptions(); in multiGetPut()
256 final ReadOptions readOptions = new ReadOptions(); in getForUpdate_cf()
270 final ReadOptions readOptions = new ReadOptions(); in getForUpdate()
288 final ReadOptions readOptions = new ReadOptions(); in multiGetForUpdate_cf()
[all …]
DOptimisticTransactionTest.java26 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_cf_conflict()
64 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_conflict()
106 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_cf_conflict()
153 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_conflict()
192 final ReadOptions readOptions = new ReadOptions()) { in undoGetForUpdate_cf_conflict()
227 final ReadOptions readOptions = new ReadOptions()) { in undoGetForUpdate_conflict()
DTransactionTest.java26 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_cf_conflict()
60 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_conflict()
98 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_cf_conflict()
140 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_conflict()
DSnapshotTest.java33 try (final ReadOptions readOptions = new ReadOptions()) { in snapshots()
93 final ReadOptions readOptions = in iteratorWithSnapshot()
94 new ReadOptions().setSnapshot(snapshot)) { in iteratorWithSnapshot()
137 final ReadOptions readOptions = new ReadOptions() in iteratorWithSnapshotOnColumnFamily()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DReadOptions.java14 public class ReadOptions extends RocksObject { class
15 public ReadOptions() { in ReadOptions() method in ReadOptions
36 public ReadOptions(ReadOptions other) { in ReadOptions() method in ReadOptions
63 public ReadOptions setVerifyChecksums( in setVerifyChecksums()
93 public ReadOptions setFillCache(final boolean fillCache) { in setFillCache()
124 public ReadOptions setSnapshot(final Snapshot snapshot) { in setSnapshot()
185 public ReadOptions setTailing(final boolean tailing) { in setTailing()
216 public ReadOptions setManaged(final boolean managed) { in setManaged()
295 public ReadOptions setPinData(final boolean pinData) { in setPinData()
326 public ReadOptions setBackgroundPurgeOnIteratorCleanup( in setBackgroundPurgeOnIteratorCleanup()
[all …]
/rocksdb-6.9/db/
Ddb_merge_operand_test.cc62 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k0", in TEST_F()
70 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k0.1", in TEST_F()
81 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k1", in TEST_F()
93 ReadOptions(), db_->DefaultColumnFamily(), "k1", values.data(), in TEST_F()
104 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k1.1", in TEST_F()
117 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2", in TEST_F()
131 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2.1", in TEST_F()
142 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2.2", in TEST_F()
160 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k3", in TEST_F()
208 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k4", in TEST_F()
[all …]
Ddb_iterator_test.cc70 ReadOptions ropt; in TEST_P()
96 ReadOptions ropt; in TEST_P()
201 ReadOptions opts; in TEST_P()
814 ReadOptions ro; in TEST_P()
835 ReadOptions ro; in TEST_P()
1535 ReadOptions ro; in TEST_P()
1590 ReadOptions ro; in TEST_P()
1637 ReadOptions ro; in TEST_P()
2198 ReadOptions ro; in TEST_P()
2357 ReadOptions ro; in TEST_P()
[all …]
Dimport_column_family_test.cc104 db_->Get(ReadOptions(), import_cfh_, "K1", &value); in TEST_F()
106 db_->Get(ReadOptions(), import_cfh_, "K2", &value); in TEST_F()
125 db_->Get(ReadOptions(), import_cfh_, "K3", &value); in TEST_F()
127 db_->Get(ReadOptions(), import_cfh_, "K4", &value); in TEST_F()
214 db_->Get(ReadOptions(), import_cfh_, Key(i), &value); in TEST_F()
235 db_->Get(ReadOptions(), import_cfh_, Key(i), &value); in TEST_F()
254 db_->Get(ReadOptions(), import_cfh_, Key(i), &value); in TEST_F()
318 db_->Get(ReadOptions(), import_cfh_, Key(i), &value1); in TEST_F()
340 db_->Get(ReadOptions(), import_cfh_, Key(i), &value1); in TEST_F()
344 db_->Get(ReadOptions(), import_cfh_, Key(i), &value1); in TEST_F()
[all …]
Dmemtable_list.h64 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
70 const ReadOptions& read_opts, ReadCallback* callback = nullptr,
78 void MultiGet(const ReadOptions& read_options, MultiGetRange* range,
86 const ReadOptions& read_opts);
96 SequenceNumber* seq, const ReadOptions& read_opts,
102 const ReadOptions& read_opts,
110 Status AddRangeTombstoneIterators(const ReadOptions& read_opts, Arena* arena,
113 void AddIterators(const ReadOptions& options,
117 void AddIterators(const ReadOptions& options,
157 SequenceNumber* seq, const ReadOptions& read_opts,
Dmemtable_list_test.cc225 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
249 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
256 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
263 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
342 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
365 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
372 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
425 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
431 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
493 &max_covering_tombstone_seq, ReadOptions()); in TEST_F()
[all …]
Ddb_tailing_iter_test.cc27 ReadOptions read_options; in TEST_F()
46 ReadOptions read_options; in TEST_F()
68 ReadOptions read_options; in TEST_F()
131 ReadOptions read_options; in TEST_F()
260 ReadOptions read_options; in TEST_F()
298 ReadOptions read_options; in TEST_F()
331 ReadOptions read_options; in TEST_F()
357 ReadOptions read_options; in TEST_F()
393 ReadOptions read_options; in TEST_F()
440 ReadOptions read_options; in TEST_F()
[all …]
Ddb_merge_operator_test.cc46 ReadOptions read_opt; in GetWithReadCallback()
95 ASSERT_TRUE(db_->Get(ReadOptions(), "k1", &value).ok()); in TEST_F()
106 ASSERT_TRUE(db_->Get(ReadOptions(), "k2", &value).ok()); in TEST_F()
117 ASSERT_TRUE(db_->Get(ReadOptions(), "k3", &value).ok()); in TEST_F()
131 ASSERT_TRUE(db_->Get(ReadOptions(), "k4", &value).ok()); in TEST_F()
144 ASSERT_TRUE(db_->Get(ReadOptions(), "k1", &value).IsCorruption()); in TEST_F()
174 auto* iter = db_->NewIterator(ReadOptions()); in TEST_F()
179 iter = db_->NewIterator(ReadOptions()); in TEST_F()
193 iter = db_->NewIterator(ReadOptions()); in TEST_F()
401 ReadOptions ro; in TEST_P()
[all …]
Ddb_range_del_test.cc274 ReadOptions read_opts; in TEST_F()
484 ReadOptions read_opts; in TEST_F()
519 ReadOptions read_opts; in TEST_F()
610 ReadOptions read_opts; in TEST_F()
701 ReadOptions read_opts; in TEST_F()
734 ReadOptions read_opts; in TEST_F()
760 ReadOptions read_opts; in TEST_F()
794 ReadOptions read_opts; in TEST_F()
828 ReadOptions read_opts; in TEST_F()
1424 ReadOptions read_opts; in TEST_F()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.h40 struct ReadOptions;
104 const ReadOptions& read_options,
115 InternalIterator* NewIterator(const ReadOptions&,
122 const ReadOptions& read_options) override;
125 Status Get(const ReadOptions& readOptions, const Slice& key,
129 void MultiGet(const ReadOptions& readOptions,
172 Status VerifyChecksum(const ReadOptions& readOptions,
224 const ReadOptions& ro, const BlockHandle& block_handle,
231 TBlockIter* NewDataBlockIterator(const ReadOptions& ro,
304 const ReadOptions& options, const MultiGetRange* batch,
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h178 virtual Status Get(const ReadOptions& options,
184 virtual Status Get(const ReadOptions& options, in Get()
193 virtual Status Get(const ReadOptions& options, const Slice& key,
195 virtual Status Get(const ReadOptions& options, const Slice& key, in Get()
204 const ReadOptions& options,
215 virtual void MultiGet(const ReadOptions& options,
253 virtual Status GetForUpdate(const ReadOptions& options,
261 virtual Status GetForUpdate(const ReadOptions& options,
283 const ReadOptions& options,
288 const ReadOptions& options, const std::vector<Slice>& keys,
[all …]
Dwrite_batch_with_index.h32 struct ReadOptions;
177 const ReadOptions* opts = nullptr);
206 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
210 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
213 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
218 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
222 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
264 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
267 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
/rocksdb-6.9/examples/
Dsimple_example.cc35 s = db->Get(ReadOptions(), "key1", &value); in main()
47 s = db->Get(ReadOptions(), "key1", &value); in main()
50 db->Get(ReadOptions(), "key2", &value); in main()
55 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key2", &pinnable_val); in main()
64 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key2", &pinnable_val); in main()
71 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key1", &pinnable_val); in main()
75 db->Get(ReadOptions(), db->DefaultColumnFamily(), "key2", &pinnable_val); in main()
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.h55 Status Get(const ReadOptions& options, ColumnFamilyHandle* column_family,
61 Status Get(const ReadOptions& options, const Slice& key, in Get()
67 Status GetForUpdate(const ReadOptions& options,
72 Status GetForUpdate(const ReadOptions& options,
77 Status GetForUpdate(const ReadOptions& options, const Slice& key, in GetForUpdate()
86 const ReadOptions& options,
91 std::vector<Status> MultiGet(const ReadOptions& options, in MultiGet()
105 const ReadOptions& options,
111 const ReadOptions& options, const std::vector<Slice>& keys, in MultiGetForUpdate()
119 Iterator* GetIterator(const ReadOptions& read_options) override;
[all …]
/rocksdb-6.9/include/rocksdb/
Ddb.h45 struct ReadOptions;
398 virtual inline Status Get(const ReadOptions& options, in Get()
410 virtual Status Get(const ReadOptions& options,
432 virtual Status Get(const ReadOptions& /*options*/, in Get() argument
471 const ReadOptions& options,
484 const ReadOptions& /*options*/, in MultiGet() argument
521 virtual void MultiGet(const ReadOptions& options,
543 virtual void MultiGet(const ReadOptions& options,
647 virtual bool KeyMayExist(const ReadOptions& options,
681 const ReadOptions& options,
[all …]
/rocksdb-6.9/table/
Dtable_reader.h25 struct ReadOptions;
51 const ReadOptions&, const SliceTransform* prefix_extractor, Arena* arena,
56 const ReadOptions& /*read_options*/) { in NewRangeTombstoneIterator() argument
98 virtual Status Get(const ReadOptions& readOptions, const Slice& key,
103 virtual void MultiGet(const ReadOptions& readOptions,
131 virtual Status VerifyChecksum(const ReadOptions& /*read_options*/, in VerifyChecksum() argument
/rocksdb-6.9/utilities/blob_db/
Dblob_db.h138 virtual Status Get(const ReadOptions& options,
143 virtual Status Get(const ReadOptions& options,
146 virtual Status Get(const ReadOptions& options, const Slice& key, in Get()
153 const ReadOptions& options,
157 const ReadOptions& options, in MultiGet()
171 virtual void MultiGet(const ReadOptions& /*options*/,
199 virtual Iterator* NewIterator(const ReadOptions& options) override = 0;
200 virtual Iterator* NewIterator(const ReadOptions& options, in NewIterator()
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration_test.cc77 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
104 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
145 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
172 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
220 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
247 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
294 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
321 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_P()
384 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_F()
407 std::unique_ptr<Iterator> it(db_->NewIterator(ReadOptions())); in TEST_F()
/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java25 final ReadOptions readOptions = new ReadOptions()) { in main()
59 final WriteOptions writeOptions, final ReadOptions readOptions) in readCommitted()
94 final WriteOptions writeOptions, final ReadOptions readOptions) in repeatableRead()
142 final ReadOptions readOptions) throws RocksDBException { in readCommitted_monotonicAtomicViews()
DTransactionSample.java26 final ReadOptions readOptions = new ReadOptions()) { in main()
60 final WriteOptions writeOptions, final ReadOptions readOptions) in readCommitted()
95 final WriteOptions writeOptions, final ReadOptions readOptions) in repeatableRead()
139 final ReadOptions readOptions) throws RocksDBException { in readCommitted_monotonicAtomicViews()

12345678910