|
@@ -124,7 +124,7 @@ running:
|
|
|
break running
|
|
break running
|
|
|
case c := <-server.checkpointPostHandshake:
|
|
case c := <-server.checkpointPostHandshake:
|
|
|
p := server.launchPeer(c)
|
|
p := server.launchPeer(c)
|
|
|
- fmt.Printf("launchPeer: %v\n", p.rw.name)
|
|
|
|
|
|
|
+ fmt.Printf("launchPeer: %v\n", p.rw.node.IP())
|
|
|
case c := <-server.checkpointAddPeer:
|
|
case c := <-server.checkpointAddPeer:
|
|
|
fmt.Printf("checkpointAddPeer: %v.\n", c.name)
|
|
fmt.Printf("checkpointAddPeer: %v.\n", c.name)
|
|
|
}
|
|
}
|
|
@@ -133,7 +133,8 @@ running:
|
|
|
|
|
|
|
|
func (server *Server) launchPeer(c *conn) *Peer {
|
|
func (server *Server) launchPeer(c *conn) *Peer {
|
|
|
p := newPeer(c, server.Protocols)
|
|
p := newPeer(c, server.Protocols)
|
|
|
- // TODO 首先完成eth协议,封装在在eth/protocols/eth/handler.go
|
|
|
|
|
|
|
+ // ❌ 首先完成eth协议,封装在在eth/protocols/eth/handler.go
|
|
|
|
|
+ // TODO 上一步先不做。干脆在实现peer功能过程中再来看,究竟是什么过程需要protocols?
|
|
|
return p
|
|
return p
|
|
|
}
|
|
}
|
|
|
|
|
|