diff options
author | danlark <[email protected]> | 2022-02-10 16:46:10 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:46:10 +0300 |
commit | baa58daefa91fde4b4769facdbd2903763b9c6a8 (patch) | |
tree | 1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus/test/perftest/perftest.cpp | |
parent | 3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (diff) |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/perftest/perftest.cpp')
-rw-r--r-- | library/cpp/messagebus/test/perftest/perftest.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp index dbbddf6ef9f..84893192789 100644 --- a/library/cpp/messagebus/test/perftest/perftest.cpp +++ b/library/cpp/messagebus/test/perftest/perftest.cpp @@ -157,7 +157,7 @@ void CheckRequest(TPerftestRequest* request) { TAutoPtr<TPerftestResponse> NewResponse(TPerftestRequest* request) { TAutoPtr<TPerftestResponse> r(new TPerftestResponse); r->SetCompressed(TheConfig->UseCompression); - r->Record.SetData(TString(request->Record.GetData().size(), '.')); + r->Record.SetData(TString(request->Record.GetData().size(), '.')); return r; } @@ -475,10 +475,10 @@ TVector<TNetAddr> ParseNodes(const TString nodes) { TVector<TString> hosts; - size_t numh = Split(nodes.data(), ",", hosts); + size_t numh = Split(nodes.data(), ",", hosts); for (int i = 0; i < int(numh); i++) { - const TNetworkAddress& networkAddress = ParseNetworkAddress(hosts[i].data()); + const TNetworkAddress& networkAddress = ParseNetworkAddress(hosts[i].data()); Y_VERIFY(networkAddress.Begin() != networkAddress.End(), "no addresses"); r.push_back(TNetAddr(networkAddress, &*networkAddress.Begin())); } @@ -542,17 +542,17 @@ void TTestStats::PeriodicallyPrint() { if (!!Server) { fprintf(stderr, "server: q: %u %s\n", (unsigned)Server->Bus->GetExecutor()->GetWorkQueueSize(), - Server->Session->GetStatusSingleLine().data()); + Server->Session->GetStatusSingleLine().data()); } if (!!ServerUsingModule) { fprintf(stderr, "server: q: %u %s\n", (unsigned)ServerUsingModule->Bus->GetExecutor()->GetWorkQueueSize(), - ServerUsingModule->Session->GetStatusSingleLine().data()); + ServerUsingModule->Session->GetStatusSingleLine().data()); } for (const auto& client : clients) { fprintf(stderr, "client: q: %u %s\n", (unsigned)client->Bus->GetExecutor()->GetWorkQueueSize(), - client->Session->GetStatusSingleLine().data()); + client->Session->GetStatusSingleLine().data()); } TStringStream stats; |