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_session.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_session.h')
-rw-r--r-- | library/cpp/messagebus/remote_server_session.h | 60 |
1 files changed, 30 insertions, 30 deletions
diff --git a/library/cpp/messagebus/remote_server_session.h b/library/cpp/messagebus/remote_server_session.h index 5de07c4e59..f5c266a7f7 100644 --- a/library/cpp/messagebus/remote_server_session.h +++ b/library/cpp/messagebus/remote_server_session.h @@ -5,50 +5,50 @@ #ifdef _MSC_VER #pragma warning(push) -#pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance +#pragma warning(disable : 4250) // 'NBus::NPrivate::TRemoteClientSession' : inherits 'NBus::NPrivate::TBusSessionImpl::NBus::NPrivate::TBusSessionImpl::GetConfig' via dominance #endif -namespace NBus { - namespace NPrivate { - class TRemoteServerSession: public TBusServerSession, public TBusSessionImpl { - friend class TRemoteServerConnection; +namespace NBus { + namespace NPrivate { + class TRemoteServerSession: public TBusServerSession, public TBusSessionImpl { + friend class TRemoteServerConnection; - private: - TObjectCounter<TRemoteServerSession> ObjectCounter; + private: + TObjectCounter<TRemoteServerSession> ObjectCounter; - TRemoteServerSessionSemaphore ServerOwnedMessages; - IBusServerHandler* const ServerHandler; + TRemoteServerSessionSemaphore ServerOwnedMessages; + IBusServerHandler* const ServerHandler; - public: - TRemoteServerSession(TBusMessageQueue* queue, TBusProtocol* proto, - IBusServerHandler* handler, - const TBusSessionConfig& config, const TString& name); + public: + TRemoteServerSession(TBusMessageQueue* queue, TBusProtocol* proto, + IBusServerHandler* handler, + const TBusSessionConfig& config, const TString& name); - void OnMessageReceived(TRemoteConnection* c, TVectorSwaps<TBusMessagePtrAndHeader>& newMsg) override; - void InvokeOnMessage(TBusMessagePtrAndHeader& request, TIntrusivePtr<TRemoteServerConnection>& conn); + void OnMessageReceived(TRemoteConnection* c, TVectorSwaps<TBusMessagePtrAndHeader>& newMsg) override; + void InvokeOnMessage(TBusMessagePtrAndHeader& request, TIntrusivePtr<TRemoteServerConnection>& conn); - EMessageStatus SendReply(const TBusIdentity& ident, TBusMessage* pRep) override; + EMessageStatus SendReply(const TBusIdentity& ident, TBusMessage* pRep) override; - EMessageStatus ForgetRequest(const TBusIdentity& ident) override; + EMessageStatus ForgetRequest(const TBusIdentity& ident) override; - int GetInFlight() const noexcept override; - void FillStatus() override; + int GetInFlight() const noexcept override; + void FillStatus() override; - void Shutdown() override; + void Shutdown() override; - void PauseInput(bool pause) override; - unsigned GetActualListenPort() override; + void PauseInput(bool pause) override; + unsigned GetActualListenPort() override; - void AcquireInWorkRequests(TArrayRef<const TBusMessagePtrAndHeader> requests); - void ReleaseInWorkResponses(TArrayRef<const TBusMessagePtrAndHeader> responses); - void ReleaseInWorkRequests(TRemoteConnection&, TBusMessage*); - void ReleaseInWork(TBusIdentity&); - void ConvertInWork(TBusIdentity& req, TBusMessage* reply); - }; + void AcquireInWorkRequests(TArrayRef<const TBusMessagePtrAndHeader> requests); + void ReleaseInWorkResponses(TArrayRef<const TBusMessagePtrAndHeader> responses); + void ReleaseInWorkRequests(TRemoteConnection&, TBusMessage*); + void ReleaseInWork(TBusIdentity&); + void ConvertInWork(TBusIdentity& req, TBusMessage* reply); + }; #ifdef _MSC_VER #pragma warning(pop) #endif - } -} + } +} |