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

1 files changed, 42 insertions, 42 deletions

diff --git a/library/cpp/threading/queue/mpmc_unordered_ring.h b/library/cpp/threading/queue/mpmc_unordered_ring.h
index 5042f7528e..59758d2c35 100644
--- a/library/cpp/threading/queue/mpmc_unordered_ring.h
+++ b/library/cpp/threading/queue/mpmc_unordered_ring.h
@@ -1,42 +1,42 @@
-#pragma once
-
-/*
-  It's not a general purpose queue.
-  No order guarantee, but it mostly ordered.
-  Items may stuck in almost empty queue.
-  Use UnsafeScanningPop to pop all stuck items.
-  Almost wait-free for producers and consumers.
- */
-
-#include <util/system/atomic.h>
-#include <util/generic/ptr.h>
-
-namespace NThreading {
-    struct TMPMCUnorderedRing {
-    public:
-        static constexpr ui16 MAX_PUSH_TRIES = 4;
-        static constexpr ui16 MAX_POP_TRIES = 4;
-
-        TMPMCUnorderedRing(size_t size);
-
-        bool Push(void* msg, ui16 retryCount = MAX_PUSH_TRIES) noexcept;
-        void StubbornPush(void* msg) {
-            while (!WeakPush(msg)) {
-            }
-        }
-
-        void* Pop() noexcept;
-
-        void* UnsafeScanningPop(ui64* last) noexcept;
-
-    private:
-        bool WeakPush(void* msg) noexcept;
-
-        size_t RingSize;
-        TArrayPtr<void*> RingBuffer;
-        ui64 WritePawl = 0;
-        ui64 WriteFront = 0;
-        ui64 ReadPawl = 0;
-        ui64 ReadFront = 0;
-    };
-}
+#pragma once 
+ 
+/* 
+  It's not a general purpose queue. 
+  No order guarantee, but it mostly ordered. 
+  Items may stuck in almost empty queue. 
+  Use UnsafeScanningPop to pop all stuck items. 
+  Almost wait-free for producers and consumers. 
+ */ 
+ 
+#include <util/system/atomic.h> 
+#include <util/generic/ptr.h> 
+ 
+namespace NThreading { 
+    struct TMPMCUnorderedRing { 
+    public: 
+        static constexpr ui16 MAX_PUSH_TRIES = 4; 
+        static constexpr ui16 MAX_POP_TRIES = 4; 
+ 
+        TMPMCUnorderedRing(size_t size); 
+ 
+        bool Push(void* msg, ui16 retryCount = MAX_PUSH_TRIES) noexcept; 
+        void StubbornPush(void* msg) { 
+            while (!WeakPush(msg)) { 
+            } 
+        } 
+ 
+        void* Pop() noexcept; 
+ 
+        void* UnsafeScanningPop(ui64* last) noexcept; 
+ 
+    private: 
+        bool WeakPush(void* msg) noexcept; 
+ 
+        size_t RingSize; 
+        TArrayPtr<void*> RingBuffer; 
+        ui64 WritePawl = 0; 
+        ui64 WriteFront = 0; 
+        ui64 ReadPawl = 0; 
+        ui64 ReadFront = 0; 
+    }; 
+}