diff options
Diffstat (limited to 'src/IvyWatcher.java')
-rwxr-xr-x | src/IvyWatcher.java | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/IvyWatcher.java b/src/IvyWatcher.java index c9a661f..b95af97 100755 --- a/src/IvyWatcher.java +++ b/src/IvyWatcher.java @@ -190,13 +190,13 @@ class IvyWatcher implements Runnable { Matcher m = recoucou.matcher(msg); // is it a correct broadcast packet ? if (!m.matches()) { - System.err.println("Ignoring bad format broadcast from "+ remotehostname+":"+packet.getPort()); + System.err.println("nomatch - Ignoring bad format broadcast from "+ remotehostname+":"+packet.getPort()+" ["+msg+"]"); return true; } // is it the correct protocol version ? int version = Integer.parseInt(m.group(1)); if ( version < Protocol.PROTOCOLMINIMUM ) { - System.err.println("Ignoring bad format broadcast from "+ + System.err.println("too old - Ignoring bad format broadcast from "+ remotehostname+":"+packet.getPort() +" protocol version "+remotehost+" we need "+Protocol.PROTOCOLMINIMUM+" minimum"); return true; @@ -242,8 +242,6 @@ class IvyWatcher implements Runnable { traceDebug("no known agent originating from " + remotehost + ":" + remotePort); try { Socket s = new Socket(remotehost,remotePort); - s.setReceiveBufferSize(bus.getBufferSize()); - s.setTcpNoDelay(true); if (!bus.createIvyClient(s,remotePort,false)) return false ; } catch ( java.net.ConnectException jnc ) { traceDebug("cannot connect to "+remotehostname+":"+remotePort+", he probably stopped his bus"); @@ -252,7 +250,7 @@ class IvyWatcher implements Runnable { traceDebug("there is already a request originating from " + remotehost + ":" + remotePort); } } catch (NumberFormatException nfe) { - System.err.println("Ignoring bad format broadcast from "+remotehostname); + System.err.println("nfe: Ignoring bad format broadcast from "+remotehostname); return true; } catch ( UnknownHostException e ) { System.err.println("Unkonwn host "+remotehost +","+e.getMessage()); |