Remove unneeded waiter object
This commit is contained in:
@@ -129,8 +129,6 @@ func _main(background context.Context, args []string) int {
|
|||||||
defer close(connectedCh)
|
defer close(connectedCh)
|
||||||
go collectStreamLines(ctx, streamMerger, logger, signalConnected)
|
go collectStreamLines(ctx, streamMerger, logger, signalConnected)
|
||||||
|
|
||||||
waiter := command.NewWaiter()
|
|
||||||
|
|
||||||
connections, err := providerConf.GetOpenVPNConnections(allSettings.OpenVPN.Provider.ServerSelection)
|
connections, err := providerConf.GetOpenVPNConnections(allSettings.OpenVPN.Provider.ServerSelection)
|
||||||
fatalOnError(err)
|
fatalOnError(err)
|
||||||
err = providerConf.BuildConf(
|
err = providerConf.BuildConf(
|
||||||
@@ -247,12 +245,6 @@ func _main(background context.Context, args []string) int {
|
|||||||
exitStatus = 1
|
exitStatus = 1
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
timeoutCtx, timeoutCancel := context.WithTimeout(background, time.Second)
|
|
||||||
defer timeoutCancel()
|
|
||||||
for _, err := range waiter.WaitForAll(timeoutCtx) {
|
|
||||||
logger.Error(err)
|
|
||||||
exitStatus = 1
|
|
||||||
}
|
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
return exitStatus
|
return exitStatus
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user