Add stress test.

.github/workflows/ubuntu-check-curl.yml

@@ -2,7 +2,7 @@ name: Ubuntu Build Test with Curl Support
 
 on:
   push:
-    branches: [ 'master', 'main', 'release/**' ]
+    branches: [ '*' ]
   pull_request:
     branches: [ '*' ]
 
@@ -98,6 +98,15 @@ jobs:
     - name: wolfmqtt make check
       run: make check
 
+    - name: wolfmqtt configure with libCurl and Stress
+      env:
+        WOLFMQTT_NO_EXTERNAL_BROKER_TESTS: 1
+      run: ./configure --enable-curl --enable-stress
+    - name: wolfmqtt make
+      run: make
+    - name: wolfmqtt make check
+      run: make check
+
       # capture logs on failure
     - name: Show logs on failure
       if: failure() || cancelled()

.github/workflows/ubuntu-check.yml

@@ -2,7 +2,7 @@ name: Ubuntu Build Test
 
 on:
   push:
-    branches: [ 'master', 'main', 'release/**' ]
+    branches: [ '*' ]
   pull_request:
     branches: [ '*' ]
 
@@ -108,6 +108,15 @@ jobs:
     - name: make check
       run: make check
 
+    - name: wolfmqtt configure with Stress
+      env:
+        WOLFMQTT_NO_EXTERNAL_BROKER_TESTS: 1
+      run: ./configure --enable-stress
+    - name: wolfmqtt make
+      run: make
+    - name: wolfmqtt make check
+      run: make check
+
       # capture logs on failure
     - name: Show logs on failure
       if: failure() || cancelled()

configure.ac

@@ -263,7 +263,6 @@ if test "x$ENABLED_CURL" = "xyes"; then
     AC_CHECK_LIB([curl],[curl_easy_init],,[AC_MSG_ERROR([libcurl is required and wasn't found on the system. It can be obtained from https://curl.se/download.html.])])
 fi
 
-
 # MQTT v5.0
 AC_ARG_ENABLE([v5],
     [AS_HELP_STRING([--enable-v5],[Enable MQTT v5.0 support (default: disabled)])],
@@ -329,10 +328,37 @@ then
     AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_MULTITHREAD"
 fi
 
+# Stress test convenience build option.
+AC_ARG_ENABLE([stress],
+    [AS_HELP_STRING([--enable-stress],[Enable stress test (default: disabled)])],
+    [ ENABLED_STRESS=$enableval ],
+    [ ENABLED_STRESS=no ]
+    )
+
+if test "x$ENABLED_STRESS" = "xyes"; then
+    if test "x$ENABLED_ALL" = "xyes"; then
+        AC_MSG_ERROR([--enable-all and --enable-stress are incompatible])
+    fi
+
+    if test "x$ENABLED_SN" = "xyes"; then
+        AC_MSG_ERROR([--enable-sn and --enable-stress are incompatible])
+    fi
+
+    ENABLED_TIMEOUT=yes
+    ENABLED_NONBLOCK=yes
+    ENABLED_MULTITHREAD=yes
+    AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_STRESS"
+    AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_NONBLOCK"
+    AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_TEST_NONBLOCK"
+    AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_TEST_NONBLOCK_TIMES=2"
+    AM_CFLAGS="$AM_CFLAGS -DWOLFMQTT_MULTITHREAD"
+    AM_CFLAGS="$AM_CFLAGS -DNUM_PUB_TASKS=5 -DNUM_PUB_PER_TASK=4"
+fi
 
 
 AM_CONDITIONAL([HAVE_LIBWOLFSSL], [test "x$ENABLED_TLS" = "xyes"])
 AM_CONDITIONAL([HAVE_LIBCURL], [test "x$ENABLED_CURL" = "xyes"])
+AM_CONDITIONAL([BUILD_STRESS], [test "x$ENABLED_STRESS" = "xyes"])
 AM_CONDITIONAL([BUILD_EXAMPLES], [test "x$ENABLED_EXAMPLES" = "xyes"])
 AM_CONDITIONAL([BUILD_STDINCAP], [test "x$ENABLED_STDINCAP" = "xyes"])
 AM_CONDITIONAL([BUILD_SN], [test "x$ENABLED_SN" = "xyes"])
@@ -465,3 +491,4 @@ echo "   * STDIN Capture:             $ENABLED_STDINCAP"
 echo "   * TLS:                       $ENABLED_TLS"
 echo "   * CURL:                      $ENABLED_CURL"
 echo "   * Multi-thread:              $ENABLED_MULTITHREAD"
+echo "   * Stress:                    $ENABLED_STRESS"

examples/mqttexample.c

@@ -563,6 +563,8 @@ int mqtt_check_timeout(int rc, word32* start_sec, word32 timeout_sec)
         return rc;
     }
 
+    if (timeout_sec == 0) { timeout_sec = 2; }
+
     elapsed_sec = mqtt_get_timer_seconds();
     if (*start_sec < elapsed_sec) {
         elapsed_sec -= *start_sec;