Removed batch result.

1 files changed, 19 insertions, 15 deletions

diff --git a/zenserver/upstream/upstreamcache.cpp b/zenserver/upstream/upstreamcache.cpp
index a221c7d8e..d5414daf1 100644
--- a/zenserver/upstream/upstreamcache.cpp
+++ b/zenserver/upstream/upstreamcache.cpp
@@ -144,10 +144,10 @@ namespace detail {
 			}
 		}
 
-		virtual GetUpstreamCacheBatchResult GetCacheRecords(std::span<CacheKey>		   CacheKeys,
-															std::span<size_t>		   KeyIndex,
-															const CacheRecordPolicy&   Policy,
-															OnCacheRecordGetComplete&& OnComplete) override
+		virtual GetUpstreamCacheResult GetCacheRecords(std::span<CacheKey>		  CacheKeys,
+													   std::span<size_t>		  KeyIndex,
+													   const CacheRecordPolicy&	  Policy,
+													   OnCacheRecordGetComplete&& OnComplete) override
 		{
 			ZEN_UNUSED(Policy);
 
@@ -161,7 +161,7 @@ namespace detail {
 				CbPackage	 Package;
 				CbObjectView Record;
 
-				if (Result.Success)
+				if (Result.ErrorCode == 0)
 				{
 					const CbValidateError ValidationResult = ValidateCompactBinary(Result.Response, CbValidateMode::All);
 					if (ValidationResult == CbValidateError::None)
@@ -179,6 +179,10 @@ namespace detail {
 						});
 					}
 				}
+				else
+				{
+					m_HealthOk = false;
+				}
 
 				OnComplete({.CacheKey = CacheKey, .KeyIndex = Index, .Record = Record, .Package = Package});
 			}
@@ -213,9 +217,9 @@ namespace detail {
 			}
 		}
 
-		virtual GetUpstreamCacheBatchResult GetCachePayloads(std::span<CacheChunkRequest> CacheChunkRequests,
-															 std::span<size_t>			  RequestIndex,
-															 OnCachePayloadGetComplete&&  OnComplete) override final
+		virtual GetUpstreamCacheResult GetCachePayloads(std::span<CacheChunkRequest> CacheChunkRequests,
+														std::span<size_t>			 RequestIndex,
+														OnCachePayloadGetComplete&&	 OnComplete) override final
 		{
 			CloudCacheSession Session(m_Client);
 
@@ -511,10 +515,10 @@ namespace detail {
 			}
 		}
 
-		virtual GetUpstreamCacheBatchResult GetCacheRecords(std::span<CacheKey>		   CacheKeys,
-															std::span<size_t>		   KeyIndex,
-															const CacheRecordPolicy&   Policy,
-															OnCacheRecordGetComplete&& OnComplete) override
+		virtual GetUpstreamCacheResult GetCacheRecords(std::span<CacheKey>		  CacheKeys,
+													   std::span<size_t>		  KeyIndex,
+													   const CacheRecordPolicy&	  Policy,
+													   OnCacheRecordGetComplete&& OnComplete) override
 		{
 			std::vector<size_t> IndexMap;
 			IndexMap.reserve(KeyIndex.size());
@@ -606,9 +610,9 @@ namespace detail {
 			}
 		}
 
-		virtual GetUpstreamCacheBatchResult GetCachePayloads(std::span<CacheChunkRequest> CacheChunkRequests,
-															 std::span<size_t>			  RequestIndex,
-															 OnCachePayloadGetComplete&&  OnComplete) override final
+		virtual GetUpstreamCacheResult GetCachePayloads(std::span<CacheChunkRequest> CacheChunkRequests,
+														std::span<size_t>			 RequestIndex,
+														OnCachePayloadGetComplete&&	 OnComplete) override final
 		{
 			std::vector<size_t> IndexMap;
 			IndexMap.reserve(RequestIndex.size());