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