p2p/server : not deal with run peer goroutines in mainloop wg

This commit is contained in:
ucwong 2020-04-01 13:45:11 +00:00
parent c786a726ff
commit a2af3d5a73

View file

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