Skip to content

Commit

Permalink
TRY MORE, +10
Browse files Browse the repository at this point in the history
  • Loading branch information
levb committed Nov 3, 2024
1 parent c2e2e2f commit abb09e6
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
3 changes: 1 addition & 2 deletions src/micro.c
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ _detach_service_from_connection(natsConnection *nc, microService *m)
if (nc == NULL || m == NULL)
return false;

printf("<>/<> _detachING_service_from_connection %s: remaining: %d, removed: %d\n", m->cfg->Name, remaining, removed);
printf("<>/<> _detachING_service_from_connection %s\n", m->cfg->Name);
natsConn_Lock(nc);
for (int i = 0; i < nc->numServices; i++)
{
Expand Down Expand Up @@ -408,7 +408,6 @@ void micro_release_endpoint_when_unsubscribed(void *closure)
if ((m == NULL) || (m->service_mu == NULL))
return;

printf("<>/<> SUB complete: service %s, endpoint %s\n", m->cfg->Name, ep->subject);
micro_lock_endpoint(ep);
sub = ep->sub;
ep->sub = NULL; // Force the subscription to be destroyed now, so NULL out the pointer to avoid a double free.
Expand Down
3 changes: 2 additions & 1 deletion test/test.c
Original file line number Diff line number Diff line change
Expand Up @@ -33561,7 +33561,7 @@ _startMicroservice(microService** new_m, natsConnection *nc, microServiceConfig
static void
_startMicroserviceOK(microService** new_m, natsConnection *nc, microServiceConfig *cfg, microEndpointConfig **eps, int num_eps, struct threadArg *arg)
{
char buf[64];
char buf[256];

snprintf(buf, sizeof(buf), "Start microservice %s: ", cfg->Name);
test(buf);
Expand Down Expand Up @@ -34414,6 +34414,7 @@ void test_MicroStartStop(void)
for (i = 0; i < NUM_MICRO_SERVICES; i++)
{
_destroyMicroservice(svcs[i]);
nats_Sleep(100); // <>/<>
}
_waitForMicroservicesAllDone(&arg);

Expand Down

0 comments on commit abb09e6

Please sign in to comment.