wip ++

levb · Oct 31, 2024 · df284c9 · df284c9
1 parent a973019
commit df284c9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/src/sub.c b/src/sub.c
@@ -140,9 +140,7 @@ void natsSub_release(natsSubscription *sub)
     natsSub_Unlock(sub);
 
     if (refs == 0)
-    {        
         _freeSub(sub);
-    }
 }
 
 void natsSub_unlockRelease(natsSubscription *sub)

diff --git a/test/test.c b/test/test.c
@@ -33583,18 +33583,17 @@ _startManyMicroservices(microService** svcs, int n, natsConnection *nc, microSer
 }
 
 #define _waitForMicroservicesAllDone(_arg)                                              \
-    {                                                                                   \
+    {                                            q                                       \
         natsMutex_Lock((_arg)->m);                                                      \
         testf("Wait for %d microservices to stop: ", (_arg)->microRunningServiceCount); \
         natsStatus waitStatus = NATS_OK;                                                \
         bool allDone = false;                                                           \
         while ((waitStatus != NATS_TIMEOUT) && !(_arg)->microAllDone)                   \
-            waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 100);  /*<>/<>*/ \
+            waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 1000);           \
         allDone = (_arg)->microAllDone;                                                 \
         natsMutex_Unlock((_arg)->m);                                                    \
         testCond((NATS_OK == waitStatus) && allDone);                                   \
-    }                                                                                   \
-    nats_Sleep(1);
+    }
 
 #define _destroyMicroservice(_s)                                                                  \
     testf("Destroy microservice %s: ", (_s)->cfg->Name);                                          \