)
func (m *monitor) connectNodesRoutine() {
- ticker := time.NewTicker(time.Duration(m.cfg.CheckFreqMinutes) * time.Minute)
+ // TODO: fix
+ // ticker := time.NewTicker(time.Duration(m.cfg.CheckFreqMinutes) * time.Minute)
+ ticker := time.NewTicker(time.Duration(m.cfg.CheckFreqMinutes) * time.Second)
for ; true; <-ticker.C {
<-m.dialCh
m.Lock()
return err
}
- log.Debugf("peerInfo ping: %v", peerInfo.Ping)
+ log.WithFields(log.Fields{"ping": peerInfo.Ping}).Debug("peerInfo")
ping, err := time.ParseDuration(peerInfo.Ping)
if err != nil {
return err