aboutsummaryrefslogtreecommitdiff
path: root/src/zenutil/filebuildstorage.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2025-04-02 15:46:05 +0200
committerGitHub Enterprise <[email protected]>2025-04-02 15:46:05 +0200
commite244e2a07a0f3bf3b11d6d875d6c2c8bb169efc5 (patch)
treebbff9ea2b9f6905dc3d342ee98521c0ed5f78a03 /src/zenutil/filebuildstorage.cpp
parent5.6.1 (diff)
downloadzen-e244e2a07a0f3bf3b11d6d875d6c2c8bb169efc5.tar.xz
zen-e244e2a07a0f3bf3b11d6d875d6c2c8bb169efc5.zip
added --find-max-block-count option to builds upload (#337)
Diffstat (limited to 'src/zenutil/filebuildstorage.cpp')
-rw-r--r--src/zenutil/filebuildstorage.cpp9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/zenutil/filebuildstorage.cpp b/src/zenutil/filebuildstorage.cpp
index 0fa05194f..7aa252e44 100644
--- a/src/zenutil/filebuildstorage.cpp
+++ b/src/zenutil/filebuildstorage.cpp
@@ -442,7 +442,7 @@ public:
SimulateLatency(0, 0);
}
- virtual CbObject FindBlocks(const Oid& BuildId) override
+ virtual CbObject FindBlocks(const Oid& BuildId, uint64_t MaxBlockCount) override
{
ZEN_TRACE_CPU("FileBuildStorage::FindBlocks");
ZEN_UNUSED(BuildId);
@@ -451,6 +451,8 @@ public:
auto _ = MakeGuard([&]() { m_Stats.TotalExecutionTimeUs += ExecutionTimer.GetElapsedTimeUs(); });
m_Stats.TotalRequestCount++;
+ uint64_t FoundCount = 0;
+
DirectoryContent Content;
GetDirectoryContent(GetBlobsMetadataFolder(), DirectoryContentFlags::IncludeFiles, Content);
CbObjectWriter Writer;
@@ -469,6 +471,11 @@ public:
CbObject BlockObject = CbObject(SharedBuffer(BlockMetaDataPayload));
Writer.AddObject(BlockObject);
+ FoundCount++;
+ if (FoundCount == MaxBlockCount)
+ {
+ break;
+ }
}
}
}