diff options
| author | Per Larsson <[email protected]> | 2021-09-07 15:11:11 +0200 |
|---|---|---|
| committer | Per Larsson <[email protected]> | 2021-09-07 15:11:11 +0200 |
| commit | c07e8c760ed56db387b6612ed8392d6e78301479 (patch) | |
| tree | a77c19e56932b121ecd1f3e0dabced5843810897 /zenserver/upstream/zen.cpp | |
| parent | Merge branch 'main' of https://github.com/EpicGames/zen (diff) | |
| download | zen-c07e8c760ed56db387b6612ed8392d6e78301479.tar.xz zen-c07e8c760ed56db387b6612ed8392d6e78301479.zip | |
Return stats from Zen/Jupiter HTTP client.
Diffstat (limited to 'zenserver/upstream/zen.cpp')
| -rw-r--r-- | zenserver/upstream/zen.cpp | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/zenserver/upstream/zen.cpp b/zenserver/upstream/zen.cpp index 7ed4eead0..8df2f2104 100644 --- a/zenserver/upstream/zen.cpp +++ b/zenserver/upstream/zen.cpp @@ -416,12 +416,10 @@ ZenStructuredCacheSession::GetCachePayload(std::string_view BucketId, const IoHa cpr::Response Response = Session.Get(); m_Log.debug("GET {}", Response); - if (Response.status_code == 200) - { - return {.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size()), .Success = true}; - } + const bool Success = Response.status_code == 200; + const IoBuffer Buffer = Success ? IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size()) : IoBuffer(); - return {}; + return {.Response = Buffer, .Bytes = Response.downloaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = Success}; } ZenCacheResult @@ -440,7 +438,7 @@ ZenStructuredCacheSession::PutCacheRecord(std::string_view BucketId, const IoHas cpr::Response Response = Session.Put(); m_Log.debug("PUT {}", Response); - return {.Success = Response.status_code == 200}; + return {.Bytes = Response.uploaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = Response.status_code == 200}; } ZenCacheResult @@ -458,7 +456,7 @@ ZenStructuredCacheSession::PutCachePayload(std::string_view BucketId, const IoHa cpr::Response Response = Session.Put(); m_Log.debug("PUT {}", Response); - return {.Success = Response.status_code == 200}; + return {.Bytes = Response.uploaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = Response.status_code == 200}; } } // namespace zen |