diff options
author | dobrokot <dobrokot@yandex-team.ru> | 2022-02-10 16:49:07 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:07 +0300 |
commit | 8d57b69dee81198a59c39e64704f7dc9f04b4fbf (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus | |
parent | 25d83bf841d8b3ce3886525078f1964ac3c293c5 (diff) | |
download | ydb-8d57b69dee81198a59c39e64704f7dc9f04b4fbf.tar.gz |
Restoring authorship annotation for <dobrokot@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r-- | library/cpp/messagebus/actor/ring_buffer.h | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/remote_client_session.h | 14 | ||||
-rw-r--r-- | library/cpp/messagebus/remote_server_session.h | 14 | ||||
-rw-r--r-- | library/cpp/messagebus/synchandler.cpp | 16 |
4 files changed, 23 insertions, 23 deletions
diff --git a/library/cpp/messagebus/actor/ring_buffer.h b/library/cpp/messagebus/actor/ring_buffer.h index 8b63149f4f..ec5706f7c7 100644 --- a/library/cpp/messagebus/actor/ring_buffer.h +++ b/library/cpp/messagebus/actor/ring_buffer.h @@ -34,7 +34,7 @@ private: return; ui32 newCapacityPow = CapacityPow; - while ((1u << newCapacityPow) < sz + ui32(Size()) + 1u) { + while ((1u << newCapacityPow) < sz + ui32(Size()) + 1u) { ++newCapacityPow; } ui32 newCapacity = 1u << newCapacityPow; diff --git a/library/cpp/messagebus/remote_client_session.h b/library/cpp/messagebus/remote_client_session.h index bde90a90b0..7160d0dae9 100644 --- a/library/cpp/messagebus/remote_client_session.h +++ b/library/cpp/messagebus/remote_client_session.h @@ -6,10 +6,10 @@ #include <util/generic/array_ref.h> #include <util/generic/object_counter.h> -#ifdef _MSC_VER -#pragma warning(push) +#ifdef _MSC_VER +#pragma warning(push) #pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance -#endif +#endif namespace NBus { namespace NPrivate { @@ -51,9 +51,9 @@ namespace NBus { TBusClientConnectionPtr GetConnection(const TNetAddr&) override; }; -#ifdef _MSC_VER -#pragma warning(pop) -#endif - +#ifdef _MSC_VER +#pragma warning(pop) +#endif + } } diff --git a/library/cpp/messagebus/remote_server_session.h b/library/cpp/messagebus/remote_server_session.h index 3970a31aa6..f5c266a7f7 100644 --- a/library/cpp/messagebus/remote_server_session.h +++ b/library/cpp/messagebus/remote_server_session.h @@ -3,10 +3,10 @@ #include "remote_server_session_semaphore.h" #include "session_impl.h" -#ifdef _MSC_VER -#pragma warning(push) +#ifdef _MSC_VER +#pragma warning(push) #pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance -#endif +#endif namespace NBus { namespace NPrivate { @@ -46,9 +46,9 @@ namespace NBus { void ConvertInWork(TBusIdentity& req, TBusMessage* reply); }; -#ifdef _MSC_VER -#pragma warning(pop) -#endif - +#ifdef _MSC_VER +#pragma warning(pop) +#endif + } } diff --git a/library/cpp/messagebus/synchandler.cpp b/library/cpp/messagebus/synchandler.cpp index 821b778d30..8e891d66b3 100644 --- a/library/cpp/messagebus/synchandler.cpp +++ b/library/cpp/messagebus/synchandler.cpp @@ -91,11 +91,11 @@ private: namespace NBus { namespace NPrivate { -#ifdef _MSC_VER -#pragma warning(push) +#ifdef _MSC_VER +#pragma warning(push) #pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance -#endif - +#endif + /////////////////////////////////////////////////////////////////////////// class TBusSyncSourceSessionImpl : private TSyncHandler @@ -147,12 +147,12 @@ namespace NBus { } }; -#ifdef _MSC_VER -#pragma warning(pop) -#endif +#ifdef _MSC_VER +#pragma warning(pop) +#endif } } - + TBusSyncSourceSession::TBusSyncSourceSession(TIntrusivePtr< ::NBus::NPrivate::TBusSyncSourceSessionImpl> session) : Session(session) { |