diff --git a/p2p/server.go b/p2p/server.go index 51e0cd7ea3..e24df21a60 100644 --- a/p2p/server.go +++ b/p2p/server.go @@ -1021,14 +1021,12 @@ func (srv *Server) launchPeer(c *conn) *Peer { // to the peer. p.events = &srv.peerFeed } - srv.loopWG.Add(1) go srv.runPeer(p) return p } // runPeer runs in its own goroutine for each peer. func (srv *Server) runPeer(p *Peer) { - defer srv.loopWG.Done() if srv.newPeerHook != nil { srv.newPeerHook(p) }