Explorar o código

HPCC-24952 Rework IBYTI processing

Missing call to noteNodeSick

Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
Richard Chapman %!s(int64=4) %!d(string=hai) anos
pai
achega
a7636343f0
Modificáronse 1 ficheiros con 7 adicións e 0 borrados
  1. 7 0
      roxie/ccd/ccdqueue.cpp

+ 7 - 0
roxie/ccd/ccdqueue.cpp

@@ -2066,6 +2066,13 @@ public:
                     hiQueue.enqueue(packet);
                 else
                     loQueue.enqueue(packet);
+                for (unsigned subChannel = 0; subChannel < MAX_SUBCHANNEL; subChannel++)
+                {
+                    if (header.subChannels[subChannel].isMe() || header.subChannels[subChannel].isNull())
+                        break;
+                    noteNodeSick(header.subChannels[subChannel].getIpAddress());
+                }
+
                 DelayedPacketEntry *goer = finger;
                 finger = finger->next;
                 removeEntry(goer);