mirrors/etcd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Do not wait for ready notify if the server is stopping

Browse Source 
Signed-off-by: Benjamin Wang <benjamin.ahrtr@gmail.com>
This commit is contained in:
Benjamin Wang
2024-12-12 21:45:28 +00:00
parent 2cf717251e
commit 93b01af668
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/embed/serve.go
View File

@ -16,6 +16,7 @@ package embed
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
defaultLog "log" defaultLog "log"
@ -102,6 +103,12 @@ func (sctx *serveCtx) serve(
logger := defaultLog.New(io.Discard, "etcdhttp", 0) logger := defaultLog.New(io.Discard, "etcdhttp", 0)
<-s.ReadyNotify() <-s.ReadyNotify()
select {
case <-s.StoppingNotify():
return errors.New("server is stopping")
case <-s.ReadyNotify():
}
sctx.lg.Info("ready to serve client requests") sctx.lg.Info("ready to serve client requests")
m := cmux.New(sctx.l) m := cmux.New(sctx.l)