You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2008/03/12 06:37:09 UTC

svn commit: r636205 - /mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java

Author: trustin
Date: Tue Mar 11 22:37:09 2008
New Revision: 636205

URL: http://svn.apache.org/viewvc?rev=636205&view=rev
Log:
Fixed issue: DIRMINA-539 - NioDatagramConnector doesn't takes the TrafficClass value set to his DatagramSessionConfig
* Made sure all datagram socket parameters are configured


Modified:
    mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java

Modified: mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java?rev=636205&r1=636204&r2=636205&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramConnector.java Tue Mar 11 22:37:09 2008
@@ -90,14 +90,9 @@
     protected DatagramChannel newHandle(SocketAddress localAddress)
             throws Exception {
         DatagramChannel ch = DatagramChannel.open();
-        ch.socket().setReuseAddress(getSessionConfig().isReuseAddress());
-        ch.socket().setReuseAddress(true);
-        ch.socket().setBroadcast(getSessionConfig().isBroadcast());
-
         if (localAddress != null) {
             ch.socket().bind(localAddress);
         }
-        
         return ch;
     }
 
@@ -111,7 +106,9 @@
     @Override
     protected NioSession newSession(IoProcessor<NioSession> processor,
             DatagramChannel handle) {
-        return new NioDatagramSession(this, handle, processor);
+        NioSession session = new NioDatagramSession(this, handle, processor);
+        session.getConfig().setAll(getSessionConfig());
+        return session;
     }
 
     @Override