svn commit: r575333 - in /mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr: APRConnector.java APRProtocol.java

[jvermillard]

Author: jvermillard
Date: Thu Sep 13 08:22:15 2007
New Revision: 575333

URL: http://svn.apache.org/viewvc?rev=575333&view=rev
Log:
Fixed UDP for APRConnector

Modified:
    
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRConnector.java
    
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRProtocol.java

Modified: 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRConnector.java
URL: 
http://svn.apache.org/viewvc/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRConnector.java?rev=575333&r1=575332&r2=575333&view=diff
==============================================================================
--- 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRConnector.java
 (original)
+++ 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRConnector.java
 Thu Sep 13 08:22:15 2007
@@ -123,7 +123,7 @@
 
             // TODO : type of socket need to be configurable
             long clientSock = Socket.create(Socket.APR_INET,
-                    Socket.SOCK_STREAM, protocol.codeProto, APRLibrary
+                    protocol.socketType, protocol.codeProto, APRLibrary
                             .getLibrary().getPool());
 
             // FIXME : error checking

Modified: 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRProtocol.java
URL: 
http://svn.apache.org/viewvc/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRProtocol.java?rev=575333&r1=575332&r2=575333&view=diff
==============================================================================
--- 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRProtocol.java
 (original)
+++ 
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRProtocol.java
 Thu Sep 13 08:22:15 2007
@@ -28,13 +28,15 @@
  * @version $Rev:  $, $Date:  $
  */
 public enum APRProtocol {
-    TCP(Socket.APR_PROTO_TCP), 
-    UDP(Socket.APR_PROTO_UDP),
-    SCTP(Socket.APR_PROTO_SCTP);
+    TCP(Socket.APR_PROTO_TCP,Socket.SOCK_STREAM), 
+    UDP(Socket.APR_PROTO_UDP,Socket.SOCK_DGRAM),
+    SCTP(Socket.APR_PROTO_SCTP,Socket.SOCK_STREAM);
 
+    int socketType;
     int codeProto;
 
-    private APRProtocol(int codeProto) {
+    private APRProtocol(int codeProto,int socketType) {
         this.codeProto = codeProto;
+        this.socketType = socketType;
     }
 }