Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-10-14 00:59:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Change disconnect log level to INFO (#1549)

Browse Source 
* Change disconnect log level to INFO

* Add disconnected log and change log levels
This commit is contained in:
Ori Newman 2021-02-23 13:52:47 +02:00 committed by GitHub
parent bee0893660
commit 9ffda2b1da
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/protocol/protocol.go
View File

@ -89,7 +89,7 @@ func (m *Manager) handleError(err error, netConnection *netadapter.NetConnection
panic(err) panic(err)
} }
} }
log.Debugf("Disconnecting from %s (reason: %s)", netConnection, protocolErr.Cause) log.Infof("Disconnecting from %s (reason: %s)", netConnection, protocolErr.Cause)
netConnection.Disconnect() netConnection.Disconnect()
return return
} }

1
infrastructure/network/netadapter/netconnection.go
View File

@ -29,6 +29,7 @@ func newNetConnection(connection server.Connection, routerInitializer RouterInit
} }
netConnection.connection.SetOnDisconnectedHandler(func() { netConnection.connection.SetOnDisconnectedHandler(func() {
log.Infof("Disconnected from %s", netConnection)
// If the disconnection came because of a network error and not because of the application layer, we // If the disconnection came because of a network error and not because of the application layer, we
// need to close the router as well. // need to close the router as well.
if atomic.AddUint32(&netConnection.isRouterClosed, 1) == 1 { if atomic.AddUint32(&netConnection.isRouterClosed, 1) == 1 {

2
infrastructure/network/netadapter/server/grpcserver/p2pserver.go
View File

@ -37,7 +37,7 @@ func (p *p2pServer) MessageStream(stream protowire.P2P_MessageStreamServer) erro
// Connect connects to the given address // Connect connects to the given address
// This is part of the P2PServer interface // This is part of the P2PServer interface
func (p *p2pServer) Connect(address string) (server.Connection, error) { func (p *p2pServer) Connect(address string) (server.Connection, error) {
log.Infof("%s Dialing to %s", p.name, address) log.Debugf("%s Dialing to %s", p.name, address)
const dialTimeout = 30 * time.Second const dialTimeout = 30 * time.Second
ctx, cancel := context.WithTimeout(context.Background(), dialTimeout) ctx, cancel := context.WithTimeout(context.Background(), dialTimeout)