diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/remote_server_connection.h | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 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 63d7f20646..925338f3ff 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; + }; - } -} + } +} |