Lines Matching refs:result
36 DBOptions result(src); in SanitizeOptions() local
38 if (result.env == nullptr) { in SanitizeOptions()
39 result.env = Env::Default(); in SanitizeOptions()
43 if (result.max_open_files != -1) { in SanitizeOptions()
48 ClipToRange(&result.max_open_files, 20, max_max_open_files); in SanitizeOptions()
50 &result.max_open_files); in SanitizeOptions()
53 if (result.info_log == nullptr) { in SanitizeOptions()
54 Status s = CreateLoggerFromOptions(dbname, result, &result.info_log); in SanitizeOptions()
57 result.info_log = nullptr; in SanitizeOptions()
61 if (!result.write_buffer_manager) { in SanitizeOptions()
62 result.write_buffer_manager.reset( in SanitizeOptions()
63 new WriteBufferManager(result.db_write_buffer_size)); in SanitizeOptions()
66 result.max_background_flushes, result.max_background_compactions, in SanitizeOptions()
67 result.max_background_jobs, true /* parallelize_compactions */); in SanitizeOptions()
68 result.env->IncBackgroundThreadsIfNeeded(bg_job_limits.max_compactions, in SanitizeOptions()
70 result.env->IncBackgroundThreadsIfNeeded(bg_job_limits.max_flushes, in SanitizeOptions()
73 if (result.rate_limiter.get() != nullptr) { in SanitizeOptions()
74 if (result.bytes_per_sync == 0) { in SanitizeOptions()
75 result.bytes_per_sync = 1024 * 1024; in SanitizeOptions()
79 if (result.delayed_write_rate == 0) { in SanitizeOptions()
80 if (result.rate_limiter.get() != nullptr) { in SanitizeOptions()
81 result.delayed_write_rate = result.rate_limiter->GetBytesPerSecond(); in SanitizeOptions()
83 if (result.delayed_write_rate == 0) { in SanitizeOptions()
84 result.delayed_write_rate = 16 * 1024 * 1024; in SanitizeOptions()
88 if (result.WAL_ttl_seconds > 0 || result.WAL_size_limit_MB > 0) { in SanitizeOptions()
89 result.recycle_log_file_num = false; in SanitizeOptions()
92 if (result.recycle_log_file_num && in SanitizeOptions()
93 (result.wal_recovery_mode == WALRecoveryMode::kPointInTimeRecovery || in SanitizeOptions()
94 result.wal_recovery_mode == WALRecoveryMode::kAbsoluteConsistency)) { in SanitizeOptions()
99 result.recycle_log_file_num = 0; in SanitizeOptions()
102 if (result.wal_dir.empty()) { in SanitizeOptions()
104 result.wal_dir = dbname; in SanitizeOptions()
106 if (result.wal_dir.back() == '/') { in SanitizeOptions()
107 result.wal_dir = result.wal_dir.substr(0, result.wal_dir.size() - 1); in SanitizeOptions()
110 if (result.db_paths.size() == 0) { in SanitizeOptions()
111 result.db_paths.emplace_back(dbname, std::numeric_limits<uint64_t>::max()); in SanitizeOptions()
114 if (result.use_direct_reads && result.compaction_readahead_size == 0) { in SanitizeOptions()
116 result.compaction_readahead_size = 1024 * 1024 * 2; in SanitizeOptions()
119 if (result.compaction_readahead_size > 0 || result.use_direct_reads) { in SanitizeOptions()
120 result.new_table_reader_for_compaction_inputs = true; in SanitizeOptions()
126 if (result.allow_2pc) { in SanitizeOptions()
127 result.avoid_flush_during_recovery = false; in SanitizeOptions()
131 ImmutableDBOptions immutable_db_options(result); in SanitizeOptions()
140 result.env->GetChildren(result.wal_dir, &filenames); in SanitizeOptions()
145 std::string trash_file = result.wal_dir + "/" + filename; in SanitizeOptions()
146 result.env->DeleteFile(trash_file); in SanitizeOptions()
154 auto sfm = static_cast<SstFileManagerImpl*>(result.sst_file_manager.get()); in SanitizeOptions()
155 for (size_t i = 0; i < result.db_paths.size(); i++) { in SanitizeOptions()
156 DeleteScheduler::CleanupDirectory(result.env, sfm, result.db_paths[i].path); in SanitizeOptions()
161 if (result.sst_file_manager.get() == nullptr) { in SanitizeOptions()
163 NewSstFileManager(result.env, result.info_log)); in SanitizeOptions()
164 result.sst_file_manager = sst_file_manager; in SanitizeOptions()
168 if (!result.paranoid_checks) { in SanitizeOptions()
169 result.skip_checking_sst_file_sizes_on_db_open = true; in SanitizeOptions()
170 ROCKS_LOG_INFO(result.info_log, in SanitizeOptions()
174 return result; in SanitizeOptions()