Improve net debug

p2p/net/conn.go

@@ -224,6 +224,9 @@ func (c *FormattedConnection) sendListener() {
 	for {
 		select {
 		case m := <-c.messages:
+			c.logger.With().Debug("sending outgoing message",
+				log.String("requestID", m.reqID))
+
 			//todo: we are hiding the error here...
 			if err := c.SendSock(m.payload); err != nil {
 				c.logger.With().Error("cannot send message to peer",
@@ -249,6 +252,7 @@ func (c *FormattedConnection) Send(ctx context.Context, m []byte) error {
 	// try to extract a requestID from the context
 	reqID, _ := log.ExtractRequestID(ctx)
 
+	c.logger.WithContext(ctx).Debug("enqueuing outgoing message")
 	c.messages <- msgToSend{m, reqID}
 	return nil
 }

p2p/net/msgcon.go

@@ -148,6 +148,9 @@ func (c *MsgConnection) sendListener() {
 	for {
 		select {
 		case m := <-c.messages:
+			c.logger.With().Debug("sending outgoing message",
+				log.String("requestID", m.reqID))
+
 			//todo: we are hiding the error here...
 			if err := c.SendSock(m.payload); err != nil {
 				log.With().Error("cannot send message to peer",
@@ -172,6 +175,7 @@ func (c *MsgConnection) Send(ctx context.Context, m []byte) error {
 	// try to extract a requestID from the context
 	reqID, _ := log.ExtractRequestID(ctx)
 
+	c.logger.WithContext(ctx).Debug("enqueuing outgoing message")
 	c.messages <- msgToSend{m, reqID}
 	return nil
 }

p2p/switch.go

@@ -360,9 +360,8 @@ func (s *Switch) sendMessageImpl(ctx context.Context, peerPubKey p2pcrypto.Publi
 	}
 
 	conn, err = s.cPool.GetConnectionIfExists(peerPubKey)
-
 	if err != nil {
-		return errors.New("this peer isn't a neighbor or connection lost")
+		return fmt.Errorf("peer not a neighbor or connection lost: %v", err)
 	}
 
 	session := conn.Session()