mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
fn: lb_agent Close should close shutdown channel (#925)
This commit is contained in:
committed by
Reed Allman
parent
dc6a3305eb
commit
c1f0707b60
@@ -136,6 +136,7 @@ func (a *lbAgent) Close() error {
|
|||||||
ctx, cancel := context.WithTimeout(context.Background(), runnerPoolShutdownTimeout)
|
ctx, cancel := context.WithTimeout(context.Background(), runnerPoolShutdownTimeout)
|
||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
||||||
|
close(a.shutdown)
|
||||||
a.rp.Shutdown(ctx)
|
a.rp.Shutdown(ctx)
|
||||||
err := a.delegatedAgent.Close()
|
err := a.delegatedAgent.Close()
|
||||||
a.wg.Wait()
|
a.wg.Wait()
|
||||||
|
|||||||
Reference in New Issue
Block a user