summaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/perftest/perftest.cpp
diff options
context:
space:
mode:
authordanlark <[email protected]>2022-02-10 16:46:10 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:10 +0300
commitbaa58daefa91fde4b4769facdbd2903763b9c6a8 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus/test/perftest/perftest.cpp
parent3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (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.cpp12
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;