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/acceptor.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/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 6f645cdfa1d..57cb010bf22 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; }; - } -} + } +} |