Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.

1 files changed, 122 insertions, 122 deletions

diff --git a/library/cpp/messagebus/handler.h b/library/cpp/messagebus/handler.h
index 60002c68a6..211b2f5bca 100644
--- a/library/cpp/messagebus/handler.h
+++ b/library/cpp/messagebus/handler.h
@@ -9,127 +9,127 @@
 #include <util/generic/noncopyable.h>
 
 namespace NBus {
-    /////////////////////////////////////////////////////////////////
-    /// \brief Interface to message bus handler
-
-    struct IBusErrorHandler {
-        friend struct ::NBus::NPrivate::TBusSessionImpl;
-
-    private:
-        TUseAfterFreeChecker UseAfterFreeChecker;
-        TUseCountChecker UseCountChecker;
-
-    public:
-        /// called when message or reply can't be delivered
-        virtual void OnError(TAutoPtr<TBusMessage> pMessage, EMessageStatus status);
-
-        virtual ~IBusErrorHandler() {
-        }
-    };
-
-    class TClientConnectionEvent {
-    public:
-        enum EType {
-            CONNECTED,
-            DISCONNECTED,
-        };
-
-    private:
-        EType Type;
-        ui64 Id;
-        TNetAddr Addr;
-
-    public:
-        TClientConnectionEvent(EType type, ui64 id, TNetAddr addr)
-            : Type(type)
-            , Id(id)
-            , Addr(addr)
-        {
-        }
-
-        EType GetType() const {
-            return Type;
-        }
-        ui64 GetId() const {
-            return Id;
-        }
-        TNetAddr GetAddr() const {
-            return Addr;
-        }
-    };
-
-    class TOnMessageContext : TNonCopyable {
-    private:
-        THolder<TBusMessage> Message;
-        TBusIdentity Ident;
-        // TODO: we don't need to store session, we have connection in ident
-        TBusServerSession* Session;
-
-    public:
-        TOnMessageContext()
-            : Session()
-        {
-        }
-        TOnMessageContext(TAutoPtr<TBusMessage> message, TBusIdentity& ident, TBusServerSession* session)
-            : Message(message)
-            , Session(session)
-        {
-            Ident.Swap(ident);
-        }
-
-        bool IsInWork() const {
-            return Ident.IsInWork();
-        }
-
-        bool operator!() const {
-            return !IsInWork();
-        }
-
-        TBusMessage* GetMessage() {
-            return Message.Get();
-        }
-
-        TBusMessage* ReleaseMessage() {
-            return Message.Release();
-        }
-
-        TBusServerSession* GetSession() {
-            return Session;
-        }
-
-        template <typename U /* <: TBusMessage */>
-        EMessageStatus SendReplyAutoPtr(TAutoPtr<U>& rep);
-
-        EMessageStatus SendReplyMove(TBusMessageAutoPtr response);
-
-        void AckMessage(TBusIdentity& ident);
-
-        void ForgetRequest();
-
-        void Swap(TOnMessageContext& that) {
-            DoSwap(Message, that.Message);
-            Ident.Swap(that.Ident);
-            DoSwap(Session, that.Session);
-        }
-
-        TNetAddr GetPeerAddrNetAddr() const;
-
-        bool IsConnectionAlive() const;
-    };
-
-    struct IBusServerHandler: public IBusErrorHandler {
-        virtual void OnMessage(TOnMessageContext& onMessage) = 0;
-        /// called when reply has been sent from destination
-        virtual void OnSent(TAutoPtr<TBusMessage> pMessage);
-    };
-
-    struct IBusClientHandler: public IBusErrorHandler {
-        /// called on source when reply arrives from destination
-        virtual void OnReply(TAutoPtr<TBusMessage> pMessage, TAutoPtr<TBusMessage> pReply) = 0;
-        /// called when client side message has gone into wire, place to call AckMessage()
-        virtual void OnMessageSent(TBusMessage* pMessage);
-        virtual void OnMessageSentOneWay(TAutoPtr<TBusMessage> pMessage);
-        virtual void OnClientConnectionEvent(const TClientConnectionEvent&);
+    ///////////////////////////////////////////////////////////////// 
+    /// \brief Interface to message bus handler 
+
+    struct IBusErrorHandler { 
+        friend struct ::NBus::NPrivate::TBusSessionImpl; 
+
+    private: 
+        TUseAfterFreeChecker UseAfterFreeChecker; 
+        TUseCountChecker UseCountChecker; 
+
+    public: 
+        /// called when message or reply can't be delivered 
+        virtual void OnError(TAutoPtr<TBusMessage> pMessage, EMessageStatus status); 
+
+        virtual ~IBusErrorHandler() { 
+        } 
+    }; 
+
+    class TClientConnectionEvent { 
+    public: 
+        enum EType { 
+            CONNECTED, 
+            DISCONNECTED, 
+        }; 
+
+    private: 
+        EType Type; 
+        ui64 Id; 
+        TNetAddr Addr; 
+
+    public: 
+        TClientConnectionEvent(EType type, ui64 id, TNetAddr addr) 
+            : Type(type) 
+            , Id(id) 
+            , Addr(addr) 
+        { 
+        } 
+ 
+        EType GetType() const { 
+            return Type; 
+        } 
+        ui64 GetId() const { 
+            return Id; 
+        } 
+        TNetAddr GetAddr() const { 
+            return Addr; 
+        } 
     };
 
-}
+    class TOnMessageContext : TNonCopyable { 
+    private: 
+        THolder<TBusMessage> Message; 
+        TBusIdentity Ident; 
+        // TODO: we don't need to store session, we have connection in ident 
+        TBusServerSession* Session; 
+
+    public: 
+        TOnMessageContext() 
+            : Session() 
+        { 
+        } 
+        TOnMessageContext(TAutoPtr<TBusMessage> message, TBusIdentity& ident, TBusServerSession* session) 
+            : Message(message) 
+            , Session(session) 
+        { 
+            Ident.Swap(ident); 
+        } 
+
+        bool IsInWork() const { 
+            return Ident.IsInWork(); 
+        } 
+
+        bool operator!() const { 
+            return !IsInWork(); 
+        } 
+
+        TBusMessage* GetMessage() { 
+            return Message.Get(); 
+        } 
+
+        TBusMessage* ReleaseMessage() { 
+            return Message.Release(); 
+        } 
+
+        TBusServerSession* GetSession() { 
+            return Session; 
+        } 
+
+        template <typename U /* <: TBusMessage */> 
+        EMessageStatus SendReplyAutoPtr(TAutoPtr<U>& rep); 
+
+        EMessageStatus SendReplyMove(TBusMessageAutoPtr response); 
+
+        void AckMessage(TBusIdentity& ident); 
+
+        void ForgetRequest(); 
+
+        void Swap(TOnMessageContext& that) { 
+            DoSwap(Message, that.Message); 
+            Ident.Swap(that.Ident); 
+            DoSwap(Session, that.Session); 
+        } 
+
+        TNetAddr GetPeerAddrNetAddr() const; 
+
+        bool IsConnectionAlive() const; 
+    }; 
+
+    struct IBusServerHandler: public IBusErrorHandler { 
+        virtual void OnMessage(TOnMessageContext& onMessage) = 0; 
+        /// called when reply has been sent from destination 
+        virtual void OnSent(TAutoPtr<TBusMessage> pMessage); 
+    }; 
+
+    struct IBusClientHandler: public IBusErrorHandler { 
+        /// called on source when reply arrives from destination 
+        virtual void OnReply(TAutoPtr<TBusMessage> pMessage, TAutoPtr<TBusMessage> pReply) = 0; 
+        /// called when client side message has gone into wire, place to call AckMessage() 
+        virtual void OnMessageSent(TBusMessage* pMessage); 
+        virtual void OnMessageSentOneWay(TAutoPtr<TBusMessage> pMessage); 
+        virtual void OnClientConnectionEvent(const TClientConnectionEvent&); 
+    }; 
+
+}