Home
last modified time | relevance | path

Searched refs:opts (Results 1 – 25 of 55) sorted by relevance

123

/rocksdb-6.9/tools/
Dsst_dump_test.cc43 Env* env = opts.env; in createSST()
133 Options opts; in TEST_F() local
134 opts.env = env(); in TEST_F()
151 Options opts; in TEST_F() local
152 opts.env = env(); in TEST_F()
173 Options opts; in TEST_F() local
174 opts.env = env(); in TEST_F()
195 Options opts; in TEST_F() local
196 opts.env = env(); in TEST_F()
217 Options opts; in TEST_F() local
[all …]
Dldb_cmd_test.cc80 Options opts; in TEST_F() local
81 opts.env = env.get(); in TEST_F()
82 opts.create_if_missing = true; in TEST_F()
260 Options opts; in TEST_F() local
261 opts.env = env.get(); in TEST_F()
262 opts.create_if_missing = true; in TEST_F()
344 Options opts; in TEST_F() local
345 opts.env = env.get(); in TEST_F()
430 Options opts; in TEST_F() local
470 Options opts; in TEST_F() local
[all …]
Dsst_dump_tool.cc210 Options opts; in ShowAllCompressionSizes() local
211 opts.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in ShowAllCompressionSizes()
212 opts.statistics->set_stats_level(StatsLevel::kAll); in ShowAllCompressionSizes()
213 const ImmutableCFOptions imoptions(opts); in ShowAllCompressionSizes()
214 const ColumnFamilyOptions cfo(opts); in ShowAllCompressionSizes()
216 ROCKSDB_NAMESPACE::InternalKeyComparator ikc(opts.comparator); in ShowAllCompressionSizes()
238 opts.statistics->getAndResetTickerCount(NUMBER_BLOCK_COMPRESSED); in ShowAllCompressionSizes()
240 opts.statistics->getAndResetTickerCount(NUMBER_BLOCK_NOT_COMPRESSED); in ShowAllCompressionSizes()
/rocksdb-6.9/java/rocksjni/
Dtransaction_options.cc34 auto* opts = in Java_org_rocksdb_TransactionOptions_isSetSnapshot() local
46 auto* opts = in Java_org_rocksdb_TransactionOptions_setSetSnapshot() local
59 auto* opts = in Java_org_rocksdb_TransactionOptions_isDeadlockDetect() local
72 auto* opts = in Java_org_rocksdb_TransactionOptions_setDeadlockDetect() local
85 auto* opts = in Java_org_rocksdb_TransactionOptions_getLockTimeout() local
99 auto* opts = in Java_org_rocksdb_TransactionOptions_setLockTimeout() local
112 auto* opts = in Java_org_rocksdb_TransactionOptions_getExpiration() local
126 auto* opts = in Java_org_rocksdb_TransactionOptions_setExpiration() local
138 auto* opts = in Java_org_rocksdb_TransactionOptions_getDeadlockDetectDepth() local
151 auto* opts = in Java_org_rocksdb_TransactionOptions_setDeadlockDetectDepth() local
[all …]
Dtransaction_db_options.cc37 auto* opts = in Java_org_rocksdb_TransactionDBOptions_getMaxNumLocks() local
49 auto* opts = in Java_org_rocksdb_TransactionDBOptions_setMaxNumLocks() local
62 auto* opts = in Java_org_rocksdb_TransactionDBOptions_getNumStripes() local
76 auto* opts = in Java_org_rocksdb_TransactionDBOptions_setNumStripes() local
88 auto* opts = in Java_org_rocksdb_TransactionDBOptions_getTransactionLockTimeout() local
101 auto* opts = in Java_org_rocksdb_TransactionDBOptions_setTransactionLockTimeout() local
113 auto* opts = in Java_org_rocksdb_TransactionDBOptions_getDefaultLockTimeout() local
126 auto* opts = in Java_org_rocksdb_TransactionDBOptions_setDefaultLockTimeout() local
139 auto* opts = in Java_org_rocksdb_TransactionDBOptions_getWritePolicy() local
154 auto* opts = in Java_org_rocksdb_TransactionDBOptions_setWritePolicy() local
[all …]
Doptimistic_transaction_options.cc23 ROCKSDB_NAMESPACE::OptimisticTransactionOptions* opts = in Java_org_rocksdb_OptimisticTransactionOptions_newOptimisticTransactionOptions() local
25 return reinterpret_cast<jlong>(opts); in Java_org_rocksdb_OptimisticTransactionOptions_newOptimisticTransactionOptions()
35 auto* opts = in Java_org_rocksdb_OptimisticTransactionOptions_isSetSnapshot() local
38 return opts->set_snapshot; in Java_org_rocksdb_OptimisticTransactionOptions_isSetSnapshot()
48 auto* opts = in Java_org_rocksdb_OptimisticTransactionOptions_setSetSnapshot() local
51 opts->set_snapshot = jset_snapshot; in Java_org_rocksdb_OptimisticTransactionOptions_setSetSnapshot()
62 auto* opts = in Java_org_rocksdb_OptimisticTransactionOptions_setComparator() local
65 opts->cmp = in Java_org_rocksdb_OptimisticTransactionOptions_setComparator()
/rocksdb-6.9/env/
Dio_posix.h139 virtual IOStatus Read(size_t n, const IOOptions& opts, Slice* result,
142 const IOOptions& opts, Slice* result,
240 virtual IOStatus Truncate(uint64_t size, const IOOptions& opts,
243 virtual IOStatus Append(const Slice& data, const IOOptions& opts,
246 const IOOptions& opts,
254 virtual uint64_t GetFileSize(const IOOptions& opts,
262 const IOOptions& opts,
266 const IOOptions& opts,
332 virtual IOStatus Append(const Slice& data, const IOOptions& opts,
337 virtual uint64_t GetFileSize(const IOOptions& opts,
[all …]
Dfile_system.cc31 const FileOptions& opts, in ReuseWritableFile() argument
34 IOStatus s = RenameFile(old_fname, fname, opts.io_options, dbg); in ReuseWritableFile()
38 return NewWritableFile(fname, opts, result, dbg); in ReuseWritableFile()
/rocksdb-6.9/db/
Ddb_range_del_test.cc145 opts.target_file_size_base = 100 * opts.max_compaction_bytes; in TEST_F()
146 Reopen(opts); in TEST_F()
256 Reopen(opts); in TEST_F()
296 Reopen(opts); in TEST_F()
463 Reopen(opts); in TEST_F()
509 Reopen(opts); in TEST_F()
535 Reopen(opts); in TEST_F()
590 Reopen(opts); in TEST_F()
688 Reopen(opts); in TEST_F()
719 Reopen(opts); in TEST_F()
[all …]
Ddb_universal_compaction_test.cc1800 Reopen(opts); in TEST_P()
1929 Reopen(opts); in TEST_F()
1967 opts.num_levels = 1; in TEST_F()
1971 Reopen(opts); in TEST_F()
2008 Reopen(opts); in TEST_F()
2080 Reopen(opts); in TEST_F()
2122 Reopen(opts); in TEST_F()
2176 opts.env = env_; in TEST_F()
2179 opts.max_open_files = -1; in TEST_F()
2184 opts.num_levels = 5; in TEST_F()
[all …]
Drepair_test.cc276 Options opts(CurrentOptions()), rev_opts(CurrentOptions()); in TEST_F() local
277 opts.comparator = BytewiseComparator(); in TEST_F()
280 DestroyAndReopen(opts); in TEST_F()
283 std::vector<Options>{opts, rev_opts}); in TEST_F()
298 ASSERT_OK(RepairDB(dbname_, opts, {{"default", opts}, {"reverse", rev_opts}}, in TEST_F()
299 opts /* unknown_cf_opts */)); in TEST_F()
301 std::vector<Options>{opts, rev_opts})); in TEST_F()
323 ASSERT_OK(RepairDB(dbname_, opts, {{"default", opts}}, in TEST_F()
326 std::vector<Options>{opts, rev_opts})); in TEST_F()
Dcuckoo_table_db_test.cc57 Options opts; in Reopen() local
59 opts = *options; in Reopen()
61 opts = CurrentOptions(); in Reopen()
62 opts.create_if_missing = true; in Reopen()
64 ASSERT_OK(DB::Open(opts, dbname_, &db_)); in Reopen()
Drepair.cc147 Options opts(db_options_, *cf_opts); in AddColumnFamily() local
148 MutableCFOptions mut_cf_opts(opts); in AddColumnFamily()
151 edit.SetComparatorName(opts.comparator->Name()); in AddColumnFamily()
675 Options opts(options); in RepairDB() local
677 DBOptions db_options(opts); in RepairDB()
678 ColumnFamilyOptions cf_options(opts); in RepairDB()
Ddb_table_properties_test.cc261 Options opts = CurrentOptions(); in TEST_F() local
262 opts.table_properties_collector_factories.emplace_back(compact_on_del); in TEST_F()
263 Reopen(opts); in TEST_F()
/rocksdb-6.9/options/
Doptions_test.cc1775 ColumnFamilyOptions opts; in TEST_F() local
1780 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1793 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1810 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1821 opts.prefix_extractor.reset(); in TEST_F()
1828 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1853 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1868 opts.merge_operator = nullptr; in TEST_F()
1873 ASSERT_OK(PersistCFOptions(opts)); in TEST_F()
1888 delete opts.compaction_filter; in TEST_F()
[all …]
Doptions_helper.cc863 std::string opts = trim(opts_str); in StringToMap() local
864 while (pos < opts.size()) { in StringToMap()
865 size_t eq_pos = opts.find('=', pos); in StringToMap()
876 while (pos < opts.size() && isspace(opts[pos])) { in StringToMap()
880 if (pos >= opts.size()) { in StringToMap()
884 if (opts[pos] == '{') { in StringToMap()
887 while (brace_pos < opts.size()) { in StringToMap()
888 if (opts[brace_pos] == '{') { in StringToMap()
904 while (pos < opts.size() && isspace(opts[pos])) { in StringToMap()
907 if (pos < opts.size() && opts[pos] != ';') { in StringToMap()
[all …]
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration.cc17 Options GetNoCompactionOptions(const Options& opts) { in GetNoCompactionOptions() argument
18 Options ret_opts = opts; in GetNoCompactionOptions()
88 Options opts = GetNoCompactionOptions(old_opts); in MigrateToUniversal() local
89 Status s = OpenDb(opts, dbname, &db); in MigrateToUniversal()
114 Options opts = old_opts; in MigrateToLevelBase() local
115 opts.target_file_size_base = new_opts.target_file_size_base; in MigrateToLevelBase()
122 return CompactToLevel(opts, dbname, 1, true); in MigrateToLevelBase()
132 Options opts = old_opts; in MigrateToLevelBase() local
133 opts.target_file_size_base = new_opts.target_file_size_base; in MigrateToLevelBase()
134 return CompactToLevel(opts, dbname, new_opts.num_levels - 1, true); in MigrateToLevelBase()
/rocksdb-6.9/table/
Dtable_reader_bench.cc72 void TableReaderBenchmark(Options& opts, EnvOptions& env_options, in TableReaderBenchmark() argument
77 ROCKSDB_NAMESPACE::InternalKeyComparator ikc(opts.comparator); in TableReaderBenchmark()
87 const ImmutableCFOptions ioptions(opts); in TableReaderBenchmark()
88 const ColumnFamilyOptions cfo(opts); in TableReaderBenchmark()
101 tb = opts.table_factory->NewTableBuilder( in TableReaderBenchmark()
109 s = DB::Open(opts, dbname, &db); in TableReaderBenchmark()
144 s = opts.table_factory->NewTableReader( in TableReaderBenchmark()
248 opts.table_factory->Name(), num_keys1, num_keys2, in TableReaderBenchmark()
257 DestroyDB(dbname, opts); in TableReaderBenchmark()
Dsst_file_reader.cc29 Rep(const Options& opts) in Rep()
30 : options(opts), in Rep()
/rocksdb-6.9/file/
Dsequence_file_reader.cc88 IOStatus Read(size_t n, const IOOptions& opts, Slice* result, char* scratch, in Read() argument
108 s = file_->Read(n, opts, result, scratch + cached_len, dbg); in Read()
117 s = ReadIntoBuffer(readahead_size_, opts, dbg); in Read()
154 IOStatus PositionedRead(uint64_t offset, size_t n, const IOOptions& opts, in PositionedRead() argument
157 return file_->PositionedRead(offset, n, opts, result, scratch, dbg); in PositionedRead()
190 IOStatus ReadIntoBuffer(size_t n, const IOOptions& opts, in ReadIntoBuffer() argument
197 IOStatus s = file_->Read(n, opts, &result, buffer_.BufferStart(), dbg); in ReadIntoBuffer()
Drandom_access_file_reader_test.cc59 void Read(const std::string& fname, const FileOptions& opts, in Read() argument
63 ASSERT_OK(fs_->NewRandomAccessFile(fpath, opts, &f, nullptr)); in Read()
112 FileOptions opts; in TEST_F() local
113 opts.use_direct_reads = true; in TEST_F()
115 Read(fname, opts, &r); in TEST_F()
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc270 Status DBWithTTLImpl::Write(const WriteOptions& opts, WriteBatch* updates) { in Write() argument
314 return db_->Write(opts, &(handler.updates_ttl)); in Write()
318 Iterator* DBWithTTLImpl::NewIterator(const ReadOptions& opts, in NewIterator() argument
320 return new TtlIterator(db_->NewIterator(opts, column_family)); in NewIterator()
325 Options opts; in SetTtl() local
326 opts = GetOptions(h); in SetTtl()
328 opts.compaction_filter_factory); in SetTtl()
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction_db.h70 virtual Status Write(const WriteOptions& opts, WriteBatch* updates) override;
71 inline Status WriteWithConcurrencyControl(const WriteOptions& opts, in WriteWithConcurrencyControl() argument
75 Transaction* txn = BeginInternalTransaction(opts); in WriteWithConcurrencyControl()
213 virtual Status Write(const WriteOptions& opts,
216 virtual Status Write(const WriteOptions& opts, WriteBatch* updates) override;
Dpessimistic_transaction_db.cc521 Status PessimisticTransactionDB::Write(const WriteOptions& opts, in Write() argument
523 return WriteWithConcurrencyControl(opts, updates); in Write()
526 Status WriteCommittedTxnDB::Write(const WriteOptions& opts, in Write() argument
529 return db_impl_->Write(opts, updates); in Write()
531 return WriteWithConcurrencyControl(opts, updates); in Write()
536 const WriteOptions& opts, in Write() argument
539 return db_impl_->Write(opts, updates); in Write()
541 return WriteWithConcurrencyControl(opts, updates); in Write()
/rocksdb-6.9/include/rocksdb/
Dfile_system.h100 FileOptions(const DBOptions& opts) in FileOptions()
101 : EnvOptions(opts) {} in FileOptions()
103 FileOptions(const EnvOptions& opts) in FileOptions()
104 : EnvOptions(opts) {} in FileOptions()
106 FileOptions(const FileOptions& opts) in FileOptions()
107 : EnvOptions(opts), io_options(opts.io_options) {} in FileOptions()
1161 void SanitizeFileOptions(FileOptions* opts) const override { in SanitizeFileOptions() argument
1162 target_->SanitizeFileOptions(opts); in SanitizeFileOptions()

123