diff --git a/cpp/src/db/DBImpl.cpp b/cpp/src/db/DBImpl.cpp index f3978447f5ba64d74430aff2f05c79d9ef8975ae..057573be04ed23c987d0d9aefb8470cf9255c9b5 100644 --- a/cpp/src/db/DBImpl.cpp +++ b/cpp/src/db/DBImpl.cpp @@ -312,7 +312,7 @@ Status DBImpl::background_merge_files(const std::string& table_id) { merge_files(table_id, kv.first, kv.second); } - _pMeta->archive_files(); + _pMeta->Archive(); try_build_index(); @@ -350,7 +350,7 @@ Status DBImpl::build_index(const meta::TableFileSchema& file) { << " from file " << to_remove.file_id; index->Cache(); - _pMeta->archive_files(); + _pMeta->Archive(); return Status::OK(); } diff --git a/cpp/src/db/DBMetaImpl.cpp b/cpp/src/db/DBMetaImpl.cpp index 4210822d73ba30ee364d03b5afb0d61a44359aa7..4871d5a51faf8b15ac4746be564697215e1d7e34 100644 --- a/cpp/src/db/DBMetaImpl.cpp +++ b/cpp/src/db/DBMetaImpl.cpp @@ -433,7 +433,7 @@ Status DBMetaImpl::GetTableFile(TableFileSchema& file_schema) { } // PXU TODO: Support Swap -Status DBMetaImpl::archive_files() { +Status DBMetaImpl::Archive() { auto& criterias = _options.archive_conf.GetCriterias(); if (criterias.size() == 0) { return Status::OK(); @@ -496,7 +496,7 @@ Status DBMetaImpl::Size(long& result) { } Status DBMetaImpl::discard_files_of_size(long to_discard_size) { - LOG(DEBUG) << "Abort to discard size=" << to_discard_size; + LOG(DEBUG) << "About to discard size=" << to_discard_size; if (to_discard_size <= 0) { return Status::OK(); } @@ -507,15 +507,15 @@ Status DBMetaImpl::discard_files_of_size(long to_discard_size) { order_by(&TableFileSchema::id), limit(10)); std::vector ids; + TableFileSchema table_file; for (auto& file : selected) { if (to_discard_size <= 0) break; - TableFileSchema group_file; - group_file.id = std::get<0>(file); - group_file.size = std::get<1>(file); - ids.push_back(group_file.id); - LOG(DEBUG) << "Discard group_file.id=" << group_file.id << " group_file.size=" << group_file.size; - to_discard_size -= group_file.size; + table_file.id = std::get<0>(file); + table_file.size = std::get<1>(file); + ids.push_back(table_file.id); + LOG(DEBUG) << "Discard table_file.id=" << table_file.file_id << " table_file.size=" << table_file.size; + to_discard_size -= table_file.size; } if (ids.size() == 0) { diff --git a/cpp/src/db/DBMetaImpl.h b/cpp/src/db/DBMetaImpl.h index fbc3aa1d79fdc4203c2a693d51052b61dabb4d68..8832c30a522f487d8333a7b90b91a8e6d8c7edb8 100644 --- a/cpp/src/db/DBMetaImpl.h +++ b/cpp/src/db/DBMetaImpl.h @@ -42,7 +42,7 @@ public: virtual Status files_to_index(TableFilesSchema&) override; - virtual Status archive_files() override; + virtual Status Archive() override; virtual Status Size(long& result) override; diff --git a/cpp/src/db/Meta.h b/cpp/src/db/Meta.h index 060d8c772c0ee0cb2855afa9e93f8a7d6b1fbf9b..6a0993a9a670f8b015dcab857d2644da560e7c75 100644 --- a/cpp/src/db/Meta.h +++ b/cpp/src/db/Meta.h @@ -44,7 +44,7 @@ public: virtual Status Size(long& result) = 0; - virtual Status archive_files() = 0; + virtual Status Archive() = 0; virtual Status files_to_index(TableFilesSchema&) = 0; diff --git a/cpp/unittest/db/meta_tests.cpp b/cpp/unittest/db/meta_tests.cpp index 7e4e2bf13de86f5c4b773068c724896280665c4c..8051d2ebcca6acfbfe342c19d78176c4291ff2e0 100644 --- a/cpp/unittest/db/meta_tests.cpp +++ b/cpp/unittest/db/meta_tests.cpp @@ -123,7 +123,7 @@ TEST_F(MetaTest, ARCHIVE_TEST_DAYS) { days.push_back(day); } - impl.archive_files(); + impl.Archive(); int i = 0; for (auto file : files) { @@ -166,7 +166,7 @@ TEST_F(MetaTest, ARCHIVE_TEST_DISK) { files.push_back(table_file); } - impl.archive_files(); + impl.Archive(); int i = 0; for (auto file : files) {