aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test/perftest
diff options
context:
space:
mode:
authorVlad Yaroslavlev <vladon@vladon.com>2022-02-10 16:46:23 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:23 +0300
commit706b83ed7de5a473436620367af31fc0ceecde07 (patch)
tree103305d30dec77e8f6367753367f59b3cd68f9f1 /library/cpp/messagebus/test/perftest
parent918e8a1574070d0ec733f0b76cfad8f8892ad2e5 (diff)
downloadydb-706b83ed7de5a473436620367af31fc0ceecde07.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/test/perftest')
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp20
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 8489319278..dd2dd69e4d 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -17,7 +17,7 @@
#include <library/cpp/threading/future/legacy_future.h>
#include <util/generic/ptr.h>
-#include <util/generic/string.h>
+#include <util/generic/string.h>
#include <util/generic/vector.h>
#include <util/generic/yexception.h>
#include <util/random/random.h>
@@ -76,7 +76,7 @@ struct TPerftestConfig {
extern TPerftestConfig* TheConfig;
extern bool TheExit;
-TVector<TNetAddr> ServerAddresses;
+TVector<TNetAddr> ServerAddresses;
struct TConfig {
TBusQueueConfig ServerQueueConfig;
@@ -142,13 +142,13 @@ TAutoPtr<TBusMessage> NewRequest() {
TAutoPtr<TPerftestRequest> r(new TPerftestRequest);
r->SetCompressed(TheConfig->UseCompression);
// TODO: use random content for better compression test
- r->Record.SetData(TString(RequestSize(), '?'));
+ r->Record.SetData(TString(RequestSize(), '?'));
return r.Release();
}
}
void CheckRequest(TPerftestRequest* request) {
- const TString& data = request->Record.GetData();
+ const TString& data = request->Record.GetData();
for (size_t i = 0; i != data.size(); ++i) {
Y_VERIFY(data.at(i) == '?', "must be question mark");
}
@@ -162,7 +162,7 @@ TAutoPtr<TPerftestResponse> NewResponse(TPerftestRequest* request) {
}
void CheckResponse(TPerftestResponse* response) {
- const TString& data = response->Record.GetData();
+ const TString& data = response->Record.GetData();
for (size_t i = 0; i != data.size(); ++i) {
Y_VERIFY(data.at(i) == '.', "must be dot");
}
@@ -237,7 +237,7 @@ public:
TBusClientSessionPtr Session;
THolder<TBusProtocol> Proto;
TBusMessageQueuePtr Bus;
- TVector<TBusClientConnectionPtr> Connections;
+ TVector<TBusClientConnectionPtr> Connections;
public:
/// constructor creates instances of protocol and session
@@ -470,10 +470,10 @@ static TNetworkAddress ParseNetworkAddress(const char* string) {
return TNetworkAddress(Name, Port);
}
-TVector<TNetAddr> ParseNodes(const TString nodes) {
- TVector<TNetAddr> r;
+TVector<TNetAddr> ParseNodes(const TString nodes) {
+ TVector<TNetAddr> r;
- TVector<TString> hosts;
+ TVector<TString> hosts;
size_t numh = Split(nodes.data(), ",", hosts);
@@ -583,7 +583,7 @@ void TTestStats::PeriodicallyPrint() {
stats << IndentText(client->Bus->GetStatus());
}
- TUnbufferedFileOutput("stats").Write(stats.Str());
+ TUnbufferedFileOutput("stats").Write(stats.Str());
}
}