aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authortobo <tobo@yandex-team.ru>2022-02-10 16:47:27 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:27 +0300
commit55a7f90e4cd31e9481cace8ee5dfd682c27e810e (patch)
tree9814fbd1c3effac9b8377c5d604b367b14e2db55 /library/cpp/messagebus
parent7fe839092527589b38f014d854c51565b3c1adfa (diff)
downloadydb-55a7f90e4cd31e9481cace8ee5dfd682c27e810e.tar.gz
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/coreconn.h2
-rw-r--r--library/cpp/messagebus/rain_check/http/client_ut.cpp24
-rw-r--r--library/cpp/messagebus/rain_check/http/http_code_extractor.cpp4
-rw-r--r--library/cpp/messagebus/remote_connection.cpp4
-rw-r--r--library/cpp/messagebus/test/helper/example.cpp4
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/one_way_ut.cpp4
-rw-r--r--library/cpp/messagebus/www/www.cpp18
8 files changed, 32 insertions, 32 deletions
diff --git a/library/cpp/messagebus/coreconn.h b/library/cpp/messagebus/coreconn.h
index c509af9055..fca228d82e 100644
--- a/library/cpp/messagebus/coreconn.h
+++ b/library/cpp/messagebus/coreconn.h
@@ -54,7 +54,7 @@ namespace NBus {
struct TMaxConnectedException: public yexception {
TMaxConnectedException(unsigned maxConnect) {
yexception& exc = *this;
- exc << TStringBuf("Exceeded maximum number of outstanding connections: ");
+ exc << TStringBuf("Exceeded maximum number of outstanding connections: ");
exc << maxConnect;
}
};
diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp
index bb5560debd..1628114391 100644
--- a/library/cpp/messagebus/rain_check/http/client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp
@@ -182,24 +182,24 @@ Y_UNIT_TEST_SUITE(RainCheckHttpClient) {
UNIT_ASSERT(!!TryGetHttpCodeFromErrorDescription(line)); \
UNIT_ASSERT_EQUAL(*TryGetHttpCodeFromErrorDescription(line), code)
- CHECK_VALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.0 200 Some random message"), 200);
- CHECK_VALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.0 404 Some random message"), 404);
- CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.0 100 Some random message"), 100);
- CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.0 105)"), 105);
- CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.1 2004 Some random message"), 200);
+ CHECK_VALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.0 200 Some random message"), 200);
+ CHECK_VALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.0 404 Some random message"), 404);
+ CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.0 100 Some random message"), 100);
+ CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.0 105)"), 105);
+ CHECK_VALID_LINE(TStringBuf("request failed(HTTP/1.1 2004 Some random message"), 200);
#undef CHECK_VALID_LINE
#define CHECK_INVALID_LINE(line) \
UNIT_ASSERT_NO_EXCEPTION(TryGetHttpCodeFromErrorDescription(line)); \
UNIT_ASSERT(!TryGetHttpCodeFromErrorDescription(line))
- CHECK_INVALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.1 1 Some random message"));
- CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.0 asdf Some random message"));
- CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200 Some random message"));
- CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.0 2x00 Some random message"));
- CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200 Some random message"));
- CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200"));
- CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.1 3334 Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("library/cpp/neh/http.cpp:<LINE>: request failed(HTTP/1.1 1 Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.0 asdf Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200 Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.0 2x00 Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200 Some random message"));
+ CHECK_INVALID_LINE(TStringBuf("HTTP/1.0 200"));
+ CHECK_INVALID_LINE(TStringBuf("request failed(HTTP/1.1 3334 Some random message"));
#undef CHECK_INVALID_LINE
}
}
diff --git a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
index 44f515d1c3..51d75762f6 100644
--- a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
+++ b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
@@ -14,9 +14,9 @@ namespace NRainCheck {
// "library/cpp/neh/http.cpp:<LINE>: request failed(<FIRST-HTTP-RESPONSE-LINE>)"
// (see library/cpp/neh/http.cpp:625). So, we will try to parse this message and
// find out HttpCode in it. It is bad temporary solution, but we have no choice.
- const TStringBuf SUBSTR = "request failed(";
+ const TStringBuf SUBSTR = "request failed(";
const size_t SUBSTR_LEN = SUBSTR.size();
- const size_t FIRST_LINE_LEN = TStringBuf("HTTP/1.X NNN").size();
+ const size_t FIRST_LINE_LEN = TStringBuf("HTTP/1.X NNN").size();
TMaybe<HttpCodes> httpCode;
diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp
index 3066a6ccea..22932569db 100644
--- a/library/cpp/messagebus/remote_connection.cpp
+++ b/library/cpp/messagebus/remote_connection.cpp
@@ -676,14 +676,14 @@ namespace NBus {
}
namespace {
- inline void WriteHeader(const TBusHeader& header, TBuffer& data) {
+ inline void WriteHeader(const TBusHeader& header, TBuffer& data) {
data.Reserve(data.Size() + sizeof(TBusHeader));
/// \todo hton instead of memcpy
memcpy(data.Data() + data.Size(), &header, sizeof(TBusHeader));
data.Advance(sizeof(TBusHeader));
}
- inline void WriteDummyHeader(TBuffer& data) {
+ inline void WriteDummyHeader(TBuffer& data) {
data.Resize(data.Size() + sizeof(TBusHeader));
}
diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp
index 985c135b95..7c6d704042 100644
--- a/library/cpp/messagebus/test/helper/example.cpp
+++ b/library/cpp/messagebus/test/helper/example.cpp
@@ -8,11 +8,11 @@ using namespace NBus;
using namespace NBus::NTest;
static void FillWithJunk(TArrayRef<char> data) {
- TStringBuf junk =
+ TStringBuf junk =
"01234567890123456789012345678901234567890123456789012345678901234567890123456789"
"01234567890123456789012345678901234567890123456789012345678901234567890123456789"
"01234567890123456789012345678901234567890123456789012345678901234567890123456789"
- "01234567890123456789012345678901234567890123456789012345678901234567890123456789";
+ "01234567890123456789012345678901234567890123456789012345678901234567890123456789";
for (size_t i = 0; i < data.size(); i += junk.size()) {
memcpy(data.data() + i, junk.data(), Min(junk.size(), data.size() - i));
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index b8f79b9220..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -125,8 +125,8 @@ TConfig Config;
////////////////////////////////////////////////////////////////
/// \brief Fast message
-using TPerftestRequest = TBusBufferMessage<TPerftestRequestRecord, 77>;
-using TPerftestResponse = TBusBufferMessage<TPerftestResponseRecord, 79>;
+using TPerftestRequest = TBusBufferMessage<TPerftestRequestRecord, 77>;
+using TPerftestResponse = TBusBufferMessage<TPerftestResponseRecord, 79>;
static size_t RequestSize() {
return RandomNumber<size_t>(TheConfig->MessageSize * 2 + 1);
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index 5ff09b74ed..9c21227e2b 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -64,7 +64,7 @@ struct NullClient : TBusClientHandlerError {
Session->RegisterService("localhost");
}
- ~NullClient() override {
+ ~NullClient() override {
Session->Shutdown();
}
@@ -106,7 +106,7 @@ public:
Session = TBusServerSession::Create(&Proto, this, sessionConfig, Queue);
}
- ~NullServer() override {
+ ~NullServer() override {
Session->Shutdown();
}
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index af3ed2761c..62ec241d85 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -121,23 +121,23 @@ namespace {
}
namespace {
- TString RootHref() {
+ TString RootHref() {
return ConcatStrings("?");
}
- TString QueueHref(TStringBuf name) {
+ TString QueueHref(TStringBuf name) {
return ConcatStrings("?q=", name);
}
- TString ServerSessionHref(TStringBuf name) {
+ TString ServerSessionHref(TStringBuf name) {
return ConcatStrings("?ss=", name);
}
- TString ClientSessionHref(TStringBuf name) {
+ TString ClientSessionHref(TStringBuf name) {
return ConcatStrings("?cs=", name);
}
- TString OldModuleHref(TStringBuf name) {
+ TString OldModuleHref(TStringBuf name) {
return ConcatStrings("?om=", name);
}
@@ -147,19 +147,19 @@ namespace {
}
*/
- void QueueLink(TStringBuf name) {
+ void QueueLink(TStringBuf name) {
A(QueueHref(name), name);
}
- void ServerSessionLink(TStringBuf name) {
+ void ServerSessionLink(TStringBuf name) {
A(ServerSessionHref(name), name);
}
- void ClientSessionLink(TStringBuf name) {
+ void ClientSessionLink(TStringBuf name) {
A(ClientSessionHref(name), name);
}
- void OldModuleLink(TStringBuf name) {
+ void OldModuleLink(TStringBuf name) {
A(OldModuleHref(name), name);
}