diff --git a/internal/msggateway/ws_server.go b/internal/msggateway/ws_server.go index 71b06f3f3a..1fd52c11ab 100644 --- a/internal/msggateway/ws_server.go +++ b/internal/msggateway/ws_server.go @@ -196,6 +196,9 @@ func (ws *WsServer) Run(done chan error) error { if sErr != nil { return errs.WrapMsg(sErr, "shutdown err") } + fmt.Println("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA") + close(shutdownDone) + fmt.Println("BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB") return nil } etcd.RegisterShutDown(shutDown) @@ -206,7 +209,6 @@ func (ws *WsServer) Run(done chan error) error { if err := shutDown(); err != nil { return err } - close(shutdownDone) if err != nil { return err }