p2p/server : make sure slot release finally, but main loop wg

This commit is contained in:
ucwong 2020-04-01 14:21:11 +00:00
parent a2af3d5a73
commit f12380fa7e

View file

@ -885,12 +885,12 @@ func (srv *Server) listenLoop() {
fd = newMeteredConn(fd, true, addr) fd = newMeteredConn(fd, true, addr)
srv.log.Trace("Accepted connection", "addr", fd.RemoteAddr()) srv.log.Trace("Accepted connection", "addr", fd.RemoteAddr())
} }
srv.loopWG.Add(1)
go func() { go func() {
defer srv.loopWG.Done() defer func() {
srv.SetupConn(fd, inboundConn, nil)
slots <- struct{}{} slots <- struct{}{}
}() }()
srv.SetupConn(fd, inboundConn, nil)
}()
} }
} }