wip ++

levb · Oct 22, 2024 · 21d25ef · 21d25ef
1 parent 964857a
commit 21d25ef
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/dispatch.c b/src/dispatch.c
@@ -280,7 +280,7 @@ nats_dispatchThreadPool(void *arg)
 
             if (completeCB != NULL)
             {
-                nats_Sleep(100);
+                // nats_Sleep(100);
                 printf("<>/<> completeCB (pool) on %s\n", sub->subject); fflush(stdout);
                 (*completeCB)(completeCBClosure);
             }
@@ -591,7 +591,7 @@ nats_dispatchThreadOwn(void *arg)
 
     if (completeCB != NULL)
     {
-        nats_Sleep(100);
+        // nats_Sleep(100);
         printf("<>/<> completeCB on %s\n", sub->subject); fflush(stdout);
         (*completeCB)(completeCBClosure);
     }

diff --git a/test/test.c b/test/test.c
@@ -33591,7 +33591,7 @@ _startManyMicroservices(microService** svcs, int n, natsConnection *nc, microSer
         bool allDone = false;                                                           \
         natsMutex_Lock((_arg)->m);                                                      \
         while ((waitStatus != NATS_TIMEOUT) && !(_arg)->microAllDone)                   \
-            waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 10000);           \
+            waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 100);  /*<>/<>*/ \
         allDone = (_arg)->microAllDone;                                                 \
         natsMutex_Unlock((_arg)->m);                                                    \
         testCond((NATS_OK == waitStatus) && allDone);                                   \