|
|
@@ -160,11 +160,18 @@ func (server *Server) postHandshakeChecks(peers map[enode.ID]*Peer, inboundCount
|
|
|
|
|
|
func (server *Server) launchPeer(c *conn) *Peer {
|
|
|
p := newPeer(c, server.Protocols)
|
|
|
- // ❌ 首先完成eth协议,封装在在eth/protocols/eth/handler.go
|
|
|
- // TODO 上一步先不做。干脆在实现peer功能过程中再来看,究竟是什么过程需要protocols?
|
|
|
+
|
|
|
+ gopool.Submit(func() {
|
|
|
+ server.runPeer(p)
|
|
|
+ })
|
|
|
+
|
|
|
return p
|
|
|
}
|
|
|
|
|
|
+func (server *Server) runPeer(p *Peer) {
|
|
|
+ // TODO 实现peer的细节
|
|
|
+}
|
|
|
+
|
|
|
func (server *Server) StopListener() {
|
|
|
<-server.sigs
|
|
|
|