@ -425,16 +425,18 @@ public class EthProtocolManager implements ProtocolManager, MinedBlockObserver {
final PeerConnection connection ,
final PeerConnection connection ,
final DisconnectReason reason ,
final DisconnectReason reason ,
final boolean initiatedByPeer ) {
final boolean initiatedByPeer ) {
if ( ethPeers . registerDisconnect ( connection ) ) {
final boolean wasActiveConnection = ethPeers . registerDisconnect ( connection ) ;
LOG . atDebug ( )
LOG . atDebug ( )
. setMessage ( "Disconnect - {} - {} - {} - {} peers left" )
. setMessage ( "Disconnect - active Connection? {} - {} - {} {} - {} {} - {} peers left" )
. addArgument ( initiatedByPeer ? "Inbound" : "Outbound" )
. addArgument ( wasActiveConnection )
. addArgument ( reason : : toString )
. addArgument ( initiatedByPeer ? "Inbound" : "Outbound" )
. addArgument ( ( ) - > connection . getPeer ( ) . getLoggableId ( ) )
. addArgument ( reason : : getValue )
. addArgument ( ethPeers : : peerCount )
. addArgument ( reason : : name )
. log ( ) ;
. addArgument ( ( ) - > connection . getPeer ( ) . getLoggableId ( ) )
LOG . atTrace ( ) . setMessage ( "{}" ) . addArgument ( ethPeers : : toString ) . log ( ) ;
. addArgument ( ( ) - > connection . getPeerInfo ( ) . getClientId ( ) )
}
. addArgument ( ethPeers : : peerCount )
. log ( ) ;
LOG . atTrace ( ) . setMessage ( "{}" ) . addArgument ( ethPeers : : toString ) . log ( ) ;
}
}
private void handleStatusMessage ( final EthPeer peer , final Message message ) {
private void handleStatusMessage ( final EthPeer peer , final Message message ) {