diff options
Diffstat (limited to 'src/Ivy.java')
| -rwxr-xr-x | src/Ivy.java | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/src/Ivy.java b/src/Ivy.java index b147af3..2196321 100755 --- a/src/Ivy.java +++ b/src/Ivy.java @@ -15,6 +15,9 @@ *</pre> * * CHANGELOG: + * 1.2.15 + * - allows the fine tuning of the IvyClient socket buffersize using + * IVY_BUFFERSIZE property * 1.2.14 * - added a lock mechanism to be sure that once a connexion has been * initiated, the ready message will be sent before stopping the bus @@ -138,6 +141,14 @@ public class Ivy implements Runnable { * the port for the UDP rendez vous, if none is supplied. */ public static final int DEFAULT_PORT = 2010; + + /** + * the default size of the IvyClients' socket buffer + * defaults to 4096, can be adjusted through the use of IVY_BUFFERSIZE JVM + * property + */ + + private static final int PREFFERREDBUFFERSIZE = 4096; // in bytes /** * the domain for the UDP rendez vous. */ @@ -146,13 +157,14 @@ public class Ivy implements Runnable { * the library version, useful for development purposes only, when java is * invoked with -DIVY_DEBUG */ - public static final String LIBVERSION ="1.2.14"; + public static final String LIBVERSION ="1.2.15"; public static final int TIMEOUTLENGTH = 1000; private String appName; private int applicationPort; /* Application port number */ private String ready_message = null; private boolean doProtectNewlines = false; + private int bufferSize = PREFFERREDBUFFERSIZE ; private SelfIvyClient selfIvyClient; private Object lockApp = new Object(); private boolean debug; @@ -196,6 +208,8 @@ public class Ivy implements Runnable { debug = (System.getProperty("IVY_DEBUG") != null) || (System.getProperty("IVY_DEBUG") != null); + if (System.getProperty("IVY_BUFFERSIZE") != null) + bufferSize = Integer.parseInt(System.getProperty("IVY_BUFFERSIZE")); if ( appcb != null ) { ivyApplicationListenerList.addElement( appcb ); } @@ -940,6 +954,8 @@ public class Ivy implements Runnable { } protected String getWatcherId() { return watcherId; } + protected int getBufferSize() { return bufferSize; } + protected int getSerial() { return myserial; } private void traceDebug(String s){ if (debug) System.out.println("-->Ivy[" + myserial + "]<-- " + s); |