Cleanup: Worker, simplify Listerer.Run() function
No functional changes, except that now the "listener shutting down" message will also be logged in case of a panic.
This commit is contained in:
parent
f244355328
commit
34f1cc076c
@ -46,20 +46,17 @@ func NewListener(client FlamencoClient, buffer UpstreamBuffer) *Listener {
|
||||
}
|
||||
|
||||
func (l *Listener) Run(ctx context.Context) {
|
||||
keepRunning := true
|
||||
for keepRunning {
|
||||
defer l.doneWg.Done()
|
||||
defer log.Debug().Msg("listener shutting down")
|
||||
|
||||
for {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
keepRunning = false
|
||||
continue
|
||||
return
|
||||
case <-time.After(10 * time.Second):
|
||||
// This is just a dummy thing.
|
||||
log.Trace().Msg("listener is still running")
|
||||
}
|
||||
log.Trace().Msg("listener is still running")
|
||||
}
|
||||
|
||||
log.Debug().Msg("listener shutting down")
|
||||
l.doneWg.Done()
|
||||
}
|
||||
|
||||
func (l *Listener) Wait() {
|
||||
|
Loading…
x
Reference in New Issue
Block a user