diff options
| author | Per Larsson <[email protected]> | 2021-09-20 08:54:09 +0200 |
|---|---|---|
| committer | Per Larsson <[email protected]> | 2021-09-20 08:54:09 +0200 |
| commit | d3c8d678d395c9ce091d93e629d77d698f714dcd (patch) | |
| tree | 647fcf3d57bf1667989daf94f52a49471141159d /zenserver/upstream/zen.cpp | |
| parent | Added upstream cache policy command line option (read|write,readonly,writeonl... (diff) | |
| download | zen-d3c8d678d395c9ce091d93e629d77d698f714dcd.tar.xz zen-d3c8d678d395c9ce091d93e629d77d698f714dcd.zip | |
Probe upstream Zen server when initializing upstream cache.
Diffstat (limited to 'zenserver/upstream/zen.cpp')
| -rw-r--r-- | zenserver/upstream/zen.cpp | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/zenserver/upstream/zen.cpp b/zenserver/upstream/zen.cpp index 55ddd310f..be4daa30a 100644 --- a/zenserver/upstream/zen.cpp +++ b/zenserver/upstream/zen.cpp @@ -382,6 +382,19 @@ ZenStructuredCacheSession::~ZenStructuredCacheSession() } ZenCacheResult +ZenStructuredCacheSession::SayHello() +{ + ExtendableStringBuilder<256> Uri; + Uri << m_Client.ServiceUrl() << "/test/hello"; + + cpr::Session& Session = m_SessionState->Session; + Session.SetOption(cpr::Url{Uri.c_str()}); + cpr::Response Response = Session.Get(); + + return {.Bytes = Response.downloaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = Response.status_code == 200}; +} + +ZenCacheResult ZenStructuredCacheSession::GetCacheRecord(std::string_view BucketId, const IoHash& Key, ZenContentType Type) { ExtendableStringBuilder<256> Uri; |