Restoring authorship annotation for <nga@yandex-team.ru>. Commit 1 of 2.

1 files changed, 46 insertions, 46 deletions

diff --git a/library/cpp/messagebus/latch.h b/library/cpp/messagebus/latch.h
index 373f4c0e13..d40aef2719 100644
--- a/library/cpp/messagebus/latch.h
+++ b/library/cpp/messagebus/latch.h
@@ -1,53 +1,53 @@
-#pragma once
-
+#pragma once 
+ 
 #include <util/system/condvar.h>
-#include <util/system/mutex.h>
-
-class TLatch {
-private:
-    // 0 for unlocked, 1 for locked
-    TAtomic Locked;
-    TMutex Mutex;
-    TCondVar CondVar;
-
-public:
+#include <util/system/mutex.h> 
+ 
+class TLatch { 
+private: 
+    // 0 for unlocked, 1 for locked 
+    TAtomic Locked; 
+    TMutex Mutex; 
+    TCondVar CondVar; 
+
+public: 
     TLatch()
         : Locked(0)
     {
     }
-
-    void Wait() {
-        // optimistic path
-        if (AtomicGet(Locked) == 0) {
-            return;
-        }
-
-        TGuard<TMutex> guard(Mutex);
+ 
+    void Wait() { 
+        // optimistic path 
+        if (AtomicGet(Locked) == 0) { 
+            return; 
+        } 
+ 
+        TGuard<TMutex> guard(Mutex); 
         while (AtomicGet(Locked) == 1) {
-            CondVar.WaitI(Mutex);
-        }
-    }
-
-    bool TryWait() {
-        return AtomicGet(Locked) == 0;
-    }
-
-    void Unlock() {
-        // optimistic path
-        if (AtomicGet(Locked) == 0) {
-            return;
-        }
-
-        TGuard<TMutex> guard(Mutex);
+            CondVar.WaitI(Mutex); 
+        } 
+    } 
+ 
+    bool TryWait() { 
+        return AtomicGet(Locked) == 0; 
+    } 
+ 
+    void Unlock() { 
+        // optimistic path 
+        if (AtomicGet(Locked) == 0) { 
+            return; 
+        } 
+ 
+        TGuard<TMutex> guard(Mutex); 
         AtomicSet(Locked, 0);
-        CondVar.BroadCast();
-    }
-
-    void Lock() {
-        AtomicSet(Locked, 1);
-    }
-
-    bool IsLocked() {
-        return AtomicGet(Locked);
-    }
-};
+        CondVar.BroadCast(); 
+    } 
+ 
+    void Lock() { 
+        AtomicSet(Locked, 1); 
+    } 
+ 
+    bool IsLocked() { 
+        return AtomicGet(Locked); 
+    } 
+};