fix warden client metadta range

6 years ago · 43c63d03cd
parent 5df7bfc200
commit 43c63d03cd
1 changed files with 2 additions and 0 deletions
--- a/pkg/net/rpc/warden/client.go
+++ b/pkg/net/rpc/warden/client.go
@ -107,6 +107,8 @@ func (c *Client) handle() grpc.UnaryClientInterceptor {
 			return
 		}
 		defer onBreaker(brk, &err)
+		_, ctx, cancel = conf.Timeout.Shrink(ctx)
+		defer cancel()
 		nmd.Range(ctx,
 			func(key string, value interface{}) {
 				if valstr, ok := value.(string); ok {