NewServer return a new p2pserver according to the pubkey
()
| 71 | |
| 72 | //NewServer return a new p2pserver according to the pubkey |
| 73 | func NewServer() *P2PServer { |
| 74 | n := netserver.NewNetServer() |
| 75 | |
| 76 | p := &P2PServer{ |
| 77 | network: n, |
| 78 | ledger: ledger.DefLedger, |
| 79 | } |
| 80 | |
| 81 | p.msgRouter = utils.NewMsgRouter(p.network) |
| 82 | p.blockSync = NewBlockSyncMgr(p) |
| 83 | p.recentPeers = make(map[uint32][]string) |
| 84 | p.quitSyncRecent = make(chan bool) |
| 85 | p.quitOnline = make(chan bool) |
| 86 | p.quitHeartBeat = make(chan bool) |
| 87 | return p |
| 88 | } |
| 89 | |
| 90 | //GetConnectionCnt return the established connect count |
| 91 | func (this *P2PServer) GetConnectionCnt() uint32 { |