Lines Matching refs:db_options_

40   auto s = env_->DeleteFile(db_options_.wal_dir + "/" + fname);  in DeleteFile()
55 s = GetSortedWalsOfType(db_options_.wal_dir, logs, kAliveLogFile); in GetSortedWalFiles()
68 std::string archivedir = ArchivalDirectory(db_options_.wal_dir); in GetSortedWalFiles()
83 ROCKS_LOG_INFO(db_options_.info_log, "Latest Archived log: %" PRIu64, in GetSortedWalFiles()
96 ROCKS_LOG_WARN(db_options_.info_log, "%s already moved to archive", in GetSortedWalFiles()
123 db_options_.wal_dir, &db_options_, read_options, file_options_, seq, in GetUpdatesSince()
137 bool const ttl_enabled = db_options_.wal_ttl_seconds > 0; in PurgeObsoleteWALFiles()
138 bool const size_limit_enabled = db_options_.wal_size_limit_mb > 0; in PurgeObsoleteWALFiles()
146 ROCKS_LOG_ERROR(db_options_.info_log, "Can't get current time: %s", in PurgeObsoleteWALFiles()
153 ? db_options_.wal_ttl_seconds / 2 in PurgeObsoleteWALFiles()
162 std::string archival_dir = ArchivalDirectory(db_options_.wal_dir); in PurgeObsoleteWALFiles()
166 ROCKS_LOG_ERROR(db_options_.info_log, "Can't get archive files: %s", in PurgeObsoleteWALFiles()
184 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
189 if (now_seconds - file_m_time > db_options_.wal_ttl_seconds) { in PurgeObsoleteWALFiles()
190 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
193 ROCKS_LOG_WARN(db_options_.info_log, "Can't delete file: %s: %s", in PurgeObsoleteWALFiles()
208 ROCKS_LOG_ERROR(db_options_.info_log, in PurgeObsoleteWALFiles()
217 s = DeleteDBFile(&db_options_, file_path, archival_dir, false, in PurgeObsoleteWALFiles()
220 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
239 static_cast<size_t>(db_options_.wal_size_limit_mb * 1024 * 1024 / log_file_size); in PurgeObsoleteWALFiles()
249 ROCKS_LOG_WARN(db_options_.info_log, in PurgeObsoleteWALFiles()
257 s = DeleteDBFile(&db_options_, db_options_.wal_dir + "/" + file_path, in PurgeObsoleteWALFiles()
258 db_options_.wal_dir, false, in PurgeObsoleteWALFiles()
261 ROCKS_LOG_WARN(db_options_.info_log, "Unable to delete file: %s: %s", in PurgeObsoleteWALFiles()
272 auto archived_log_name = ArchivedLogFileName(db_options_.wal_dir, number); in ArchiveWALFile()
278 ROCKS_LOG_INFO(db_options_.info_log, "Move log file %s to %s -- %s\n", in ArchiveWALFile()
375 ROCKS_LOG_ERROR(db_options_.info_log, "[WalManger] Unknown file type %s", in ReadFirstRecord()
390 std::string fname = LogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
401 ArchivedLogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
431 s = env_->GetFileSize(LogFileName(db_options_.wal_dir, number), &size_bytes); in GetLiveWalFile()
480 reporter.info_log = db_options_.info_log.get(); in ReadFirstLine()
483 reporter.ignore_error = !db_options_.paranoid_checks; in ReadFirstLine()
484 log::Reader reader(db_options_.info_log, std::move(file_reader), &reporter, in ReadFirstLine()
490 (status.ok() || !db_options_.paranoid_checks)) { in ReadFirstLine()