directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: r359352 - in /directory/network/trunk: ./ src/java/org/apache/mina/transport/socket/nio/ src/java/org/apache/mina/transport/socket/nio/support/ src/test/org/apache/mina/transport/socket/nio/
Date Wed, 28 Dec 2005 02:40:18 GMT
Author: trustin
Date: Tue Dec 27 18:39:43 2005
New Revision: 359352

URL: http://svn.apache.org/viewcvs?rev=359352&view=rev
Log:
Replaced tabs with four spaces

Modified:
    directory/network/trunk/project.xml
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManager.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
    directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramSessionImpl.java
    directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/AbstractBindTest.java

Modified: directory/network/trunk/project.xml
URL: http://svn.apache.org/viewcvs/directory/network/trunk/project.xml?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/project.xml (original)
+++ directory/network/trunk/project.xml Tue Dec 27 18:39:43 2005
@@ -215,9 +215,9 @@
 
       <excludes>
         <exclude>**/Abstract*</exclude>
-	<!--
+    <!--
         <exclude>**/DatagramBindTest*</exclude>
-	-->
+    -->
         <exclude>**/*RegressionTest*</exclude>
       </excludes>
       

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
Tue Dec 27 18:39:43 2005
@@ -38,53 +38,53 @@
         init( new DatagramAcceptorDelegate( this ) );
     }
 
-	public int getReceiveBufferSize()
-	{
-		return ( ( DatagramAcceptorDelegate ) delegate ).getReceiveBufferSize();
-	}
-
-	public void setReceiveBufferSize( int receiveBufferSize )
-	{
-		( ( DatagramAcceptorDelegate ) delegate ).setReceiveBufferSize( receiveBufferSize );
-	}
-
-	public boolean getBroadcast()
-	{
-		return ( ( DatagramAcceptorDelegate ) delegate ).getBroadcast();
-	}
-
-	public void setBroadcast( boolean broadcast )
-	{
-		( ( DatagramAcceptorDelegate ) delegate ).setBroadcast( broadcast );
-	}
-
-	public int getSendBufferSize()
-	{
-		return ( ( DatagramAcceptorDelegate ) delegate ).getSendBufferSize();
-	}
-
-	public void setSendBufferSize( int sendBufferSize )
-	{
-		( ( DatagramAcceptorDelegate ) delegate ).setSendBufferSize( sendBufferSize );
-	}
-
-	public int getTrafficClass()
-	{
-		return ( ( DatagramAcceptorDelegate ) delegate ).getTrafficClass();
-	}
-
-	public void setTrafficClass( int trafficClass )
-	{
-		( ( DatagramAcceptorDelegate ) delegate ).setTrafficClass( trafficClass );
-	}
-
-	public boolean getReuseAddress()
-	{
-		return ( ( DatagramAcceptorDelegate ) delegate ).getReuseAddress();
-	}
-
-	public void setReuseAddress( boolean reuseAddress )
-	{
-		( ( DatagramAcceptorDelegate ) delegate ).setReuseAddress( reuseAddress );
-	}
+    public int getReceiveBufferSize()
+    {
+        return ( ( DatagramAcceptorDelegate ) delegate ).getReceiveBufferSize();
+    }
+
+    public void setReceiveBufferSize( int receiveBufferSize )
+    {
+        ( ( DatagramAcceptorDelegate ) delegate ).setReceiveBufferSize( receiveBufferSize
);
+    }
+
+    public boolean getBroadcast()
+    {
+        return ( ( DatagramAcceptorDelegate ) delegate ).getBroadcast();
+    }
+
+    public void setBroadcast( boolean broadcast )
+    {
+        ( ( DatagramAcceptorDelegate ) delegate ).setBroadcast( broadcast );
+    }
+
+    public int getSendBufferSize()
+    {
+        return ( ( DatagramAcceptorDelegate ) delegate ).getSendBufferSize();
+    }
+
+    public void setSendBufferSize( int sendBufferSize )
+    {
+        ( ( DatagramAcceptorDelegate ) delegate ).setSendBufferSize( sendBufferSize );
+    }
+
+    public int getTrafficClass()
+    {
+        return ( ( DatagramAcceptorDelegate ) delegate ).getTrafficClass();
+    }
+
+    public void setTrafficClass( int trafficClass )
+    {
+        ( ( DatagramAcceptorDelegate ) delegate ).setTrafficClass( trafficClass );
+    }
+
+    public boolean getReuseAddress()
+    {
+        return ( ( DatagramAcceptorDelegate ) delegate ).getReuseAddress();
+    }
+
+    public void setReuseAddress( boolean reuseAddress )
+    {
+        ( ( DatagramAcceptorDelegate ) delegate ).setReuseAddress( reuseAddress );
+    }
 }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
Tue Dec 27 18:39:43 2005
@@ -38,54 +38,54 @@
         init( new DatagramConnectorDelegate( this ) );
     }
 
-	public int getReceiveBufferSize()
-	{
-		return ( ( DatagramConnectorDelegate ) delegate ).getReceiveBufferSize();
-	}
-
-	public void setReceiveBufferSize( int receiveBufferSize )
-	{
-		( ( DatagramConnectorDelegate ) delegate ).setReceiveBufferSize( receiveBufferSize );
-	}
-
-	public boolean getBroadcast()
-	{
-		return ( ( DatagramConnectorDelegate ) delegate ).getBroadcast();
-	}
-
-	public void setBroadcast( boolean broadcast )
-	{
-		( ( DatagramConnectorDelegate ) delegate ).setBroadcast( broadcast );
-	}
-
-	public int getSendBufferSize()
-	{
-		return ( ( DatagramConnectorDelegate ) delegate ).getSendBufferSize();
-	}
-
-	public void setSendBufferSize( int sendBufferSize )
-	{
-		( ( DatagramConnectorDelegate ) delegate ).setSendBufferSize( sendBufferSize );
-	}
-
-	public int getTrafficClass()
-	{
-		return ( ( DatagramConnectorDelegate ) delegate ).getTrafficClass();
-	}
-
-	public void setTrafficClass( int trafficClass )
-	{
-		( ( DatagramConnectorDelegate ) delegate ).setTrafficClass( trafficClass );
-	}
-
-
-	public boolean getReuseAddress()
-	{
-		return ( ( DatagramConnectorDelegate ) delegate ).getReuseAddress();
-	}
-
-	public void setReuseAddress( boolean reuseAddress )
-	{
-		( ( DatagramConnectorDelegate ) delegate ).setReuseAddress( reuseAddress );
-	}
+    public int getReceiveBufferSize()
+    {
+        return ( ( DatagramConnectorDelegate ) delegate ).getReceiveBufferSize();
+    }
+
+    public void setReceiveBufferSize( int receiveBufferSize )
+    {
+        ( ( DatagramConnectorDelegate ) delegate ).setReceiveBufferSize( receiveBufferSize
);
+    }
+
+    public boolean getBroadcast()
+    {
+        return ( ( DatagramConnectorDelegate ) delegate ).getBroadcast();
+    }
+
+    public void setBroadcast( boolean broadcast )
+    {
+        ( ( DatagramConnectorDelegate ) delegate ).setBroadcast( broadcast );
+    }
+
+    public int getSendBufferSize()
+    {
+        return ( ( DatagramConnectorDelegate ) delegate ).getSendBufferSize();
+    }
+
+    public void setSendBufferSize( int sendBufferSize )
+    {
+        ( ( DatagramConnectorDelegate ) delegate ).setSendBufferSize( sendBufferSize );
+    }
+
+    public int getTrafficClass()
+    {
+        return ( ( DatagramConnectorDelegate ) delegate ).getTrafficClass();
+    }
+
+    public void setTrafficClass( int trafficClass )
+    {
+        ( ( DatagramConnectorDelegate ) delegate ).setTrafficClass( trafficClass );
+    }
+
+
+    public boolean getReuseAddress()
+    {
+        return ( ( DatagramConnectorDelegate ) delegate ).getReuseAddress();
+    }
+
+    public void setReuseAddress( boolean reuseAddress )
+    {
+        ( ( DatagramConnectorDelegate ) delegate ).setReuseAddress( reuseAddress );
+    }
 }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSession.java
Tue Dec 27 18:39:43 2005
@@ -30,44 +30,44 @@
  */
 public interface DatagramSession extends IoSession
 {
-	/**
-	 * @see DatagramSocket#getReceiveBufferSize()
-	 */
-	int getReceiveBufferSize() throws SocketException;
-	/**
-	 * @see DatagramSocket#setReceiveBufferSize(int)
-	 */
-	void setReceiveBufferSize( int receiveBufferSize ) throws SocketException;
-	/**
-	 * @see DatagramSocket#getReuseAddress()
-	 */
-	boolean getReuseAddress() throws SocketException;
-	/**
-	 * @see DatagramSocket#setReuseAddress(boolean)
-	 */
-	void setReuseAddress( boolean reuseAddress ) throws SocketException;
-	/**
-	 * @see DatagramSocket#getBroadcast()
-	 */
-	boolean getBroadcast() throws SocketException;
-	/**
-	 * @see DatagramSocket#setBroadcast(boolean)
-	 */
-	void setBroadcast( boolean broadcast ) throws SocketException;
-	/**
-	 * @see DatagramSocket#getSendBufferSize()
-	 */
-	int getSendBufferSize() throws SocketException;
-	/**
-	 * @see DatagramSocket#setSendBufferSize(int)
-	 */
-	void setSendBufferSize( int sendBufferSize ) throws SocketException;
-	/**
-	 * @see DatagramSocket#getTrafficClass()
-	 */
-	int getTrafficClass() throws SocketException;
-	/**
-	 * @see DatagramSocket#setTrafficClass(int)
-	 */
-	void setTrafficClass( int trafficClass ) throws SocketException;
+    /**
+     * @see DatagramSocket#getReceiveBufferSize()
+     */
+    int getReceiveBufferSize() throws SocketException;
+    /**
+     * @see DatagramSocket#setReceiveBufferSize(int)
+     */
+    void setReceiveBufferSize( int receiveBufferSize ) throws SocketException;
+    /**
+     * @see DatagramSocket#getReuseAddress()
+     */
+    boolean getReuseAddress() throws SocketException;
+    /**
+     * @see DatagramSocket#setReuseAddress(boolean)
+     */
+    void setReuseAddress( boolean reuseAddress ) throws SocketException;
+    /**
+     * @see DatagramSocket#getBroadcast()
+     */
+    boolean getBroadcast() throws SocketException;
+    /**
+     * @see DatagramSocket#setBroadcast(boolean)
+     */
+    void setBroadcast( boolean broadcast ) throws SocketException;
+    /**
+     * @see DatagramSocket#getSendBufferSize()
+     */
+    int getSendBufferSize() throws SocketException;
+    /**
+     * @see DatagramSocket#setSendBufferSize(int)
+     */
+    void setSendBufferSize( int sendBufferSize ) throws SocketException;
+    /**
+     * @see DatagramSocket#getTrafficClass()
+     */
+    int getTrafficClass() throws SocketException;
+    /**
+     * @see DatagramSocket#setTrafficClass(int)
+     */
+    void setTrafficClass( int trafficClass ) throws SocketException;
 }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManager.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManager.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManager.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/DatagramSessionManager.java
Tue Dec 27 18:39:43 2005
@@ -32,44 +32,44 @@
  */
 public interface DatagramSessionManager extends IoSessionManager
 {
-	/**
-	 * @see DatagramSocket#getBroadcast()
-	 */
-	boolean getBroadcast();
-	/**
-	 * @see DatagramSocket#setBroadcast(boolean)
-	 */
-	void setBroadcast( boolean broadcast );
-	/**
-	 * @see DatagramSocket#getReuseAddress()
-	 */
-	boolean getReuseAddress();
-	/**
-	 * @see DatagramSocket#setReuseAddress(boolean)
-	 */
-	void setReuseAddress( boolean reuseAddress );
-	/**
-	 * @see DatagramSocket#getReceiveBufferSize()
-	 */
-	int getReceiveBufferSize();
-	/**
-	 * @see DatagramSocket#setReceiveBufferSize(int)
-	 */
-	void setReceiveBufferSize( int receiveBufferSize );
-	/**
-	 * @see DatagramSocket#getSendBufferSize()
-	 */
-	int getSendBufferSize();
-	/**
-	 * @see DatagramSocket#setSendBufferSize(int)
-	 */
-	void setSendBufferSize( int sendBufferSize );
-	/**
-	 * @see DatagramSocket#getTrafficClass()
-	 */
-	int getTrafficClass();
-	/**
-	 * @see DatagramSocket#setTrafficClass(int)
-	 */
-	void setTrafficClass( int trafficClass );
+    /**
+     * @see DatagramSocket#getBroadcast()
+     */
+    boolean getBroadcast();
+    /**
+     * @see DatagramSocket#setBroadcast(boolean)
+     */
+    void setBroadcast( boolean broadcast );
+    /**
+     * @see DatagramSocket#getReuseAddress()
+     */
+    boolean getReuseAddress();
+    /**
+     * @see DatagramSocket#setReuseAddress(boolean)
+     */
+    void setReuseAddress( boolean reuseAddress );
+    /**
+     * @see DatagramSocket#getReceiveBufferSize()
+     */
+    int getReceiveBufferSize();
+    /**
+     * @see DatagramSocket#setReceiveBufferSize(int)
+     */
+    void setReceiveBufferSize( int receiveBufferSize );
+    /**
+     * @see DatagramSocket#getSendBufferSize()
+     */
+    int getSendBufferSize();
+    /**
+     * @see DatagramSocket#setSendBufferSize(int)
+     */
+    void setSendBufferSize( int sendBufferSize );
+    /**
+     * @see DatagramSocket#getTrafficClass()
+     */
+    int getTrafficClass();
+    /**
+     * @see DatagramSocket#setTrafficClass(int)
+     */
+    void setTrafficClass( int trafficClass );
 }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
Tue Dec 27 18:39:43 2005
@@ -217,56 +217,56 @@
     
     public boolean getBroadcast()
     {
-    	return broadcast;
+        return broadcast;
     }
     
     public void setBroadcast( boolean broadcast )
     {
-    	this.broadcast = broadcast;
+        this.broadcast = broadcast;
     }
     
     public boolean getReuseAddress()
     {
-    	return reuseAddress;
+        return reuseAddress;
     }
     
     public void setReuseAddress( boolean reuseAddress )
     {
-    	this.reuseAddress = reuseAddress;
+        this.reuseAddress = reuseAddress;
     }
 
 
-	public int getReceiveBufferSize()
-	{
-		return receiveBufferSize;
-	}
+    public int getReceiveBufferSize()
+    {
+        return receiveBufferSize;
+    }
 
-	public void setReceiveBufferSize( int receiveBufferSize )
-	{
-		this.receiveBufferSize = receiveBufferSize;
-	}
+    public void setReceiveBufferSize( int receiveBufferSize )
+    {
+        this.receiveBufferSize = receiveBufferSize;
+    }
 
-	public int getSendBufferSize()
-	{
-		return sendBufferSize;
-	}
+    public int getSendBufferSize()
+    {
+        return sendBufferSize;
+    }
 
-	public void setSendBufferSize( int sendBufferSize )
-	{
-		this.sendBufferSize = sendBufferSize;
-	}
+    public void setSendBufferSize( int sendBufferSize )
+    {
+        this.sendBufferSize = sendBufferSize;
+    }
 
-	public int getTrafficClass()
-	{
-		return trafficClass;
-	}
+    public int getTrafficClass()
+    {
+        return trafficClass;
+    }
 
-	public void setTrafficClass( int trafficClass )
-	{
-		this.trafficClass = trafficClass;
-	}
+    public void setTrafficClass( int trafficClass )
+    {
+        this.trafficClass = trafficClass;
+    }
 
-	private synchronized void startupWorker() throws IOException
+    private synchronized void startupWorker() throws IOException
     {
         if( worker == null )
         {
@@ -555,15 +555,15 @@
                 ch.socket().setBroadcast( broadcast );
                 if( receiveBufferSize > 0 )
                 {
-                	ch.socket().setReceiveBufferSize( receiveBufferSize );
+                    ch.socket().setReceiveBufferSize( receiveBufferSize );
                 }
                 if( sendBufferSize > 0 )
                 {
-                	ch.socket().setSendBufferSize( sendBufferSize );
+                    ch.socket().setSendBufferSize( sendBufferSize );
                 }
                 if( trafficClass > 0 )
                 {
-                	ch.socket().setTrafficClass( trafficClass );
+                    ch.socket().setTrafficClass( trafficClass );
                 }
                 ch.configureBlocking( false );
                 ch.socket().bind( req.address );
@@ -586,7 +586,7 @@
                 {
                     try
                     {
-                    	ch.disconnect();
+                        ch.disconnect();
                         ch.close();
                     }
                     catch( Throwable e )
@@ -630,7 +630,7 @@
                     SelectionKey key = ch.keyFor( selector );
                     key.cancel();
                     selector.wakeup(); // wake up again to trigger thread death
-                	ch.disconnect();
+                    ch.disconnect();
                     ch.close();
                 }
             }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
Tue Dec 27 18:39:43 2005
@@ -106,15 +106,15 @@
             ch.socket().setBroadcast( broadcast );
             if( receiveBufferSize > 0 )
             {
-            	ch.socket().setReceiveBufferSize( receiveBufferSize );
+                ch.socket().setReceiveBufferSize( receiveBufferSize );
             }
             if( sendBufferSize > 0 )
             {
-            	ch.socket().setSendBufferSize( sendBufferSize );
+                ch.socket().setSendBufferSize( sendBufferSize );
             }
             if( trafficClass > 0 )
             {
-            	ch.socket().setTrafficClass( trafficClass );
+                ch.socket().setTrafficClass( trafficClass );
             }
             if( localAddress != null )
             {
@@ -134,7 +134,7 @@
             {
                 try
                 {
-                	ch.disconnect();
+                    ch.disconnect();
                     ch.close();
                 }
                 catch( IOException e )
@@ -155,7 +155,7 @@
             {
                 try
                 {
-                	ch.disconnect();
+                    ch.disconnect();
                     ch.close();
                 }
                 catch( IOException e2 )
@@ -178,55 +178,55 @@
     
     public boolean getBroadcast()
     {
-    	return broadcast;
+        return broadcast;
     }
     
     public void setBroadcast( boolean broadcast )
     {
-    	this.broadcast = broadcast;
+        this.broadcast = broadcast;
     }
     
     public boolean getReuseAddress()
     {
-    	return reuseAddress;
+        return reuseAddress;
     }
     
     public void setReuseAddress( boolean reuseAddress )
     {
-    	this.reuseAddress = reuseAddress;
+        this.reuseAddress = reuseAddress;
     }
 
-	public int getReceiveBufferSize()
-	{
-		return receiveBufferSize;
-	}
-
-	public void setReceiveBufferSize( int receiveBufferSize )
-	{
-		this.receiveBufferSize = receiveBufferSize;
-	}
-
-	public int getSendBufferSize()
-	{
-		return sendBufferSize;
-	}
-
-	public void setSendBufferSize( int sendBufferSize )
-	{
-		this.sendBufferSize = sendBufferSize;
-	}
-
-	public int getTrafficClass()
-	{
-		return trafficClass;
-	}
-
-	public void setTrafficClass( int trafficClass )
-	{
-		this.trafficClass = trafficClass;
-	}
+    public int getReceiveBufferSize()
+    {
+        return receiveBufferSize;
+    }
+
+    public void setReceiveBufferSize( int receiveBufferSize )
+    {
+        this.receiveBufferSize = receiveBufferSize;
+    }
+
+    public int getSendBufferSize()
+    {
+        return sendBufferSize;
+    }
+
+    public void setSendBufferSize( int sendBufferSize )
+    {
+        this.sendBufferSize = sendBufferSize;
+    }
+
+    public int getTrafficClass()
+    {
+        return trafficClass;
+    }
+
+    public void setTrafficClass( int trafficClass )
+    {
+        this.trafficClass = trafficClass;
+    }
 
-	private synchronized void startupWorker() throws IOException
+    private synchronized void startupWorker() throws IOException
     {
         if( worker == null )
         {
@@ -610,7 +610,7 @@
                 {
                     try
                     {
-                    	req.channel.disconnect();
+                        req.channel.disconnect();
                         req.channel.close();
                     }
                     catch (IOException e)
@@ -643,7 +643,7 @@
                 DatagramChannel ch = ( DatagramChannel ) key.channel();
                 try
                 {
-                	ch.disconnect();
+                    ch.disconnect();
                     ch.close();
                 }
                 catch( IOException e )

Modified: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramSessionImpl.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramSessionImpl.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramSessionImpl.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/DatagramSessionImpl.java
Tue Dec 27 18:39:43 2005
@@ -172,32 +172,32 @@
         managerDelegate.updateTrafficMask( this );
     }
 
-	public int getReceiveBufferSize() throws SocketException {
-		return ch.socket().getReceiveBufferSize();
-	}
+    public int getReceiveBufferSize() throws SocketException {
+        return ch.socket().getReceiveBufferSize();
+    }
 
-	public void setReceiveBufferSize( int receiveBufferSize ) throws SocketException
-	{
-		ch.socket().setReceiveBufferSize( receiveBufferSize );
-	}
+    public void setReceiveBufferSize( int receiveBufferSize ) throws SocketException
+    {
+        ch.socket().setReceiveBufferSize( receiveBufferSize );
+    }
 
-	public boolean getBroadcast() throws SocketException
-	{
-		return ch.socket().getBroadcast();
-	}
+    public boolean getBroadcast() throws SocketException
+    {
+        return ch.socket().getBroadcast();
+    }
 
-	public void setBroadcast( boolean broadcast ) throws SocketException
-	{
-		ch.socket().setBroadcast( broadcast );
-	}
+    public void setBroadcast( boolean broadcast ) throws SocketException
+    {
+        ch.socket().setBroadcast( broadcast );
+    }
 
-	public int getSendBufferSize() throws SocketException
-	{
-		return ch.socket().getSendBufferSize();
-	}
+    public int getSendBufferSize() throws SocketException
+    {
+        return ch.socket().getSendBufferSize();
+    }
 
-	public void setSendBufferSize( int sendBufferSize ) throws SocketException
-	{
-		ch.socket().setSendBufferSize( sendBufferSize );
-	}
+    public void setSendBufferSize( int sendBufferSize ) throws SocketException
+    {
+        ch.socket().setSendBufferSize( sendBufferSize );
+    }
 }

Modified: directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/AbstractBindTest.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/AbstractBindTest.java?rev=359352&r1=359351&r2=359352&view=diff
==============================================================================
--- directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/AbstractBindTest.java
(original)
+++ directory/network/trunk/src/test/org/apache/mina/transport/socket/nio/AbstractBindTest.java
Tue Dec 27 18:39:43 2005
@@ -44,11 +44,11 @@
         this.acceptor = acceptor;
     }
     
-	private void bind( boolean reuseAddress ) throws IOException
-	{
-		setReuseAddress( reuseAddress );
+    private void bind( boolean reuseAddress ) throws IOException
+    {
+        setReuseAddress( reuseAddress );
 
-    	// Find an availble test port and bind to it.
+        // Find an availble test port and bind to it.
         boolean socketBound = false;
 
         // Let's start from port #1 to detect possible resource leak
@@ -76,19 +76,19 @@
         }
 
         //System.out.println( "Using port " + port + " for testing." );
-	}
+    }
 
-	private void setReuseAddress( boolean reuseAddress )
-	{
-		if( acceptor instanceof DatagramAcceptor )
-		{
-			( ( DatagramAcceptor ) acceptor ).setReuseAddress( reuseAddress );
-		}
-		else if( acceptor instanceof SocketAcceptor )
-		{
-			( ( SocketAcceptor ) acceptor ).setReuseAddress( reuseAddress );
-		}
-	}
+    private void setReuseAddress( boolean reuseAddress )
+    {
+        if( acceptor instanceof DatagramAcceptor )
+        {
+            ( ( DatagramAcceptor ) acceptor ).setReuseAddress( reuseAddress );
+        }
+        else if( acceptor instanceof SocketAcceptor )
+        {
+            ( ( SocketAcceptor ) acceptor ).setReuseAddress( reuseAddress );
+        }
+    }
     
     public void tearDown()
     {
@@ -104,8 +104,8 @@
     
     public void testDuplicateBind() throws IOException
     {
-    	bind( false );
-    	
+        bind( false );
+        
         try
         {
             acceptor.bind( new InetSocketAddress( port ), new EchoProtocolHandler() );
@@ -118,8 +118,8 @@
 
     public void testDuplicateUnbind() throws IOException
     {
-    	bind( false );
-    	
+        bind( false );
+        
         // this should succeed
         acceptor.unbind( new InetSocketAddress( port ) );
         
@@ -136,8 +136,8 @@
     
     public void testManyTimes() throws IOException
     {
-    	bind( true );
-    	
+        bind( true );
+        
         InetSocketAddress addr = new InetSocketAddress( port );
         EchoProtocolHandler handler = new EchoProtocolHandler();
         for( int i = 0; i < 1024; i++ ) 
@@ -149,7 +149,7 @@
     
     public void _testRegressively() throws IOException
     {
-    	setReuseAddress( true );
+        setReuseAddress( true );
 
         InetSocketAddress addr = new InetSocketAddress( port );
         EchoProtocolHandler handler = new EchoProtocolHandler();



Mime
View raw message