From 4584fd6e56fa5c5a7428828e7d3aea4e25a17977 Mon Sep 17 00:00:00 2001
From: Dan Engelbrecht <dan.engelbrecht@epicgames.com>
Date: Mon, 11 Nov 2024 09:46:09 +0100
Subject: WIP allow control of size for batch iteration allow adding
 compositebuffers as attachments directly add batch2 httpstore api to allow
 batching of CAS & Oid with range requests allow responses with file handles
 from project store

Signed-off-by: Dan Engelbrecht <dan.engelbrecht@epicgames.com>
---
 src/zenserver/projectstore/projectstore.h | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'src/zenserver/projectstore/projectstore.h')

diff --git a/src/zenserver/projectstore/projectstore.h b/src/zenserver/projectstore/projectstore.h
index 49970b677..52debe271 100644
--- a/src/zenserver/projectstore/projectstore.h
+++ b/src/zenserver/projectstore/projectstore.h
@@ -7,6 +7,7 @@
 #include <zencore/xxhash.h>
 #include <zenhttp/httpserver.h>
 #include <zenstore/gc.h>
+#include <zenutil/openprocesscache.h>
 
 ZEN_THIRD_PARTY_INCLUDES_START
 #include <tsl/robin_map.h>
@@ -118,10 +119,12 @@ public:
 		IoBuffer					 GetChunkByRawHash(const IoHash& RawHash);
 		bool						 IterateChunks(std::span<IoHash>												 RawHashes,
 												   const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
-												   WorkerThreadPool*												 OptionalWorkerPool);
+												   WorkerThreadPool*												 OptionalWorkerPool,
+												   uint64_t															 LargeSizeLimit);
 		bool						 IterateChunks(std::span<Oid>													 ChunkIds,
 												   const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
-												   WorkerThreadPool*												 OptionalWorkerPool);
+												   WorkerThreadPool*												 OptionalWorkerPool,
+												   uint64_t															 LargeSizeLimit);
 		inline static const uint32_t kInvalidOp = ~0u;
 
 		/** Persist a new oplog entry
@@ -469,6 +472,7 @@ private:
 	mutable RwLock							  m_UpdateCaptureLock;
 	uint32_t								  m_UpdateCaptureRefCounter = 0;
 	std::unique_ptr<std::vector<std::string>> m_CapturedProjects;
+	OpenProcessCache						  m_OpenProcessCache;
 
 	std::filesystem::path BasePathForProject(std::string_view ProjectId);
 
-- 
cgit v1.2.3