@@ -398,8 +398,8 @@ func TestP2PNetworkAddress(t *testing.T) {
398398 cfg := config .GetDefaultLocal ()
399399 log := logging .TestingLog (t )
400400 netA , err := NewP2PNetwork (log , cfg , "" , nil , GenesisInfo {genesisID , config .Devtestnet }, & nopeNodeInfo {}, nil , nil )
401- defer netA .Stop ()
402401 require .NoError (t , err )
402+ defer netA .Stop ()
403403 addrInfo := netA .service .AddrInfo ()
404404 // close the real service since we will substitute a mock one
405405 netA .service .Close ()
@@ -801,6 +801,8 @@ func TestP2PHTTPHandler(t *testing.T) {
801801 // zero clients allowed, rate limiting window (10s) is greater than queue deadline (1s)
802802 netB , err := NewP2PNetwork (log , cfg , "" , nil , GenesisInfo {genesisID , config .Devtestnet }, & nopeNodeInfo {}, nil , nil )
803803 require .NoError (t , err )
804+ defer netB .Stop () // even though netB.Start is not called, NewP2PNetwork creates goroutines to stop
805+
804806 pstore , err := peerstore .MakePhonebook (0 , 10 * time .Second )
805807 require .NoError (t , err )
806808 pstore .AddPersistentPeers ([]* peer.AddrInfo {& peerInfoA }, "net" , phonebook .RelayRole )
@@ -1426,6 +1428,7 @@ func TestP2PTxTopicValidator_NoWsPeer(t *testing.T) {
14261428
14271429 net , err := NewP2PNetwork (log , cfg , "" , nil , GenesisInfo {genesisID , config .Devtestnet }, & nopeNodeInfo {}, nil , nil )
14281430 require .NoError (t , err )
1431+ defer net .Stop ()
14291432
14301433 peerID := peer .ID ("12345678" ) // must be 8+ in size
14311434 msg := pubsub.Message {Message : & pb.Message {}, ID : string (peerID )}
@@ -1455,6 +1458,7 @@ func TestGetPeersFiltersSelf(t *testing.T) {
14551458
14561459 net , err := NewP2PNetwork (log , cfg , t .TempDir (), []string {}, GenesisInfo {"test-genesis" , "test-network" }, & nopeNodeInfo {}, nil , nil )
14571460 require .NoError (t , err )
1461+ defer net .Stop ()
14581462 selfID := net .service .ID ()
14591463
14601464 // Create and add self
0 commit comments