|
|
@@ -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()
|