|
|
|
@ -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
|
|
|
|
|
}
|
|
|
|
|