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

Assorted fixes

Browse Source
This commit is contained in:
Francesco Mazzoli
2023-01-30 22:14:45 +00:00
parent e90c1cadb8
commit 4243ff71e2
18 changed files with 349 additions and 249 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
cpp/cdc/CDC.cpp
View File

@@ -500,7 +500,7 @@ public:
if (_shared.stop.load()) {
return;
}
if (successfulIterationAt - eggsNow() < 1_mins) {
if (eggsNow() - successfulIterationAt < 1_mins) {
continue;
}
std::string err = fetchShards(_shuckleHost, _shucklePort, 100_ms, *shards);
@@ -564,10 +564,15 @@ public:
}
void run() {
EggsTime successfulIterationAt = 0;
for (;;) {
std::this_thread::sleep_for(std::chrono::milliseconds(10));
if (_shared.stop.load()) {
return;
}
if (eggsNow() - successfulIterationAt < 1_mins) {
continue;
}
uint16_t port = _shared.ownPort.load();
if (port == 0) {
// shard server isn't up yet
@@ -578,11 +583,11 @@ public:
std::string err = registerCDC(_shuckleHost, _shucklePort, 100_ms, _ownIp, port);
if (!err.empty()) {
RAISE_ALERT(_env, "Couldn't register ourselves with shuckle: %s", err);
std::this_thread::sleep_for(std::chrono::milliseconds(100));
EggsTime successfulIterationAt = 0;
continue;
}
LOG_INFO(_env, "Successfully registered with shuckle, will register again in one minute");
std::this_thread::sleep_for(std::chrono::minutes(1));
successfulIterationAt = eggsNow();
}
}
};