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

contrib/libs/libaio/io_cancel.c

@@ -19,4 +19,4 @@
 #include "libaio.h"
 #include "syscall.h"
 
-io_syscall3(int, io_cancel, io_cancel, io_context_t, ctx, struct iocb *, iocb, struct io_event *, event) 
+io_syscall3(int, io_cancel, io_cancel, io_context_t, ctx, struct iocb *, iocb, struct io_event *, event)

contrib/libs/libaio/io_getevents.c

@@ -39,8 +39,8 @@ struct aio_ring {
 	unsigned        header_length;  /* size of aio_ring */
 };
 
- 
-int io_getevents(io_context_t ctx, long min_nr, long nr, struct io_event * events, struct timespec * timeout) 
+
+int io_getevents(io_context_t ctx, long min_nr, long nr, struct io_event * events, struct timespec * timeout)
 {
 	struct aio_ring *ring;
 	ring = (struct aio_ring*)ctx;

contrib/libs/libaio/io_queue_wait.c

@@ -24,7 +24,7 @@
 
 struct timespec;
 
-int io_queue_wait(io_context_t ctx, struct timespec *timeout) 
+int io_queue_wait(io_context_t ctx, struct timespec *timeout)
 {
 	return io_getevents(ctx, 0, 0, NULL, timeout);
 }

library/cpp/actors/core/event_local.h

@@ -9,7 +9,7 @@ namespace NActors {
     template <typename TEv, ui32 TEventType>
     class TEventLocal: public TEventBase<TEv, TEventType> {
     public:
-        TString ToStringHeader() const override { 
+        TString ToStringHeader() const override {
             return TypeName<TEv>();
         }
 
@@ -17,7 +17,7 @@ namespace NActors {
             Y_FAIL("Serialization of local event %s type %" PRIu32, TypeName<TEv>().data(), TEventType);
         }
 
-        bool IsSerializable() const override { 
+        bool IsSerializable() const override {
             return false;
         }
 

library/cpp/actors/core/event_pb.h

@@ -88,19 +88,19 @@ namespace NActors {
             return Event;
         }
 
-        bool Next(void** data, int* size) override; 
-        void BackUp(int count) override; 
+        bool Next(void** data, int* size) override;
+        void BackUp(int count) override;
         int64_t ByteCount() const override {
             return TotalSerializedDataSize;
         }
-        bool WriteAliasedRaw(const void* data, int size) override; 
-        bool AllowsAliasing() const override; 
+        bool WriteAliasedRaw(const void* data, int size) override;
+        bool AllowsAliasing() const override;
 
         bool WriteRope(const TRope *rope) override;
         bool WriteString(const TString *s) override;
 
     protected:
-        void DoRun() override; 
+        void DoRun() override;
         void Resume();
         bool Produce(const void *data, size_t size);
 

library/cpp/actors/core/executor_pool_basic.h

@@ -58,7 +58,7 @@ namespace NActors {
         const ui32 EventsPerMailbox;
 
         const int RealtimePriority;
- 
+
         TAtomic ThreadUtilization;
         TAtomic MaxUtilizationCounter;
         TAtomic MaxUtilizationAccumulator;

library/cpp/actors/core/executor_pool_io.h

@@ -23,13 +23,13 @@ namespace NActors {
         TTicketLock ScheduleLock;
 
         const TString PoolName;
- 
+
     public:
         TIOExecutorPool(ui32 poolId, ui32 threads, const TString& poolName = "", TAffinity* affinity = nullptr,
                         ui32 maxActivityType = 1);
         explicit TIOExecutorPool(const TIOExecutorPoolConfig& cfg);
         ~TIOExecutorPool();
- 
+
         ui32 GetReadyActivation(TWorkerContext& wctx, ui64 revolvingCounter) override;
 
         void Schedule(TInstant deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie, TWorkerId workerId) override;

library/cpp/actors/core/executor_pool_united.h

@@ -60,7 +60,7 @@ namespace NActors {
 
         // Returns per worker schedule writers
         NSchedulerQueue::TWriter* GetScheduleWriter(TWorkerId workerId) const;
- 
+
         // Sets executor for specified pool
         void SetupPool(TPoolId pool, IExecutorPool* executorPool, TMailboxTable* mailboxTable);
 

library/cpp/actors/core/executor_thread.h

@@ -83,7 +83,7 @@ namespace NActors {
         TVector<THolder<IActor>> DyingActors;
         TActorId CurrentRecipient;
         ui64 CurrentActorScheduledEventsCounter = 0;
- 
+
         // Thread-specific
         TWorkerContext Ctx;
         ui64 RevolvingReadCounter = 0;

library/cpp/actors/core/log_settings.cpp

@@ -49,34 +49,34 @@ namespace NActors {
         }
 
         void TSettings::Append(EComponent minVal, EComponent maxVal, EComponentToStringFunc func) {
-            Y_VERIFY(minVal >= 0, "NLog::TSettings: minVal must be non-negative"); 
+            Y_VERIFY(minVal >= 0, "NLog::TSettings: minVal must be non-negative");
             Y_VERIFY(maxVal > minVal, "NLog::TSettings: maxVal must be greater than minVal");
 
             // update bounds
-            if (!MaxVal || minVal < MinVal) { 
-                MinVal = minVal; 
-            } 
+            if (!MaxVal || minVal < MinVal) {
+                MinVal = minVal;
+            }
 
             if (!MaxVal || maxVal > MaxVal) {
-                MaxVal = maxVal; 
- 
+                MaxVal = maxVal;
+
                 // expand ComponentNames to the new bounds
-                auto oldMask = Mask; 
-                Mask = PowerOf2Mask(MaxVal); 
- 
-                TArrayHolder<TAtomic> oldComponentInfo(new TAtomic[Mask + 1]); 
-                ComponentInfo.Swap(oldComponentInfo); 
-                int startVal = oldMask ? oldMask + 1 : 0; 
-                for (int i = 0; i < startVal; i++) { 
-                    AtomicSet(ComponentInfo[i], AtomicGet(oldComponentInfo[i])); 
-                } 
- 
-                TComponentSettings defSetting(DefPriority, DefSamplingPriority, DefSamplingRate); 
-                for (int i = startVal; i < Mask + 1; i++) { 
-                    AtomicSet(ComponentInfo[i], defSetting.Raw.Data); 
-                } 
- 
-                ComponentNames.resize(Mask + 1); 
+                auto oldMask = Mask;
+                Mask = PowerOf2Mask(MaxVal);
+
+                TArrayHolder<TAtomic> oldComponentInfo(new TAtomic[Mask + 1]);
+                ComponentInfo.Swap(oldComponentInfo);
+                int startVal = oldMask ? oldMask + 1 : 0;
+                for (int i = 0; i < startVal; i++) {
+                    AtomicSet(ComponentInfo[i], AtomicGet(oldComponentInfo[i]));
+                }
+
+                TComponentSettings defSetting(DefPriority, DefSamplingPriority, DefSamplingRate);
+                for (int i = startVal; i < Mask + 1; i++) {
+                    AtomicSet(ComponentInfo[i], defSetting.Raw.Data);
+                }
+
+                ComponentNames.resize(Mask + 1);
             }
 
             // assign new names but validate if newly added members were not used before