We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8124ee3 commit 73540d9Copy full SHA for 73540d9
pkg/remote/trans/nphttp2/server_handler.go
@@ -380,11 +380,15 @@ func (t *svrTransHandler) SetPipeline(p *remote.TransPipeline) {
380
}
381
382
func (t *svrTransHandler) GracefulShutdown(ctx context.Context) error {
383
+ t.mu.Lock()
384
+ if t.li.Len() == 0 {
385
+ t.mu.Unlock()
386
+ return nil
387
+ }
388
klog.Info("KITEX: gRPC GracefulShutdown starts")
389
defer func() {
390
klog.Info("KITEX: gRPC GracefulShutdown ends")
391
}()
- t.mu.Lock()
392
for elem := t.li.Front(); elem != nil; elem = elem.Next() {
393
svrTrans := elem.Value.(*SvrTrans)
394
svrTrans.tr.Drain()
0 commit comments