diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:17 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:17 +0300 |
commit | d3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch) | |
tree | dd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/messagebus/remote_server_connection.h | |
parent | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff) | |
download | ydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/remote_server_connection.h')
-rw-r--r-- | library/cpp/messagebus/remote_server_connection.h | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/library/cpp/messagebus/remote_server_connection.h b/library/cpp/messagebus/remote_server_connection.h index 925338f3ff..63d7f20646 100644 --- a/library/cpp/messagebus/remote_server_connection.h +++ b/library/cpp/messagebus/remote_server_connection.h @@ -4,29 +4,29 @@ #include <util/generic/object_counter.h> -namespace NBus { - namespace NPrivate { - class TRemoteServerConnection: public TRemoteConnection { - friend struct TBusSessionImpl; - friend class TRemoteServerSession; +namespace NBus { + namespace NPrivate { + class TRemoteServerConnection: public TRemoteConnection { + friend struct TBusSessionImpl; + friend class TRemoteServerSession; - TObjectCounter<TRemoteServerConnection> ObjectCounter; + TObjectCounter<TRemoteServerConnection> ObjectCounter; - public: - TRemoteServerConnection(TRemoteServerSessionPtr session, ui64 id, TNetAddr addr); + public: + TRemoteServerConnection(TRemoteServerSessionPtr session, ui64 id, TNetAddr addr); - void Init(SOCKET socket, TInstant now); + void Init(SOCKET socket, TInstant now); - inline TRemoteServerSession* GetSession(); + inline TRemoteServerSession* GetSession(); - void HandleEvent(SOCKET socket, void* cookie) override; + void HandleEvent(SOCKET socket, void* cookie) override; - bool NeedInterruptRead() override; + bool NeedInterruptRead() override; - void MessageSent(TArrayRef<TBusMessagePtrAndHeader> messages) override; + void MessageSent(TArrayRef<TBusMessagePtrAndHeader> messages) override; - void ReaderProcessMessageUnknownVersion(TArrayRef<const char> dataRef) override; - }; + void ReaderProcessMessageUnknownVersion(TArrayRef<const char> dataRef) override; + }; - } -} + } +} |