Browse Source

HPCC-18244 UDP test program uttest needs to set requestToSend timeout

Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
Richard Chapman 7 years ago
parent
commit
a7b1913020
1 changed files with 10 additions and 0 deletions
  1. 10 0
      roxie/udplib/uttest.cpp

+ 10 - 0
roxie/udplib/uttest.cpp

@@ -49,6 +49,8 @@ void usage()
         "--udpLocalWriteSocketSize nn\n"
         "--udpRetryBusySenders nn\n"
         "--maxPacketsPerSender nn\n"
+        "--udpQueueSize nn\n"
+        "--udpRTSTimeout nn\n"
         "--udpSnifferEnabled 0|1\n"     
         "--udpTraceCategories nn\n"
         "--udpTraceLevel nn\n"
@@ -621,6 +623,7 @@ int main(int argc, char * argv[] )
     DBGLOG("%s",cmdline.str());
 //  queryLogMsgManager()->enterQueueingMode();
 //  queryLogMsgManager()->setQueueDroppingLimit(512, 32);
+    udpRequestToSendTimeout = 5000;
     for (c = 1; c < argc; c++)
     {
         const char *ip = argv[c];
@@ -634,6 +637,13 @@ int main(int argc, char * argv[] )
                     usage();
                 udpQueueSize = atoi(argv[c]);
             }
+            if (strcmp(ip, "--udpRTSTimeout")==0)
+            {
+                c++;
+                if (c==argc || !isdigit(*argv[c]))
+                    usage();
+                udpRequestToSendTimeout = atoi(argv[c]);
+            }
             else if (strcmp(ip, "--jumboFrames")==0)
             {
                 roxiemem::setDataAlignmentSize(0x2000);