diff --git a/netadapter/server/grpcserver/connection_loops.go b/netadapter/server/grpcserver/connection_loops.go
index 2b49a6e46..c2369fee9 100644
--- a/netadapter/server/grpcserver/connection_loops.go
+++ b/netadapter/server/grpcserver/connection_loops.go
@@ -41,6 +41,7 @@ func (c *gRPCConnection) sendLoop() error {
 			return err
 		}
 
+		log.Debugf("outgoing '%s' message to %s", message.Command(), c)
 		log.Tracef("outgoing '%s' message to %s: %s", message.Command(), c, logger.NewLogClosure(func() string {
 			return spew.Sdump(message)
 		}))
@@ -74,6 +75,7 @@ func (c *gRPCConnection) receiveLoop() error {
 			return err
 		}
 
+		log.Debugf("incoming '%s' message from %s", message.Command(), c)
 		log.Tracef("incoming '%s' message from %s: %s", message.Command(), c, logger.NewLogClosure(func() string {
 			return spew.Sdump(message)
 		}))
diff --git a/protocol/flowcontext/ibd.go b/protocol/flowcontext/ibd.go
index 068427572..75812d6af 100644
--- a/protocol/flowcontext/ibd.go
+++ b/protocol/flowcontext/ibd.go
@@ -25,7 +25,7 @@ func (f *FlowContext) StartIBDIfRequired() {
 
 	atomic.StoreUint32(&f.isInIBD, 1)
 	f.ibdPeer = peer
-	peer.StartIBD()
+	spawn("StartIBDIfRequired-peer.StartIBD", peer.StartIBD)
 }
 
 // IsInIBD is true if IBD is currently running
diff --git a/protocol/flowcontext/log.go b/protocol/flowcontext/log.go
index 5d415723f..66936bfc1 100644
--- a/protocol/flowcontext/log.go
+++ b/protocol/flowcontext/log.go
@@ -2,6 +2,8 @@ package flowcontext
 
 import (
 	"github.com/kaspanet/kaspad/logger"
+	"github.com/kaspanet/kaspad/util/panics"
 )
 
 var log, _ = logger.Get(logger.SubsystemTags.PROT)
+var spawn = panics.GoroutineWrapperFunc(log)