Costmetic fixes.

Author: js-labs

src/main/java/org/jsl/collider/DatagramListener.java

@@ -32,7 +32,7 @@ public abstract class DatagramListener
     public int forwardReadMaxSize;
     public int readMinSize;
 
-    public DatagramListener( InetSocketAddress addr )
+    public DatagramListener(InetSocketAddress addr)
     {
         m_addr = addr;
 
@@ -48,5 +48,5 @@ public InetSocketAddress getAddr()
         return m_addr;
     }
 
-    public abstract void onDataReceived( RetainableByteBuffer data, SocketAddress sourceAddr );
+    public abstract void onDataReceived(RetainableByteBuffer data, SocketAddress sourceAddr);
 }

src/main/java/org/jsl/collider/DatagramListenerImpl.java

@@ -481,7 +481,7 @@ public void stopAndWait() throws InterruptedException
                             m_lock.lock();
                             try
                             {
-                                assert( m_run );
+                                assert(m_run);
                                 m_run = false;
                                 m_cond.signalAll();
                             }
@@ -494,7 +494,7 @@ public void stopAndWait() throws InterruptedException
                         }
                         else
                         {
-                            m_collider.executeInSelectorThread( new Stopper() );
+                            m_collider.executeInSelectorThread(new Stopper());
                             break;
                         }
                     }

src/main/java/org/jsl/collider/RetainableByteBuffer.java

@@ -148,8 +148,8 @@ public final boolean clearSafe()
      * NIO ByteBuffer interface mimic.
      */
 
-    ByteOrder order() { return m_buf.order(); }
-    RetainableByteBuffer order(ByteOrder byteOrder) { m_buf.order(byteOrder); return this; }
+    public ByteOrder order() { return m_buf.order(); }
+    public RetainableByteBuffer order(ByteOrder byteOrder) { m_buf.order(byteOrder); return this; }
 
     public abstract int capacity();
     public abstract RetainableByteBuffer clear();
@@ -186,29 +186,32 @@ public final RetainableByteBuffer slice()
         return new Slice(m_buf.slice(), this);
     }
 
-    public abstract byte get( int index );
-    public abstract RetainableByteBuffer put( int index, byte value );
+    public abstract byte get(int index);
+    public abstract RetainableByteBuffer put(int index, byte value);
 
-    public abstract int getInt( int index );
-    public abstract RetainableByteBuffer putInt( int index, int value );
+    public abstract short getShort(int index);
+    public abstract RetainableByteBuffer putShort(int index, short value);
 
-    public abstract short getShort( int index );
-    public abstract RetainableByteBuffer putShort( int index, short value );
+    public abstract int getInt(int index);
+    public abstract RetainableByteBuffer putInt(int index, int value);
 
-    public abstract float getFloat( int index );
-    public abstract RetainableByteBuffer putFloat( int index, float value );
+    public abstract long getLong(int index);
+    public abstract RetainableByteBuffer putLong(int index, long value);
 
-    public abstract double getDouble( int index );
-    public abstract RetainableByteBuffer putDouble( int index, double value );
+    public abstract float getFloat(int index);
+    public abstract RetainableByteBuffer putFloat(int index, float value);
+
+    public abstract double getDouble(int index);
+    public abstract RetainableByteBuffer putDouble(int index, double value);
 
     public final byte get()
     {
         return m_buf.get();
     }
 
-    public final RetainableByteBuffer get( ByteBuffer dst )
+    public final RetainableByteBuffer get(ByteBuffer dst)
     {
-        dst.put( m_buf );
+        dst.put(m_buf);
         return this;
     }
 
@@ -223,9 +226,9 @@ public final RetainableByteBuffer get( byte [] dst, int offset, int length )
         return this;
     }
 
-    public final RetainableByteBuffer put( byte value )
+    public final RetainableByteBuffer put(byte value)
     {
-        m_buf.put( value );
+        m_buf.put(value);
         return this;
     }
 
@@ -246,15 +249,26 @@ public final RetainableByteBuffer put( byte [] src )
         return put( src, 0, src.length );
     }
 
-    public final RetainableByteBuffer put( byte [] src, int offset, int length )
+    public final RetainableByteBuffer put(byte [] src, int offset, int length)
+    {
+        m_buf.put(src, offset, length);
+        return this;
+    }
+
+    public final RetainableByteBuffer putShort(short value)
     {
-        m_buf.put( src, offset, length );
+        m_buf.putShort(value);
         return this;
     }
 
-    public final RetainableByteBuffer putInt( int value )
+    public final short getShort()
+    {
+        return m_buf.getShort();
+    }
+
+    public final RetainableByteBuffer putInt(int value)
     {
-        m_buf.putInt( value );
+        m_buf.putInt(value);
         return this;
     }
 
@@ -263,15 +277,15 @@ public final int getInt()
         return m_buf.getInt();
     }
 
-    public final RetainableByteBuffer putShort( short value )
+    public final RetainableByteBuffer putLong(long value)
     {
-        m_buf.putShort( value );
+        m_buf.putLong(value);
         return this;
     }
 
-    public final short getShort()
+    public final long getLong()
     {
-        return m_buf.getShort();
+        return m_buf.getLong();
     }
 
     public final RetainableByteBuffer putFloat( float value )
@@ -296,15 +310,15 @@ public final double getDouble()
         return m_buf.getDouble();
     }
 
-    public static RetainableByteBuffer allocate( int capacity )
+    public static RetainableByteBuffer allocate(int capacity)
     {
-        final ByteBuffer byteBuffer = ByteBuffer.allocate( capacity );
-        return new Impl( byteBuffer );
+        final ByteBuffer byteBuffer = ByteBuffer.allocate(capacity);
+        return new Impl(byteBuffer);
     }
 
-    public static RetainableByteBuffer allocateDirect( int capacity )
+    public static RetainableByteBuffer allocateDirect(int capacity)
     {
-        final ByteBuffer byteBuffer = ByteBuffer.allocateDirect( capacity );
-        return new Impl( byteBuffer );
+        final ByteBuffer byteBuffer = ByteBuffer.allocateDirect(capacity);
+        return new Impl(byteBuffer);
     }
 }