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

Add gc running gauge

Browse Source 
Summary: title

Reviewers: dgleich

Reviewed By: dgleich

Differential Revision: https://phabricator.memgraph.io/D1228
This commit is contained in:
Marin Tomic 2018-02-22 15:30:47 +01:00
parent c7eaf4711a
commit fc75fadee3
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/database/storage_gc.hpp
View File

@ -5,6 +5,7 @@
#include "data_structures/concurrent/concurrent_map.hpp" #include "data_structures/concurrent/concurrent_map.hpp"
#include "database/storage.hpp" #include "database/storage.hpp"
#include "mvcc/version_list.hpp" #include "mvcc/version_list.hpp"
#include "stats/metrics.hpp"
#include "storage/deferred_deleter.hpp" #include "storage/deferred_deleter.hpp"
#include "storage/edge.hpp" #include "storage/edge.hpp"
#include "storage/garbage_collector.hpp" #include "storage/garbage_collector.hpp"
@ -15,6 +16,12 @@
namespace database { namespace database {
namespace {
stats::Gauge &gc_running = stats::GetGauge("storage.garbage_collection", 0);
} // namespace
/** Garbage collection capabilities for database::Storage. Extracted into a /** Garbage collection capabilities for database::Storage. Extracted into a
* separate class for better code organization, and because the GC requires a * separate class for better code organization, and because the GC requires a
* tx::Engine, while the Storage itself can exist without it. Even though, a * tx::Engine, while the Storage itself can exist without it. Even though, a
@ -70,8 +77,12 @@ class StorageGc {
{ {
// This can be run concurrently // This can be run concurrently
utils::Timer x; utils::Timer x;
gc_running.Set(1);
vertices_.gc_.Run(snapshot, tx_engine_); vertices_.gc_.Run(snapshot, tx_engine_);
edges_.gc_.Run(snapshot, tx_engine_); edges_.gc_.Run(snapshot, tx_engine_);
gc_running.Set(0);
VLOG(1) << "Garbage collector mvcc phase time: " << x.Elapsed().count(); VLOG(1) << "Garbage collector mvcc phase time: " << x.Elapsed().count();
} }
// This has to be run sequentially after gc because gc modifies // This has to be run sequentially after gc because gc modifies