addresses = append(addresses, address)
}
+ // TODO: add start time here
// connected peers will be skipped in switch.DialPeers()
m.sw.DialPeers(addresses)
log.Info("DialPeers done.")
if n, ok := nodeMap[node.ID.String()]; ok && n.String() == node.String() {
continue
}
- log.Info("discover new node: ", node)
+ log.Infof("discover new node: %v", node)
if err := m.upSertNode(&config.Node{
PublicKey: node.ID.String(),
}
for label, reactor := range m.sw.GetReactors() {
- log.Debug("start reactor: (%s:%v)", label, reactor)
+ log.Debugf("start reactor: (%s:%v)", label, reactor)
if _, err := reactor.Start(); err != nil {
return nil
}