diff options
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; |