Home
last modified time | relevance | path

Searched refs:get (Results 1 – 25 of 340) sorted by relevance

12345678910>>...14

/rocksdb-6.9/utilities/simulator_cache/
Dcache_simulator_test.cc304 get.block_size = 1; in TEST_F()
307 get.block_key = "1"; in TEST_F()
308 get.get_id = 1; in TEST_F()
310 get.referenced_key = in TEST_F()
346 get.get_id = 2; in TEST_F()
357 get.get_id = 3; in TEST_F()
367 get.get_id = 3; in TEST_F()
378 get.get_id = 3; in TEST_F()
390 get.get_id = 4; in TEST_F()
406 get.get_id = 0; in TEST_F()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DColumnFamilyTest.java153 String retVal = new String(db.get(columnFamilyHandleList.get(1), in openWithColumnFamilies()
156 assertThat((db.get(columnFamilyHandleList.get(1), in openWithColumnFamilies()
159 assertThat((db.get(columnFamilyHandleList.get(1), in openWithColumnFamilies()
163 assertThat(db.get(columnFamilyHandleList.get(0), new ReadOptions(), in openWithColumnFamilies()
196 getResult = db.get(columnFamilyHandleList.get(0), "key1".getBytes(), in getWithOutValueAndCf()
201 getResult = db.get(columnFamilyHandleList.get(0), new ReadOptions(), in getWithOutValueAndCf()
317 assertThat(db.get(columnFamilyHandleList.get(1), in writeBatch()
319 assertThat(new String(db.get(columnFamilyHandleList.get(1), in writeBatch()
321 assertThat(new String(db.get(columnFamilyHandleList.get(1), in writeBatch()
537 iter = iterators.get(1); in iterators()
[all …]
DMemoryUtilTest.java55 assertThat(usage.get(MemoryUsageType.kMemTableTotal)).isEqualTo( in getApproximateMemoryUsageByType()
57 assertThat(usage.get(MemoryUsageType.kMemTableUnFlushed)).isEqualTo( in getApproximateMemoryUsageByType()
59 assertThat(usage.get(MemoryUsageType.kTableReadersTotal)).isEqualTo( in getApproximateMemoryUsageByType()
61 assertThat(usage.get(MemoryUsageType.kCacheTotal)).isEqualTo(0); in getApproximateMemoryUsageByType()
65 db.get(key); in getApproximateMemoryUsageByType()
69 assertThat(usage.get(MemoryUsageType.kMemTableTotal)).isEqualTo( in getApproximateMemoryUsageByType()
72 assertThat(usage.get(MemoryUsageType.kMemTableUnFlushed)).isEqualTo( in getApproximateMemoryUsageByType()
75 assertThat(usage.get(MemoryUsageType.kTableReadersTotal)).isEqualTo( in getApproximateMemoryUsageByType()
92 assertThat(usage.get(MemoryUsageType.kCacheTotal)).isEqualTo(null); in getApproximateMemoryUsageByTypeNulls()
128 db.get(key); in getApproximateMemoryUsageByTypeMultiple()
[all …]
DRocksDBTest.java128 assertThat(cfHandles.get(1)).isNotNull(); in createColumnFamilies()
130 assertThat(cfHandles.get(2)).isNotNull(); in createColumnFamilies()
224 result.get(tmp); in put()
236 result.get(tmp2); in put()
392 db.get(key); in getOutOfArrayMaxSizeValue()
677 db.put(columnFamilyHandles.get(1), in fullCompactRangeColumnFamily()
788 db.put(columnFamilyHandles.get(1), in compactRangeWithKeysColumnFamily()
840 db.put(columnFamilyHandles.get(1), in compactRangeWithKeysReduceColumnFamily()
1054 columnFamilyHandles.get(1), in compactRangeToLevelColumnFamily()
1427 assertThat(logFiles.get(0).type()) in getSortedWalFiles()
[all …]
DTtlDBTest.java34 assertThat(ttlDB.get("key".getBytes())). in ttlDBOpen()
36 assertThat(ttlDB.get("key".getBytes())).isNotNull(); in ttlDBOpen()
45 assertThat(ttlDB.get("key".getBytes())). in ttlDBOpenWithTtl()
49 assertThat(ttlDB.get("key".getBytes())).isNull(); in ttlDBOpenWithTtl()
71 assertThat(ttlDB.get("key".getBytes())). in ttlDbOpenWithColumnFamilies()
73 ttlDB.put(columnFamilyHandleList.get(1), "key".getBytes(), in ttlDbOpenWithColumnFamilies()
75 assertThat(ttlDB.get(columnFamilyHandleList.get(1), in ttlDbOpenWithColumnFamilies()
80 ttlDB.compactRange(columnFamilyHandleList.get(1)); in ttlDbOpenWithColumnFamilies()
82 assertThat(ttlDB.get("key".getBytes())).isNotNull(); in ttlDbOpenWithColumnFamilies()
83 assertThat(ttlDB.get(columnFamilyHandleList.get(1), in ttlDbOpenWithColumnFamilies()
[all …]
DMergeTest.java42 final byte[] value = db.get("key".getBytes()); in stringOption()
103 db.put(columnFamilyHandleList.get(1), in cFStringOption()
106 db.merge(columnFamilyHandleList.get(1), in cFStringOption()
109 byte[] value = db.get(columnFamilyHandleList.get(1), in cFStringOption()
145 db.put(columnFamilyHandleList.get(1), in cFUInt64AddOption()
148 db.merge(columnFamilyHandleList.get(1), in cFUInt64AddOption()
151 byte[] value = db.get(columnFamilyHandleList.get(1), in cFUInt64AddOption()
231 db.put(columnFamilyHandleList.get(1), in cFOperatorOption()
236 byte[] value = db.get(columnFamilyHandleList.get(1), in cFOperatorOption()
293 db.put(columnFamilyHandleList.get(1), in cFUInt64AddOperatorOption()
[all …]
DAbstractTransactionTest.java137 assertThat(txn2.get(readOptions, k1)).isNull(); in rollback()
168 assertThat(txn.get(readOptions, k2)).isNull(); in savePoint()
175 assertThat(txn2.get(readOptions, k2)).isNull(); in savePoint()
201 assertThat(txn.get(readOptions, k1)).isNull(); in getPut()
417 assertThat(txn.get(readOptions, k1)).isNull(); in delete()
441 assertThat(txn.get(testCf, readOptions, key)) in delete_parts_cf()
467 assertThat(txn.get(readOptions, key)).isNull(); in delete_parts()
492 assertThat(txn.get(readOptions, k1)).isNull(); in getPutUntracked()
593 assertThat(txn.get(readOptions, k1)).isNull(); in deleteUntracked()
638 assertThat(txn.get(readOptions, key)).isNull(); in deleteUntracked_parts()
[all …]
DBackupEngineTest.java68 be.deleteBackup(backupInfo.get(0).backupId()); in deleteBackup()
73 assertThat(newBackupInfo.get(0).backupId()). in deleteBackup()
74 isEqualTo(backupInfo.get(1).backupId()); in deleteBackup()
102 assertThat(newBackupInfo.get(0).backupId()). in purgeOldBackups()
103 isEqualTo(backupInfo.get(3).backupId()); in purgeOldBackups()
130 assertThat(new String(db.get("key1".getBytes()))).endsWith("V3"); in restoreLatestBackup()
131 assertThat(new String(db.get("key2".getBytes()))).endsWith("V3"); in restoreLatestBackup()
147 assertThat(new String(db.get("key1".getBytes()))).endsWith("V2"); in restoreLatestBackup()
148 assertThat(new String(db.get("key2".getBytes()))).endsWith("V2"); in restoreLatestBackup()
180 assertThat(new String(db.get("key1".getBytes()))).endsWith("V3"); in restoreFromBackup()
[all …]
DTableFilterTest.java48 db.put(columnFamilyHandles.get(0), in readOptions()
50 db.put(columnFamilyHandles.get(0), in readOptions()
52 db.put(columnFamilyHandles.get(0), in readOptions()
54 db.put(columnFamilyHandles.get(1), in readOptions()
56 db.put(columnFamilyHandles.get(1), in readOptions()
58 db.put(columnFamilyHandles.get(1), in readOptions()
64 db.newIterator(columnFamilyHandles.get(0), readOptions)) { in readOptions()
74 db.newIterator(columnFamilyHandles.get(1), readOptions)) { in readOptions()
84 assertThat(cfNameCollectingTableFilter.cfNames.get(0)) in readOptions()
86 assertThat(cfNameCollectingTableFilter.cfNames.get(1)) in readOptions()
DKeyMayExistTest.java95 exists = db.keyMayExist(columnFamilyHandleList.get(0), "key".getBytes(UTF_8), in keyMayExist()
101 exists = db.keyMayExist(columnFamilyHandleList.get(0), "key".getBytes(UTF_8), in keyMayExist()
118 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
124 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
129 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
135 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
141 exists = db.keyMayExist(columnFamilyHandleList.get(1), in keyMayExist()
145 exists = db.keyMayExist(columnFamilyHandleList.get(1), in keyMayExist()
150 exists = db.keyMayExist(columnFamilyHandleList.get(1), in keyMayExist()
154 exists = db.keyMayExist(columnFamilyHandleList.get(1), in keyMayExist()
[all …]
DWriteBatchTest.java76 assertThat(handler.getEvents().get(0)).isEqualTo(new Event(PUT, foo, bar)); in multipleBatchOperations()
78 assertThat(handler.getEvents().get(2)).isEqualTo(new Event(PUT, baz, boo)); in multipleBatchOperations()
79 assertThat(handler.getEvents().get(3)).isEqualTo(new Event(MERGE, baz, hoo)); in multipleBatchOperations()
228 assertThat(db.get("key1".getBytes())).isEqualTo("value".getBytes()); in deleteRange()
229 assertThat(db.get("key2".getBytes())).isEqualTo("12345678".getBytes()); in deleteRange()
230 assertThat(db.get("key3".getBytes())).isEqualTo("abcdefg".getBytes()); in deleteRange()
231 assertThat(db.get("key4".getBytes())).isEqualTo("xyz".getBytes()); in deleteRange()
236 assertThat(db.get("key1".getBytes())).isEqualTo("value".getBytes()); in deleteRange()
237 assertThat(db.get("key2".getBytes())).isNull(); in deleteRange()
238 assertThat(db.get("key3".getBytes())).isNull(); in deleteRange()
[all …]
/rocksdb-6.9/db/
Dprefix_test.cc362 SeekIterator(iter.get(), 1, 6); in TEST_F()
365 SeekIterator(iter.get(), 1, 5); in TEST_F()
368 SeekIterator(iter.get(), 1, 5); in TEST_F()
374 SeekIterator(iter.get(), 2, 0); in TEST_F()
387 SeekIterator(iter.get(), 1, 7); in TEST_F()
391 SeekIterator(iter.get(), 1, 6); in TEST_F()
400 SeekIterator(iter.get(), 2, 0); in TEST_F()
408 SeekIterator(iter.get(), 1, 7); in TEST_F()
412 SeekIterator(iter.get(), 1, 5); in TEST_F()
422 SeekIterator(iter.get(), 1, 5); in TEST_F()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_picker_test.cc142 ASSERT_TRUE(compaction.get() == nullptr); in TEST_F()
153 ASSERT_TRUE(compaction.get() == nullptr); in TEST_F()
166 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
179 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
197 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
228 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
275 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
299 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
324 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
353 ASSERT_TRUE(compaction.get() != nullptr); in TEST_F()
[all …]
/rocksdb-6.9/table/block_based/
Dpartitioned_filter_block_test.cc203 NewBuilder(pib.get())); in TestBlockPerKey()
218 VerifyReader(builder.get(), pib.get()); in TestBlockPerKey()
238 VerifyReader(builder.get(), pib.get(), prefix_extractor); in TestBlockPerTwoKeys()
244 NewBuilder(pib.get())); in TestBlockPerAllKeys()
256 VerifyReader(builder.get(), pib.get()); in TestBlockPerAllKeys()
302 VerifyReader(builder.get(), pib.get(), empty); in TEST_P()
330 NewBuilder(pib.get(), prefix_extractor.get())); in TEST_P()
337 CutABlock(pib.get(), pkeys[2]); in TEST_P()
339 NewReader(builder.get(), pib.get())); in TEST_P()
369 NewBuilder(pib.get(), prefix_extractor.get())); in TEST_P()
[all …]
Dblock_test.cc380 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
386 nullptr, stats.get()); in TEST_F()
413 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
418 nullptr, stats.get()); in TEST_F()
448 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
453 nullptr, stats.get()); in TEST_F()
483 ASSERT_EQ(BlockReadAmpBitmap(100, 1, stats.get()).GetBytesPerBit(), 1u); in TEST_F()
484 ASSERT_EQ(BlockReadAmpBitmap(100, 2, stats.get()).GetBytesPerBit(), 2u); in TEST_F()
485 ASSERT_EQ(BlockReadAmpBitmap(100, 4, stats.get()).GetBytesPerBit(), 4u); in TEST_F()
504 bool useValueDeltaEncoding() const { return std::get<0>(GetParam()); } in useValueDeltaEncoding()
[all …]
/rocksdb-6.9/utilities/backupable/
Dbackupable_db_test.cc559 backupdir_, test_backup_env_.get(), true, logger_.get(), true)); in BackupableDBTest()
1196 FillDB(db_.get(), 0, 300); in TEST_F()
1371 FillDB(db_.get(), 0, 100); in TEST_F()
1373 FillDB(db_.get(), 100, 200); in TEST_F()
1375 FillDB(db_.get(), 200, 300); in TEST_F()
1447 FillDB(db_.get(), 0, 100); in TEST_F()
1479 FillDB(db_.get(), 0, 100); in TEST_F()
1482 db_.get(), true, in TEST_F()
1500 FillDB(db_.get(), 0, 100); in TEST_F()
1573 FillDB(db_.get(), 0, 100); in TEST_F()
[all …]
/rocksdb-6.9/tools/rdb/
Dunit_test.js53 assert.equal(a.get(1), null)
54 assert.equal(a.get(['a']), null)
55 assert.equal(a.get('a', 1), null)
56 assert.equal(a.get(1, 'a'), null)
57 assert.equal(a.get(1, 1), null)
73 assert.equal(a.get(), null)
74 assert.equal(a.get('a'), null)
82 assert.equal(a.get('a'), 'first')
88 assert.equal(a.get('a'), 'first')
92 assert.equal(a.get('b'), null)
[all …]
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java398 int len = db_.get(key, value); in runTask()
436 num_ = (Integer) flags.get(Flag.num); in DbBenchmark()
439 flags.get(Flag.num) : flags.get(Flag.reads)); in DbBenchmark()
444 randSeed_ = (Long) flags.get(Flag.seed); in DbBenchmark()
445 databaseDir_ = (String) flags.get(Flag.db); in DbBenchmark()
548 (Integer)flags_.get(Flag.open_files)); in prepareOptions()
550 (Boolean)flags_.get(Flag.use_fsync)); in prepareOptions()
552 (String)flags_.get(Flag.wal_dir)); in prepareOptions()
558 (Boolean)flags_.get(Flag.mmap_read)); in prepareOptions()
560 (Boolean)flags_.get(Flag.mmap_write)); in prepareOptions()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc675 AssertItersEqual(iter.get(), result_iter.get()); in TEST_F()
1362 AssertKey("k", iter.get()); in TEST_F()
1364 AssertKey("l", iter.get()); in TEST_F()
1367 AssertKey("m", iter.get()); in TEST_F()
1370 AssertKey("mm", iter.get()); in TEST_F()
1371 AssertValue("kk", iter.get()); in TEST_F()
1375 AssertKey("n", iter.get()); in TEST_F()
1377 AssertKey("mm", iter.get()); in TEST_F()
1381 AssertKey("ab", iter.get()); in TEST_F()
1384 AssertKey("x", iter.get()); in TEST_F()
[all …]
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java127 byte[] value = db.get("hello".getBytes()); in main()
140 System.out.format("%s ", new String(db.get( in main()
163 System.out.format("%s ", new String(db.get( in main()
169 value = db.get("1x1".getBytes()); in main()
171 value = db.get("world".getBytes()); in main()
180 byte[] testResult = db.get(testKey); in main()
184 testResult = db.get(readOptions, testKey); in main()
192 len = db.get(testKey, insufficientArray); in main()
196 len = db.get(testKey, enoughArray); in main()
207 len = db.get(testKey, enoughArray); in main()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRocksDB.java49 if (libraryLoaded.get() == LibraryState.LOADED) { in loadLibrary()
289 .get(i); in open()
413 .get(i); in openReadOnly()
557 = columnFamilyDescriptors.get(i); in createColumnFamilies()
1912 return get(nativeHandle_, key, offset, len, in get()
2039 keyValueMap.put(keys.get(i), values[i]); in multiGet()
2098 keyValueMap.put(keys.get(i), values[i]); in multiGet()
2138 keyValueMap.put(keys.get(i), values[i]); in multiGet()
2198 keyValueMap.put(keys.get(i), values[i]); in multiGet()
4208 final Range range = ranges.get(i); in toRangeSliceHandles()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/util/
DBytewiseComparator.java62 start.get(diffIndex) == limit.get(diffIndex)) {
69 final int startByte = start.get(diffIndex) & 0xff;
70 final int limitByte = limit.get(diffIndex) & 0xff;
79 start.put(diffIndex, (byte)((start.get(diffIndex) & 0xff) + 1));
94 if ((start.get(diffIndex) & 0xff) <
96 start.put(diffIndex, (byte)((start.get(diffIndex) & 0xff) + 1));
112 final int byt = key.get(i) & 0xff;
/rocksdb-6.9/java/rocksjni/
Dsst_file_manager.cc66 sptr_sst_file_manager->get()->SetMaxAllowedSpaceUsage(jmax_allowed_space); in Java_org_rocksdb_SstFileManager_setMaxAllowedSpaceUsage()
80 sptr_sst_file_manager->get()->SetCompactionBufferSize( in Java_org_rocksdb_SstFileManager_setCompactionBufferSize()
94 return sptr_sst_file_manager->get()->IsMaxAllowedSpaceReached(); in Java_org_rocksdb_SstFileManager_isMaxAllowedSpaceReached()
108 return sptr_sst_file_manager->get() in Java_org_rocksdb_SstFileManager_isMaxAllowedSpaceReachedIncludingCompactions()
123 return sptr_sst_file_manager->get()->GetTotalSize(); in Java_org_rocksdb_SstFileManager_getTotalSize()
137 auto tracked_files = sptr_sst_file_manager->get()->GetTrackedFiles(); in Java_org_rocksdb_SstFileManager_getTrackedFiles()
190 return sptr_sst_file_manager->get()->GetDeleteRateBytesPerSecond(); in Java_org_rocksdb_SstFileManager_getDeleteRateBytesPerSecond()
203 sptr_sst_file_manager->get()->SetDeleteRateBytesPerSecond(jdelete_rate); in Java_org_rocksdb_SstFileManager_setDeleteRateBytesPerSecond()
217 return sptr_sst_file_manager->get()->GetMaxTrashDBRatio(); in Java_org_rocksdb_SstFileManager_getMaxTrashDBRatio()
232 sptr_sst_file_manager->get()->SetMaxTrashDBRatio(jratio); in Java_org_rocksdb_SstFileManager_setMaxTrashDBRatio()
/rocksdb-6.9/tools/
Ddb_crashtest.py123 test_tmpdir = os.environ.get(_TEST_DIR_ENV_VAR)
209 if dest_params.get("compression_type") != "zstd" or \
219 if dest_params.get("test_batches_snapshots") == 1 or \
220 dest_params.get("use_txn") == 1:
224 if dest_params.get("unordered_write", 0) == 1:
227 if dest_params.get("disable_wal", 0) == 1:
230 if dest_params.get("open_files", 1) != -1:
235 if dest_params.get("compaction_style", 0) == 2:
245 if dest_params.get("atomic_flush", 0) == 1:
378 if cmd_params.get('disable_wal', 0) == 1:
[all …]
/rocksdb-6.9/options/
Dcf_options.cc30 merge_operator(cf_options.merge_operator.get()), in ImmutableCFOptions()
32 compaction_filter_factory(cf_options.compaction_filter_factory.get()), in ImmutableCFOptions()
41 info_log(db_options.info_log.get()), in ImmutableCFOptions()
42 statistics(db_options.statistics.get()), in ImmutableCFOptions()
43 rate_limiter(db_options.rate_limiter.get()), in ImmutableCFOptions()
46 fs(db_options.fs.get()), in ImmutableCFOptions()
50 memtable_factory(cf_options.memtable_factory.get()), in ImmutableCFOptions()
51 table_factory(cf_options.table_factory.get()), in ImmutableCFOptions()
78 cf_options.memtable_insert_with_hint_prefix_extractor.get()), in ImmutableCFOptions()
81 file_checksum_gen_factory(db_options.file_checksum_gen_factory.get()) {} in ImmutableCFOptions()

12345678910>>...14