aboutsummaryrefslogtreecommitdiff
path: root/src/zenserver/projectstore/remoteprojectstore.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2024-03-28 14:56:20 +0100
committerGitHub Enterprise <[email protected]>2024-03-28 14:56:20 +0100
commit76ac4d541c603dd869e18cfbc6644ebf6c6e22d7 (patch)
treef919560d5ddb5a33057f9337d930ca327149dafd /src/zenserver/projectstore/remoteprojectstore.cpp
parentadd "fieldnames" query param for GetProjectFiles/GetProjectChunkInfos (#29) (diff)
downloadzen-76ac4d541c603dd869e18cfbc6644ebf6c6e22d7.tar.xz
zen-76ac4d541c603dd869e18cfbc6644ebf6c6e22d7.zip
Use multithreading to fetch size/rawsize of entries in `/prj/{project}/oplog/{log}/chunkinfos` and `/prj/{project}/oplog/{log}/files` (#30)
- Improvement: Use multithreading to fetch size/rawsize of entries in `/prj/{project}/oplog/{log}/chunkinfos` and `/prj/{project}/oplog/{log}/files` - Improvement: Add `GetMediumWorkerPool()` in addition to `LargeWorkerPool()` and `SmallWorkerPool()`
Diffstat (limited to 'src/zenserver/projectstore/remoteprojectstore.cpp')
-rw-r--r--src/zenserver/projectstore/remoteprojectstore.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/zenserver/projectstore/remoteprojectstore.cpp b/src/zenserver/projectstore/remoteprojectstore.cpp
index 3887272bf..ae4777278 100644
--- a/src/zenserver/projectstore/remoteprojectstore.cpp
+++ b/src/zenserver/projectstore/remoteprojectstore.cpp
@@ -1711,7 +1711,7 @@ SaveOplog(CidStore& ChunkStore,
UploadInfo Info;
WorkerThreadPool& WorkerPool = GetLargeWorkerPool();
- WorkerThreadPool& NetworkWorkerPool = GetSmallWorkerPool();
+ WorkerThreadPool& NetworkWorkerPool = GetMediumWorkerPool();
const RemoteProjectStore::RemoteStoreInfo RemoteStoreInfo = RemoteStore.GetInfo();
@@ -2239,7 +2239,7 @@ LoadOplog(CidStore& ChunkStore,
Stopwatch Timer;
WorkerThreadPool& WorkerPool = GetLargeWorkerPool();
- WorkerThreadPool& NetworkWorkerPool = GetSmallWorkerPool();
+ WorkerThreadPool& NetworkWorkerPool = GetMediumWorkerPool();
std::unordered_set<IoHash, IoHash::Hasher> Attachments;