Restoring authorship annotation for <thegeorg@yandex-team.ru>. Commit 1 of 2.

12 files changed, 20 insertions, 20 deletions

diff --git a/library/cpp/messagebus/event_loop.cpp b/library/cpp/messagebus/event_loop.cpp
index f685135bed..2ae3e527be 100644
--- a/library/cpp/messagebus/event_loop.cpp
+++ b/library/cpp/messagebus/event_loop.cpp
@@ -350,7 +350,7 @@ TChannelPtr TEventLoop::TImpl::Register(TSocket socket, TEventHandlerPtr eventHa
 }
 
 void TEventLoop::TImpl::Wakeup() {
-    if (NBus::NPrivate::SocketSend(WakeupWriteSocket, TArrayRef<const char>("", 1)) < 0) {
+    if (NBus::NPrivate::SocketSend(WakeupWriteSocket, TArrayRef<const char>("", 1)) < 0) { 
         if (LastSystemError() != EAGAIN) {
             Y_FAIL("failed to send to wakeup socket: %s", LastSystemErrorText());
         }
diff --git a/library/cpp/messagebus/network.cpp b/library/cpp/messagebus/network.cpp
index 304bedae5a..29ecd6a2a7 100644
--- a/library/cpp/messagebus/network.cpp
+++ b/library/cpp/messagebus/network.cpp
@@ -131,7 +131,7 @@ void NBus::NPrivate::SetSockOptTcpCork(SOCKET s, bool value) {
 #endif
 }
 
-ssize_t NBus::NPrivate::SocketSend(SOCKET s, TArrayRef<const char> data) {
+ssize_t NBus::NPrivate::SocketSend(SOCKET s, TArrayRef<const char> data) { 
     int flags = 0;
 #if defined(_linux_) || defined(_freebsd_)
     flags |= MSG_NOSIGNAL;
@@ -143,7 +143,7 @@ ssize_t NBus::NPrivate::SocketSend(SOCKET s, TArrayRef<const char> data) {
     return r;
 }
 
-ssize_t NBus::NPrivate::SocketRecv(SOCKET s, TArrayRef<char> buffer) {
+ssize_t NBus::NPrivate::SocketRecv(SOCKET s, TArrayRef<char> buffer) { 
     int flags = 0;
 #if defined(_linux_) || defined(_freebsd_)
     flags |= MSG_NOSIGNAL;
diff --git a/library/cpp/messagebus/network.h b/library/cpp/messagebus/network.h
index cc4bd76ea3..aaa2789b62 100644
--- a/library/cpp/messagebus/network.h
+++ b/library/cpp/messagebus/network.h
@@ -2,7 +2,7 @@
 
 #include "netaddr.h"
 
-#include <util/generic/array_ref.h>
+#include <util/generic/array_ref.h> 
 #include <util/generic/ptr.h>
 #include <util/network/socket.h>
 
@@ -12,9 +12,9 @@ namespace NBus {
     namespace NPrivate {
         void SetSockOptTcpCork(SOCKET s, bool value);
 
-        [[nodiscard]] ssize_t SocketSend(SOCKET s, TArrayRef<const char> data);
+        [[nodiscard]] ssize_t SocketSend(SOCKET s, TArrayRef<const char> data); 
 
-        [[nodiscard]] ssize_t SocketRecv(SOCKET s, TArrayRef<char> buffer);
+        [[nodiscard]] ssize_t SocketRecv(SOCKET s, TArrayRef<char> buffer); 
 
     }
 
diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h
index 8d1c4a5d52..1cbff60f26 100644
--- a/library/cpp/messagebus/oldmodule/module.h
+++ b/library/cpp/messagebus/oldmodule/module.h
@@ -73,10 +73,10 @@ namespace NBus {
         }
         TJobHandler(const TJobHandler&) = default;
         TJobHandler& operator =(const TJobHandler&) = default;
-        bool operator==(TJobHandler h) const {
+        bool operator==(TJobHandler h) const { 
             return MyPtr == h.MyPtr;
         }
-        bool operator!=(TJobHandler h) const {
+        bool operator!=(TJobHandler h) const { 
             return MyPtr != h.MyPtr;
         }
         bool operator!() const {
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.cpp b/library/cpp/messagebus/protobuf/ybusbuf.cpp
index 63415b3737..d47eee0672 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.cpp
+++ b/library/cpp/messagebus/protobuf/ybusbuf.cpp
@@ -2,7 +2,7 @@
 
 #include <library/cpp/messagebus/actor/what_thread_does.h>
 
-#include <google/protobuf/io/coded_stream.h>
+#include <google/protobuf/io/coded_stream.h> 
 
 using namespace NBus;
 
@@ -78,7 +78,7 @@ TAutoPtr<TBusMessage> TBusBufferProtocol::Deserialize(ui16 messageType, TArrayRe
     // Need to override protobuf message size limit
     // NOTE: the payload size has already been checked against session MaxMessageSize
     google::protobuf::io::CodedInputStream input(reinterpret_cast<const ui8*>(payload.data()), payload.size());
-    input.SetTotalBytesLimit(payload.size());
+    input.SetTotalBytesLimit(payload.size()); 
 
     bool ok = bmess->GetRecord()->ParseFromCodedStream(&input) && input.ConsumedEntireMessage();
     if (!ok) {
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.h b/library/cpp/messagebus/protobuf/ybusbuf.h
index 57b4267ea5..4f8aca472f 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.h
+++ b/library/cpp/messagebus/protobuf/ybusbuf.h
@@ -2,8 +2,8 @@
 
 #include <library/cpp/messagebus/ybus.h>
 
-#include <google/protobuf/descriptor.h>
-#include <google/protobuf/message.h>
+#include <google/protobuf/descriptor.h> 
+#include <google/protobuf/message.h> 
 
 #include <util/generic/cast.h>
 #include <util/generic/vector.h>
diff --git a/library/cpp/messagebus/rain_check/core/coro.cpp b/library/cpp/messagebus/rain_check/core/coro.cpp
index 500841dd5b..53248ae3f0 100644
--- a/library/cpp/messagebus/rain_check/core/coro.cpp
+++ b/library/cpp/messagebus/rain_check/core/coro.cpp
@@ -7,7 +7,7 @@
 
 using namespace NRainCheck;
 
-TContClosure TCoroTaskRunner::ContClosure(TCoroTaskRunner* runner, TArrayRef<char> memRegion) {
+TContClosure TCoroTaskRunner::ContClosure(TCoroTaskRunner* runner, TArrayRef<char> memRegion) { 
     TContClosure contClosure;
     contClosure.TrampoLine = runner;
     contClosure.Stack = memRegion;
diff --git a/library/cpp/messagebus/rain_check/core/coro.h b/library/cpp/messagebus/rain_check/core/coro.h
index 95e2a30f9b..0106e8a4a9 100644
--- a/library/cpp/messagebus/rain_check/core/coro.h
+++ b/library/cpp/messagebus/rain_check/core/coro.h
@@ -25,7 +25,7 @@ namespace NRainCheck {
         ~TCoroTaskRunner() override;
 
     private:
-        static TContClosure ContClosure(TCoroTaskRunner* runner, TArrayRef<char> memRegion);
+        static TContClosure ContClosure(TCoroTaskRunner* runner, TArrayRef<char> memRegion); 
 
         bool ReplyReceived() override /* override */;
 
diff --git a/library/cpp/messagebus/rain_check/core/coro_stack.h b/library/cpp/messagebus/rain_check/core/coro_stack.h
index 2f3520e6e4..9f90ad4abc 100644
--- a/library/cpp/messagebus/rain_check/core/coro_stack.h
+++ b/library/cpp/messagebus/rain_check/core/coro_stack.h
@@ -25,8 +25,8 @@ namespace NRainCheck {
                 return SizeValue;
             }
 
-            TArrayRef<char> MemRegion() {
-                return TArrayRef((char*)Data(), Size());
+            TArrayRef<char> MemRegion() { 
+                return TArrayRef((char*)Data(), Size()); 
             }
 
             ui32* MagicNumberLocation() {
diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp
index 22932569db..628a8c10e3 100644
--- a/library/cpp/messagebus/remote_connection.cpp
+++ b/library/cpp/messagebus/remote_connection.cpp
@@ -412,7 +412,7 @@ namespace NBus {
             ssize_t bytes;
             {
                 TWhatThreadDoesPushPop pp("recv syscall");
-                bytes = SocketRecv(ReaderData.Channel->GetSocket(), TArrayRef<char>(ReaderData.Buffer.Pos(), ReaderData.Buffer.Avail()));
+                bytes = SocketRecv(ReaderData.Channel->GetSocket(), TArrayRef<char>(ReaderData.Buffer.Pos(), ReaderData.Buffer.Avail())); 
             }
 
             if (bytes < 0) {
@@ -621,7 +621,7 @@ namespace NBus {
                 ssize_t bytes;
                 {
                     TWhatThreadDoesPushPop pp("send syscall");
-                    bytes = SocketSend(WriterData.Channel->GetSocket(), TArrayRef<const char>(WriterData.Buffer.LeftPos(), WriterData.Buffer.Size()));
+                    bytes = SocketSend(WriterData.Channel->GetSocket(), TArrayRef<const char>(WriterData.Buffer.LeftPos(), WriterData.Buffer.Size())); 
                 }
 
                 if (bytes < 0) {
diff --git a/library/cpp/messagebus/storage.h b/library/cpp/messagebus/storage.h
index 7d168844ed..37e0f140b7 100644
--- a/library/cpp/messagebus/storage.h
+++ b/library/cpp/messagebus/storage.h
@@ -85,7 +85,7 @@ namespace NBus {
                 }
             };
 
-            typedef google::dense_hash_map<TBusKey, TValue, TIdHash> TKeyToMessage;
+            typedef google::dense_hash_map<TBusKey, TValue, TIdHash> TKeyToMessage; 
 
             TKeyToMessage KeyToMessage;
         };
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index e13cf06dea..ff3ea2d5cc 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -2,7 +2,7 @@ LIBRARY()
 
 OWNER(g:messagebus)
 
-IF (SANITIZER_TYPE == "undefined")
+IF (SANITIZER_TYPE == "undefined") 
     NO_SANITIZE()
 ENDIF()