Lines Matching refs:immutable_db_options_
262 if (immutable_db_options_.write_dbid_to_manifest) { in NewDB()
271 ROCKS_LOG_INFO(immutable_db_options_.info_log, "Creating manifest 1 \n"); in NewDB()
281 immutable_db_options_.manifest_preallocation_size); in NewDB()
284 immutable_db_options_.listeners)); in NewDB()
290 s = SyncManifest(env_, &immutable_db_options_, log.file()); in NewDB()
361 immutable_db_options_.wal_dir, in Recover()
362 immutable_db_options_.db_paths); in Recover()
375 if (immutable_db_options_.create_if_missing) { in Recover()
386 if (immutable_db_options_.error_if_exists) { in Recover()
400 immutable_db_options_.use_direct_io_for_flush_and_compaction; in Recover()
422 if (!immutable_db_options_.best_efforts_recovery) { in Recover()
452 if (immutable_db_options_.write_dbid_to_manifest && s.ok()) { in Recover()
466 if (immutable_db_options_.paranoid_checks && s.ok()) { in Recover()
479 if (s.ok() && immutable_db_options_.persist_stats_to_disk) { in Recover()
510 if (!immutable_db_options_.best_efforts_recovery) { in Recover()
511 s = env_->GetChildren(immutable_db_options_.wal_dir, &filenames); in Recover()
515 immutable_db_options_.wal_dir); in Recover()
543 std::string fname = LogFileName(immutable_db_options_.wal_dir, log); in Recover()
627 immutable_db_options_.info_log, in PersistentStatsProcessFormatVersion()
633 immutable_db_options_.info_log, in PersistentStatsProcessFormatVersion()
735 if (immutable_db_options_.wal_filter != nullptr) { in RecoverLogFiles()
744 immutable_db_options_.wal_filter->ColumnFamilyLogNumberMap(cf_lognumber_map, in RecoverLogFiles()
756 ROCKS_LOG_INFO(immutable_db_options_.info_log, in RecoverLogFiles()
767 std::string fname = LogFileName(immutable_db_options_.wal_dir, log_number); in RecoverLogFiles()
769 ROCKS_LOG_INFO(immutable_db_options_.info_log, in RecoverLogFiles()
771 static_cast<int>(immutable_db_options_.wal_recovery_mode)); in RecoverLogFiles()
775 auto info_log = immutable_db_options_.info_log.get(); in RecoverLogFiles()
802 std::move(file), fname, immutable_db_options_.log_readahead_size)); in RecoverLogFiles()
808 reporter.info_log = immutable_db_options_.info_log.get(); in RecoverLogFiles()
810 if (!immutable_db_options_.paranoid_checks || in RecoverLogFiles()
811 immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
821 log::Reader reader(immutable_db_options_.info_log, std::move(file_reader), in RecoverLogFiles()
832 immutable_db_options_.wal_recovery_mode) && in RecoverLogFiles()
842 if (immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
858 if (immutable_db_options_.wal_filter != nullptr) { in RecoverLogFiles()
863 immutable_db_options_.wal_filter->LogRecordFound( in RecoverLogFiles()
880 immutable_db_options_.wal_filter->Name()); in RecoverLogFiles()
893 immutable_db_options_.wal_filter->Name()); in RecoverLogFiles()
911 immutable_db_options_.info_log, in RecoverLogFiles()
917 static_cast<int>(immutable_db_options_.wal_recovery_mode), in RecoverLogFiles()
918 immutable_db_options_.wal_filter->Name(), new_count, in RecoverLogFiles()
923 immutable_db_options_.wal_filter->Name()); in RecoverLogFiles()
988 if (immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
992 } else if (immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
1001 ROCKS_LOG_INFO(immutable_db_options_.info_log, in RecoverLogFiles()
1006 assert(immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
1008 immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
1033 (immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
1035 immutable_db_options_.wal_recovery_mode == in RecoverLogFiles()
1039 ROCKS_LOG_ERROR(immutable_db_options_.info_log, in RecoverLogFiles()
1077 if (flushed || !immutable_db_options_.avoid_flush_during_recovery) { in RecoverLogFiles()
1143 assert(immutable_db_options_.avoid_flush_during_recovery); in RestoreAliveLogFiles()
1153 std::string fname = LogFileName(immutable_db_options_.wal_dir, log_number); in RestoreAliveLogFiles()
1170 BuildDBOptions(immutable_db_options_, mutable_db_options_)), in RestoreAliveLogFiles()
1180 ROCKS_LOG_WARN(immutable_db_options_.info_log, in RestoreAliveLogFiles()
1208 ROCKS_LOG_DEBUG(immutable_db_options_.info_log, in WriteLevel0TableForRecovery()
1255 LogFlush(immutable_db_options_.info_log); in WriteLevel0TableForRecovery()
1256 ROCKS_LOG_DEBUG(immutable_db_options_.info_log, in WriteLevel0TableForRecovery()
1332 BuildDBOptions(immutable_db_options_, mutable_db_options_); in CreateWAL()
1336 LogFileName(immutable_db_options_.wal_dir, log_file_num); in CreateWAL()
1339 ROCKS_LOG_INFO(immutable_db_options_.info_log, in CreateWAL()
1343 LogFileName(immutable_db_options_.wal_dir, recycle_log_number); in CreateWAL()
1356 const auto& listeners = immutable_db_options_.listeners; in CreateWAL()
1361 immutable_db_options_.recycle_log_file_num > 0, in CreateWAL()
1362 immutable_db_options_.manual_wal_flush); in CreateWAL()
1391 s = impl->env_->CreateDirIfMissing(impl->immutable_db_options_.wal_dir); in Open()
1394 for (auto& db_path : impl->immutable_db_options_.db_paths) { in Open()
1423 impl->wal_in_db_path_ = IsWalDirSameAsDBPath(&impl->immutable_db_options_); in Open()
1511 s = log_writer->file()->Sync(impl->immutable_db_options_.use_fsync); in Open()
1517 if (s.ok() && impl->immutable_db_options_.persist_stats_to_disk) { in Open()
1567 impl->immutable_db_options_.sst_file_manager.get()); in Open()
1593 paths.emplace_back(impl->immutable_db_options_.db_paths[0].path); in Open()
1604 impl->immutable_db_options_.env->GetChildren(path, &existing_files); in Open()
1629 impl->immutable_db_options_.db_paths[0].path); in Open()
1634 ROCKS_LOG_HEADER(impl->immutable_db_options_.info_log, "DB pointer %p", in Open()
1636 LogFlush(impl->immutable_db_options_.info_log); in Open()