BeamMP/BeamMP-Server
1
0
Fork 0
mirror of https://github.com/BeamMP/BeamMP-Server.git synced 2026-04-18 06:10:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

heartbeat every 30 seconds, or if anything changed, with a limit of once

Browse Source 
every 5 seconds
This commit is contained in:
Lion Kortlepel
2021-01-30 02:40:26 +01:00
parent 710bb939ad
commit 5f3fecb92c
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/Init/Heartbeat.cpp
View File

@@ -53,16 +53,29 @@ std::string RunPromise(const std::string& host, const std::string& target, const
DebugPrintTID(); DebugPrintTID();
std::string R; std::string R;
std::string T; std::string T;
// these are "hot-change" related variables
static std::string LastR = "";
static std::chrono::high_resolution_clock::time_point LastNormalUpdateTime = std::chrono::high_resolution_clock::now();
bool isAuth = false; bool isAuth = false;
while (true) { while (true) {
R = GenerateCall(); R = GenerateCall();
// a hot-change occurs when a setting has changed, to update the backend of that change.
auto Now = std::chrono::high_resolution_clock::now();
if (LastR == R && (Now - LastNormalUpdateTime) < std::chrono::seconds(30)) {
std::this_thread::sleep_for(std::chrono::seconds(5));
continue;
}
LastR = R;
LastNormalUpdateTime = Now;
if (!CustomIP.empty()) if (!CustomIP.empty())
R += "&ip=" + CustomIP; R += "&ip=" + CustomIP;
T = RunPromise("beammp.com", "/heartbeatv2", {}, R); T = RunPromise("beammp.com", "/heartbeatv2", {}, R);
if (T.substr(0, 2) != "20") { if (T.substr(0, 2) != "20") {
//Backend system refused server startup! //Backend system refused server startup!
std::this_thread::sleep_for(std::chrono::seconds(10)); std::this_thread::sleep_for(std::chrono::seconds(5));
T = RunPromise("backup1.beammp.com", "/heartbeatv2", {}, R); T = RunPromise("backup1.beammp.com", "/heartbeatv2", {}, R);
if (T.substr(0, 2) != "20") { if (T.substr(0, 2) != "20") {
warn("Backend system refused server! Server might not show in the public list"); warn("Backend system refused server! Server might not show in the public list");
@@ -77,7 +90,6 @@ std::string RunPromise(const std::string& host, const std::string& target, const
info(("Resumed authenticated session!")); info(("Resumed authenticated session!"));
isAuth = true; isAuth = true;
} }
std::this_thread::sleep_for(std::chrono::seconds(10));
} }
} }
void HBInit() { void HBInit() {