fix: config

pull/2997/head
icey-yu 9 months ago
parent 59cbabed8e
commit bc09ca0f44

@ -190,9 +190,8 @@ func (ws *WsServer) Run(done chan error) error {
netErr = errs.WrapMsg(err, "ws start err", server.Addr) netErr = errs.WrapMsg(err, "ws start err", server.Addr)
} }
}() }()
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
shutDown := func() error { shutDown := func() error {
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
defer cancel()
sErr := server.Shutdown(ctx) sErr := server.Shutdown(ctx)
if sErr != nil { if sErr != nil {
return errs.WrapMsg(sErr, "shutdown err") return errs.WrapMsg(sErr, "shutdown err")
@ -200,8 +199,8 @@ func (ws *WsServer) Run(done chan error) error {
close(shutdownDone) close(shutdownDone)
return nil return nil
} }
log.ZError(context.Background(), "NJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJJ", nil)
etcd.RegisterShutDown(shutDown) etcd.RegisterShutDown(shutDown)
defer cancel()
var err error var err error
select { select {
case err = <-done: case err = <-done:

Loading…
Cancel
Save