diff options
| author | Stefan Boberg <[email protected]> | 2025-10-03 10:10:05 +0200 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2025-10-03 10:10:05 +0200 |
| commit | f7664974cd32286b0623082a395c91ba1ceb9ce0 (patch) | |
| tree | 268b845873228a49775c4bee1896086629ea0c0d /src | |
| parent | move zenutil builds code to zenremotestore (#543) (diff) | |
| download | zen-f7664974cd32286b0623082a395c91ba1ceb9ce0.tar.xz zen-f7664974cd32286b0623082a395c91ba1ceb9ce0.zip | |
cache RPC replay fixes (minor) (#544)
* fixes misleading server side log message when using `--onhost`
* fixed `--onhost` behaviour in zen (no longer replays twice)
Diffstat (limited to 'src')
| -rw-r--r-- | src/zen/cmds/rpcreplay_cmd.cpp | 9 | ||||
| -rw-r--r-- | src/zenserver/cache/httpstructuredcache.cpp | 2 |
2 files changed, 10 insertions, 1 deletions
diff --git a/src/zen/cmds/rpcreplay_cmd.cpp b/src/zen/cmds/rpcreplay_cmd.cpp index d7047d82e..55600c5d8 100644 --- a/src/zen/cmds/rpcreplay_cmd.cpp +++ b/src/zen/cmds/rpcreplay_cmd.cpp @@ -212,6 +212,13 @@ RpcReplayCommand::Run(const ZenCliOptions& GlobalOptions, int argc, char** argv) m_ThreadCount = Max(m_ThreadCount, 1); + ZEN_CONSOLE("Replay '{}' (start offset {}, stride {}) to '{}', {} threads", + m_RecordingPath, + m_Offset, + m_Stride, + m_HostName, + m_ThreadCount); + Stopwatch TotalTimer; if (m_OnHost) @@ -223,6 +230,8 @@ RpcReplayCommand::Run(const ZenCliOptions& GlobalOptions, int argc, char** argv) HttpClient::KeyValueMap({{"path", m_RecordingPath}, {"thread-count", fmt::format("{}", m_ThreadCount)}}))) { ZEN_CONSOLE("{}", Response.ToText()); + + return; } else { diff --git a/src/zenserver/cache/httpstructuredcache.cpp b/src/zenserver/cache/httpstructuredcache.cpp index dad4ed803..a9d6be8f2 100644 --- a/src/zenserver/cache/httpstructuredcache.cpp +++ b/src/zenserver/cache/httpstructuredcache.cpp @@ -447,7 +447,7 @@ HttpStructuredCacheService::HandleRequest(HttpServerRequest& Request) std::unique_ptr<cache::IRpcRequestReplayer> Replayer(cache::MakeDiskRequestReplayer(RecordPath, false)); ReplayRequestRecorder(RequestContext, *Replayer, ThreadCount < 1 ? 1 : ThreadCount); - ZEN_INFO("cache RPC replay STARTED"); + ZEN_INFO("cache RPC replay COMPLETED"); Request.WriteResponse(HttpResponseCode::OK); return; |