Fix proxy panic if quit before init (#5981)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/5984/head
congqixia 2021-06-22 17:40:07 +08:00 committed by GitHub
parent 20a3d601ea
commit 7a2546c24a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 7 deletions

View File

@ -370,13 +370,23 @@ func (node *Proxy) Start() error {
func (node *Proxy) Stop() error {
node.cancel()
node.idAllocator.Close()
node.segAssigner.Close()
node.sched.Close()
node.tick.Close()
err := node.chTicker.close()
if err != nil {
return err
if node.idAllocator != nil {
node.idAllocator.Close()
}
if node.segAssigner != nil {
node.segAssigner.Close()
}
if node.sched != nil {
node.sched.Close()
}
if node.tick != nil {
node.tick.Close()
}
if node.chTicker != nil {
err := node.chTicker.close()
if err != nil {
return err
}
}
node.wg.Wait()