|
|
@@ -92,7 +92,7 @@ func (server *Server) Start() (err error) {
|
|
|
// 配置拨号调度
|
|
|
server.setupDialScheduler()
|
|
|
|
|
|
- // server核心允许
|
|
|
+ // server核心运行
|
|
|
server.run()
|
|
|
|
|
|
return nil
|
|
|
@@ -114,6 +114,8 @@ running:
|
|
|
for {
|
|
|
select {
|
|
|
case <-server.quit:
|
|
|
+ fmt.Printf("exit signal by user.\n")
|
|
|
+
|
|
|
break running
|
|
|
}
|
|
|
}
|
|
|
@@ -283,7 +285,7 @@ func (server *Server) setupListening() (err error) {
|
|
|
server.loopWG.Add(1)
|
|
|
|
|
|
gopool.Submit(func() {
|
|
|
- nat.Map(server.NAT, server.quit, "tcp", tcp.Port, tcp.Port, "ethereum p2p")
|
|
|
+ nat.Map(server.NAT, server.quit, "tcp", tcp.Port, tcp.Port, "blockchain-p2p")
|
|
|
|
|
|
server.loopWG.Done()
|
|
|
})
|