Restoring authorship annotation for Anton Samokhvalov <[email protected]>. Commit 1 of 2.

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 f5c266a7f74..5de07c4e59d 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
 
-    }
-}
+    } 
+}