diff --git a/network/network.go b/network/network.go index fd2c955be..3a372b808 100644 --- a/network/network.go +++ b/network/network.go @@ -252,7 +252,7 @@ func (n *network) SendTo(msg []byte, pid lp2pcore.PeerID) error { } func (n *network) Broadcast(msg []byte, topicID TopicID) error { - n.logger.Debug("publishing new message", "topic", topicID) + n.logger.Trace("publishing new message", "topic", topicID) switch topicID { case TopicIDGeneral: if n.generalTopic == nil { diff --git a/network/notifee.go b/network/notifee.go index 9a7d02eb3..28e146ed1 100644 --- a/network/notifee.go +++ b/network/notifee.go @@ -30,6 +30,7 @@ func newNotifeeService(host lp2phost.Host, eventChannel chan<- Event, func (n *NotifeeService) Connected(lp2pn lp2pnetwork.Network, conn lp2pnetwork.Conn) { peerID := conn.RemotePeer() + n.logger.Info("connected to peer", "pid", peerID) go func() { for i := 0; i < 10; i++ { @@ -39,9 +40,7 @@ func (n *NotifeeService) Connected(lp2pn lp2pnetwork.Network, conn lp2pnetwork.C protocols, _ := lp2pn.Peerstore().SupportsProtocols(peerID, n.protocolID) if len(protocols) > 0 { - n.logger.Info("connected to peer", "pid", peerID) n.eventChannel <- &ConnectEvent{PeerID: peerID} - return } }