directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akaras...@apache.org
Subject svn commit: rev 46258 - incubator/directory/seda/trunk/src/java/org/apache/seda/listener
Date Fri, 17 Sep 2004 16:41:31 GMT
Author: akarasulu
Date: Fri Sep 17 09:41:30 2004
New Revision: 46258

Added:
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/ListenerAddress.java
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/SocketListenerAddress.java
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerConfig.java
      - copied, changed from rev 46257, incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerConfig.java
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerManager.java
      - copied, changed from rev 46257, incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerManager.java
Removed:
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerConfig.java
   incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerManager.java
Log:
Commiting a few changes to make Trustin's patch work.  There were several 
missing classes in the patches which I simply took a guess on to make things
compile.  The echo test now breaks so we have to figure out whats going on.


Added: incubator/directory/seda/trunk/src/java/org/apache/seda/listener/ListenerAddress.java
==============================================================================
--- (empty file)
+++ incubator/directory/seda/trunk/src/java/org/apache/seda/listener/ListenerAddress.java
Fri Sep 17 09:41:30 2004
@@ -0,0 +1,28 @@
+/*
+ *   Copyright 2004 The Apache Software Foundation
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *   See the License for the specific language governing permissions and
+ *   limitations under the License.
+ *
+ */
+package org.apache.seda.listener;
+
+/**
+ * Document me.
+ *
+ * @author <a href="mailto:directory-dev@incubator.apache.org">Apache Directory
+ *         Project</a>
+ * @version $Rev$
+ */
+public class ListenerAddress
+{
+}

Added: incubator/directory/seda/trunk/src/java/org/apache/seda/listener/SocketListenerAddress.java
==============================================================================
--- (empty file)
+++ incubator/directory/seda/trunk/src/java/org/apache/seda/listener/SocketListenerAddress.java
Fri Sep 17 09:41:30 2004
@@ -0,0 +1,44 @@
+/*
+ *   Copyright 2004 The Apache Software Foundation
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *   See the License for the specific language governing permissions and
+ *   limitations under the License.
+ *
+ */
+package org.apache.seda.listener;
+
+import org.apache.seda.protocol.InetServiceEntry;
+
+import java.net.InetAddress;
+
+/**
+ * Document me.
+ *
+ * @author <a href="mailto:directory-dev@incubator.apache.org">Apache Directory
+ *         Project</a>
+ * @version $Rev$
+ */
+public class SocketListenerAddress extends ListenerAddress
+{
+    private final InetAddress address;
+
+    
+    public SocketListenerAddress( InetAddress address )
+    {
+        this.address = address;
+    }
+
+    public final InetAddress getAddress()
+    {
+        return address;
+    }
+}

Copied: incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerConfig.java
(from rev 46257, incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerConfig.java)
==============================================================================
--- incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerConfig.java
(original)
+++ incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerConfig.java
Fri Sep 17 09:41:30 2004
@@ -0,0 +1,121 @@
+/*
+ *   Copyright 2004 The Apache Software Foundation
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *   See the License for the specific language governing permissions and
+ *   limitations under the License.
+ *
+ */
+package org.apache.seda.listener;
+
+
+import org.apache.seda.protocol.InetServiceEntry;
+
+
+/**
+ * A default server listener.
+ *
+ * @author <a href="mailto:akarasulu@apache.org">Alex Karasulu</a>
+ * @author $LastChangedBy$
+ * @version $LastChangedRevision$
+ */
+public class TCPListenerConfig extends ListenerConfig
+{
+    /** the connection backlog */
+    private int backlog;
+    /** the interface address or hostname of the server */
+    private byte[] address;
+    /** the inet service provided by this listener */
+    private InetServiceEntry servEnt;
+
+    /**
+     * Creates a default listener with all the supplied properties.
+     * 
+     * @param address the address for the server listener
+     * @param servEnt the inet service entry for the service this listner
+     * provides
+     */
+    public TCPListenerConfig( ListenerAddress address, InetServiceEntry servEnt )
+    {
+        super( address );
+        this.servEnt = servEnt;
+    }
+    
+    
+    /* (non-Javadoc)
+     * @see org.apache.seda.listener.ServerListener#getBacklog()
+     */
+    public int getBacklog()
+    {
+        return this.backlog;
+    }
+
+
+    /* (non-Javadoc)
+     * @see org.apache.seda.listener.ServerListener#getURL()
+     */
+    public String getURL()
+    {
+        StringBuffer l_buf = new StringBuffer();
+        
+        l_buf.append( servEnt.getName() );
+        l_buf.append( "://" );
+        l_buf.append( this.address );
+        l_buf.append( ':' );
+        l_buf.append( servEnt.getPort() );
+        
+        return l_buf.toString();
+    }
+
+
+    /**
+     * Gets the Inet service entry for the service this config's listner
+     * provides.
+     *
+     * @return the served service's entry
+     */
+    public InetServiceEntry getInetServiceEntry()
+    {
+        return servEnt;
+    }
+
+
+    /**
+     * Sets the address for the 
+     * 
+     * @param a_address The address to set.
+     */
+    protected void setAddress( byte[] a_address )
+    {
+        this.address = a_address;
+    }
+    
+
+    /**
+     * @param a_backlog The backlog to set.
+     */
+    protected void setBacklog( int a_backlog )
+    {
+        this.backlog = a_backlog;
+    }
+
+    
+    /**
+     * Set's the inet service entry.
+     *
+     * @param servEnt the service entry of the service this listener provides
+     */
+    protected void setInetServiceEntry( InetServiceEntry servEnt )
+    {
+        this.servEnt = servEnt;
+    }
+}
+

Copied: incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerManager.java
(from rev 46257, incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerManager.java)
==============================================================================
--- incubator/directory/seda/trunk/src/java/org/apache/seda/listener/DefaultListenerManager.java
(original)
+++ incubator/directory/seda/trunk/src/java/org/apache/seda/listener/TCPListenerManager.java
Fri Sep 17 09:41:30 2004
@@ -36,7 +36,7 @@
  * @author <a href="mailto:directory-dev@incubator.apache.org">Apache Directory Project</a>
  * @version $Rev$
  */
-public class DefaultListenerManager 
+public class TCPListenerManager 
     implements
     DisconnectSubscriber,
     ProtocolSubscriber,
@@ -72,7 +72,7 @@
      * @param router the router to publish events to
      * @throws IOException
      */
-    public DefaultListenerManager( EventRouter router ) throws IOException
+    public TCPListenerManager( EventRouter router ) throws IOException
     {
         this.router = router;
         this.clients = new HashSet();

Mime
View raw message