Logging

eth/protocols/eth/handlers.go

@@ -244,6 +244,11 @@ func handleGetBTCBlocks(backend Backend, msg Decoder, peer *Peer) error {
 		return fmt.Errorf("%w: message %v: %v", errDecode, msg, err)
 	}
 	response := ServiceGetBTCBlocksQuery(backend.Chain(), query.GetBTCBlocksRequest)
+
+	for i := 0; i < len(response); i++ {
+		log.Info(fmt.Sprintf("BTC response[%d] length: %d", i, len(response[i])))
+	}
+
 	return peer.ReplyBTCBlocksRLP(query.RequestId, response)
 }
 

p2p/message.go

@@ -20,6 +20,7 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
+	"github.com/ethereum/go-ethereum/log"
 	"io"
 	"sync/atomic"
 	"time"
@@ -101,6 +102,7 @@ func Send(w MsgWriter, msgcode uint64, data interface{}) error {
 	if err != nil {
 		return err
 	}
+	log.Info("Sending bytes to peer", "bytes", size)
 	return w.WriteMsg(Msg{Code: msgcode, Size: uint32(size), Payload: r})
 }