mirrors/ipscan
2
0
Fork 0
mirror of https://github.com/angryip/ipscan.git synced 2025-10-26 11:18:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

TCPPinger now implements some workarounds for buggy JVMs (GCJ & Mac in particular)

Browse Source 
git-svn-id: https://ipscan.svn.sourceforge.net/svnroot/ipscan/trunk@402 375186e5-ef17-0410-b0b6-91563547dcda
This commit is contained in:
angryziber 2008-04-14 20:08:33 +00:00
parent 292fb95513
commit e70a48194a
2 changed files with 39 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/net/azib/ipscan/core/net/TCPPinger.java
View File

@ -25,7 +25,7 @@ public class TCPPinger implements Pinger {
static final Logger LOG = Logger.getLogger(TCPPinger.class.getName());
// try different ports in sequence, starting with 80 (which is most probably not filtered)
private static final int[] PROBE_TCP_PORTS = {80, 80, 443, 22, 7, 8080};
private static final int[] PROBE_TCP_PORTS = {80, 80, 443, 8080, 22, 7};
private int timeout;
@ -40,28 +40,33 @@ public class TCPPinger implements Pinger {
for (int i = 0; i < count && !Thread.currentThread().isInterrupted(); i++) {
Socket socket = new Socket();
long startTime = System.currentTimeMillis();
try {
// cycle through different ports until a working one is found
int probePort = workingPort >= 0 ? workingPort : PROBE_TCP_PORTS[i % PROBE_TCP_PORTS.length];
// set some optimization options
socket.setReuseAddress(true);
socket.setReceiveBufferSize(32);
socket.connect(new InetSocketAddress(address, probePort), timeout);
socket.connect(new InetSocketAddress(address, probePort), timeout);
if (socket.isConnected()) {
result.addReply(System.currentTimeMillis()-startTime);
// one positive result is enough for TCP
result.enableTimeoutAdaptation();
socket.setTcpNoDelay(true);
// some Java implementations (e.g. GNU and Mac) can erroneously report connections
// when there really are no successful connections made :-(
// let's try to send something to ensure that connection is really established
socket.getOutputStream().write(13);
// it worked - success
success(result, startTime);
// it worked! - remember the current port
workingPort = probePort;
}
}
catch (ConnectException e) {
// we've got an RST packet from the host - it is alive
result.addReply(System.currentTimeMillis()-startTime);
result.enableTimeoutAdaptation();
success(result, startTime);
}
catch (SocketTimeoutException e) {
}
@ -70,7 +75,21 @@ public class TCPPinger implements Pinger {
break;
}
catch (IOException e) {
LOG.log(Level.FINER, address.toString(), e);
// RST should result in the ConnectException, but not all Java implementations respect that
if (e.getMessage().contains(/*Connection*/"refused")) {
// we've got an RST packet from the host - it is alive
success(result, startTime);
}
else
// this should result in a NoRouteToHostException, but not all Java implementation respect that
if (e.getMessage().contains(/*No*/"route to host")) {
// host is down
break;
}
else {
// something unknown
LOG.log(Level.FINER, address.toString(), e);
}
}
finally {
try {
@ -82,6 +101,12 @@ public class TCPPinger implements Pinger {
return result;
}
private void success(PingResult result, long startTime) {
result.addReply(System.currentTimeMillis()-startTime);
// one positive result is enough for TCP
result.enableTimeoutAdaptation();
}
public void close() throws IOException {
// nothing to do here

6
src/net/azib/ipscan/core/net/UDPPinger.java
View File

@ -57,8 +57,10 @@ public class UDPPinger implements Pinger {
break;
}
catch (SocketException e) {
// TODO: this may also mean that the host is down
// however, sometimes 'No route to host' also gets here...
if (e.getMessage().contains(/*No*/"route to host")) {
// sometimes 'No route to host' also gets here...
break;
}
}
catch (IOException e) {
LOG.log(Level.FINER, address.toString(), e);