wip ++++

levb · Oct 31, 2024 · 9dd00ef · 9dd00ef
1 parent ff5e06d
commit 9dd00ef
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.github/workflows/build-test.yml b/.github/workflows/build-test.yml
@@ -181,7 +181,7 @@ jobs:
           export PATH=../deps/nats-server:../deps/nats-streaming-server:$PATH
           export NATS_TEST_SERVER_VERSION="$(nats-server -v)"
           flags=""
-          ctest -VV -R '^MicroServiceStops' --timeout 60 --output-on-failure --repeat-until-fail 20 # ${{ inputs.repeat }}
+          ctest -VV -R '^MicroServiceAsync' --timeout 60 --output-on-failure --repeat-until-fail 20 # ${{ inputs.repeat }}
           # ctest -L 'test' --timeout 60 --output-on-failure --repeat-until-fail ${{ inputs.repeat }}
 
       - name: Upload coverage reports to Codecov

diff --git a/src/micro.c b/src/micro.c
@@ -246,7 +246,7 @@ _stop_service(microService *m, bool unsubscribe)
     if (m == NULL)
         return micro_ErrorInvalidArg;
 
-    printf("<>/<> microService_Stop %s\n", m->cfg->Name);
+    printf("<>/<> microService_Stop %s, unsub %d\n", m->cfg->Name, unsubscribe);
     _lock_service(m);
     alreadyStopped = m->stopped;
     m->stopped = true;
@@ -599,7 +599,7 @@ _on_error(natsConnection *nc, natsSubscription *sub, natsStatus s, void *not_use
     {
         m = all[i];
         _on_service_error(m, subject, s);
-        _stop_service(m, false); // subs will be terminated by the error.
+        _stop_service(m, true);
     }
 }