From 21d25ef8ffc18c8a1691e92c06f322e16761b28c Mon Sep 17 00:00:00 2001 From: Lev Brouk Date: Tue, 22 Oct 2024 07:50:35 -0700 Subject: [PATCH] wip ++ --- src/dispatch.c | 4 ++-- test/test.c | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/dispatch.c b/src/dispatch.c index bbf5dccb..d1de0c88 100644 --- 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 index b902093b..be065e48 100644 --- 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); \