diff options
author | tobo <tobo@yandex-team.ru> | 2022-02-10 16:47:27 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:27 +0300 |
commit | 7fe839092527589b38f014d854c51565b3c1adfa (patch) | |
tree | 309e97022d3530044b712b8f71318c78faf7856e /library/cpp/messagebus | |
parent | d0d68c395c10da4cb56a1c845504570a04d7893e (diff) | |
download | ydb-7fe839092527589b38f014d854c51565b3c1adfa.tar.gz |
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r-- | library/cpp/messagebus/coreconn.h | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/http/client_ut.cpp | 24 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/http/http_code_extractor.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/remote_connection.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/test/helper/example.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/test/perftest/perftest.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/test/ut/one_way_ut.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/www/www.cpp | 18 |
8 files changed, 32 insertions, 32 deletions
diff --git a/library/cpp/messagebus/coreconn.h b/library/cpp/messagebus/coreconn.h index fca228d82e..c509af9055 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 1628114391..bb5560debd 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 51d75762f6..44f515d1c3 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 22932569db..3066a6ccea 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 7c6d704042..985c135b95 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 8489319278..b8f79b9220 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 9c21227e2b..5ff09b74ed 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 62ec241d85..af3ed2761c 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); } |