github/ZeroTierOne
1
0
Fork 0
mirror of https://github.com/ZeroTier/ZeroTierOne synced 2025-08-21 05:43:59 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Merge pull request #2495 from zerotier/gl/cv1-os-arch
Some checks are pending
/ build_macos (push) Waiting to run
Details
/ build_windows (push) Waiting to run
Details
/ build_ubuntu (push) Waiting to run
Details

Browse source 
hosted controller changes for cv1 os/arch reporting
This commit is contained in:
Grant Limberg 2025-08-20 15:09:35 -07:00 • committed by GitHub
commit 86f402edb7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 23 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

28
controller/CV1.cpp
View file

@ -1406,7 +1406,7 @@ void CV1::commitThread()
{ {
fprintf(stderr, "%s: commitThread start\n", _myAddressStr.c_str()); fprintf(stderr, "%s: commitThread start\n", _myAddressStr.c_str());
std::pair<nlohmann::json, bool> qitem; std::pair<nlohmann::json, bool> qitem;
while (_commitQueue.get(qitem) & (_run == 1)) { while (_commitQueue.get(qitem) && (_run == 1)) {
auto provider = opentelemetry::trace::Provider::GetTracerProvider(); auto provider = opentelemetry::trace::Provider::GetTracerProvider();
auto tracer = provider->GetTracer("cv1"); auto tracer = provider->GetTracer("cv1");
auto span = tracer->StartSpan("cv1::commitThread"); auto span = tracer->StartSpan("cv1::commitThread");
@ -1933,9 +1933,16 @@ void CV1::onlineNotification_Postgres()
std::string ipAddr = i->second.physicalAddress.toIpString(ipTmp); std::string ipAddr = i->second.physicalAddress.toIpString(ipTmp);
std::string timestamp = std::to_string(ts); std::string timestamp = std::to_string(ts);
std::string osArch = i->second.osArch; std::string osArch = i->second.osArch;
std::vector<std::string> osArchSplit = split(osArch, '/');
std::string os = "unknown";
std::string arch = "unknown";
if (osArchSplit.size() == 2) {
os = osArchSplit[0];
arch = osArchSplit[1];
}
std::stringstream memberUpdate; std::stringstream memberUpdate;
memberUpdate << "INSERT INTO ztc_member_status (network_id, member_id, address, last_updated) VALUES " memberUpdate << "INSERT INTO ztc_member_status (network_id, member_id, address, last_updated, os, arch) VALUES "
<< "('" << networkId << "', '" << memberId << "', "; << "('" << networkId << "', '" << memberId << "', ";
if (ipAddr.empty()) { if (ipAddr.empty()) {
memberUpdate << "NULL, "; memberUpdate << "NULL, ";
@ -1943,8 +1950,12 @@ void CV1::onlineNotification_Postgres()
else { else {
memberUpdate << "'" << ipAddr << "', "; memberUpdate << "'" << ipAddr << "', ";
} }
memberUpdate << "TO_TIMESTAMP(" << timestamp << "::double precision/1000)) " memberUpdate << "TO_TIMESTAMP(" << timestamp << "::double precision/1000), "
<< " ON CONFLICT (network_id, member_id) DO UPDATE SET address = EXCLUDED.address, last_updated = EXCLUDED.last_updated"; << "'" << os << "', "
<< "'" << arch << "'"
<< ") "
<< " ON CONFLICT (network_id, member_id) DO UPDATE SET address = EXCLUDED.address, last_updated = EXCLUDED.last_updated, "
<< "os = EXCLUDED.os, arch = EXCLUDED.arch";
pipe.insert(memberUpdate.str()); pipe.insert(memberUpdate.str());
Metrics::pgsql_node_checkin++; Metrics::pgsql_node_checkin++;
@ -2056,8 +2067,15 @@ uint64_t CV1::_doRedisUpdate(sw::redis::Transaction& tx, std::string& controller
std::string ipAddr = i->second.physicalAddress.toIpString(ipTmp); std::string ipAddr = i->second.physicalAddress.toIpString(ipTmp);
std::string timestamp = std::to_string(ts); std::string timestamp = std::to_string(ts);
std::string osArch = i->second.osArch; std::string osArch = i->second.osArch;
std::vector<std::string> osArchSplit = split(osArch, '/');
std::string os = "unknown";
std::string arch = "unknown";
if (osArchSplit.size() == 2) {
os = osArchSplit[0];
arch = osArchSplit[1];
}
std::unordered_map<std::string, std::string> record = { { "id", memberId }, { "address", ipAddr }, { "last_updated", std::to_string(ts) } }; std::unordered_map<std::string, std::string> record = { { "id", memberId }, { "address", ipAddr }, { "last_updated", std::to_string(ts) }, { "os", os }, { "arch", arch } };
tx.zadd("nodes-online:{" + controllerId + "}", memberId, ts) tx.zadd("nodes-online:{" + controllerId + "}", memberId, ts)
.zadd("nodes-online2:{" + controllerId + "}", networkId + "-" + memberId, ts) .zadd("nodes-online2:{" + controllerId + "}", networkId + "-" + memberId, ts)
.zadd("network-nodes-online:{" + controllerId + "}:" + networkId, memberId, ts) .zadd("network-nodes-online:{" + controllerId + "}:" + networkId, memberId, ts)