| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | DBOptionsTest.java | 45 assertThat(opt).isNotNull(); in getDBOptionsFromProps() 60 assertThat(opt).isNull(); in failDBOptionsFromPropsWithIllegalValue() 82 opt.optimizeForSmallDb(); in linkageOfPrepMethods() 90 opt.setEnv(env); in env() 152 opt.setMaxOpenFiles(intValue); in maxOpenFiles() 170 opt.setUseFsync(boolValue); in useFsync() 185 opt.setDbPaths(dbPaths); in dbPaths() 195 opt.setDbLogDir(str); in dbLogDir() 204 opt.setWalDir(str); in walDir() 644 opt.setAllow2pc(boolValue); in allow2pc() [all …]
|
| D | OptionsTest.java | 78 opt.setNumLevels(intValue); in numLevels() 382 opt.setUseFsync(boolValue); in useFsync() 397 opt.setDbPaths(dbPaths); in dbPaths() 407 opt.setDbLogDir(str); in dbLogDir() 416 opt.setWalDir(str); in walDir() 799 opt.setUnorderedWrite(true); in unordredWrite() 863 opt.setAllow2pc(boolValue); in allow2pc() 874 opt.setRowCache(lruCache); in rowCache() 976 opt.setTwoWriteQueues(true); in twoWriteQueues() 985 opt.setManualWalFlush(true); in manualWalFlush() [all …]
|
| D | ColumnFamilyOptionsTest.java | 49 assertThat(opt).isNotNull(); in getColumnFamilyOptionsFromProps() 64 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithIllegalValue() argument 66 assertThat(opt).isNull(); in failColumnFamilyOptionsFromPropsWithIllegalValue() 72 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithNullValue() argument 79 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithEmptyProps() argument 89 opt.setWriteBufferSize(longValue); in writeBufferSize() 116 opt.setNumLevels(intValue); in numLevels() 152 opt.setTargetFileSizeBase(longValue); in targetFileSizeBase() 263 opt.setArenaBlockSize(longValue); in arenaBlockSize() 326 opt.setBloomLocality(intValue); in bloomLocality() [all …]
|
| D | ReadOptionsTest.java | 38 opt.setVerifyChecksums(false); in copyConstructor() 39 opt.setFillCache(false); in copyConstructor() 66 opt.setFillCache(boolValue); in fillCache() 76 opt.setTailing(boolValue); in tailing() 84 opt.setSnapshot(null); in snapshot() 101 opt.setManaged(true); in managed() 109 opt.setTotalOrderSeek(true); in totalOrderSeek() 117 opt.setPrefixSameAsStart(true); in prefixSameAsStart() 125 opt.setPinData(true); in pinData() 143 opt.setReadaheadSize(longValue); in readaheadSize() [all …]
|
| D | CompactRangeOptionsTest.java | 23 opt.setExclusiveManualCompaction(value); in exclusiveManualCompaction() 48 opt.setChangeLevel(value); in changeLevel() 51 opt.setChangeLevel(value); in changeLevel() 59 opt.setTargetLevel(value); in targetLevel() 62 opt.setTargetLevel(value); in targetLevel() 70 opt.setTargetPathId(value); in targetPathId() 73 opt.setTargetPathId(value); in targetPathId() 81 opt.setAllowWriteStall(value); in allowWriteStall() 84 opt.setAllowWriteStall(value); in allowWriteStall() 92 opt.setMaxSubcompactions(value); in maxSubcompactions() [all …]
|
| D | CompactionOptionsUniversalTest.java | 22 opt.setSizeRatio(sizeRatio); in sizeRatio() 23 assertThat(opt.sizeRatio()).isEqualTo(sizeRatio); in sizeRatio() 31 opt.setMinMergeWidth(minMergeWidth); in minMergeWidth() 32 assertThat(opt.minMergeWidth()).isEqualTo(minMergeWidth); in minMergeWidth() 40 opt.setMaxMergeWidth(maxMergeWidth); in maxMergeWidth() 41 assertThat(opt.maxMergeWidth()).isEqualTo(maxMergeWidth); in maxMergeWidth() 49 opt.setMaxSizeAmplificationPercent(maxSizeAmplificationPercent); in maxSizeAmplificationPercent() 58 opt.setCompressionSizePercent(compressionSizePercent); in compressionSizePercent() 67 opt.setStopStyle(stopStyle); in stopStyle() 68 assertThat(opt.stopStyle()).isEqualTo(stopStyle); in stopStyle() [all …]
|
| D | CompressionOptionsTest.java | 22 opt.setWindowBits(windowBits); in windowBits() 23 assertThat(opt.windowBits()).isEqualTo(windowBits); in windowBits() 31 opt.setLevel(level); in level() 32 assertThat(opt.level()).isEqualTo(level); in level() 40 opt.setStrategy(strategy); in strategy() 41 assertThat(opt.strategy()).isEqualTo(strategy); in strategy() 49 opt.setMaxDictBytes(maxDictBytes); in maxDictBytes() 58 opt.setZStdMaxTrainBytes(zstdMaxTrainBytes); in zstdMaxTrainBytes() 66 assertThat(opt.enabled()).isFalse(); in enabled() 67 opt.setEnabled(true); in enabled() [all …]
|
| D | MergeTest.java | 32 try (final Options opt = new Options() in stringOption() argument 35 final RocksDB db = RocksDB.open(opt, in stringOption() 64 try (final Options opt = new Options() in uint64AddOption() argument 67 final RocksDB db = RocksDB.open(opt, in uint64AddOption() 168 final Options opt = new Options() in operatorOption() 171 final RocksDB db = RocksDB.open(opt, in operatorOption() 190 final Options opt = new Options() in uint64AddOperatorOption() 193 final RocksDB db = RocksDB.open(opt, in uint64AddOperatorOption() 418 try (final Options opt = new Options() in emptyStringInSetMergeOperatorByName() argument 429 opt.setMergeOperatorName(null); in nullStringInSetMergeOperatorByNameOptions() [all …]
|
| D | TransactionOptionsTest.java | 21 try (final TransactionOptions opt = new TransactionOptions()) { in snapshot() argument 23 opt.setSetSnapshot(boolValue); in snapshot() 24 assertThat(opt.isSetSnapshot()).isEqualTo(boolValue); in snapshot() 32 opt.setDeadlockDetect(boolValue); in deadlockDetect() 33 assertThat(opt.isDeadlockDetect()).isEqualTo(boolValue); in deadlockDetect() 41 opt.setLockTimeout(longValue); in lockTimeout() 42 assertThat(opt.getLockTimeout()).isEqualTo(longValue); in lockTimeout() 50 opt.setExpiration(longValue); in expiration() 51 assertThat(opt.getExpiration()).isEqualTo(longValue); in expiration() 59 opt.setDeadlockDetectDepth(longValue); in deadlockDetectDepth() [all …]
|
| D | TransactionDBOptionsTest.java | 21 try (final TransactionDBOptions opt = new TransactionDBOptions()) { in maxNumLocks() argument 23 opt.setMaxNumLocks(longValue); in maxNumLocks() 24 assertThat(opt.getMaxNumLocks()).isEqualTo(longValue); in maxNumLocks() 30 try (final TransactionDBOptions opt = new TransactionDBOptions()) { in maxNumStripes() argument 32 opt.setNumStripes(longValue); in maxNumStripes() 33 assertThat(opt.getNumStripes()).isEqualTo(longValue); in maxNumStripes() 41 opt.setTransactionLockTimeout(longValue); in transactionLockTimeout() 50 opt.setDefaultLockTimeout(longValue); in defaultLockTimeout() 51 assertThat(opt.getDefaultLockTimeout()).isEqualTo(longValue); in defaultLockTimeout() 59 opt.setWritePolicy(writePolicy); in writePolicy() [all …]
|
| D | BackupEngineTest.java | 33 try(final Options opt = new Options().setCreateIfMissing(true); in backupDb() argument 34 final RocksDB db = RocksDB.open(opt, in backupDb() 54 try(final Options opt = new Options().setCreateIfMissing(true); in deleteBackup() argument 55 final RocksDB db = RocksDB.open(opt, in deleteBackup() 82 try(final Options opt = new Options().setCreateIfMissing(true); in purgeOldBackups() argument 83 final RocksDB db = RocksDB.open(opt, in purgeOldBackups() 110 try(final Options opt = new Options().setCreateIfMissing(true)) { in restoreLatestBackup() argument 114 db = RocksDB.open(opt, in restoreLatestBackup() 165 db = RocksDB.open(opt, in restoreFromBackup() 195 db = RocksDB.open(opt, in restoreFromBackup() [all …]
|
| D | StatisticsTest.java | 36 final Options opt = new Options() in getTickerCount() 39 final RocksDB db = RocksDB.open(opt, in getTickerCount() 57 final Options opt = new Options() in getAndResetTickerCount() 60 final RocksDB db = RocksDB.open(opt, in getAndResetTickerCount() 82 final Options opt = new Options() in getHistogramData() 85 final RocksDB db = RocksDB.open(opt, in getHistogramData() 113 final Options opt = new Options() in getHistogramString() 116 final RocksDB db = RocksDB.open(opt, in getHistogramString() 133 final Options opt = new Options() in reset() 136 final RocksDB db = RocksDB.open(opt, in reset() [all …]
|
| D | CompactionOptionsFIFOTest.java | 21 try (final CompactionOptionsFIFO opt = new CompactionOptionsFIFO()) { in maxTableFilesSize() argument 22 opt.setMaxTableFilesSize(size); in maxTableFilesSize() 23 assertThat(opt.maxTableFilesSize()).isEqualTo(size); in maxTableFilesSize() 30 try (final CompactionOptionsFIFO opt = new CompactionOptionsFIFO()) { in allowCompaction() argument 31 opt.setAllowCompaction(allowCompaction); in allowCompaction() 32 assertThat(opt.allowCompaction()).isEqualTo(allowCompaction); in allowCompaction()
|
| /rocksdb-6.9/build_tools/ |
| D | gnu_parallel | 74 if($opt::header and not $opt::pipe) { 105 if($opt::filter_hosts and (@opt::sshlogin or @opt::sshloginfile)) { 110 if($opt::nonall or $opt::onall) { 121 if($opt::eta or $opt::bar) { 154 if($opt::pipe and @opt::a) { 863 if(defined $opt::i and $opt::i) { rpl('{}',$opt::i); } 883 if(defined $opt::header) { $opt::colsep = defined $opt::colsep ? $opt::colsep : "\t"; } 928 $opt::delay = $opt::sshdelay; 1035 $opt::progress = $opt::eta; 2353 if($opt::transfer or @opt::return or $opt::cleanup or @opt::basefile) { [all …]
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool_test.cc | 104 Options opt; in TEST_F() local 115 opt.wal_dir = wal_path_; in TEST_F() 119 VerifyOptions(opt); in TEST_F() 125 Options opt; in TEST_F() local 127 opt.num_levels = 1; in TEST_F() 138 opt.wal_dir = wal_path_; in TEST_F() 142 VerifyOptions(opt); in TEST_F() 148 Options opt; in TEST_F() local 150 opt.num_levels = 12; in TEST_F() 165 VerifyOptions(opt); in TEST_F() [all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | compaction_options_universal.cc | 33 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_setSizeRatio() local 45 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_sizeRatio() local 57 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_setMinMergeWidth() local 69 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_minMergeWidth() local 81 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_setMaxMergeWidth() local 93 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_maxMergeWidth() local 105 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_setMaxSizeAmplificationPercent() local 118 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_maxSizeAmplificationPercent() local 131 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_setCompressionSizePercent() local 144 auto* opt = in Java_org_rocksdb_CompactionOptionsUniversal_compressionSizePercent() local [all …]
|
| D | compression_options.cc | 22 return reinterpret_cast<jlong>(opt); in Java_org_rocksdb_CompressionOptions_newCompressionOptions() 33 opt->window_bits = static_cast<int>(jwindow_bits); in Java_org_rocksdb_CompressionOptions_setWindowBits() 44 return static_cast<jint>(opt->window_bits); in Java_org_rocksdb_CompressionOptions_windowBits() 55 opt->level = static_cast<int>(jlevel); in Java_org_rocksdb_CompressionOptions_setLevel() 66 return static_cast<jint>(opt->level); in Java_org_rocksdb_CompressionOptions_level() 77 opt->strategy = static_cast<int>(jstrategy); in Java_org_rocksdb_CompressionOptions_setStrategy() 88 return static_cast<jint>(opt->strategy); in Java_org_rocksdb_CompressionOptions_strategy() 110 return static_cast<jint>(opt->max_dict_bytes); in Java_org_rocksdb_CompressionOptions_maxDictBytes() 132 return static_cast<jint>(opt->zstd_max_train_bytes); in Java_org_rocksdb_CompressionOptions_zstdMaxTrainBytes() 143 opt->enabled = jenabled == JNI_TRUE; in Java_org_rocksdb_CompressionOptions_setEnabled() [all …]
|
| D | options.cc | 187 opt->comparator = comparator; in Java_org_rocksdb_Options_setComparatorHandle__JJB() 317 opt->statistics = *pSptr; in Java_org_rocksdb_Options_setStatistics() 533 opt->db_paths = db_paths; in Java_org_rocksdb_Options_setDbPaths() 1823 opt->wal_recovery_mode = in Java_org_rocksdb_Options_setWalRecoveryMode() 1837 opt->wal_recovery_mode); in Java_org_rocksdb_Options_walRecoveryMode() 3406 auto* opt = in Java_org_rocksdb_ColumnFamilyOptions_setComparatorHandle__JJB() local 3541 auto* opt = in Java_org_rocksdb_ColumnFamilyOptions_memTableFactoryName() local 3596 auto* opt = in Java_org_rocksdb_ColumnFamilyOptions_tableFactoryName() local 4974 opt->statistics = *pSptr; in Java_org_rocksdb_DBOptions_setStatistics() 5059 opt->db_paths = db_paths; in Java_org_rocksdb_DBOptions_setDbPaths() [all …]
|
| D | compaction_options_fifo.cc | 21 const auto* opt = new ROCKSDB_NAMESPACE::CompactionOptionsFIFO(); in Java_org_rocksdb_CompactionOptionsFIFO_newCompactionOptionsFIFO() local 22 return reinterpret_cast<jlong>(opt); in Java_org_rocksdb_CompactionOptionsFIFO_newCompactionOptionsFIFO() 32 auto* opt = in Java_org_rocksdb_CompactionOptionsFIFO_setMaxTableFilesSize() local 34 opt->max_table_files_size = static_cast<uint64_t>(jmax_table_files_size); in Java_org_rocksdb_CompactionOptionsFIFO_setMaxTableFilesSize() 44 auto* opt = in Java_org_rocksdb_CompactionOptionsFIFO_maxTableFilesSize() local 46 return static_cast<jlong>(opt->max_table_files_size); in Java_org_rocksdb_CompactionOptionsFIFO_maxTableFilesSize() 56 auto* opt = in Java_org_rocksdb_CompactionOptionsFIFO_setAllowCompaction() local 58 opt->allow_compaction = static_cast<bool>(allow_compaction); in Java_org_rocksdb_CompactionOptionsFIFO_setAllowCompaction() 68 auto* opt = in Java_org_rocksdb_CompactionOptionsFIFO_allowCompaction() local 70 return static_cast<jboolean>(opt->allow_compaction); in Java_org_rocksdb_CompactionOptionsFIFO_allowCompaction()
|
| /rocksdb-6.9/db/ |
| D | c.cc | 576 delete opt; in rocksdb_restore_options_destroy() 3143 delete opt; in rocksdb_readoptions_destroy() 3172 opt->rep.iterate_upper_bound = &opt->upper_bound; in rocksdb_readoptions_set_iterate_upper_bound() 3184 opt->rep.iterate_lower_bound = &opt->lower_bound; in rocksdb_readoptions_set_iterate_lower_bound() 3244 delete opt; in rocksdb_writeoptions_destroy() 3284 delete opt; in rocksdb_compactoptions_destroy() 3312 delete opt; in rocksdb_flushoptions_destroy() 3402 return opt; in rocksdb_envoptions_create() 3471 return opt; in rocksdb_ingestexternalfileoptions_create() 3505 delete opt; in rocksdb_ingestexternalfileoptions_destroy() [all …]
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_options_parser.py | 90 for opt in options_union: 91 diff[opt] = {} 93 if opt not in opt_old: 95 diff[opt][col_fam] = (None, opt_new[opt][col_fam]) 98 diff[opt][col_fam] = (opt_old[opt][col_fam], None) 102 if opt_old[opt][col_fam] != opt_new[opt][col_fam]: 108 diff[opt][col_fam] = (opt_old[opt][col_fam], None) 111 if opt_old[opt][col_fam] != opt_new[opt][col_fam]: 117 diff[opt][col_fam] = (None, opt_new[opt][col_fam]) 118 if not diff[opt]: [all …]
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-01-16-migrating-from-leveldb-to-rocksdb-2.markdown | 25 Options opt; 26 opt.create_if_missing = true; 27 opt.max_open_files = 1000; 28 opt.block_size = 4096; 48 LevelDBOptions opt; 50 opt.max_open_files = 1000; 51 opt.block_size = 4096; 72 - Options opt; 73 + LevelDBOptions opt; 98 Options opt; [all …]
|
| /rocksdb-6.9/utilities/memory/ |
| D | memory_test.cc | 104 Options opt; in TEST_F() local 105 opt.create_if_missing = true; in TEST_F() 107 opt.max_write_buffer_number = 10; in TEST_F() 109 opt.disable_auto_compactions = true; in TEST_F() 113 DestroyDB(GetDBName(i), opt); in TEST_F() 157 Options opt; in TEST_F() local 158 opt.create_if_missing = true; in TEST_F() 161 opt.max_write_buffer_number = 10; in TEST_F() 163 opt.disable_auto_compactions = true; in TEST_F() 167 {"one", ColumnFamilyOptions(opt)}, in TEST_F() [all …]
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | persistent_cache_bench.cc | 63 opt.writer_dispatch_size = FLAGS_writer_iosize; in NewBlockCache() 64 opt.writer_qdepth = FLAGS_writer_qdepth; in NewBlockCache() 65 opt.pipeline_writes = FLAGS_enable_pipelined_writes; in NewBlockCache() 66 opt.max_write_pipeline_backlog_size = std::numeric_limits<uint64_t>::max(); in NewBlockCache() 67 std::unique_ptr<PersistentCacheTier> cache(new BlockCacheTier(opt)); in NewBlockCache() 75 const size_t mem_size, const PersistentCacheConfig& opt) { in NewTieredCache() argument 99 PersistentCacheConfig opt(Env::Default(), FLAGS_path, in NewTieredCache() local 101 opt.writer_dispatch_size = FLAGS_writer_iosize; in NewTieredCache() 102 opt.writer_qdepth = FLAGS_writer_qdepth; in NewTieredCache() 103 opt.pipeline_writes = FLAGS_enable_pipelined_writes; in NewTieredCache() [all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | c.h | 161 rocksdb_restore_options_t* opt); 163 rocksdb_restore_options_t* opt, int v); 827 rocksdb_options_t* opt, uint64_t n); 867 rocksdb_options_t* opt); 906 rocksdb_options_t* opt, size_t v); 908 rocksdb_options_t* opt, size_t v); 995 rocksdb_options_t* opt, int level); 1048 rocksdb_options_t* opt, unsigned char); 1357 rocksdb_envoptions_t* opt); 1704 rocksdb_transactiondb_options_t* opt); [all …]
|