diff options
| author | Per Larsson <[email protected]> | 2021-12-15 20:12:41 +0100 |
|---|---|---|
| committer | Per Larsson <[email protected]> | 2021-12-15 20:12:41 +0100 |
| commit | 9313768464789551f287304eadb2fb3f139cdf18 (patch) | |
| tree | 2e0da7e5ac6217b0d587b297f2827fede4379b7c /zenserver/upstream/jupiter.cpp | |
| parent | Updated readme. (diff) | |
| download | zen-9313768464789551f287304eadb2fb3f139cdf18.tar.xz zen-9313768464789551f287304eadb2fb3f139cdf18.zip | |
Added trace scopes.
Diffstat (limited to 'zenserver/upstream/jupiter.cpp')
| -rw-r--r-- | zenserver/upstream/jupiter.cpp | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/zenserver/upstream/jupiter.cpp b/zenserver/upstream/jupiter.cpp index 177184591..ffb9b1cbf 100644 --- a/zenserver/upstream/jupiter.cpp +++ b/zenserver/upstream/jupiter.cpp @@ -10,6 +10,7 @@ #include <zencore/iohash.h> #include <zencore/string.h> #include <zencore/thread.h> +#include <zencore/trace.h> ZEN_THIRD_PARTY_INCLUDES_START #include <cpr/cpr.h> @@ -86,6 +87,8 @@ CloudCacheSession::Authenticate() CloudCacheResult CloudCacheSession::GetDerivedData(std::string_view BucketId, std::string_view Key) { + ZEN_TRACE_CPU("HordeClient::GetDerivedData"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -203,6 +206,8 @@ CloudCacheSession::GetBlob(const IoHash& Key) CloudCacheResult CloudCacheSession::GetCompressedBlob(const IoHash& Key) { + ZEN_TRACE_CPU("HordeClient::GetCompressedBlob"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -239,6 +244,8 @@ CloudCacheSession::GetCompressedBlob(const IoHash& Key) CloudCacheResult CloudCacheSession::GetObject(const IoHash& Key) { + ZEN_TRACE_CPU("HordeClient::GetObject"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -275,6 +282,8 @@ CloudCacheSession::GetObject(const IoHash& Key) CloudCacheResult CloudCacheSession::PutDerivedData(std::string_view BucketId, std::string_view Key, IoBuffer DerivedData) { + ZEN_TRACE_CPU("HordeClient::PutDerivedData"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -320,6 +329,8 @@ CloudCacheSession::PutDerivedData(std::string_view BucketId, const IoHash& Key, PutRefResult CloudCacheSession::PutRef(std::string_view BucketId, const IoHash& Key, IoBuffer Ref, ZenContentType RefType) { + ZEN_TRACE_CPU("HordeClient::PutRef"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -387,6 +398,8 @@ CloudCacheSession::PutRef(std::string_view BucketId, const IoHash& Key, IoBuffer FinalizeRefResult CloudCacheSession::FinalizeRef(std::string_view BucketId, const IoHash& Key, const IoHash& RefHash) { + ZEN_TRACE_CPU("HordeClient::FinalizeRef"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -451,6 +464,8 @@ CloudCacheSession::FinalizeRef(std::string_view BucketId, const IoHash& Key, con CloudCacheResult CloudCacheSession::PutBlob(const IoHash& Key, IoBuffer Blob) { + ZEN_TRACE_CPU("HordeClient::PutBlob"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -486,6 +501,8 @@ CloudCacheSession::PutBlob(const IoHash& Key, IoBuffer Blob) CloudCacheResult CloudCacheSession::PutCompressedBlob(const IoHash& Key, IoBuffer Blob) { + ZEN_TRACE_CPU("HordeClient::PutCompressedBlob"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -521,6 +538,8 @@ CloudCacheSession::PutCompressedBlob(const IoHash& Key, IoBuffer Blob) CloudCacheResult CloudCacheSession::PutObject(const IoHash& Key, IoBuffer Object) { + ZEN_TRACE_CPU("HordeClient::PutObject"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -556,6 +575,8 @@ CloudCacheSession::PutObject(const IoHash& Key, IoBuffer Object) CloudCacheResult CloudCacheSession::RefExists(std::string_view BucketId, const IoHash& Key) { + ZEN_TRACE_CPU("HordeClient::RefExists"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -626,6 +647,8 @@ CloudCacheSession::ObjectExists(const std::set<IoHash>& Keys) CloudCacheResult CloudCacheSession::PostComputeTasks(std::string_view ChannelId, IoBuffer TasksData) { + ZEN_TRACE_CPU("HordeClient::PostComputeTasks"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -695,6 +718,8 @@ CloudCacheSession::GetComputeUpdates(std::string_view ChannelId, const uint32_t CloudCacheResult CloudCacheSession::GetObjectTree(const IoHash& Key) { + ZEN_TRACE_CPU("HordeClient::GetObjectTree"); + const CloudCacheAccessToken& AccessToken = GetAccessToken(); if (!AccessToken.IsValid()) { @@ -919,6 +944,8 @@ CloudCacheClient::~CloudCacheClient() CloudCacheAccessToken CloudCacheClient::AcquireAccessToken() { + ZEN_TRACE_CPU("HordeClient::AcquireAccessToken"); + using namespace std::chrono; // If an access token was provided, return it instead of querying OAuth |