aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRobert Drynkin <rob.drynkin@gmail.com>2024-01-17 13:26:44 +0100
committerGitHub <noreply@github.com>2024-01-17 13:26:44 +0100
commit473760134173f4b2459c44787b48dc1f09ea8476 (patch)
treeee9e9a7554209a86619181a8a44c38ce43c1fb85
parenta0c44acd6a8dd119921f5ac8ce5d0f7fd474d24c (diff)
downloadydb-473760134173f4b2459c44787b48dc1f09ea8476.tar.gz
Make test actorsystem actor id globaly unique (#1081)
-rw-r--r--ydb/core/util/testactorsys.h8
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);