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

11 files changed, 35 insertions, 35 deletions

diff --git a/library/cpp/actors/core/actor_coroutine_ut.cpp b/library/cpp/actors/core/actor_coroutine_ut.cpp
index 558a2f7e96..951512b877 100644
--- a/library/cpp/actors/core/actor_coroutine_ut.cpp
+++ b/library/cpp/actors/core/actor_coroutine_ut.cpp
@@ -94,7 +94,7 @@ Y_UNIT_TEST_SUITE(ActorCoro) {
             DoneEvent.Signal();
         }
 
-        void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> event) override { 
+        void ProcessUnexpectedEvent(TAutoPtr<IEventHandle> event) override {
             if (event->GetTypeRewrite() == Enough) {
                 Finish = true;
             }
diff --git a/library/cpp/actors/core/event_pb_ut.cpp b/library/cpp/actors/core/event_pb_ut.cpp
index 5e434fdf63..a16c3092b3 100644
--- a/library/cpp/actors/core/event_pb_ut.cpp
+++ b/library/cpp/actors/core/event_pb_ut.cpp
@@ -6,20 +6,20 @@
 Y_UNIT_TEST_SUITE(TEventSerialization) {
     struct TMockEvent: public NActors::IEventBase {
         TBigMessage* msg;
-        bool 
-        SerializeToArcadiaStream(NActors::TChunkSerializer* chunker) const override { 
+        bool
+        SerializeToArcadiaStream(NActors::TChunkSerializer* chunker) const override {
             return msg->SerializeToZeroCopyStream(chunker);
         }
         bool IsSerializable() const override {
             return true;
         }
-        TString ToStringHeader() const override { 
+        TString ToStringHeader() const override {
             return TString();
         }
         virtual TString Serialize() const {
             return TString();
         }
-        ui32 Type() const override { 
+        ui32 Type() const override {
             return 0;
         };
     };
diff --git a/library/cpp/actors/core/io_dispatcher.cpp b/library/cpp/actors/core/io_dispatcher.cpp
index 729c3bcb16..90699ff16c 100644
--- a/library/cpp/actors/core/io_dispatcher.cpp
+++ b/library/cpp/actors/core/io_dispatcher.cpp
@@ -27,7 +27,7 @@ namespace NActors {
                 : Timestamp(timestamp)
                 , Callback(std::move(ev->Callback))
             {}
- 
+
             void Execute() {
                 Callback();
             }
@@ -52,7 +52,7 @@ namespace NActors {
                 }
                 CondVar.Signal();
             }
- 
+
             bool Dequeue(std::list<TTask>& list, bool *sendNotify) {
                 with_lock (Mutex) {
                     CondVar.Wait(Mutex, [&] { return NumThreadsToStop || !Tasks.empty(); });
@@ -169,7 +169,7 @@ namespace NActors {
             , ThreadsStopped(counters->GetCounter("ThreadsStopped", true))
         {}
 
-        ~TIoDispatcherActor() override { 
+        ~TIoDispatcherActor() override {
             TaskQueue.Stop();
         }
 
diff --git a/library/cpp/actors/core/scheduler_actor.cpp b/library/cpp/actors/core/scheduler_actor.cpp
index 329aeebd34..febc5e40dd 100644
--- a/library/cpp/actors/core/scheduler_actor.cpp
+++ b/library/cpp/actors/core/scheduler_actor.cpp
@@ -24,11 +24,11 @@ namespace NActors {
             Y_VERIFY(Descriptor != -1, "timerfd_create() failed with %s", strerror(errno));
         }
 
-        ~TTimerDescriptor() override { 
+        ~TTimerDescriptor() override {
             close(Descriptor);
         }
 
-        int GetDescriptor() override { 
+        int GetDescriptor() override {
             return Descriptor;
         }
     };
diff --git a/library/cpp/actors/http/http_proxy_incoming.cpp b/library/cpp/actors/http/http_proxy_incoming.cpp
index a92c458c1e..80fe2af53d 100644
--- a/library/cpp/actors/http/http_proxy_incoming.cpp
+++ b/library/cpp/actors/http/http_proxy_incoming.cpp
@@ -56,11 +56,11 @@ public:
         response = nullptr;
     }
 
-    TAutoPtr<IEventHandle> AfterRegister(const TActorId& self, const TActorId& parent) override { 
+    TAutoPtr<IEventHandle> AfterRegister(const TActorId& self, const TActorId& parent) override {
         return new IEventHandle(self, parent, new TEvents::TEvBootstrap());
     }
 
-    void Die(const TActorContext& ctx) override { 
+    void Die(const TActorContext& ctx) override {
         ctx.Send(Endpoint.Owner, new TEvHttpProxy::TEvHttpConnectionClosed(ctx.SelfID, std::move(RecycledRequests)));
         TSocketImpl::Shutdown();
         TBase::Die(ctx);
diff --git a/library/cpp/actors/http/http_proxy_outgoing.cpp b/library/cpp/actors/http/http_proxy_outgoing.cpp
index b72ec0c2e8..d9189dba8a 100644
--- a/library/cpp/actors/http/http_proxy_outgoing.cpp
+++ b/library/cpp/actors/http/http_proxy_outgoing.cpp
@@ -29,7 +29,7 @@ public:
         TSocketImpl::SetTimeout(SOCKET_TIMEOUT);
     }
 
-    void Die(const NActors::TActorContext& ctx) override { 
+    void Die(const NActors::TActorContext& ctx) override {
         ctx.Send(Owner, new TEvHttpProxy::TEvHttpConnectionClosed(ctx.SelfID));
         TSocketImpl::Shutdown(); // to avoid errors when connection already closed
         TBase::Die(ctx);
diff --git a/library/cpp/actors/interconnect/profiler.h b/library/cpp/actors/interconnect/profiler.h
index c8ee78e5f2..77a59e3179 100644
--- a/library/cpp/actors/interconnect/profiler.h
+++ b/library/cpp/actors/interconnect/profiler.h
@@ -131,7 +131,7 @@ namespace NActors {
                     s << key << " num# " << value.size() << " sum# " << sum << "ns max# " << (i->Duration * 1000000 / cyclesPerMs) << "ns";
                     if (i->Interior) {
                         s << " {" << i->Interior << "}";
-                    } 
+                    }
                 }
             }
 
diff --git a/library/cpp/actors/interconnect/ut_fat/main.cpp b/library/cpp/actors/interconnect/ut_fat/main.cpp
index 965fce77e6..5d19bc3003 100644
--- a/library/cpp/actors/interconnect/ut_fat/main.cpp
+++ b/library/cpp/actors/interconnect/ut_fat/main.cpp
@@ -29,11 +29,11 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
         {
         }
 
-        ~TSenderActor() override { 
+        ~TSenderActor() override {
             Cerr << "Sent " << SequenceNumber << " messages\n";
         }
 
-        void SendMessage(const TActorContext& ctx) override { 
+        void SendMessage(const TActorContext& ctx) override {
             const ui32 flags = IEventHandle::MakeFlags(0, SendFlags);
             const ui64 cookie = SequenceNumber;
             const TString payload('@', RandomNumber<size_t>(65536) + 4096);
@@ -43,7 +43,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
             ++SequenceNumber;
         }
 
-        void Handle(TEvents::TEvUndelivered::TPtr& ev, const TActorContext& ctx) override { 
+        void Handle(TEvents::TEvUndelivered::TPtr& ev, const TActorContext& ctx) override {
             auto record = std::find(InFly.begin(), InFly.end(), ev->Cookie);
             if (SendFlags & IEventHandle::FlagGenerateUnsureUndelivered) {
                 if (record != InFly.end()) {
@@ -56,7 +56,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
             }
         }
 
-        void Handle(TEvTestResponse::TPtr& ev, const TActorContext& ctx) override { 
+        void Handle(TEvTestResponse::TPtr& ev, const TActorContext& ctx) override {
             Y_VERIFY(InFly);
             const NInterconnectTest::TEvTestResponse& record = ev->Get()->Record;
             Y_VERIFY(record.HasConfirmedSequenceNumber());
@@ -85,7 +85,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
         {
         }
 
-        void Handle(TEvTest::TPtr& ev, const TActorContext& /*ctx*/) override { 
+        void Handle(TEvTest::TPtr& ev, const TActorContext& /*ctx*/) override {
             const NInterconnectTest::TEvTest& m = ev->Get()->Record;
             Y_VERIFY(m.HasSequenceNumber());
             Y_VERIFY(m.GetSequenceNumber() >= ReceivedCount, "got #%" PRIu64 " expected at least #%" PRIu64,
@@ -94,7 +94,7 @@ Y_UNIT_TEST_SUITE(InterconnectUnstableConnection) {
             SenderNode->Send(ev->Sender, new TEvTestResponse(m.GetSequenceNumber()));
         }
 
-        ~TReceiverActor() override { 
+        ~TReceiverActor() override {
             Cerr << "Received " << ReceivedCount << " messages\n";
         }
     };
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index af7ea2e336..6fa25b9965 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -242,7 +242,7 @@ namespace NActors {
             Y_UNUSED(Runtime);
         }
 
-        void Prepare(TActorSystem *actorSystem, volatile ui64 *currentTimestamp, volatile ui64 *currentMonotonic) override { 
+        void Prepare(TActorSystem *actorSystem, volatile ui64 *currentTimestamp, volatile ui64 *currentMonotonic) override {
             Y_UNUSED(actorSystem);
             Node->ActorSystemTimestamp = currentTimestamp;
             Node->ActorSystemMonotonic = currentMonotonic;
@@ -253,13 +253,13 @@ namespace NActors {
             Y_UNUSED(scheduleReadersCount);
         }
 
-        void Start() override { 
+        void Start() override {
         }
 
-        void PrepareStop() override { 
+        void PrepareStop() override {
         }
 
-        void Stop() override { 
+        void Stop() override {
         }
 
     private:
@@ -343,7 +343,7 @@ namespace NActors {
         }
 
         // for actorsystem
-        bool Send(TAutoPtr<IEventHandle>& ev) override { 
+        bool Send(TAutoPtr<IEventHandle>& ev) override {
             TGuard<TMutex> guard(Runtime->Mutex);
             bool verbose = (Runtime->CurrentDispatchContext ? !Runtime->CurrentDispatchContext->Options->Quiet : true) && VERBOSE;
             if (Runtime->BlockedOutput.find(ev->Sender) != Runtime->BlockedOutput.end()) {
@@ -393,21 +393,21 @@ namespace NActors {
             return true;
         }
 
-        void ScheduleActivation(ui32 activation) override { 
+        void ScheduleActivation(ui32 activation) override {
             Y_UNUSED(activation);
         }
 
-        void ScheduleActivationEx(ui32 activation, ui64 revolvingCounter) override { 
+        void ScheduleActivationEx(ui32 activation, ui64 revolvingCounter) override {
             Y_UNUSED(activation);
             Y_UNUSED(revolvingCounter);
         }
 
-        TActorId Register(IActor *actor, TMailboxType::EType mailboxType, ui64 revolvingCounter, 
+        TActorId Register(IActor *actor, TMailboxType::EType mailboxType, ui64 revolvingCounter,
             const TActorId& parentId) override {
             return Runtime->Register(actor, NodeIndex, PoolId, mailboxType, revolvingCounter, parentId);
         }
 
-        TActorId Register(IActor *actor, TMailboxHeader *mailbox, ui32 hint, const TActorId& parentId) override { 
+        TActorId Register(IActor *actor, TMailboxHeader *mailbox, ui32 hint, const TActorId& parentId) override {
             return Runtime->Register(actor, NodeIndex, PoolId, mailbox, hint, parentId);
         }
 
@@ -418,13 +418,13 @@ namespace NActors {
             Y_UNUSED(scheduleSz);
         }
 
-        void Start() override { 
+        void Start() override {
         }
 
-        void PrepareStop() override { 
+        void PrepareStop() override {
         }
 
-        void Shutdown() override { 
+        void Shutdown() override {
         }
 
         bool Cleanup() override {
@@ -432,7 +432,7 @@ namespace NActors {
         }
 
         // generic
-        TAffinity* Affinity() const override { 
+        TAffinity* Affinity() const override {
             Y_FAIL();
         }
 
diff --git a/library/cpp/actors/util/rope_cont_deque.h b/library/cpp/actors/util/rope_cont_deque.h
index 3bc3476023..d1d122c49c 100644
--- a/library/cpp/actors/util/rope_cont_deque.h
+++ b/library/cpp/actors/util/rope_cont_deque.h
@@ -8,7 +8,7 @@ namespace NRopeDetails {
 template<typename TChunk>
 class TChunkList {
     std::deque<TChunk> Chunks;
- 
+
     static constexpr size_t MaxInplaceItems = 4;
     using TInplace = TStackVec<TChunk, MaxInplaceItems>;
     TInplace Inplace;
diff --git a/library/cpp/actors/util/rope_ut.cpp b/library/cpp/actors/util/rope_ut.cpp
index f9ed32891b..cabeed9230 100644
--- a/library/cpp/actors/util/rope_ut.cpp
+++ b/library/cpp/actors/util/rope_ut.cpp
@@ -40,7 +40,7 @@ TString RopeToString(const TRope& rope) {
         res.append(iter.ContiguousData(), iter.ContiguousSize());
         iter.AdvanceToNextContiguousBlock();
     }
- 
+
     UNIT_ASSERT_VALUES_EQUAL(rope.GetSize(), res.size());
 
     TString temp = TString::Uninitialized(rope.GetSize());