mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2026-01-06 11:00:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Insert stats when shutting down

Browse Source
This commit is contained in:
Francesco Mazzoli
2023-07-17 12:27:07 +00:00
parent dcb76a86c2
commit 2b1b1a1c15
2 changed files with 40 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
cpp/cdc/CDC.cpp
View File

@@ -673,6 +673,23 @@ public:
std::vector<Stat> stats;
std::string prefix = "cdc";
const auto insertCDCStats = [this, &stats]() {
std::string err;
for (CDCMessageKind kind : allCDCMessageKind) {
std::ostringstream prefix;
prefix << "cdc." << kind;
_shared.timings[(int)kind]->toStats(prefix.str(), stats);
}
err = insertStats(_shuckleHost, _shucklePort, 10_sec, stats);
stats.clear();
if (err.empty()) {
for (CDCMessageKind kind : allCDCMessageKind) {
_shared.timings[(int)kind]->reset();
}
}
return err;
};
#define GO_TO_NEXT_ITERATION \
sleepFor(10_ms); \
continue; \
@@ -695,22 +712,14 @@ public:
LOG_INFO(_env, "about to insert stats to %s:%s", _shuckleHost, _shucklePort);
std::string err;
for (CDCMessageKind kind : allCDCMessageKind) {
std::ostringstream prefix;
prefix << "cdc." << kind;
_shared.timings[(int)kind]->toStats(prefix.str(), stats);
}
err = insertStats(_shuckleHost, _shucklePort, 10_sec, stats);
err = insertCDCStats();
lastRequestSuccessful = err.empty();
lastRequestT = t;
if (!lastRequestSuccessful) {
RAISE_ALERT(_env, "could not reach shuckle: %s", err);
GO_TO_NEXT_ITERATION
}
stats.clear();
for (CDCMessageKind kind : allCDCMessageKind) {
_shared.timings[(int)kind]->reset();
}
LOG_INFO(_env, "stats inserted, will wait one hour");
}
#undef GO_TO_NEXT_ITERATION