Browse Source

etcdserver/corrupt: set dial timeout for peer clientv3

Preliminary commit for initial hash checking.
Dial timeout when other nodes have not been booted.

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
Gyu-Ho Lee 8 years ago
parent
commit
f6f0fb12e0
1 changed files with 5 additions and 1 deletions
  1. 5 1
      etcdserver/corrupt.go

+ 5 - 1
etcdserver/corrupt.go

@@ -56,8 +56,12 @@ func (s *EtcdServer) checkHashKV() error {
 			continue
 		}
 
-		cli, cerr := clientv3.New(clientv3.Config{Endpoints: m.PeerURLs})
+		cli, cerr := clientv3.New(clientv3.Config{
+			DialTimeout: s.Cfg.ReqTimeout(),
+			Endpoints:   m.PeerURLs,
+		})
 		if cerr != nil {
+			plog.Warningf("%s failed to create client to peer %s for hash checking (%v)", s.ID(), types.ID(m.ID), cerr)
 			continue
 		}