Kaynağa Gözat

Merge pull request #1542 from allencloud/change-reapNode-interval

update reapNode interval
Santhosh Manohar 8 yıl önce
ebeveyn
işleme
31dd4362a8
2 değiştirilmiş dosya ile 2 ekleme ve 2 silme
  1. 1 1
      libnetwork/controller.go
  2. 1 1
      libnetwork/networkdb/cluster.go

+ 1 - 1
libnetwork/controller.go

@@ -702,7 +702,7 @@ func (c *controller) NewNetwork(networkType, name string, id string, options ...
 	defer func() {
 		if err != nil {
 			if e := c.deleteFromStore(epCnt); e != nil {
-				log.Warnf("couldnt rollback from store, epCnt %v on failure (%v): %v", epCnt, err, e)
+				log.Warnf("could not rollback from store, epCnt %v on failure (%v): %v", epCnt, err, e)
 			}
 		}
 	}()

+ 1 - 1
libnetwork/networkdb/cluster.go

@@ -241,7 +241,7 @@ func (nDB *NetworkDB) reapDeadNode() {
 	defer nDB.Unlock()
 	for id, n := range nDB.failedNodes {
 		if n.reapTime > 0 {
-			n.reapTime -= reapPeriod
+			n.reapTime -= nodeReapPeriod
 			continue
 		}
 		logrus.Debugf("Removing failed node %v from gossip cluster", n.Name)