diff options
author | hor911 <hor911@yandex-team.ru> | 2022-03-04 12:15:50 +0300 |
---|---|---|
committer | hor911 <hor911@yandex-team.ru> | 2022-03-04 12:15:50 +0300 |
commit | 4de4646021e9377bcda9b448fd2cb224b15b6aa9 (patch) | |
tree | 1137c0ccfbde0ac32037d810673c56ed819e3c22 | |
parent | b45021d3597dc78ff3b6939d65e4365634b88f78 (diff) | |
download | ydb-4de4646021e9377bcda9b448fd2cb224b15b6aa9.tar.gz |
Crash in Dynamic IC NS
ref:b1ce45634bdaa00aa8476171d37a65534c332b2c
-rw-r--r-- | library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp b/library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp index 5e48401b14..79007f2738 100644 --- a/library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp +++ b/library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp @@ -58,7 +58,7 @@ namespace NActors { auto now = Now(); for (auto& pending : PendingRequests) { - if (pending.Deadline > now) { + if (pending.Request && pending.Deadline > now) { LOG_ERROR_IC("ICN06", "Unknown nodeId: %u", pending.Request->Get()->Record.GetNodeId()); auto reply = new TEvLocalNodeInfo; reply->NodeId = pending.Request->Get()->Record.GetNodeId(); @@ -144,7 +144,7 @@ namespace NActors { node.Address, node.Host, node.ResolveHost, node.Port, node.Location); for (auto& pending : PendingRequests) { - if (pending.Request->Get()->Record.GetNodeId() == node.NodeId) { + if (pending.Request && pending.Request->Get()->Record.GetNodeId() == node.NodeId) { LOG_DEBUG_IC("ICN05", "Pending nodeId: %u discovered", node.NodeId); RegisterWithSameMailbox( CreateResolveActor(node.NodeId, NodeTable[node.NodeId], pending.Request->Sender, SelfId(), pending.Deadline)); |