diff options
| author | Dan Engelbrecht <[email protected]> | 2024-12-02 13:00:08 +0100 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2024-12-02 13:00:08 +0100 |
| commit | 6c7d07bf2ccc758995edfd71842c23908b484a4f (patch) | |
| tree | 289795592caf8905b8418eb5188aa31877e10eb8 /src/zenserver/projectstore/projectstore.cpp | |
| parent | added support for dynamic LLM tags (#245) (diff) | |
| download | zen-6c7d07bf2ccc758995edfd71842c23908b484a4f.tar.xz zen-6c7d07bf2ccc758995edfd71842c23908b484a4f.zip | |
fix time regression on CI - iteratechunks block size (#249)
* don't allow compact in time critical oplog calls
* bump small chunk size limit when doing iteratechunks
Diffstat (limited to 'src/zenserver/projectstore/projectstore.cpp')
| -rw-r--r-- | src/zenserver/projectstore/projectstore.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/zenserver/projectstore/projectstore.cpp b/src/zenserver/projectstore/projectstore.cpp index 1296f1269..415c80078 100644 --- a/src/zenserver/projectstore/projectstore.cpp +++ b/src/zenserver/projectstore/projectstore.cpp @@ -4030,7 +4030,7 @@ ProjectStore::GetProjectFiles(const std::string_view ProjectId, return true; }, &GetSmallWorkerPool(EWorkloadType::Burst), - 8u * 1024u); + 256u * 1024u); } CbObjectWriter Response; @@ -4187,7 +4187,7 @@ ProjectStore::GetProjectChunkInfos(const std::string_view ProjectId, return true; }, &WorkerPool, - 8u * 1024u); + 256u * 1024u); } CbObjectWriter Response; @@ -4235,7 +4235,7 @@ ProjectStore::GetChunkInfo(const std::string_view ProjectId, } Project->TouchProject(); - ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ true, /*VerifyPathOnDisk*/ false); + ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ false, /*VerifyPathOnDisk*/ false); if (!FoundLog) { return {HttpResponseCode::NotFound, fmt::format("Chunk info request for unknown oplog '{}/{}'", ProjectId, OplogId)}; @@ -4315,7 +4315,7 @@ ProjectStore::GetChunkRange(const std::string_view ProjectId, } Project->TouchProject(); - ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ true, /*VerifyPathOnDisk*/ false); + ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ false, /*VerifyPathOnDisk*/ false); if (!FoundLog) { return {HttpResponseCode::NotFound, fmt::format("Chunk request for unknown oplog '{}/{}'", ProjectId, OplogId)}; @@ -4425,7 +4425,7 @@ ProjectStore::GetChunk(const std::string_view ProjectId, } Project->TouchProject(); - ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ true, /*VerifyPathOnDisk*/ false); + ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ false, /*VerifyPathOnDisk*/ false); if (!FoundLog) { return {HttpResponseCode::NotFound, fmt::format("Chunk request for unknown oplog '{}/{}'", ProjectId, OplogId)}; @@ -4472,7 +4472,7 @@ ProjectStore::PutChunk(const std::string_view ProjectId, } Project->TouchProject(); - ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ true, /*VerifyPathOnDisk*/ false); + ProjectStore::Oplog* FoundLog = Project->OpenOplog(OplogId, /*AllowCompact*/ false, /*VerifyPathOnDisk*/ false); if (!FoundLog) { return {HttpResponseCode::NotFound, fmt::format("Chunk put request for unknown oplog '{}/{}'", ProjectId, OplogId)}; @@ -4730,7 +4730,7 @@ ProjectStore::Rpc(HttpServerRequest& HttpReq, } Project->TouchProject(); - ProjectStore::Oplog* Oplog = Project->OpenOplog(OplogId, /*AllowCompact*/ true, /*VerifyPathOnDisk*/ true); + ProjectStore::Oplog* Oplog = Project->OpenOplog(OplogId, /*AllowCompact*/ false, /*VerifyPathOnDisk*/ true); if (!Oplog) { HttpReq.WriteResponse(HttpResponseCode::NotFound, |