aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors
diff options
context:
space:
mode:
authorDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:17 +0300
commit4b11037e5a7d071c63e3c966199fe7102e6462e4 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/actors
parent17e20fa084178ddcb16255f974dbde74fb93608b (diff)
downloadydb-4b11037e5a7d071c63e3c966199fe7102e6462e4.tar.gz
Restoring authorship annotation for Daniil Cherednik <dcherednik@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors')
-rw-r--r--library/cpp/actors/core/actor.cpp6
-rw-r--r--library/cpp/actors/core/actor.h40
-rw-r--r--library/cpp/actors/core/actor_coroutine.h2
-rw-r--r--library/cpp/actors/dnsresolver/dnsresolver_ondemand.cpp4
-rw-r--r--library/cpp/actors/helpers/flow_controlled_queue.cpp2
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp2
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_session.cpp2
-rw-r--r--library/cpp/actors/interconnect/mock/ic_mock.cpp2
-rw-r--r--library/cpp/actors/testlib/test_runtime.cpp2
9 files changed, 31 insertions, 31 deletions
diff --git a/library/cpp/actors/core/actor.cpp b/library/cpp/actors/core/actor.cpp
index 4a5049a32c4..6f9ba6a42bb 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 19aeeef00b5..ed29bd14b9e 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 8c2f9f37c6f..6bcb768eafc 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 8636ff94c6c..2025162e951 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 d206ebc6f9b..d75cc540236 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 c8d8de482cf..7e2d8ccb948 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 01a4e7655ab..2ded7f9f537 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 0dc1b87ed58..884503e6022 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 6173afc49e8..6fa25b99656 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()));