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

1 files changed, 46 insertions, 46 deletions

diff --git a/library/cpp/messagebus/latch.h b/library/cpp/messagebus/latch.h
index d40aef27196..373f4c0e13b 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);
+    }
+};