start mdns service when new

33cn · Sep 13, 2023 · fa0e210 · fa0e210
1 parent cc83394
commit fa0e210
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/system/p2p/dht/extension/mdns.go b/system/p2p/dht/extension/mdns.go
@@ -30,6 +30,11 @@ func NewMDNS(ctx context.Context, peerhost host.Host, serviceTag string) (*MDNS,
 	notifee := &discoveryNotifee{}
 	notifee.PeerChan = make(chan peer.AddrInfo, 1)
 	ser := discovery.NewMdnsService(peerhost, serviceTag, notifee)
+	err := ser.Start()
+	if err != nil {
+		log.Error("NewMDNS", "start mdns service err", err)
+		return nil, err
+	}
 	mnds := new(MDNS)
 	mnds.Service = ser
 	mnds.notifee = notifee

diff --git a/system/p2p/dht/extension/mdns_test.go b/system/p2p/dht/extension/mdns_test.go
@@ -14,12 +14,8 @@ func Test_mdns(t *testing.T) {
 	hosts := getNetHosts(2, t)
 	tmdns, err := NewMDNS(ctx, hosts[0], "33test123")
 	require.Nil(t, err)
-	require.Nil(t, tmdns.Service.Start())
-	//_, err = NewMDNS(ctx, hosts[1], "33test123")
-	//require.Nil(t, err)
 	tmdns, err = NewMDNS(ctx, hosts[1], "33test123")
 	require.Nil(t, err)
-	require.Nil(t, tmdns.Service.Start())
 
 	select {
 	case peerinfo := <-tmdns.PeerChan():