-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Refuse connection from ips that are already in processing queue #1082
Conversation
@@ -115,6 +92,43 @@ public void initChannel(NioSocketChannel ch) throws Exception { | |||
logger.error("Unexpected error: ", e); | |||
} | |||
} | |||
|
|||
private boolean shouldRefuseIncoming(NioSocketChannel ch) { | |||
if(!isInbound()) return false; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it's better to check it outside
@@ -115,6 +92,43 @@ public void initChannel(NioSocketChannel ch) throws Exception { | |||
logger.error("Unexpected error: ", e); | |||
} | |||
} | |||
|
|||
private boolean shouldRefuseIncoming(NioSocketChannel ch) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe something like isEligibleForConnection
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i like it!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
almost )
* @param peerAddr Peer address | ||
* @return true if we already have connection from this address, otherwise false | ||
*/ | ||
public boolean ipAlreadyWaiting(InetAddress peerAddr) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
isAddressInQueue
?
@mkalinin please, take a look