| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_impl.cc | 75 DBOptions db_options = db_->GetDBOptions(); in CreateCheckpoint() local
86 db_options.info_log, in CreateCheckpoint()
102 db_options.info_log, in CreateCheckpoint()
112 db_options, in CreateCheckpoint()
125 db_options.use_fsync); in CreateCheckpoint()
167 const DBOptions& db_options, in CreateCustomCheckpoint() argument
189 if (!db_options.allow_2pc) { in CreateCustomCheckpoint()
217 if (s.ok() && db_options.allow_2pc) { in CreateCustomCheckpoint()
345 const auto db_options = db_->GetDBOptions(); in ExportColumnFamily() local
361 ROCKS_LOG_INFO(db_options.info_log, in ExportColumnFamily()
[all …]
|
| /rocksdb-6.9/options/ |
| D | cf_options.cc | 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()
44 info_log_level(db_options.info_log_level), in ImmutableCFOptions()
45 env(db_options.env), in ImmutableCFOptions()
46 fs(db_options.fs.get()), in ImmutableCFOptions()
47 allow_mmap_reads(db_options.allow_mmap_reads), in ImmutableCFOptions()
49 db_paths(db_options.db_paths), in ImmutableCFOptions()
58 use_fsync(db_options.use_fsync), in ImmutableCFOptions()
74 listeners(db_options.listeners), in ImmutableCFOptions()
[all …]
|
| D | db_options.cc.d | 1 options/db_options.cc.d options/db_options.o: options/db_options.cc \
2 options/db_options.h include/rocksdb/options.h \
|
| /rocksdb-6.9/tools/advisor/test/ |
| D | test_db_options_parser.py | 23 self.db_options = DatabaseOptions(self.og_options, misc_options)
73 options = self.db_options.get_all_options()
79 expected_misc_options, self.db_options.get_misc_options()
82 ['default', 'col_fam_A'], self.db_options.get_column_families()
92 options = self.db_options.get_options(opt_to_get)
121 options = self.db_options.get_options(get_opts)
134 self.db_options.update_options(update_opts)
140 options = self.db_options.get_options(get_opts)
148 expected_misc_options, self.db_options.get_misc_options()
154 self.db_options.generate_options_config('testing')
[all …]
|
| D | test_db_bench_runner.py | 24 self.db_options = DatabaseOptions(options_path)
56 self.db_options.update_options(update_dict)
58 self.db_options, db_path
69 self.db_options.update_options(update_dict)
71 self.db_options, db_path
82 self.db_options.update_options(update_dict)
85 self.db_options, db_path
88 self.db_options.get_misc_options()
115 self.db_options = DatabaseOptions(options_path)
119 self.db_options.update_options(update_dict)
[all …]
|
| /rocksdb-6.9/file/ |
| D | file_util.cc | 92 Status DeleteDBFile(const ImmutableDBOptions* db_options, in DeleteDBFile() argument
97 static_cast<SstFileManagerImpl*>(db_options->sst_file_manager.get()); in DeleteDBFile()
101 return db_options->env->DeleteFile(fname); in DeleteDBFile()
109 return db_options->env->DeleteFile(fname); in DeleteDBFile()
113 bool IsWalDirSameAsDBPath(const ImmutableDBOptions* db_options) { in IsWalDirSameAsDBPath() argument
115 assert(!db_options->db_paths.empty()); in IsWalDirSameAsDBPath()
116 Status s = db_options->env->AreFilesSame(db_options->wal_dir, in IsWalDirSameAsDBPath()
117 db_options->db_paths[0].path, &same); in IsWalDirSameAsDBPath()
119 same = db_options->wal_dir == db_options->db_paths[0].path; in IsWalDirSameAsDBPath()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_open.cc | 32 return Options(db_options, cf_options); in SanitizeOptions()
193 const DBOptions& db_options, in ValidateOptions() argument
202 s = ValidateOptions(db_options); in ValidateOptions()
212 if (db_options.allow_mmap_reads && db_options.use_direct_reads) { in ValidateOptions()
219 if (db_options.allow_mmap_writes && in ValidateOptions()
231 if (db_options.unordered_write && in ValidateOptions()
237 if (db_options.unordered_write && db_options.enable_pipelined_write) { in ValidateOptions()
242 if (db_options.atomic_flush && db_options.enable_pipelined_write) { in ValidateOptions()
248 if (db_options.atomic_flush && db_options.best_efforts_recovery) { in ValidateOptions()
1290 DBOptions db_options(options); in Open() local
[all …]
|
| D | db_impl_readonly.cc | 19 DBImplReadOnly::DBImplReadOnly(const DBOptions& db_options, in DBImplReadOnly() argument
21 : DBImpl(db_options, dbname) { in DBImplReadOnly()
140 DBOptions db_options(options); in OpenForReadOnly() local
147 s = DB::OpenForReadOnly(db_options, dbname, column_families, &handles, dbptr); in OpenForReadOnly()
158 const DBOptions& db_options, const std::string& dbname, in OpenForReadOnly() argument
166 DBImplReadOnly* impl = new DBImplReadOnly(db_options, dbname); in OpenForReadOnly()
|
| /rocksdb-6.9/env/ |
| D | file_system.cc | 56 const DBOptions& db_options) const { in OptimizeForLogWrite()
58 optimized_file_options.bytes_per_sync = db_options.wal_bytes_per_sync; in OptimizeForLogWrite()
60 db_options.writable_file_max_buffer_size; in OptimizeForLogWrite()
71 const ImmutableDBOptions& db_options) const { in OptimizeForCompactionTableWrite()
74 db_options.use_direct_io_for_flush_and_compaction; in OptimizeForCompactionTableWrite()
80 const ImmutableDBOptions& db_options) const { in OptimizeForCompactionTableRead()
82 optimized_file_options.use_direct_reads = db_options.use_direct_reads; in OptimizeForCompactionTableRead()
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_bench_runner.py | 119 def get_log_options(self, db_options, db_path): argument
131 log_options = db_options.get_options([dump_period, log_dir])
199 def run_experiment(self, db_options, db_path): argument
201 self._setup_db_before_experiment(db_options, db_path)
203 command = self._build_experiment_command(db_options, db_path)
214 db_options, parsed_output[self.DB_PATH]
218 logs_file_prefix, db_options.get_column_families()
228 DataSource.Type.DB_OPTIONS: [db_options],
|
| D | rule_parser_example.py | 19 db_options = DatabaseOptions(args.rocksdb_options)
22 args.log_files_path_prefix, db_options.get_column_families()
29 DataSource.Type.DB_OPTIONS: [db_options],
42 data_sources, db_options.get_column_families()
|
| /rocksdb-6.9/tools/dump/ |
| D | rocksdb_dump.cc | 29 DEFINE_string(db_options, "",
45 ROCKSDB_NAMESPACE::Options db_options; in main() local
49 db_options, FLAGS_db_options, &parsed_options); in main()
54 db_options = parsed_options; in main()
58 if (!tool.Run(dump_options, db_options)) { in main()
|
| D | rocksdb_undump.cc | 28 DEFINE_string(db_options, "",
44 ROCKSDB_NAMESPACE::Options db_options; in main() local
48 db_options, FLAGS_db_options, &parsed_options); in main()
53 db_options = parsed_options; in main()
57 if (!tool.Run(undump_options, db_options)) { in main()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | optimistic_transaction_db_impl.cc | 41 DBOptions db_options(options); in Open() local
47 Status s = Open(db_options, dbname, column_families, &handles, dbptr); in Open()
59 const DBOptions& db_options, const std::string& dbname, in Open() argument
63 return OptimisticTransactionDB::Open(db_options, in Open()
69 const DBOptions& db_options, in Open() argument
92 s = DB::Open(db_options, dbname, column_families_copy, handles, &db); in Open()
|
| D | pessimistic_transaction_db.cc | 195 DBOptions db_options(options); in Open() local
201 Status s = TransactionDB::Open(db_options, txn_db_options, dbname, in Open()
214 const DBOptions& db_options, const TransactionDBOptions& txn_db_options, in Open() argument
221 db_options.unordered_write) { in Open()
226 db_options.unordered_write) { in Open()
232 db_options.unordered_write && !db_options.two_write_queues) { in Open()
240 DBOptions db_options_2pc = db_options; in Open()
266 DBOptions* db_options, std::vector<ColumnFamilyDescriptor>* column_families, in PrepareWrap() argument
286 db_options->allow_2pc = true; in PrepareWrap()
|
| /rocksdb-6.9/db/ |
| D | column_family.cc | 179 db_options.db_paths.size() > 1) { in CheckCFPathsSupported()
272 ROCKS_LOG_WARN(db_options.info_log.get(), in SanitizeOptions()
281 ROCKS_LOG_WARN(db_options.info_log.get(), in SanitizeOptions()
298 ROCKS_LOG_WARN(db_options.info_log.get(), in SanitizeOptions()
330 result.cf_paths = db_options.db_paths; in SanitizeOptions()
500 ioptions_(db_options, initial_cf_options_), in ColumnFamilyData()
520 allow_2pc_(db_options.allow_2pc), in ColumnFamilyData()
1289 if (s.ok() && db_options.unordered_write && in ValidateOptions()
1321 const DBOptions& db_options, in SetOptions() argument
1330 s = ValidateOptions(db_options, cf_options); in SetOptions()
[all …]
|
| D | wal_manager.h | 38 WalManager(const ImmutableDBOptions& db_options,
40 : db_options_(db_options), in db_options_() argument
42 env_(db_options.env), in db_options_()
43 fs_(db_options.fs.get()), in db_options_()
46 wal_in_db_path_(IsWalDirSameAsDBPath(&db_options)) {} in db_options_()
|
| D | c_test.c | 1201 rocksdb_options_t* db_options = rocksdb_options_create(); in main() local
1202 rocksdb_options_set_create_if_missing(db_options, 1); in main()
1203 db = rocksdb_open(db_options, dbname, &err); in main()
1343 rocksdb_options_destroy(db_options); in main()
1663 rocksdb_options_t* db_options = rocksdb_options_create(); in main() local
1664 rocksdb_options_set_create_if_missing(db_options, 1); in main()
1754 rocksdb_destroy_db(db_options, dbname, &err); in main()
1755 rocksdb_options_destroy(db_options); in main()
1785 rocksdb_options_set_create_if_missing(db_options, 1); in main()
1786 db = rocksdb_open(db_options, dbname, &err); in main()
[all …]
|
| D | manual_compaction_test.cc | 129 Options db_options; in TEST_F() local
130 db_options.write_buffer_size = 1024; in TEST_F()
131 db_options.create_if_missing = true; in TEST_F()
132 db_options.compression = kNoCompression; in TEST_F()
133 ASSERT_OK(DB::Open(db_options, dbname_, &db)); in TEST_F()
|
| D | repair.cc | 92 Repairer(const std::string& dbname, const DBOptions& db_options, in Repairer() argument
97 env_(db_options.env), in Repairer()
99 db_options_(SanitizeOptions(dbname_, db_options)), in Repairer()
645 Status RepairDB(const std::string& dbname, const DBOptions& db_options, in RepairDB() argument
651 Repairer repairer(dbname, db_options, column_families, in RepairDB()
660 Status RepairDB(const std::string& dbname, const DBOptions& db_options, in RepairDB() argument
666 Repairer repairer(dbname, db_options, in RepairDB()
677 DBOptions db_options(opts); in RepairDB() local
679 Repairer repairer(dbname, db_options, in RepairDB()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util.cc | 17 DBOptions* db_options, in LoadOptionsFromFile() argument
28 *db_options = *parser.db_opt(); in LoadOptionsFromFile()
75 DBOptions* db_options, in LoadLatestOptions() argument
84 return LoadOptionsFromFile(dbpath + "/" + options_file_name, env, db_options, in LoadLatestOptions()
89 const std::string& dbpath, Env* env, const DBOptions& db_options, in CheckOptionsCompatibility() argument
109 db_options, cf_names, cf_opts, dbpath + "/" + options_file_name, &fs, in CheckOptionsCompatibility()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2019-08-15-unordered-write.markdown | 25 DBOptions db_options;
26 db_options.unordered_write = true;
27 db_options.two_write_queues = true;
41 DBOptions db_options;
42 db_options.unordered_write = true;
44 DB::Open(db_options, kDBPath, &db);
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db.cc | 19 DBOptions db_options(options); in Open() local
25 Status s = BlobDB::Open(db_options, bdb_options, dbname, column_families, in Open()
36 Status BlobDB::Open(const DBOptions& db_options, in Open() argument
47 BlobDBImpl* blob_db_impl = new BlobDBImpl(dbname, bdb_options, db_options, in Open()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 73 DBOptions db_options(options); in Open() local
79 Status s = DBWithTTL::Open(db_options, dbname, column_families, &handles, in Open()
91 const DBOptions& db_options, const std::string& dbname, in Open() argument
106 db_options.env == nullptr ? Env::Default() : db_options.env); in Open()
112 st = DB::OpenForReadOnly(db_options, dbname, column_families_sanitized, in Open()
115 st = DB::Open(db_options, dbname, column_families_sanitized, handles, &db); in Open()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | options_util.h | 66 DBOptions* db_options,
76 DBOptions* db_options,
97 const std::string& dbpath, Env* env, const DBOptions& db_options,
|