diff options
author | Robert Drynkin <rob.drynkin@gmail.com> | 2024-01-17 13:26:44 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-01-17 13:26:44 +0100 |
commit | 473760134173f4b2459c44787b48dc1f09ea8476 (patch) | |
tree | ee9e9a7554209a86619181a8a44c38ce43c1fb85 | |
parent | a0c44acd6a8dd119921f5ac8ce5d0f7fd474d24c (diff) | |
download | ydb-473760134173f4b2459c44787b48dc1f09ea8476.tar.gz |
Make test actorsystem actor id globaly unique (#1081)
-rw-r--r-- | ydb/core/util/testactorsys.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/core/util/testactorsys.h b/ydb/core/util/testactorsys.h index 07aec0de15..02220a1781 100644 --- a/ydb/core/util/testactorsys.h +++ b/ydb/core/util/testactorsys.h @@ -102,12 +102,12 @@ class TTestActorSystem { struct TMailboxInfo { TMailboxHeader Header{TMailboxType::Simple}; - ui64 ActorLocalId = 1; }; const ui32 MaxNodeId; std::map<TInstant, std::deque<TScheduleItem>> ScheduleQ; TInstant Clock = TInstant::Zero(); + ui64 ActorLocalId = 1; std::unordered_map<TMailboxId, TMailboxInfo, THash<std::tuple<ui32, ui32, ui32>>> Mailboxes; TProgramShouldContinue ProgramShouldContinue; TAppData AppData; @@ -473,11 +473,11 @@ public: // register actor in mailbox const auto& it = Mailboxes.try_emplace(TMailboxId(nodeId, poolId, mboxId)).first; TMailboxInfo& mbox = it->second; - mbox.Header.AttachActor(mbox.ActorLocalId, actor); + mbox.Header.AttachActor(ActorLocalId, actor); // generate actor id - const TActorId actorId(nodeId, poolId, mbox.ActorLocalId, mboxId); - ++mbox.ActorLocalId; + const TActorId actorId(nodeId, poolId, ActorLocalId, mboxId); + ++ActorLocalId; if (OwnLogPriority >= NActors::NLog::EPrio::Info) { *LogStream << "[TestActorSystem] Register actor \"" << name << "\" with id " << actorId.ToString() << Endl; RegisterActorName(actorId, name); |