aboutsummaryrefslogtreecommitdiff
path: root/src/zenremotestore/builds/buildstorageutil.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/zenremotestore/builds/buildstorageutil.cpp')
-rw-r--r--src/zenremotestore/builds/buildstorageutil.cpp19
1 files changed, 14 insertions, 5 deletions
diff --git a/src/zenremotestore/builds/buildstorageutil.cpp b/src/zenremotestore/builds/buildstorageutil.cpp
index 36b45e800..b249d7d52 100644
--- a/src/zenremotestore/builds/buildstorageutil.cpp
+++ b/src/zenremotestore/builds/buildstorageutil.cpp
@@ -63,11 +63,13 @@ ResolveBuildStorage(OperationLogOutput& Output,
std::string HostUrl;
std::string HostName;
+ double HostLatencySec = -1.0;
std::string CacheUrl;
std::string CacheName;
bool HostAssumeHttp2 = ClientSettings.AssumeHttp2;
bool CacheAssumeHttp2 = ClientSettings.AssumeHttp2;
+ double CacheLatencySec = -1.0;
JupiterServerDiscovery DiscoveryResponse;
const std::string_view DiscoveryHost = Host.empty() ? OverrideHost : Host;
@@ -98,8 +100,9 @@ ResolveBuildStorage(OperationLogOutput& Output,
{
ZEN_OPERATION_LOG_INFO(Output, "Server endpoint at '{}/api/v1/status/servers' succeeded", OverrideHost);
}
- HostUrl = OverrideHost;
- HostName = GetHostNameFromUrl(OverrideHost);
+ HostUrl = OverrideHost;
+ HostName = GetHostNameFromUrl(OverrideHost);
+ HostLatencySec = TestResult.LatencySeconds;
}
else
{
@@ -137,6 +140,7 @@ ResolveBuildStorage(OperationLogOutput& Output,
HostUrl = ServerEndpoint.BaseUrl;
HostAssumeHttp2 = ServerEndpoint.AssumeHttp2;
HostName = ServerEndpoint.Name;
+ HostLatencySec = TestResult.LatencySeconds;
break;
}
else
@@ -183,6 +187,7 @@ ResolveBuildStorage(OperationLogOutput& Output,
CacheUrl = CacheEndpoint.BaseUrl;
CacheAssumeHttp2 = CacheEndpoint.AssumeHttp2;
CacheName = CacheEndpoint.Name;
+ CacheLatencySec = TestResult.LatencySeconds;
break;
}
}
@@ -204,6 +209,7 @@ ResolveBuildStorage(OperationLogOutput& Output,
CacheUrl = ZenServerLocalHostUrl;
CacheAssumeHttp2 = false;
CacheName = "localhost";
+ CacheLatencySec = TestResult.LatencySeconds;
}
}
});
@@ -219,8 +225,9 @@ ResolveBuildStorage(OperationLogOutput& Output,
if (ZenCacheEndpointTestResult TestResult = TestZenCacheEndpoint(ZenCacheHost, /*AssumeHttp2*/ false, ClientSettings.Verbose);
TestResult.Success)
{
- CacheUrl = ZenCacheHost;
- CacheName = GetHostNameFromUrl(ZenCacheHost);
+ CacheUrl = ZenCacheHost;
+ CacheName = GetHostNameFromUrl(ZenCacheHost);
+ CacheLatencySec = TestResult.LatencySeconds;
}
else
{
@@ -231,10 +238,12 @@ ResolveBuildStorage(OperationLogOutput& Output,
return BuildStorageResolveResult{.HostUrl = HostUrl,
.HostName = HostName,
.HostAssumeHttp2 = HostAssumeHttp2,
+ .HostLatencySec = HostLatencySec,
.CacheUrl = CacheUrl,
.CacheName = CacheName,
- .CacheAssumeHttp2 = CacheAssumeHttp2};
+ .CacheAssumeHttp2 = CacheAssumeHttp2,
+ .CacheLatencySec = CacheLatencySec};
}
std::vector<ChunkBlockDescription>