提交 66b69818 编写于 作者: G groot

modify log

上级 2e3caca4
...@@ -799,7 +799,7 @@ DBImpl::BackgroundCompaction(std::set<std::string> table_ids) { ...@@ -799,7 +799,7 @@ DBImpl::BackgroundCompaction(std::set<std::string> table_ids) {
meta_ptr_->Archive(); meta_ptr_->Archive();
{ {
uint64_t ttl = 1 * meta::SECOND; // default: file will be deleted after few seconds uint64_t ttl = 10 * meta::SECOND; // default: file will be hard-deleted few seconds after soft-deleted
if (options_.mode_ == DBOptions::MODE::CLUSTER_WRITABLE) { if (options_.mode_ == DBOptions::MODE::CLUSTER_WRITABLE) {
ttl = meta::H_SEC; ttl = meta::H_SEC;
} }
......
...@@ -1801,8 +1801,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) { ...@@ -1801,8 +1801,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) {
mysqlpp::Query query = connectionPtr->query(); mysqlpp::Query query = connectionPtr->query();
query << "SELECT id, table_id, file_id, date" query << "SELECT id, table_id, file_id, date"
<< " FROM " << META_TABLEFILES << " WHERE file_type IN (" << " FROM " << META_TABLEFILES << " WHERE file_type IN ("
<< std::to_string(TableFileSchema::TO_DELETE) << "," << std::to_string(TableFileSchema::TO_DELETE) << "," << std::to_string(TableFileSchema::BACKUP) << ")"
<< std::to_string(TableFileSchema::BACKUP) << ")"
<< " AND updated_time < " << std::to_string(now - seconds * US_PS) << ";"; << " AND updated_time < " << std::to_string(now - seconds * US_PS) << ";";
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << query.str(); ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << query.str();
...@@ -1835,7 +1834,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) { ...@@ -1835,7 +1834,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) {
if (table_file.file_type_ == (int)TableFileSchema::TO_DELETE) { if (table_file.file_type_ == (int)TableFileSchema::TO_DELETE) {
// delete file from disk storage // delete file from disk storage
utils::DeleteTableFilePath(options_, table_file); utils::DeleteTableFilePath(options_, table_file);
ENGINE_LOG_DEBUG << "Removing file id:" << table_file.id_ << " location:" << table_file.location_; ENGINE_LOG_DEBUG << "Remove file id:" << table_file.id_ << " location:" << table_file.location_;
idsToDelete.emplace_back(std::to_string(table_file.id_)); idsToDelete.emplace_back(std::to_string(table_file.id_));
table_ids.insert(table_file.table_id_); table_ids.insert(table_file.table_id_);
...@@ -1863,7 +1862,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) { ...@@ -1863,7 +1862,7 @@ MySQLMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) {
} }
if (clean_files > 0) { if (clean_files > 0) {
ENGINE_LOG_DEBUG << "Clean " << clean_files << " files deleted in " << seconds << " seconds"; ENGINE_LOG_DEBUG << "Clean " << clean_files << " files expired in " << seconds << " seconds";
} }
} // Scoped Connection } // Scoped Connection
} catch (std::exception& e) { } catch (std::exception& e) {
......
...@@ -1351,7 +1351,7 @@ SqliteMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) { ...@@ -1351,7 +1351,7 @@ SqliteMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) {
// delete file from disk storage // delete file from disk storage
utils::DeleteTableFilePath(options_, table_file); utils::DeleteTableFilePath(options_, table_file);
ENGINE_LOG_DEBUG << "Removing file id:" << table_file.file_id_ << " location:" << table_file.location_; ENGINE_LOG_DEBUG << "Remove file id:" << table_file.file_id_ << " location:" << table_file.location_;
table_ids.insert(table_file.table_id_); table_ids.insert(table_file.table_id_);
} }
...@@ -1365,7 +1365,7 @@ SqliteMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) { ...@@ -1365,7 +1365,7 @@ SqliteMetaImpl::CleanUpFilesWithTTL(uint64_t seconds, CleanUpFilter* filter) {
} }
if (clean_files > 0) { if (clean_files > 0) {
ENGINE_LOG_DEBUG << "Clean " << clean_files << " files deleted in " << seconds << " seconds"; ENGINE_LOG_DEBUG << "Clean " << clean_files << " files expired in " << seconds << " seconds";
} }
} catch (std::exception& e) { } catch (std::exception& e) {
return HandleException("Encounter exception when clean table files", e.what()); return HandleException("Encounter exception when clean table files", e.what());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册