Fix transport manager data race

skycoin · Dec 12, 2019 · b5f049d · b5f049d
1 parent 8fe511b
commit b5f049d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/transport/manager.go b/pkg/transport/manager.go
@@ -82,6 +82,10 @@ func (tm *Manager) serve(ctx context.Context) {
 		tm.Logger.Infof("listening on network: %s", netType)
 		listeners = append(listeners, lis)
 
+		if tm.isClosing() {
+			return
+		}
+
 		tm.wg.Add(1)
 		go func() {
 			defer tm.wg.Done()
@@ -298,6 +302,7 @@ func (tm *Manager) close() {
 	}
 
 	tm.wg.Wait()
+
 	close(tm.readCh)
 }