Skip to content

Commit 4737601

Browse files
authored
Make test actorsystem actor id globaly unique (#1081)
1 parent a0c44ac commit 4737601

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

ydb/core/util/testactorsys.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,12 +102,12 @@ class TTestActorSystem {
102102

103103
struct TMailboxInfo {
104104
TMailboxHeader Header{TMailboxType::Simple};
105-
ui64 ActorLocalId = 1;
106105
};
107106

108107
const ui32 MaxNodeId;
109108
std::map<TInstant, std::deque<TScheduleItem>> ScheduleQ;
110109
TInstant Clock = TInstant::Zero();
110+
ui64 ActorLocalId = 1;
111111
std::unordered_map<TMailboxId, TMailboxInfo, THash<std::tuple<ui32, ui32, ui32>>> Mailboxes;
112112
TProgramShouldContinue ProgramShouldContinue;
113113
TAppData AppData;
@@ -473,11 +473,11 @@ class TTestActorSystem {
473473
// register actor in mailbox
474474
const auto& it = Mailboxes.try_emplace(TMailboxId(nodeId, poolId, mboxId)).first;
475475
TMailboxInfo& mbox = it->second;
476-
mbox.Header.AttachActor(mbox.ActorLocalId, actor);
476+
mbox.Header.AttachActor(ActorLocalId, actor);
477477

478478
// generate actor id
479-
const TActorId actorId(nodeId, poolId, mbox.ActorLocalId, mboxId);
480-
++mbox.ActorLocalId;
479+
const TActorId actorId(nodeId, poolId, ActorLocalId, mboxId);
480+
++ActorLocalId;
481481
if (OwnLogPriority >= NActors::NLog::EPrio::Info) {
482482
*LogStream << "[TestActorSystem] Register actor \"" << name << "\" with id " << actorId.ToString() << Endl;
483483
RegisterActorName(actorId, name);

0 commit comments

Comments
 (0)