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

1 files changed, 33 insertions, 33 deletions

diff --git a/library/cpp/messagebus/remote_client_session_semaphore.h b/library/cpp/messagebus/remote_client_session_semaphore.h
index 955440b25f..286ca3c86f 100644
--- a/library/cpp/messagebus/remote_client_session_semaphore.h
+++ b/library/cpp/messagebus/remote_client_session_semaphore.h
@@ -7,36 +7,36 @@
 #include <util/system/condvar.h>
 #include <util/system/mutex.h>
 
-namespace NBus { 
-    namespace NPrivate { 
-        class TRemoteClientSessionSemaphore: public TComplexConditionSemaphore<TRemoteClientSessionSemaphore> { 
-        private: 
-            const char* const Name; 
-
-            TAtomicBase const Limit; 
-            TAtomic Current; 
-            TAtomic StopSignal; 
-
-        public: 
-            TRemoteClientSessionSemaphore(TAtomicBase limit, const char* name = "unnamed"); 
-            ~TRemoteClientSessionSemaphore(); 
-
-            TAtomicBase GetCurrent() const { 
-                return AtomicGet(Current); 
-            } 
-
-            void Acquire(); 
-            bool TryAcquire(); 
-            void Increment(); 
-            void IncrementMultiple(TAtomicBase count); 
-            bool TryWait(); 
-            void Release(); 
-            void ReleaseMultiple(TAtomicBase count); 
-            void Stop(); 
-
-        private: 
-            void CheckNeedToUnlock(); 
-        }; 
-
-    } 
-} 
+namespace NBus {
+    namespace NPrivate {
+        class TRemoteClientSessionSemaphore: public TComplexConditionSemaphore<TRemoteClientSessionSemaphore> {
+        private:
+            const char* const Name;
+
+            TAtomicBase const Limit;
+            TAtomic Current;
+            TAtomic StopSignal;
+
+        public:
+            TRemoteClientSessionSemaphore(TAtomicBase limit, const char* name = "unnamed");
+            ~TRemoteClientSessionSemaphore();
+
+            TAtomicBase GetCurrent() const {
+                return AtomicGet(Current);
+            }
+
+            void Acquire();
+            bool TryAcquire();
+            void Increment();
+            void IncrementMultiple(TAtomicBase count);
+            bool TryWait();
+            void Release();
+            void ReleaseMultiple(TAtomicBase count);
+            void Stop();
+
+        private:
+            void CheckNeedToUnlock();
+        };
+
+    }
+}