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

3 files changed, 244 insertions, 244 deletions

diff --git a/library/cpp/actors/README.md b/library/cpp/actors/README.md
index 76222392b6..c39908f2f5 100644
--- a/library/cpp/actors/README.md
+++ b/library/cpp/actors/README.md
@@ -72,7 +72,7 @@ SelfId – узнать собственный адрес. Возвращаем�
 В рамках одной акторсистемы может сосуществовать несколько независимых тредпулов, каждый актор регистрируется на конкретном и в процессе жизни не может мигрировать (но может создавать новые акторы на произвольном тредпуле). Используется для крупноблочного разделения ресурсов, либо между разными активностями (вот здесь – обрабатываем один класс запросов, а вот здесь - другой), либо между разными профилями активности (вот здесь обрабатываем быстрые запросы, здесь – медленные, а вот там – вообще батчёвые). Например в YDB работает системный тредпул (в котором запускаются акторы, необходимые для функционирования YDB, и для которого мы следим что бы не было длительной блокировки в обработчиках), пользовательский тредпул (в котором обрабатываются запросы и потенциально обработчики могут уходить в себя подольше, но это не повлияет на инфраструктуру), батчёвый тредпул (куда отгружается длительная обработка – компакшены дисков, сканы таблиц и подобное) и, в жирных нодах – тредпул интерконнекта (как наиболее чувствительного к задержкам).
 Пересылка сообщений между акторами разных тредпулов но одной локальной акторсистемы остаётся локальной, принудительной сериализации сообщения не происходит.
 
-При регистрации актор прикрепляется к мейлбоксу (в типичном случае на собственном мейлбоксе, но по особой нужде можно находясь внутри обработки сообщения прикрепить порождённый актор к текущему активному мейлбоксу – см. RegisterWithSameMailbox (ранее RegisterLocal) – в этом случае будет гарантироваться отсутствие конкурентной обработки сообщений). Собственно Send – это и есть заворачивание ивента в хендл, помещение хендла в очередь мейлбокса и добавление мейлбокса в очередь активации тредпула. В рамках одного мейлбокса – обработка FIFO, между мейлбоксами таких гарантий нет, хотя и стараемся активировать мейлбоксы примерно в порядке появления в них сообщений. 
+При регистрации актор прикрепляется к мейлбоксу (в типичном случае на собственном мейлбоксе, но по особой нужде можно находясь внутри обработки сообщения прикрепить порождённый актор к текущему активному мейлбоксу – см. RegisterWithSameMailbox (ранее RegisterLocal) – в этом случае будет гарантироваться отсутствие конкурентной обработки сообщений). Собственно Send – это и есть заворачивание ивента в хендл, помещение хендла в очередь мейлбокса и добавление мейлбокса в очередь активации тредпула. В рамках одного мейлбокса – обработка FIFO, между мейлбоксами таких гарантий нет, хотя и стараемся активировать мейлбоксы примерно в порядке появления в них сообщений.
 
 При регистрации актора можно выбрать тип мейлбокса, они немного отличаются стоимость добавления – либо дёшево, но похуже под контеншеном, либо почти wait-free, но подороже. См. комментарии к TMailboxType за актуальными подсказками что-как.
 
diff --git a/library/cpp/actors/core/actor_ut.cpp b/library/cpp/actors/core/actor_ut.cpp
index cbbddace9f..e1b765ec72 100644
--- a/library/cpp/actors/core/actor_ut.cpp
+++ b/library/cpp/actors/core/actor_ut.cpp
@@ -5,60 +5,60 @@
 #include "scheduler_basic.h"
 #include "actor_bootstrapped.h"
 
-#include <library/cpp/actors/util/threadparkpad.h> 
+#include <library/cpp/actors/util/threadparkpad.h>
 #include <library/cpp/testing/unittest/registar.h>
 
-#include <util/generic/algorithm.h> 
-#include <util/system/atomic.h> 
-#include <util/system/rwlock.h> 
-#include <util/system/hp_timer.h> 
+#include <util/generic/algorithm.h>
+#include <util/system/atomic.h>
+#include <util/system/rwlock.h>
+#include <util/system/hp_timer.h>
 
 using namespace NActors;
 
-struct TTestEndDecorator : TDecorator { 
-    TThreadParkPad* Pad; 
-    TAtomic* ActorsAlive; 
-
-    TTestEndDecorator(THolder<IActor>&& actor, TThreadParkPad* pad, TAtomic* actorsAlive) 
-        : TDecorator(std::move(actor)) 
-        , Pad(pad) 
-        , ActorsAlive(actorsAlive) 
-    { 
-        AtomicIncrement(*ActorsAlive); 
-    } 
- 
-    ~TTestEndDecorator() { 
-        if (AtomicDecrement(*ActorsAlive) == 0) { 
-            Pad->Unpark(); 
-        } 
-    } 
-}; 
- 
-Y_UNIT_TEST_SUITE(ActorBenchmark) { 
+struct TTestEndDecorator : TDecorator {
+    TThreadParkPad* Pad;
+    TAtomic* ActorsAlive;
+
+    TTestEndDecorator(THolder<IActor>&& actor, TThreadParkPad* pad, TAtomic* actorsAlive)
+        : TDecorator(std::move(actor))
+        , Pad(pad)
+        , ActorsAlive(actorsAlive)
+    {
+        AtomicIncrement(*ActorsAlive);
+    }
+
+    ~TTestEndDecorator() {
+        if (AtomicDecrement(*ActorsAlive) == 0) {
+            Pad->Unpark();
+        }
+    }
+};
+
+Y_UNIT_TEST_SUITE(ActorBenchmark) {
     static constexpr bool DefaultNoRealtime = true;
-    static constexpr ui32 DefaultSpinThreshold = 1000000; 
-    static constexpr ui32 TotalEventsAmount = 1000; 
- 
-    class TDummyActor : public TActor<TDummyActor> { 
-    public: 
-        TDummyActor() : TActor<TDummyActor>(&TDummyActor::StateFunc) {} 
-        STFUNC(StateFunc) { 
+    static constexpr ui32 DefaultSpinThreshold = 1000000;
+    static constexpr ui32 TotalEventsAmount = 1000;
+
+    class TDummyActor : public TActor<TDummyActor> {
+    public:
+        TDummyActor() : TActor<TDummyActor>(&TDummyActor::StateFunc) {}
+        STFUNC(StateFunc) {
             (void)ev;
-            (void)ctx; 
-        } 
-    }; 
- 
+            (void)ctx;
+        }
+    };
+
     enum ERole {
         Leader,
         Follower
     };
 
-    class TSendReceiveActor : public TActorBootstrapped<TSendReceiveActor> { 
-    public: 
+    class TSendReceiveActor : public TActorBootstrapped<TSendReceiveActor> {
+    public:
         static constexpr auto ActorActivityType() {
-            return ACTORLIB_COMMON; 
+            return ACTORLIB_COMMON;
         }
- 
+
         TSendReceiveActor(double* elapsedTime, TActorId receiver, bool allocation, ERole role, ui32 neighbours = 0)
             : EventsCounter(TotalEventsAmount)
             , ElapsedTime(elapsedTime)
@@ -66,48 +66,48 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
             , AllocatesMemory(allocation)
             , Role(role)
             , MailboxNeighboursCount(neighbours)
-        {} 
- 
-        void Bootstrap(const TActorContext &ctx) { 
-            if (!Receiver) { 
-                this->Receiver = SelfId(); 
+        {}
+
+        void Bootstrap(const TActorContext &ctx) {
+            if (!Receiver) {
+                this->Receiver = SelfId();
             } else {
                 EventsCounter /= 2; // We want to measure CPU requirement for one-way send
-            } 
-            Timer.Reset(); 
-            Become(&TThis::StateFunc); 
-            for (ui32 i = 0; i < MailboxNeighboursCount; ++i) { 
-                ctx.RegisterWithSameMailbox(new TDummyActor()); 
-            } 
+            }
+            Timer.Reset();
+            Become(&TThis::StateFunc);
+            for (ui32 i = 0; i < MailboxNeighboursCount; ++i) {
+                ctx.RegisterWithSameMailbox(new TDummyActor());
+            }
             if (Role == Leader) {
                 Send(Receiver, new TEvents::TEvPing());
             }
-        } 
- 
-        STATEFN(StateFunc) { 
+        }
+
+        STATEFN(StateFunc) {
             if (EventsCounter == 0 && ElapsedTime != nullptr) {
-                *ElapsedTime = Timer.Passed() / TotalEventsAmount; 
-                PassAway(); 
-            } 
- 
-            if (AllocatesMemory) { 
-                Send(ev->Sender, new TEvents::TEvPing()); 
-            } else { 
-                std::swap(*const_cast<TActorId*>(&ev->Sender), *const_cast<TActorId*>(&ev->Recipient)); 
-                ev->DropRewrite(); 
-                TActivationContext::Send(ev.Release()); 
-            } 
+                *ElapsedTime = Timer.Passed() / TotalEventsAmount;
+                PassAway();
+            }
+
+            if (AllocatesMemory) {
+                Send(ev->Sender, new TEvents::TEvPing());
+            } else {
+                std::swap(*const_cast<TActorId*>(&ev->Sender), *const_cast<TActorId*>(&ev->Recipient));
+                ev->DropRewrite();
+                TActivationContext::Send(ev.Release());
+            }
             EventsCounter--;
-        } 
- 
-    private: 
-        THPTimer Timer; 
+        }
+
+    private:
+        THPTimer Timer;
         ui64 EventsCounter;
-        double* ElapsedTime; 
-        TActorId Receiver; 
-        bool AllocatesMemory; 
+        double* ElapsedTime;
+        TActorId Receiver;
+        bool AllocatesMemory;
         ERole Role;
-        ui32 MailboxNeighboursCount; 
+        ui32 MailboxNeighboursCount;
     };
 
     void AddBasicPool(THolder<TActorSystemSetup>& setup, ui32 threads, bool activateEveryEvent) {
@@ -121,10 +121,10 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
             basic.EventsPerMailbox = 1;
         } else {
             basic.EventsPerMailbox = Max<ui32>();
-        } 
+        }
         setup->CpuManager.Basic.emplace_back(std::move(basic));
     }
- 
+
     void AddUnitedPool(THolder<TActorSystemSetup>& setup, ui32 concurrency, bool activateEveryEvent) {
         TUnitedExecutorPoolConfig united;
         united.PoolId = setup->GetExecutorsCount();
@@ -182,34 +182,34 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
 
     double BenchSendReceive(bool allocation, NActors::TMailboxType::EType mType, EPoolType poolType) {
         THolder<TActorSystemSetup> setup = InitActorSystemSetup(poolType, 1, 1, false, false);
-        TActorSystem actorSystem(setup); 
-        actorSystem.Start(); 
- 
-        TThreadParkPad pad; 
-        TAtomic actorsAlive = 0; 
-        double elapsedTime = 0; 
+        TActorSystem actorSystem(setup);
+        actorSystem.Start();
+
+        TThreadParkPad pad;
+        TAtomic actorsAlive = 0;
+        double elapsedTime = 0;
         THolder<IActor> endActor{
             new TTestEndDecorator(THolder(
                 new TSendReceiveActor(&elapsedTime, {}, allocation, Leader)), &pad, &actorsAlive)};
- 
-        actorSystem.Register(endActor.Release(), mType); 
- 
-        pad.Park(); 
-        actorSystem.Stop(); 
- 
+
+        actorSystem.Register(endActor.Release(), mType);
+
+        pad.Park();
+        actorSystem.Stop();
+
         return 1e9 * elapsedTime;
-    } 
- 
+    }
+
     double BenchSendActivateReceive(ui32 poolsCount, ui32 threads, bool allocation, EPoolType poolType) {
         THolder<TActorSystemSetup> setup = InitActorSystemSetup(poolType, poolsCount, threads, true, false);
         TActorSystem actorSystem(setup);
-        actorSystem.Start(); 
- 
-        TThreadParkPad pad; 
-        TAtomic actorsAlive = 0; 
-        double elapsedTime = 0; 
+        actorSystem.Start();
+
+        TThreadParkPad pad;
+        TAtomic actorsAlive = 0;
+        double elapsedTime = 0;
         ui32 followerPoolId = 0;
- 
+
         ui32 leaderPoolId = poolsCount == 1 ? 0 : 1;
         TActorId followerId = actorSystem.Register(
             new TSendReceiveActor(nullptr, {}, allocation, Follower), TMailboxType::HTSwap, followerPoolId);
@@ -218,46 +218,46 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
                 new TSendReceiveActor(&elapsedTime, followerId, allocation, Leader)), &pad, &actorsAlive)};
         actorSystem.Register(leader.Release(), TMailboxType::HTSwap, leaderPoolId);
 
-        pad.Park(); 
-        actorSystem.Stop(); 
- 
+        pad.Park();
+        actorSystem.Stop();
+
         return 1e9 * elapsedTime;
-    } 
- 
+    }
+
     double BenchSendActivateReceiveWithMailboxNeighbours(ui32 MailboxNeighbourActors, EPoolType poolType) {
         THolder<TActorSystemSetup> setup = InitActorSystemSetup(poolType, 1, 1, false, false);
         TActorSystem actorSystem(setup);
-        actorSystem.Start(); 
- 
-        TThreadParkPad pad; 
-        TAtomic actorsAlive = 0; 
-        double elapsedTime = 0; 
- 
+        actorSystem.Start();
+
+        TThreadParkPad pad;
+        TAtomic actorsAlive = 0;
+        double elapsedTime = 0;
+
         TActorId followerId = actorSystem.Register(
             new TSendReceiveActor(nullptr, {}, false, Follower, MailboxNeighbourActors), TMailboxType::HTSwap);
         THolder<IActor> leader{
             new TTestEndDecorator(THolder(
                 new TSendReceiveActor(&elapsedTime, followerId, false, Leader, MailboxNeighbourActors)), &pad, &actorsAlive)};
         actorSystem.Register(leader.Release(), TMailboxType::HTSwap);
- 
-        pad.Park(); 
-        actorSystem.Stop(); 
- 
+
+        pad.Park();
+        actorSystem.Stop();
+
         return 1e9 * elapsedTime;
-    } 
- 
+    }
+
     double BenchContentedThreads(ui32 threads, ui32 actorsPairsCount, EPoolType poolType) {
         THolder<TActorSystemSetup> setup = InitActorSystemSetup(poolType, 1, threads, true, false);
         TActorSystem actorSystem(setup);
-        actorSystem.Start(); 
- 
-        TThreadParkPad pad; 
-        TAtomic actorsAlive = 0; 
-        THPTimer Timer; 
- 
+        actorSystem.Start();
+
+        TThreadParkPad pad;
+        TAtomic actorsAlive = 0;
+        THPTimer Timer;
+
         TVector<double> dummy(actorsPairsCount);
-        Timer.Reset(); 
-        for (ui32 i = 0; i < actorsPairsCount; ++i) { 
+        Timer.Reset();
+        for (ui32 i = 0; i < actorsPairsCount; ++i) {
             ui32 followerPoolId = 0;
             ui32 leaderPoolId = 0;
             TActorId followerId = actorSystem.Register(
@@ -266,63 +266,63 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
                 new TTestEndDecorator(THolder(
                     new TSendReceiveActor(&dummy[i], followerId, true, Leader)), &pad, &actorsAlive)};
             actorSystem.Register(leader.Release(), TMailboxType::HTSwap, leaderPoolId);
-        } 
- 
-        pad.Park(); 
-        auto elapsedTime = Timer.Passed() / TotalEventsAmount; 
-        actorSystem.Stop(); 
- 
+        }
+
+        pad.Park();
+        auto elapsedTime = Timer.Passed() / TotalEventsAmount;
+        actorSystem.Stop();
+
         return 1e9 * elapsedTime;
-    } 
- 
-    auto Mean(const TVector<double>& data) { 
+    }
+
+    auto Mean(const TVector<double>& data) {
         return Accumulate(data.begin(), data.end(), 0.0) / data.size();
-    } 
- 
-    auto Deviation(const TVector<double>& data) { 
-        auto mean = Mean(data); 
-        double deviation = 0.0; 
-        for (const auto& x : data) { 
-            deviation += (x - mean) * (x - mean); 
-        } 
+    }
+
+    auto Deviation(const TVector<double>& data) {
+        auto mean = Mean(data);
+        double deviation = 0.0;
+        for (const auto& x : data) {
+            deviation += (x - mean) * (x - mean);
+        }
         return std::sqrt(deviation / data.size());
-    } 
- 
-    struct TStats { 
-        double Mean; 
-        double Deviation; 
-        TString ToString() { 
+    }
+
+    struct TStats {
+        double Mean;
+        double Deviation;
+        TString ToString() {
             return TStringBuilder() << Mean << " ± " << Deviation << " ns " << std::ceil(Deviation / Mean * 1000) / 10.0 << "%";
-        } 
-    }; 
- 
-    template <typename Func> 
+        }
+    };
+
+    template <typename Func>
     TStats CountStats(Func func, ui32 itersCount = 5) {
-        TVector<double> elapsedTimes; 
-        for (ui32 i = 0; i < itersCount; ++i) { 
-            auto elapsedTime = func(); 
-            elapsedTimes.push_back(elapsedTime); 
-        } 
-        return {Mean(elapsedTimes), Deviation(elapsedTimes)}; 
-    } 
- 
-    TVector<NActors::TMailboxType::EType> MailboxTypes = { 
-        TMailboxType::Simple, 
-        TMailboxType::Revolving, 
-        TMailboxType::HTSwap, 
-        TMailboxType::ReadAsFilled, 
-        TMailboxType::TinyReadAsFilled 
-    }; 
- 
+        TVector<double> elapsedTimes;
+        for (ui32 i = 0; i < itersCount; ++i) {
+            auto elapsedTime = func();
+            elapsedTimes.push_back(elapsedTime);
+        }
+        return {Mean(elapsedTimes), Deviation(elapsedTimes)};
+    }
+
+    TVector<NActors::TMailboxType::EType> MailboxTypes = {
+        TMailboxType::Simple,
+        TMailboxType::Revolving,
+        TMailboxType::HTSwap,
+        TMailboxType::ReadAsFilled,
+        TMailboxType::TinyReadAsFilled
+    };
+
     Y_UNIT_TEST(SendReceive1Pool1ThreadAlloc) {
-        for (const auto& mType : MailboxTypes) { 
-            auto stats = CountStats([mType] { 
+        for (const auto& mType : MailboxTypes) {
+            auto stats = CountStats([mType] {
                 return BenchSendReceive(true, mType, EPoolType::Basic);
-            }); 
-            Cerr << stats.ToString() << " " << mType << Endl; 
-        } 
-    } 
- 
+            });
+            Cerr << stats.ToString() << " " << mType << Endl;
+        }
+    }
+
     Y_UNIT_TEST(SendReceive1Pool1ThreadAllocUnited) {
         for (const auto& mType : MailboxTypes) {
             auto stats = CountStats([mType] {
@@ -332,14 +332,14 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
         }
     }
 
-    Y_UNIT_TEST(SendReceive1Pool1ThreadNoAlloc) { 
-        for (const auto& mType : MailboxTypes) { 
-            auto stats = CountStats([mType] { 
+    Y_UNIT_TEST(SendReceive1Pool1ThreadNoAlloc) {
+        for (const auto& mType : MailboxTypes) {
+            auto stats = CountStats([mType] {
                 return BenchSendReceive(false, mType, EPoolType::Basic);
-            }); 
-            Cerr << stats.ToString() << " " << mType << Endl; 
-        } 
-    } 
+            });
+            Cerr << stats.ToString() << " " << mType << Endl;
+        }
+    }
 
     Y_UNIT_TEST(SendReceive1Pool1ThreadNoAllocUnited) {
         for (const auto& mType : MailboxTypes) {
@@ -350,13 +350,13 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
         }
     }
 
-    Y_UNIT_TEST(SendActivateReceive1Pool1ThreadAlloc) { 
-        auto stats = CountStats([] { 
+    Y_UNIT_TEST(SendActivateReceive1Pool1ThreadAlloc) {
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 1, true, EPoolType::Basic);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive1Pool1ThreadAllocUnited) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 1, true, EPoolType::United);
@@ -364,13 +364,13 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
         Cerr << stats.ToString() << Endl;
     }
 
-    Y_UNIT_TEST(SendActivateReceive1Pool1ThreadNoAlloc) { 
-        auto stats = CountStats([] { 
+    Y_UNIT_TEST(SendActivateReceive1Pool1ThreadNoAlloc) {
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 1, false, EPoolType::Basic);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive1Pool1ThreadNoAllocUnited) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 1, false, EPoolType::United);
@@ -378,13 +378,13 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
         Cerr << stats.ToString() << Endl;
     }
 
-    Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsAlloc) { 
-        auto stats = CountStats([] { 
+    Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsAlloc) {
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 2, true, EPoolType::Basic);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsAllocUnited) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 2, true, EPoolType::United);
@@ -392,48 +392,48 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
         Cerr << stats.ToString() << Endl;
     }
 
-    Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsNoAlloc) { 
-        auto stats = CountStats([] { 
+    Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsNoAlloc) {
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 2, false, EPoolType::Basic);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive1Pool2ThreadsNoAllocUnited) {
-        auto stats = CountStats([] { 
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(1, 2, false, EPoolType::United);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive2Pool1ThreadAlloc) {
-        auto stats = CountStats([] { 
+        auto stats = CountStats([] {
             return BenchSendActivateReceive(2, 1, true, EPoolType::Basic);
-        }); 
-        Cerr << stats.ToString() << Endl; 
-    } 
- 
+        });
+        Cerr << stats.ToString() << Endl;
+    }
+
     Y_UNIT_TEST(SendActivateReceive2Pool1ThreadAllocUnited) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(2, 1, true, EPoolType::United);
         });
         Cerr << stats.ToString() << Endl;
-    } 
- 
+    }
+
     Y_UNIT_TEST(SendActivateReceive2Pool1ThreadNoAlloc) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(2, 1, false, EPoolType::Basic);
         });
         Cerr << stats.ToString() << Endl;
-    } 
- 
+    }
+
     Y_UNIT_TEST(SendActivateReceive2Pool1ThreadNoAllocUnited) {
         auto stats = CountStats([] {
             return BenchSendActivateReceive(2, 1, false, EPoolType::United);
         });
         Cerr << stats.ToString() << Endl;
-    } 
- 
+    }
+
     void RunBenchContentedThreads(ui32 threads, EPoolType poolType) {
         for (ui32 actorPairs = 1; actorPairs <= 2 * threads; actorPairs++) {
             auto stats = CountStats([threads, actorPairs, poolType] {
@@ -441,8 +441,8 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
             });
             Cerr << stats.ToString() << " actorPairs: " << actorPairs << Endl;
         }
-    } 
- 
+    }
+
     Y_UNIT_TEST(SendActivateReceive1Pool1Threads)       { RunBenchContentedThreads(1, EPoolType::Basic);  }
     Y_UNIT_TEST(SendActivateReceive1Pool1ThreadsUnited) { RunBenchContentedThreads(1, EPoolType::United); }
     Y_UNIT_TEST(SendActivateReceive1Pool2Threads)       { RunBenchContentedThreads(2, EPoolType::Basic);  }
@@ -460,15 +460,15 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
     Y_UNIT_TEST(SendActivateReceive1Pool8Threads)       { RunBenchContentedThreads(8, EPoolType::Basic);  }
     Y_UNIT_TEST(SendActivateReceive1Pool8ThreadsUnited) { RunBenchContentedThreads(8, EPoolType::United); }
 
-    Y_UNIT_TEST(SendActivateReceiveWithMailboxNeighbours) { 
-        TVector<ui32> NeighbourActors = {0, 1, 2, 3, 4, 5, 6, 7, 8, 16, 32, 64, 128, 256}; 
-        for (const auto& neighbour : NeighbourActors) { 
-            auto stats = CountStats([neighbour] { 
+    Y_UNIT_TEST(SendActivateReceiveWithMailboxNeighbours) {
+        TVector<ui32> NeighbourActors = {0, 1, 2, 3, 4, 5, 6, 7, 8, 16, 32, 64, 128, 256};
+        for (const auto& neighbour : NeighbourActors) {
+            auto stats = CountStats([neighbour] {
                 return BenchSendActivateReceiveWithMailboxNeighbours(neighbour, EPoolType::Basic);
-            }); 
+            });
             Cerr << stats.ToString() << " neighbourActors: " << neighbour << Endl;
-        } 
-    } 
+        }
+    }
 
     Y_UNIT_TEST(SendActivateReceiveWithMailboxNeighboursUnited) {
         TVector<ui32> NeighbourActors = {0, 1, 2, 3, 4, 5, 6, 7, 8, 16, 32, 64, 128, 256};
@@ -479,20 +479,20 @@ Y_UNIT_TEST_SUITE(ActorBenchmark) {
             Cerr << stats.ToString() << " neighbourActors: " << neighbour << Endl;
         }
     }
-} 
- 
-Y_UNIT_TEST_SUITE(TestDecorator) { 
+}
+
+Y_UNIT_TEST_SUITE(TestDecorator) {
     struct TPingDecorator : TDecorator {
         TAutoPtr<IEventHandle> SavedEvent = nullptr;
-        ui64* Counter; 
+        ui64* Counter;
 
-        TPingDecorator(THolder<IActor>&& actor, ui64* counter) 
+        TPingDecorator(THolder<IActor>&& actor, ui64* counter)
             : TDecorator(std::move(actor))
             , Counter(counter)
         {
         }
 
-        bool DoBeforeReceiving(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx) override { 
+        bool DoBeforeReceiving(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx) override {
             *Counter += 1;
             if (ev->Type != TEvents::THelloWorld::Pong) {
                 TAutoPtr<IEventHandle> pingEv = new IEventHandle(SelfId(), SelfId(), new TEvents::TEvPing());
@@ -506,15 +506,15 @@ Y_UNIT_TEST_SUITE(TestDecorator) {
     };
 
     struct TPongDecorator : TDecorator {
-        ui64* Counter; 
+        ui64* Counter;
 
-        TPongDecorator(THolder<IActor>&& actor, ui64* counter) 
+        TPongDecorator(THolder<IActor>&& actor, ui64* counter)
             : TDecorator(std::move(actor))
             , Counter(counter)
         {
         }
 
-        bool DoBeforeReceiving(TAutoPtr<IEventHandle>& ev, const TActorContext&) override { 
+        bool DoBeforeReceiving(TAutoPtr<IEventHandle>& ev, const TActorContext&) override {
             *Counter += 1;
             if (ev->Type == TEvents::THelloWorld::Ping) {
                 TAutoPtr<IEventHandle> pongEv = new IEventHandle(SelfId(), SelfId(), new TEvents::TEvPong());
@@ -555,14 +555,14 @@ Y_UNIT_TEST_SUITE(TestDecorator) {
         THolder<IActor> pongActor = MakeHolder<TPongDecorator>(std::move(innerActor), &pongCounter);
         ui64 pingCounter = 0;
         THolder<IActor> pingActor = MakeHolder<TPingDecorator>(std::move(pongActor), &pingCounter);
- 
-        TThreadParkPad pad; 
-        TAtomic actorsAlive = 0; 
+
+        TThreadParkPad pad;
+        TAtomic actorsAlive = 0;
 
         THolder<IActor> endActor = MakeHolder<TTestEndDecorator>(std::move(pingActor), &pad, &actorsAlive);
-        actorSystem.Register(endActor.Release(), TMailboxType::HTSwap); 
- 
-        pad.Park(); 
+        actorSystem.Register(endActor.Release(), TMailboxType::HTSwap);
+
+        pad.Park();
         actorSystem.Stop();
         UNIT_ASSERT(pongCounter == 2 && pingCounter == 2);
     }
diff --git a/library/cpp/actors/core/ya.make b/library/cpp/actors/core/ya.make
index 69cecdb415..880a9d00db 100644
--- a/library/cpp/actors/core/ya.make
+++ b/library/cpp/actors/core/ya.make
@@ -99,9 +99,9 @@ SRCS(
     servicemap.h
 )
 
-GENERATE_ENUM_SERIALIZATION(defs.h) 
+GENERATE_ENUM_SERIALIZATION(defs.h)
 GENERATE_ENUM_SERIALIZATION(actor.h)
- 
+
 PEERDIR(
     library/cpp/actors/memory_log
     library/cpp/actors/prof