Skip to content

Commit 50e97f8

Browse files
authored
Merge pull request #19041 from ahrtr/serve_20241211
Do not wait for ready notify if the server is stopping
2 parents 2cf7172 + 93b01af commit 50e97f8

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

server/embed/serve.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ package embed
1616

1717
import (
1818
"context"
19+
"errors"
1920
"fmt"
2021
"io"
2122
defaultLog "log"
@@ -102,6 +103,12 @@ func (sctx *serveCtx) serve(
102103
logger := defaultLog.New(io.Discard, "etcdhttp", 0)
103104
<-s.ReadyNotify()
104105

106+
select {
107+
case <-s.StoppingNotify():
108+
return errors.New("server is stopping")
109+
case <-s.ReadyNotify():
110+
}
111+
105112
sctx.lg.Info("ready to serve client requests")
106113

107114
m := cmux.New(sctx.l)

0 commit comments

Comments
 (0)