You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2007/09/13 17:22:16 UTC
svn commit: r575333 - in
/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr:
APRConnector.java APRProtocol.java
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;
}
}