aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@yandex-team.ru>2022-03-04 12:15:50 +0300
committerhor911 <hor911@yandex-team.ru>2022-03-04 12:15:50 +0300
commit4de4646021e9377bcda9b448fd2cb224b15b6aa9 (patch)
tree1137c0ccfbde0ac32037d810673c56ed819e3c22
parentb45021d3597dc78ff3b6939d65e4365634b88f78 (diff)
downloadydb-4de4646021e9377bcda9b448fd2cb224b15b6aa9.tar.gz
Crash in Dynamic IC NS
ref:b1ce45634bdaa00aa8476171d37a65534c332b2c
-rw-r--r--library/cpp/actors/interconnect/interconnect_nameserver_dynamic.cpp4
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));