"os/user"
"strings"
"sync"
- // "time"
"github.com/jinzhu/gorm"
log "github.com/sirupsen/logrus"
"github.com/vapor/event"
"github.com/vapor/netsync/chainmgr"
"github.com/vapor/netsync/consensusmgr"
- "github.com/vapor/p2p"
- // msgs "github.com/vapor/netsync/messages"
"github.com/vapor/netsync/peers"
+ "github.com/vapor/p2p"
"github.com/vapor/p2p/discover/dht"
"github.com/vapor/p2p/discover/mdns"
"github.com/vapor/p2p/signlib"
log.Info("bestHeight: ", bestHeight)
m.processPeerInfos(peers.GetPeerInfos())
- // TODO:
- // msg := struct{ msgs.BlockchainMessage }{&msgs.GetBlockMessage{Height: bestHeight + 1}}
- // for _, peer := range m.sw.GetPeers().List() {
- // peers.SendMsg(peer.ID(), msgs.BlockchainChannel, msg)
- // }
-
for _, peer := range m.sw.GetPeers().List() {
p := peers.GetPeer(peer.ID())
if p == nil {