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/acceptor.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/acceptor.h')
-rw-r--r-- | library/cpp/messagebus/acceptor.h | 66 |
1 files changed, 33 insertions, 33 deletions
diff --git a/library/cpp/messagebus/acceptor.h b/library/cpp/messagebus/acceptor.h index 57cb010bf22..6f645cdfa1d 100644 --- a/library/cpp/messagebus/acceptor.h +++ b/library/cpp/messagebus/acceptor.h @@ -11,50 +11,50 @@ #include <util/system/event.h> -namespace NBus { - namespace NPrivate { - class TAcceptor - : public NEventLoop::IEventHandler, - private ::NActor::TActor<TAcceptor> { - friend struct TBusSessionImpl; - friend class ::NActor::TActor<TAcceptor>; +namespace NBus { + namespace NPrivate { + class TAcceptor + : public NEventLoop::IEventHandler, + private ::NActor::TActor<TAcceptor> { + friend struct TBusSessionImpl; + friend class ::NActor::TActor<TAcceptor>; - public: - TAcceptor(TBusSessionImpl* session, ui64 acceptorId, SOCKET socket, const TNetAddr& addr); + public: + TAcceptor(TBusSessionImpl* session, ui64 acceptorId, SOCKET socket, const TNetAddr& addr); - void HandleEvent(SOCKET socket, void* cookie) override; + void HandleEvent(SOCKET socket, void* cookie) override; - void Shutdown(); + void Shutdown(); - inline ::NActor::TActor<TAcceptor>* GetActor() { - return this; - } + inline ::NActor::TActor<TAcceptor>* GetActor() { + return this; + } - private: - void SendStatus(TInstant now); - void Act(::NActor::TDefaultTag); + private: + void SendStatus(TInstant now); + void Act(::NActor::TDefaultTag); - private: - const ui64 AcceptorId; + private: + const ui64 AcceptorId; - TBusSessionImpl* const Session; - NEventLoop::TChannelPtr Channel; + TBusSessionImpl* const Session; + NEventLoop::TChannelPtr Channel; - TAcceptorStatus Stats; + TAcceptorStatus Stats; - TAtomicShutdownState ShutdownState; + TAtomicShutdownState ShutdownState; - struct TGranStatus { - TGranStatus(TDuration gran) - : Listen(gran) - { - } + struct TGranStatus { + TGranStatus(TDuration gran) + : Listen(gran) + { + } - TGranUp<TAcceptorStatus> Listen; - }; + TGranUp<TAcceptorStatus> Listen; + }; - TGranStatus GranStatus; + TGranStatus GranStatus; }; - } -} + } +} |