diff options
| author | tobo <[email protected]> | 2022-02-10 16:47:27 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:47:27 +0300 | 
| commit | 55a7f90e4cd31e9481cace8ee5dfd682c27e810e (patch) | |
| tree | 9814fbd1c3effac9b8377c5d604b367b14e2db55 /library/cpp/messagebus | |
| parent | 7fe839092527589b38f014d854c51565b3c1adfa (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 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 c509af90552..fca228d82e8 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 bb5560debdb..16281143911 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 44f515d1c37..51d75762f68 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 3066a6cceae..22932569dbd 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 985c135b959..7c6d704042c 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 b8f79b92202..84893192789 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 5ff09b74ed0..9c21227e2bd 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 af3ed2761cb..62ec241d852 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);      }  | 
