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

1 files changed, 15 insertions, 15 deletions

diff --git a/library/cpp/messagebus/misc/tokenquota.h b/library/cpp/messagebus/misc/tokenquota.h
index d5bdd79625..190547fa54 100644
--- a/library/cpp/messagebus/misc/tokenquota.h
+++ b/library/cpp/messagebus/misc/tokenquota.h
@@ -25,26 +25,26 @@ namespace NBus {
             Y_UNUSED(padd_);
         }
 
-        bool Acquire(TAtomic level = 1, bool force = false) { 
-            level = Max(TAtomicBase(level), TAtomicBase(1)); 
+        bool Acquire(TAtomic level = 1, bool force = false) {
+            level = Max(TAtomicBase(level), TAtomicBase(1));
 
-            if (Enabled && (Acquired < level || force)) { 
+            if (Enabled && (Acquired < level || force)) {
                 Acquired += AtomicSwap(&Tokens_, 0);
             }
 
             return !Enabled || Acquired >= level;
         }
 
-        void Consume(size_t items) { 
-            if (Enabled) { 
+        void Consume(size_t items) {
+            if (Enabled) {
                 Y_ASSERT(Acquired >= TAtomicBase(items));
 
                 Acquired -= items;
             }
         }
 
-        bool Return(size_t items_) noexcept { 
-            if (!Enabled || items_ == 0) 
+        bool Return(size_t items_) noexcept {
+            if (!Enabled || items_ == 0)
                 return false;
 
             const TAtomic items = items_;
@@ -53,31 +53,31 @@ namespace NBus {
             return (value - items < WakeLev && value >= WakeLev);
         }
 
-        bool IsEnabled() const noexcept { 
+        bool IsEnabled() const noexcept {
             return Enabled;
         }
 
-        bool IsAboveWake() const noexcept { 
+        bool IsAboveWake() const noexcept {
             return !Enabled || (WakeLev <= AtomicGet(Tokens_));
         }
 
-        size_t Tokens() const noexcept { 
+        size_t Tokens() const noexcept {
             return Acquired + AtomicGet(Tokens_);
         }
 
-        size_t Check(const TAtomic level) const noexcept { 
+        size_t Check(const TAtomic level) const noexcept {
             return !Enabled || level <= Acquired;
         }
 
     private:
-        bool Enabled; 
-        TAtomicBase Acquired; 
+        bool Enabled;
+        TAtomicBase Acquired;
         const TAtomicBase WakeLev;
-        TAtomic Tokens_; 
+        TAtomic Tokens_;
 
         /* This padd requires for align Tokens_ member on its own
             CPU cacheline. */
 
-        ui64 padd_; 
+        ui64 padd_;
     };
 }