Procházet zdrojové kódy

etcdserver: improve error message when timeout due to leader fail

Yicheng Qin před 10 roky
rodič
revize
c229e6e655
3 změnil soubory, kde provedl 3 přidání a 3 odebrání
  1. 1 1
      etcdserver/errors.go
  2. 1 1
      etcdserver/etcdhttp/http.go
  3. 1 1
      etcdserver/server.go

+ 1 - 1
etcdserver/errors.go

@@ -29,7 +29,7 @@ var (
 	ErrPeerURLexists          = errors.New("etcdserver: peerURL exists")
 	ErrCanceled               = errors.New("etcdserver: request cancelled")
 	ErrTimeout                = errors.New("etcdserver: request timed out")
-	ErrTimeoutDueToLeaderLost = errors.New("etcdserver: request timed out, possibly due to leader lost")
+	ErrTimeoutDueToLeaderFail = errors.New("etcdserver: request timed out, possibly due to previous leader failure")
 )
 
 func isKeyNotFound(err error) bool {

+ 1 - 1
etcdserver/etcdhttp/http.go

@@ -54,7 +54,7 @@ func writeError(w http.ResponseWriter, err error) {
 		herr := httptypes.NewHTTPError(e.HTTPStatus(), e.Error())
 		herr.WriteTo(w)
 	default:
-		if err == etcdserver.ErrTimeoutDueToLeaderLost {
+		if err == etcdserver.ErrTimeoutDueToLeaderFail {
 			plog.Error(err)
 		} else {
 			plog.Errorf("got unexpected response error (%v)", err)

+ 1 - 1
etcdserver/server.go

@@ -1022,7 +1022,7 @@ func (s *EtcdServer) parseProposeCtxErr(err error, start time.Time) error {
 		curLeadElected := s.r.leadElectedTime()
 		prevLeadLost := curLeadElected.Add(-2 * time.Duration(s.cfg.ElectionTicks) * time.Duration(s.cfg.TickMs) * time.Millisecond)
 		if start.After(prevLeadLost) && start.Before(curLeadElected) {
-			return ErrTimeoutDueToLeaderLost
+			return ErrTimeoutDueToLeaderFail
 		}
 		return ErrTimeout
 	default: