tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added more logging to cleaner.

Browse Source
This commit is contained in:
Kruno Tomola Fabro 2016-08-30 15:25:11 +01:00
parent 2eb5d3c3ff
commit 7f4206e25c
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/dbms/cleaner.cpp
View File

@ -18,11 +18,15 @@ Cleaning::Cleaning(ConcurrentMap<std::string, Db> &dbs) : dbms(dbs)
std::time_t now = std::time(nullptr); std::time_t now = std::time(nullptr);
if (now >= last_clean + cleaning_cycle) { if (now >= last_clean + cleaning_cycle) {
logger.info("Started cleaning cyle");
for (auto &db : dbs.access()) { for (auto &db : dbs.access()) {
logger.info("Cleaning database \"{}\"", db.first);
DbTransaction t(db.second); DbTransaction t(db.second);
try { try {
logger.info("Cleaning edges");
t.clean_edge_section(); t.clean_edge_section();
logger.info("Cleaning vertices");
t.clean_vertex_section(); t.clean_vertex_section();
} catch (const std::exception &e) { } catch (const std::exception &e) {
logger.error( logger.error(
@ -34,6 +38,7 @@ Cleaning::Cleaning(ConcurrentMap<std::string, Db> &dbs) : dbms(dbs)
t.trans.commit(); t.trans.commit();
} }
last_clean = now; last_clean = now;
logger.info("Finished cleaning cyle");
} else { } else {
std::this_thread::sleep_for(std::chrono::seconds(1)); std::this_thread::sleep_for(std::chrono::seconds(1));
} }