directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: rev 56609 - incubator/directory/seda/trunk/src/test/org/apache/seda
Date Thu, 04 Nov 2004 16:50:44 GMT
Author: trustin
Date: Thu Nov  4 08:50:44 2004
New Revision: 56609

Modified:
   incubator/directory/seda/trunk/src/test/org/apache/seda/ProtocolTestCase.java
Log:
Fixed that UDP service entry is not added and UDP port is not bound.

Modified: incubator/directory/seda/trunk/src/test/org/apache/seda/ProtocolTestCase.java
==============================================================================
--- incubator/directory/seda/trunk/src/test/org/apache/seda/ProtocolTestCase.java	(original)
+++ incubator/directory/seda/trunk/src/test/org/apache/seda/ProtocolTestCase.java	Thu Nov
 4 08:50:44 2004
@@ -24,9 +24,11 @@
 import org.apache.seda.listener.AvailablePortFinder;
 import org.apache.seda.listener.ListenerConfig;
 import org.apache.seda.listener.TCPListenerConfig;
+import org.apache.seda.listener.UDPListenerConfig;
 import org.apache.seda.protocol.DefaultInetServicesDatabase;
 import org.apache.seda.protocol.InetServiceEntry;
 import org.apache.seda.protocol.ProtocolProvider;
+import org.apache.seda.protocol.TransportTypeEnum;
 
 
 /**
@@ -45,7 +47,8 @@
     protected ProtocolProvider proto = null;
 
     /** the listener configuration for the protocol */
-    protected ListenerConfig config = null;
+    protected ListenerConfig tcpConfig;
+    protected ListenerConfig udpConfig;
 
     /** the server port number for the test protocol */
     protected int port;
@@ -63,7 +66,7 @@
     protected void tearDown() throws Exception
     {
         super.tearDown();
-        fe.getTCPListenerManager().unbind(config);
+        fe.getTCPListenerManager().unbind(tcpConfig);
         fe.stop();
         fe = null;
     }
@@ -80,11 +83,17 @@
 
         this.port = AvailablePortFinder.getNextAvailable(6666);
 
-        InetServiceEntry srvEntry =
-            new InetServiceEntry(proto.getName(), port, proto);
+        InetServiceEntry srvEntry;
+        
+        srvEntry = new InetServiceEntry(proto.getName(), port, proto, TransportTypeEnum.TCP);
         ((DefaultInetServicesDatabase) fe.getInetServicesDatabase()).addEntry(srvEntry);
-        config = new TCPListenerConfig(InetAddress.getLocalHost(), srvEntry);
-        fe.getTCPListenerManager().bind(config);
+        tcpConfig = new TCPListenerConfig(InetAddress.getLocalHost(), srvEntry);
+        fe.getTCPListenerManager().bind(tcpConfig);
+        
+        srvEntry = new InetServiceEntry(proto.getName(), port, proto, TransportTypeEnum.UDP);
+        ((DefaultInetServicesDatabase) fe.getInetServicesDatabase()).addEntry(srvEntry);
+        udpConfig = new UDPListenerConfig(InetAddress.getLocalHost(), srvEntry);
+        fe.getUDPListenerManager().bind(udpConfig);
     }
     
     public static void assertEquals(byte[] expected, byte[] actual) {

Mime
View raw message