diff --git a/app/protocol/flows/handshake/receiveversion.go b/app/protocol/flows/handshake/receiveversion.go index f3357dab1..fc2c5a87b 100644 --- a/app/protocol/flows/handshake/receiveversion.go +++ b/app/protocol/flows/handshake/receiveversion.go @@ -42,9 +42,11 @@ func ReceiveVersion(context HandleHandshakeContext, incomingRoute *router.Route, } func (flow *receiveVersionFlow) start() (*appmessage.NetAddress, error) { - onEnd := logger.LogAndMeasureExecutionTime(log, "receiveVersionFlow.start()") + onEnd := logger.LogAndMeasureExecutionTime(log, "receiveVersionFlow.start") defer onEnd() + log.Debugf("Starting receiveVersionFlow with %s", flow.peer.Address()) + message, err := flow.incomingRoute.DequeueWithTimeout(common.DefaultTimeout) if err != nil { return nil, err diff --git a/app/protocol/flows/handshake/sendversion.go b/app/protocol/flows/handshake/sendversion.go index a98c8568d..dcd4ce602 100644 --- a/app/protocol/flows/handshake/sendversion.go +++ b/app/protocol/flows/handshake/sendversion.go @@ -51,6 +51,8 @@ func (flow *sendVersionFlow) start() error { onEnd := logger.LogAndMeasureExecutionTime(log, "sendVersionFlow.start") defer onEnd() + log.Debugf("Starting sendVersionFlow with %s", flow.peer.Address()) + // Version message. localAddress := flow.AddressManager().BestLocalAddress(flow.peer.Connection().NetAddress()) subnetworkID := flow.Config().SubnetworkID