Skip to content

Commit 86d5027

Browse files
Hui Xiaoinikep
authored andcommitted
Replace usage of GetColumnFamilyOptionsFromString(const ColumnFamilyOptions& base_options...) for upcoming RocksDB deprecation
Reviewed By: yoshinorim Differential Revision: D42943192 fbshipit-source-id: fbed01c
1 parent 8382ccd commit 86d5027

File tree

1 file changed

+17
-5
lines changed

1 file changed

+17
-5
lines changed

storage/rocksdb/rdb_cf_options.cc

Lines changed: 17 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,14 +69,20 @@ void Rdb_cf_options::get(const std::string &cf_name,
6969
rocksdb::ColumnFamilyOptions *const opts) {
7070
assert(opts != nullptr);
7171

72+
rocksdb::ConfigOptions config_options;
73+
config_options.input_strings_escaped = false;
74+
config_options.ignore_unknown_options = false;
75+
7276
// Get defaults.
73-
rocksdb::GetColumnFamilyOptionsFromString(*opts, m_default_config, opts);
77+
rocksdb::GetColumnFamilyOptionsFromString(config_options, *opts,
78+
m_default_config, opts);
7479

7580
// Get a custom confguration if we have one.
7681
Name_to_config_t::iterator it = m_name_map.find(cf_name);
7782

7883
if (it != m_name_map.end()) {
79-
rocksdb::GetColumnFamilyOptionsFromString(*opts, it->second, opts);
84+
rocksdb::GetColumnFamilyOptionsFromString(config_options, *opts, it->second,
85+
opts);
8086
}
8187
}
8288

@@ -93,10 +99,13 @@ void Rdb_cf_options::update(const std::string &cf_name,
9399

94100
bool Rdb_cf_options::set_default(const std::string &default_config) {
95101
rocksdb::ColumnFamilyOptions options;
102+
rocksdb::ConfigOptions config_options;
103+
config_options.input_strings_escaped = false;
104+
config_options.ignore_unknown_options = false;
96105

97106
if (!default_config.empty()) {
98107
rocksdb::Status s = rocksdb::GetColumnFamilyOptionsFromString(
99-
options, default_config, &options);
108+
config_options, options, default_config, &options);
100109
if (!s.ok()) {
101110
// NO_LINT_DEBUG
102111
fprintf(stderr,
@@ -260,6 +269,9 @@ bool Rdb_cf_options::parse_cf_options(const std::string &cf_options,
260269
std::string opt_str;
261270
std::stringstream ss;
262271
rocksdb::ColumnFamilyOptions options;
272+
rocksdb::ConfigOptions config_options;
273+
config_options.input_strings_escaped = false;
274+
config_options.ignore_unknown_options = false;
263275

264276
// Only print warnings if the caller didn't pass an output stream
265277
bool print_warnings = (output == nullptr);
@@ -298,8 +310,8 @@ bool Rdb_cf_options::parse_cf_options(const std::string &cf_options,
298310
}
299311

300312
// Generate an error if the <opt_str> is not valid according to RocksDB.
301-
rocksdb::Status s =
302-
rocksdb::GetColumnFamilyOptionsFromString(options, opt_str, &options);
313+
rocksdb::Status s = rocksdb::GetColumnFamilyOptionsFromString(
314+
config_options, options, opt_str, &options);
303315
if (!s.ok()) {
304316
(*output) << "Invalid cf config for '" << cf.c_str()
305317
<< "' in override options: " << s.getState()

0 commit comments

Comments
 (0)