aboutsummaryrefslogtreecommitdiff
path: root/src/zenremotestore/projectstore/remoteprojectstore.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2025-12-12 15:16:49 +0100
committerGitHub Enterprise <[email protected]>2025-12-12 15:16:49 +0100
commite6a9fd6408ff99eb5c7da0a315dd79814e528145 (patch)
tree2b7c55793edf2869a50e69886bcae9f2e305ec81 /src/zenremotestore/projectstore/remoteprojectstore.cpp
parentadd otel instrumentation (#581) (diff)
downloadzen-e6a9fd6408ff99eb5c7da0a315dd79814e528145.tar.xz
zen-e6a9fd6408ff99eb5c7da0a315dd79814e528145.zip
show download source data (#689)
* show source stats for jupiter/cache
Diffstat (limited to 'src/zenremotestore/projectstore/remoteprojectstore.cpp')
-rw-r--r--src/zenremotestore/projectstore/remoteprojectstore.cpp27
1 files changed, 27 insertions, 0 deletions
diff --git a/src/zenremotestore/projectstore/remoteprojectstore.cpp b/src/zenremotestore/projectstore/remoteprojectstore.cpp
index 99c36b460..5652d5271 100644
--- a/src/zenremotestore/projectstore/remoteprojectstore.cpp
+++ b/src/zenremotestore/projectstore/remoteprojectstore.cpp
@@ -3282,6 +3282,33 @@ LoadOplog(CidStore& ChunkStore,
remotestore_impl::LogRemoteStoreStatsDetails(RemoteStore.GetStats());
+ {
+ std::string DownloadDetails;
+ RemoteProjectStore::ExtendedStats ExtendedStats;
+ if (RemoteStore.GetExtendedStats(ExtendedStats))
+ {
+ if (!ExtendedStats.m_ReceivedBytesPerSource.empty())
+ {
+ uint64_t Total = 0;
+ ExtendableStringBuilder<128> SB;
+
+ for (auto& It : ExtendedStats.m_ReceivedBytesPerSource)
+ {
+ if (SB.Size() > 0)
+ {
+ SB.Append(", "sv);
+ }
+ SB.Append(It.first);
+ SB.Append(": "sv);
+ SB.Append(NiceBytes(It.second));
+ Total += It.second;
+ }
+
+ remotestore_impl::ReportMessage(OptionalContext, fmt::format("Downloaded {} ({})", NiceBytes(Total), SB.ToView()));
+ }
+ }
+ }
+
remotestore_impl::ReportMessage(
OptionalContext,
fmt::format("Loaded oplog '{}' {} in {} ({}), Blocks: {} ({}), Attachments: {} ({}), Stored: {} ({}), Missing: {} {}",