Просмотр исходного кода

HPCC-25613 Check roxie udp timeouts

Testing didn't find any issues, but worth releasing some minor tracing updates
that were made whild validating.

Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
Richard Chapman 4 лет назад
Родитель
Сommit
5a2293a15c
3 измененных файлов с 7 добавлено и 2 удалено
  1. 1 1
      dockerfiles/startall.sh
  2. 1 1
      roxie/ccd/ccdserver.cpp
  3. 5 0
      roxie/udplib/udptrs.cpp

+ 1 - 1
dockerfiles/startall.sh

@@ -76,7 +76,7 @@ else
     if echo "${line}" | egrep -q 'missing$'; then
       let "missingDeps++"
     fi
-  done < <(helm dependency list ${scriptdir}/../helm/hpcc)
+  done < <(helm dependency list ${scriptdir}/../helm/hpcc | grep -v WARNING)
   if [[ ${missingDeps} -gt 0 ]]; then
     echo "Some of the chart dependencies are missing."
     echo "Either issue a 'helm dependency update ${scriptdir}/../helm/hpcc' to fetch them,"

+ 1 - 1
roxie/ccd/ccdserver.cpp

@@ -4874,7 +4874,7 @@ public:
             {
                 if (!anyActivity && !localAgent && lastActivity-msTick() >= timeout)
                 {
-                    activity.queryLogCtx().CTXLOG("Input has stalled - retry required?");
+                    activity.queryLogCtx().CTXLOG("Input has stalled for %u ms - retry required?", timeout);
                     retryPending();
                 }
             }

+ 5 - 0
roxie/udplib/udptrs.cpp

@@ -610,7 +610,12 @@ public:
             }
         }
         if (udpResendLostPackets)
+        {
+            DBGLOG("UdpSender: created resend list with %u entries", TRACKER_BITS);
             resendList = new UdpResendList;
+        }
+        else
+            DBGLOG("UdpSender: resend list disabled");
     }
 
     ~UdpReceiverEntry()