Restoring authorship annotation for <asorotsky@yandex-team.ru>. Commit 1 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