Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-06-09 23:56:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add the Address of node to whom connected in log of send/receiveVersion (#1423)

Browse Source 
* Add the Address of node to whom connected in log of send/receiveVersion

* Don't call functions before LogAndMeasureExecutionTime

Co-authored-by: Ori Newman <orinewman1@gmail.com>
This commit is contained in:
Svarog 2021-01-17 16:31:48 +02:00 committed by GitHub
parent d4f3a252ff
commit 9a81b1328a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/protocol/flows/handshake/receiveversion.go
View File

@ -42,9 +42,11 @@ func ReceiveVersion(context HandleHandshakeContext, incomingRoute *router.Route,
} }
func (flow *receiveVersionFlow) start() (*appmessage.NetAddress, error) { func (flow *receiveVersionFlow) start() (*appmessage.NetAddress, error) {
onEnd := logger.LogAndMeasureExecutionTime(log, "receiveVersionFlow.start()") onEnd := logger.LogAndMeasureExecutionTime(log, "receiveVersionFlow.start")
defer onEnd() defer onEnd()
log.Debugf("Starting receiveVersionFlow with %s", flow.peer.Address())
message, err := flow.incomingRoute.DequeueWithTimeout(common.DefaultTimeout) message, err := flow.incomingRoute.DequeueWithTimeout(common.DefaultTimeout)
if err != nil { if err != nil {
return nil, err return nil, err

2
app/protocol/flows/handshake/sendversion.go
View File

@ -51,6 +51,8 @@ func (flow *sendVersionFlow) start() error {
onEnd := logger.LogAndMeasureExecutionTime(log, "sendVersionFlow.start") onEnd := logger.LogAndMeasureExecutionTime(log, "sendVersionFlow.start")
defer onEnd() defer onEnd()
log.Debugf("Starting sendVersionFlow with %s", flow.peer.Address())
// Version message. // Version message.
localAddress := flow.AddressManager().BestLocalAddress(flow.peer.Connection().NetAddress()) localAddress := flow.AddressManager().BestLocalAddress(flow.peer.Connection().NetAddress())
subnetworkID := flow.Config().SubnetworkID subnetworkID := flow.Config().SubnetworkID