Restoring authorship annotation for Daniil Cherednik <dcherednik@yandex-team.ru>. Commit 1 of 2.

9 files changed, 31 insertions, 31 deletions

diff --git a/library/cpp/actors/core/actor.cpp b/library/cpp/actors/core/actor.cpp
index 6f9ba6a42b..4a5049a32c 100644
--- a/library/cpp/actors/core/actor.cpp
+++ b/library/cpp/actors/core/actor.cpp
@@ -61,17 +61,17 @@ namespace NActors {
         return TActivationContext::Schedule(delta, new IEventHandle(*this, {}, ev), cookie);
     }
 
-    TActorId TActivationContext::RegisterWithSameMailbox(IActor* actor, TActorId parentId) {
+    TActorId TActivationContext::RegisterWithSameMailbox(IActor* actor, TActorId parentId) { 
         Y_VERIFY_DEBUG(parentId);
         auto& ctx = *TlsActivationContext;
         return ctx.ExecutorThread.RegisterActor(actor, &ctx.Mailbox, parentId.Hint(), parentId);
     }
 
-    TActorId TActorContext::RegisterWithSameMailbox(IActor* actor) const {
+    TActorId TActorContext::RegisterWithSameMailbox(IActor* actor) const { 
         return ExecutorThread.RegisterActor(actor, &Mailbox, SelfID.Hint(), SelfID);
     }
 
-    TActorId IActor::RegisterWithSameMailbox(IActor* actor) const noexcept {
+    TActorId IActor::RegisterWithSameMailbox(IActor* actor) const noexcept { 
         return TlsActivationContext->ExecutorThread.RegisterActor(actor, &TlsActivationContext->Mailbox, SelfActorId.Hint(), SelfActorId);
     }
 
diff --git a/library/cpp/actors/core/actor.h b/library/cpp/actors/core/actor.h
index ed29bd14b9..19aeeef00b 100644
--- a/library/cpp/actors/core/actor.h
+++ b/library/cpp/actors/core/actor.h
@@ -71,12 +71,12 @@ namespace NActors {
         // register new actor in ActorSystem on new fresh mailbox.
         static TActorId Register(IActor* actor, TActorId parentId = TActorId(), TMailboxType::EType mailboxType = TMailboxType::HTSwap, ui32 poolId = Max<ui32>());
 
-        // Register new actor in ActorSystem on same _mailbox_ as current actor.
-        // There is one thread per mailbox to execute actor, which mean
-        // no _cpu core scalability_ for such actors.
-        // This method of registration can be usefull if multiple actors share
-        // some memory.
-        static TActorId RegisterWithSameMailbox(IActor* actor, TActorId parentId);
+        // Register new actor in ActorSystem on same _mailbox_ as current actor. 
+        // There is one thread per mailbox to execute actor, which mean 
+        // no _cpu core scalability_ for such actors. 
+        // This method of registration can be usefull if multiple actors share 
+        // some memory. 
+        static TActorId RegisterWithSameMailbox(IActor* actor, TActorId parentId); 
 
         static const TActorContext& AsActorContext();
         static TActorContext ActorContextFor(TActorId id);
@@ -141,12 +141,12 @@ namespace NActors {
         // register new actor in ActorSystem on new fresh mailbox.
         TActorId Register(IActor* actor, TMailboxType::EType mailboxType = TMailboxType::HTSwap, ui32 poolId = Max<ui32>()) const;
 
-        // Register new actor in ActorSystem on same _mailbox_ as current actor.
-        // There is one thread per mailbox to execute actor, which mean
-        // no _cpu core scalability_ for such actors.
-        // This method of registration can be usefull if multiple actors share
-        // some memory.
-        TActorId RegisterWithSameMailbox(IActor* actor) const;
+        // Register new actor in ActorSystem on same _mailbox_ as current actor. 
+        // There is one thread per mailbox to execute actor, which mean 
+        // no _cpu core scalability_ for such actors. 
+        // This method of registration can be usefull if multiple actors share 
+        // some memory. 
+        TActorId RegisterWithSameMailbox(IActor* actor) const; 
 
         std::pair<ui32, ui32> CountMailboxEvents(ui32 maxTraverse = Max<ui32>()) const;
     };
@@ -204,7 +204,7 @@ namespace NActors {
         virtual void Schedule(TDuration delta, IEventBase* ev, ISchedulerCookie* cookie = nullptr) const noexcept = 0;
 
         virtual TActorId Register(IActor*, TMailboxType::EType mailboxType = TMailboxType::HTSwap, ui32 poolId = Max<ui32>()) const noexcept = 0;
-        virtual TActorId RegisterWithSameMailbox(IActor*) const noexcept = 0;
+        virtual TActorId RegisterWithSameMailbox(IActor*) const noexcept = 0; 
     };
 
     class TDecorator;
@@ -368,12 +368,12 @@ namespace NActors {
         // register new actor in ActorSystem on new fresh mailbox.
         TActorId Register(IActor* actor, TMailboxType::EType mailboxType = TMailboxType::HTSwap, ui32 poolId = Max<ui32>()) const noexcept final;
 
-        // Register new actor in ActorSystem on same _mailbox_ as current actor.
-        // There is one thread per mailbox to execute actor, which mean
-        // no _cpu core scalability_ for such actors.
-        // This method of registration can be usefull if multiple actors share
-        // some memory.
-        TActorId RegisterWithSameMailbox(IActor* actor) const noexcept final;
+        // Register new actor in ActorSystem on same _mailbox_ as current actor. 
+        // There is one thread per mailbox to execute actor, which mean 
+        // no _cpu core scalability_ for such actors. 
+        // This method of registration can be usefull if multiple actors share 
+        // some memory. 
+        TActorId RegisterWithSameMailbox(IActor* actor) const noexcept final; 
 
         std::pair<ui32, ui32> CountMailboxEvents(ui32 maxTraverse = Max<ui32>()) const;
 
@@ -478,7 +478,7 @@ namespace NActors {
         virtual bool DoBeforeReceiving(TAutoPtr<IEventHandle>& /*ev*/, const TActorContext& /*ctx*/) {
             return true;
         }
-
+ 
         virtual void DoAfterReceiving(const TActorContext& /*ctx*/)
         {
         }
diff --git a/library/cpp/actors/core/actor_coroutine.h b/library/cpp/actors/core/actor_coroutine.h
index 6bcb768eaf..8c2f9f37c6 100644
--- a/library/cpp/actors/core/actor_coroutine.h
+++ b/library/cpp/actors/core/actor_coroutine.h
@@ -134,7 +134,7 @@ namespace NActors {
             return GetActorContext().Register(actor, mailboxType, poolId);
         }
 
-        TActorId RegisterWithSameMailbox(IActor* actor) {
+        TActorId RegisterWithSameMailbox(IActor* actor) { 
             return GetActorContext().RegisterWithSameMailbox(actor);
         }
 
diff --git a/library/cpp/actors/dnsresolver/dnsresolver_ondemand.cpp b/library/cpp/actors/dnsresolver/dnsresolver_ondemand.cpp
index 2025162e95..8636ff94c6 100644
--- a/library/cpp/actors/dnsresolver/dnsresolver_ondemand.cpp
+++ b/library/cpp/actors/dnsresolver/dnsresolver_ondemand.cpp
@@ -32,9 +32,9 @@ namespace NDnsResolver {
         TActorId GetUpstream() {
             if (Y_UNLIKELY(!CachingResolverId)) {
                 if (Y_LIKELY(!SimpleResolverId)) {
-                    SimpleResolverId = RegisterWithSameMailbox(CreateSimpleDnsResolver(Options));
+                    SimpleResolverId = RegisterWithSameMailbox(CreateSimpleDnsResolver(Options)); 
                 }
-                CachingResolverId = RegisterWithSameMailbox(CreateCachingDnsResolver(SimpleResolverId, Options));
+                CachingResolverId = RegisterWithSameMailbox(CreateCachingDnsResolver(SimpleResolverId, Options)); 
             }
             return CachingResolverId;
         }
diff --git a/library/cpp/actors/helpers/flow_controlled_queue.cpp b/library/cpp/actors/helpers/flow_controlled_queue.cpp
index d75cc54023..d206ebc6f9 100644
--- a/library/cpp/actors/helpers/flow_controlled_queue.cpp
+++ b/library/cpp/actors/helpers/flow_controlled_queue.cpp
@@ -94,7 +94,7 @@ class TFlowControlledRequestQueue : public IActor {
 
     void RegisterReqActor(THolder<IEventHandle> ev) {
         TFlowControlledRequestActor *reqActor = new TFlowControlledRequestActor(ActivityType, this, ev->Sender, ev->Cookie, ev->Flags);
-        const TActorId reqActorId = RegisterWithSameMailbox(reqActor);
+        const TActorId reqActorId = RegisterWithSameMailbox(reqActor); 
         RegisteredRequests.emplace_back(reqActor);
 
         if (!Subscribed && (Target.NodeId() != SelfId().NodeId())) {
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
index 7e2d8ccb94..c8d8de482c 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
@@ -364,7 +364,7 @@ namespace NActors {
             }
 
             // Create new session actor.
-            SessionID = RegisterWithSameMailbox(Session = new TInterconnectSessionTCP(this, msg->Params));
+            SessionID = RegisterWithSameMailbox(Session = new TInterconnectSessionTCP(this, msg->Params)); 
             IActor::InvokeOtherActor(*Session, &TInterconnectSessionTCP::Init);
             SessionVirtualId = msg->Self;
             RemoteSessionVirtualId = msg->Peer;
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
index 2ded7f9f53..01a4e7655a 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.cpp
@@ -245,7 +245,7 @@ namespace NActors {
         auto actor = MakeHolder<TInputSessionTCP>(SelfId(), Socket, ReceiveContext, Proxy->Common,
             Proxy->Metrics, Proxy->PeerNodeId, nextPacket, GetDeadPeerTimeout(), Params);
         ReceiveContext->UnlockLastProcessedPacketSerial();
-        ReceiverId = Params.Encryption ? RegisterWithSameMailbox(actor.Release()) : Register(actor.Release(), TMailboxType::ReadAsFilled);
+        ReceiverId = Params.Encryption ? RegisterWithSameMailbox(actor.Release()) : Register(actor.Release(), TMailboxType::ReadAsFilled); 
 
         // register our socket in poller actor
         LOG_DEBUG_IC_SESSION("ICS11", "registering socket in PollerActor");
diff --git a/library/cpp/actors/interconnect/mock/ic_mock.cpp b/library/cpp/actors/interconnect/mock/ic_mock.cpp
index 884503e602..0dc1b87ed5 100644
--- a/library/cpp/actors/interconnect/mock/ic_mock.cpp
+++ b/library/cpp/actors/interconnect/mock/ic_mock.cpp
@@ -227,7 +227,7 @@ namespace NActors {
                 CheckSession();
                 if (!Session) {
                     Session = new TSessionMockActor(this, State.GetValidSessionId());
-                    RegisterWithSameMailbox(Session);
+                    RegisterWithSameMailbox(Session); 
                 }
                 return Session;
             }
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index 6fa25b9965..6173afc49e 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -1791,7 +1791,7 @@ namespace NActors {
 
         void Bootstrap(const TActorContext& ctx) {
             Become(&TStrandingActorDecorator::StateFunc);
-            ReplyId = ctx.RegisterWithSameMailbox(new TReplyActor(this));
+            ReplyId = ctx.RegisterWithSameMailbox(new TReplyActor(this)); 
             DelegateeOptions.OnlyMailboxes.push_back(TEventMailboxId(Delegatee.NodeId(), Delegatee.Hint()));
             for (const auto& actor : AdditionalActors) {
                 DelegateeOptions.OnlyMailboxes.push_back(TEventMailboxId(actor.NodeId(), actor.Hint()));