bunker: fix a halting waitgroup issue.

This commit is contained in:
fiatjaf
2025-12-16 13:13:12 -03:00
parent 68bbece3db
commit 6f00ff4c73

View File

@@ -366,6 +366,7 @@ var bunker = &cli.Command{
handlerWg.Add(len(relayURLs)) handlerWg.Add(len(relayURLs))
for _, relayURL := range relayURLs { for _, relayURL := range relayURLs {
go func(relayURL string) { go func(relayURL string) {
defer handlerWg.Done()
if relay, _ := sys.Pool.EnsureRelay(relayURL); relay != nil { if relay, _ := sys.Pool.EnsureRelay(relayURL); relay != nil {
err := relay.Publish(ctx, eventResponse) err := relay.Publish(ctx, eventResponse)
printLock.Lock() printLock.Lock()
@@ -375,7 +376,6 @@ var bunker = &cli.Command{
log("* failed to send response: %s\n", err) log("* failed to send response: %s\n", err)
} }
printLock.Unlock() printLock.Unlock()
handlerWg.Done()
} }
}(relayURL) }(relayURL)
} }