Skip to content

Commit

Permalink
wip ++11
Browse files Browse the repository at this point in the history
  • Loading branch information
levb committed Nov 1, 2024
1 parent a422534 commit 4d4dfde
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion test/test.c
Original file line number Diff line number Diff line change
Expand Up @@ -33510,6 +33510,8 @@ _microServiceDoneHandler(microService *m)
arg->microRunningServiceCount--;
if (arg->microRunningServiceCount == 0)
{
printf("<>/<> SERVICE done\n");
fflush(stdout);
arg->microAllDone = true;
natsCondition_Broadcast(arg->c);
}
Expand Down Expand Up @@ -33589,7 +33591,7 @@ _startManyMicroservices(microService** svcs, int n, natsConnection *nc, microSer
natsStatus waitStatus = NATS_OK; \
bool allDone = false; \
while ((waitStatus != NATS_TIMEOUT) && !(_arg)->microAllDone) \
waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 1000); \
waitStatus = natsCondition_TimedWait((_arg)->c, (_arg)->m, 10000);/* <>/<> */ \
allDone = (_arg)->microAllDone; \
natsMutex_Unlock((_arg)->m); \
testCond((NATS_OK == waitStatus) && allDone); \
Expand Down

0 comments on commit 4d4dfde

Please sign in to comment.