diff --git a/etcdserver/v3_server.go b/etcdserver/v3_server.go index dca135c46..3e041d239 100644 --- a/etcdserver/v3_server.go +++ b/etcdserver/v3_server.go @@ -35,9 +35,6 @@ const ( // specify a large value might end up with shooting in the foot. maxRequestBytes = 1.5 * 1024 * 1024 - // max timeout for waiting a v3 request to go through raft. - maxV3RequestTimeout = 5 * time.Second - // In the health case, there might be a small gap (10s of entries) between // the applied index and committed index. // However, if the committed entries are very heavy to apply, the gap might grow. @@ -557,7 +554,7 @@ func (s *EtcdServer) processInternalRaftRequestOnce(ctx context.Context, r pb.In } ch := s.w.Register(id) - cctx, cancel := context.WithTimeout(ctx, maxV3RequestTimeout) + cctx, cancel := context.WithTimeout(ctx, s.Cfg.ReqTimeout()) defer cancel() start := time.Now()