diff options
| author | Dan Engelbrecht <[email protected]> | 2024-03-21 10:58:28 +0100 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2024-03-21 10:58:28 +0100 |
| commit | 9b82209e3368de806a48554d85cb7c364973eb2d (patch) | |
| tree | 8b52dbe1fd5a1a3255c51198a7b31bef77cf9009 /src/zenstore/include | |
| parent | improved process monitoring behaviour with invalid pids (#16) (diff) | |
| download | zen-9b82209e3368de806a48554d85cb7c364973eb2d.tar.xz zen-9b82209e3368de806a48554d85cb7c364973eb2d.zip | |
add support for responding with partial cache chunks (#11)
* add support for responding with partial cache chunks
Diffstat (limited to 'src/zenstore/include')
| -rw-r--r-- | src/zenstore/include/zenstore/cache/cacherpc.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/zenstore/include/zenstore/cache/cacherpc.h b/src/zenstore/include/zenstore/cache/cacherpc.h index c57e2818c..a98010a7c 100644 --- a/src/zenstore/include/zenstore/cache/cacherpc.h +++ b/src/zenstore/include/zenstore/cache/cacherpc.h @@ -104,7 +104,7 @@ private: CbPackage HandleRpcGetCacheRecords(const CacheRequestContext& Context, CbObjectView BatchRequest); CbPackage HandleRpcPutCacheValues(const CacheRequestContext& Context, const CbPackage& BatchRequest); CbPackage HandleRpcGetCacheValues(const CacheRequestContext& Context, CbObjectView BatchRequest); - CbPackage HandleRpcGetCacheChunks(const CacheRequestContext& Context, CbObjectView BatchRequest); + CbPackage HandleRpcGetCacheChunks(const CacheRequestContext& Context, RpcAcceptOptions AcceptOptions, CbObjectView BatchRequest); PutResult PutCacheRecord(PutRequestData& Request, const CbPackage* Package); @@ -139,6 +139,7 @@ private: /** HandleRpcGetCacheChunks Helper: Send response message containing all chunk results. */ CbPackage WriteGetCacheChunksResponse(const CacheRequestContext& Context, std::string_view Namespace, + RpcAcceptOptions AcceptOptions, std::vector<cache::detail::ChunkRequest>& Requests); LoggerRef Log() { return m_Log; } @@ -152,4 +153,4 @@ private: bool AreDiskWritesAllowed() const; }; -} // namespace zen
\ No newline at end of file +} // namespace zen |