|
|
@@ -92,9 +92,33 @@ func (server *Server) Start() (err error) {
|
|
|
// 配置拨号调度
|
|
|
server.setupDialScheduler()
|
|
|
|
|
|
+ // server核心允许
|
|
|
+ server.run()
|
|
|
+
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
+func (server *Server) run() {
|
|
|
+ server.loopWG.Add(1)
|
|
|
+
|
|
|
+ fmt.Printf("Started P2P networking, self: %v.", server.localnode.Node().URLv4())
|
|
|
+ defer server.loopWG.Done()
|
|
|
+ defer server.discmix.Close()
|
|
|
+ defer server.dialsched.stop()
|
|
|
+
|
|
|
+ //var (
|
|
|
+ // peers = make(map[enode.ID]*Peer)
|
|
|
+ // inboundCount = 0
|
|
|
+ //)
|
|
|
+running:
|
|
|
+ for {
|
|
|
+ select {
|
|
|
+ case <-server.quit:
|
|
|
+ break running
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
// 本地协议
|
|
|
func (server *Server) setupCaps() (err error) {
|
|
|
for _, capability := range params.Caps {
|
