Merge pull request #9230 from mxpv/exit
Exit shim when shutdown manager is done
This commit is contained in:
commit
9fcc3beb59
@ -379,7 +379,7 @@ func run(ctx context.Context, manager Manager, name string, config Config) error
|
|||||||
}
|
}
|
||||||
|
|
||||||
if err := serve(ctx, server, signals, sd.Shutdown); err != nil {
|
if err := serve(ctx, server, signals, sd.Shutdown); err != nil {
|
||||||
if err != shutdown.ErrShutdown {
|
if !errors.Is(err, shutdown.ErrShutdown) {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -391,10 +391,10 @@ func run(ctx context.Context, manager Manager, name string, config Config) error
|
|||||||
}
|
}
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case <-publisher.Done():
|
case <-sd.Done():
|
||||||
return nil
|
return nil
|
||||||
case <-time.After(5 * time.Second):
|
case <-time.After(5 * time.Second):
|
||||||
return errors.New("publisher not closed")
|
return errors.New("shim shutdown timeout")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user