[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/socketfactory ...

Ron Sigal ron_sigal at yahoo.com
Tue Jan 16 00:52:56 EST 2007


  User: rsigal  
  Date: 07/01/16 00:52:56

  Added:       src/main/org/jboss/remoting/socketfactory       Tag:
                        remoting_2_x
                        CreationListenerServerSocketFactory.java
                        ServerSocketFactoryWrapper.java
                        SocketFactoryWrapper.java
                        SocketCreationListener.java
                        CreationListenerSocketFactory.java
                        CreationListenerServerSocket.java
  Log:
  JBREM-298: Added classes to support socket creation listener facility.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.1   +99 -0     JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/CreationListenerServerSocketFactory.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: CreationListenerServerSocketFactory.java
  ===================================================================
  RCS file: CreationListenerServerSocketFactory.java
  diff -N CreationListenerServerSocketFactory.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ CreationListenerServerSocketFactory.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,99 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import java.io.IOException;
  +import java.io.Serializable;
  +import java.net.InetAddress;
  +import java.net.ServerSocket;
  +
  +import javax.net.ServerSocketFactory;
  +
  +/** 
  + * A CreationListenerServerSocketFactory wraps a ServerSocketFactory, and whenever
  + * the ServerSocketFactory creates a ServerSocket, the ServerSocket is wrapped in a
  + * CreationListenerServerSocket.
  + * 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 10, 2007
  + * </p>
  + */
  +public class CreationListenerServerSocketFactory
  +   extends ServerSocketFactory
  +   implements ServerSocketFactoryWrapper, Serializable
  +{
  +   private static final long serialVersionUID = -7939318527267014514L;
  +   
  +   private ServerSocketFactory factory;
  +   private SocketCreationListener listener;
  +   
  +   
  +   public CreationListenerServerSocketFactory(ServerSocketFactory factory,
  +                                              SocketCreationListener listener)
  +   {
  +      this.factory = factory;
  +      this.listener = listener;
  +   }
  +
  +   
  +   public ServerSocket createServerSocket() throws IOException
  +   {
  +      ServerSocket serverSocket = factory.createServerSocket();
  +      return new CreationListenerServerSocket(serverSocket, listener);
  +   }
  +   
  +   
  +   public ServerSocket createServerSocket(int port) throws IOException
  +   {
  +      ServerSocket serverSocket = factory.createServerSocket(port);
  +      return new CreationListenerServerSocket(serverSocket, listener);
  +   }
  +
  +   
  +   public ServerSocket createServerSocket(int port, int backlog) throws IOException
  +   {
  +      ServerSocket serverSocket = factory.createServerSocket(port, backlog);
  +      return new CreationListenerServerSocket(serverSocket, listener);
  +   }
  +
  +   
  +   public ServerSocket createServerSocket(int port, int backlog, InetAddress ifAddress)
  +   throws IOException
  +   {
  +      ServerSocket serverSocket = factory.createServerSocket(port, backlog, ifAddress);
  +      return new CreationListenerServerSocket(serverSocket, listener);
  +   }
  +
  +
  +   public ServerSocketFactory getServerSocketFactory()
  +   {
  +      return factory;
  +   }
  +
  +
  +   public void setServerSocketFactory(ServerSocketFactory factory)
  +   {
  +      this.factory = factory;
  +   }
  +}
  
  
  
  1.1.2.1   +38 -0     JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/ServerSocketFactoryWrapper.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ServerSocketFactoryWrapper.java
  ===================================================================
  RCS file: ServerSocketFactoryWrapper.java
  diff -N ServerSocketFactoryWrapper.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ ServerSocketFactoryWrapper.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,38 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import javax.net.ServerSocketFactory;
  +
  +/** 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 13, 2007
  + * </p>
  + */
  +public interface ServerSocketFactoryWrapper
  +{
  +   ServerSocketFactory getServerSocketFactory();
  +   
  +   void setServerSocketFactory(ServerSocketFactory factory);
  +}
  
  
  
  1.1.2.1   +38 -0     JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/SocketFactoryWrapper.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SocketFactoryWrapper.java
  ===================================================================
  RCS file: SocketFactoryWrapper.java
  diff -N SocketFactoryWrapper.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ SocketFactoryWrapper.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,38 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import javax.net.SocketFactory;
  +
  +/** 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 13, 2007
  + * </p>
  + */
  +public interface SocketFactoryWrapper
  +{
  +   SocketFactory getSocketFactory();
  +   
  +   void setSocketFactory(SocketFactory factory);
  +}
  
  
  
  1.1.2.1   +37 -0     JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/SocketCreationListener.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SocketCreationListener.java
  ===================================================================
  RCS file: SocketCreationListener.java
  diff -N SocketCreationListener.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ SocketCreationListener.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,37 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import java.io.IOException;
  +import java.net.Socket;
  +
  +/** 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 10, 2007
  + * </p>
  + */
  +public interface SocketCreationListener
  +{
  +   void socketCreated(Socket socket) throws IOException;
  +}
  
  
  
  1.1.2.1   +162 -0    JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/CreationListenerSocketFactory.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: CreationListenerSocketFactory.java
  ===================================================================
  RCS file: CreationListenerSocketFactory.java
  diff -N CreationListenerSocketFactory.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ CreationListenerSocketFactory.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,162 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import java.io.IOException;
  +import java.io.Serializable;
  +import java.net.InetAddress;
  +import java.net.Socket;
  +import java.net.UnknownHostException;
  +
  +import javax.net.SocketFactory;
  +import javax.net.ssl.SSLSocketFactory;
  +
  +/** 
  + * A CreationListenerSocketFactory wraps a SocketFactory and notifies a listener
  + * of the creation of a Socket before returning the socket.
  + * 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 10, 2007
  + * </p>
  + */
  +public class CreationListenerSocketFactory
  +   extends SSLSocketFactory
  +   implements SocketFactoryWrapper, Serializable
  +{
  +   private static final long serialVersionUID = 1210774093889434553L;
  +   
  +   private SocketFactory factory;
  +   private SocketCreationListener listener;
  +   
  +   
  +   public CreationListenerSocketFactory(SocketCreationListener listener)
  +   {
  +      this(SocketFactory.getDefault(), listener);
  +   }
  +   
  +   
  +   public CreationListenerSocketFactory(SocketFactory factory, SocketCreationListener listener)
  +   {
  +      this.factory = factory;
  +      this.listener = listener;
  +   }
  +   
  +   
  +   public Socket createSocket() throws IOException
  +   {
  +      checkFactory();
  +      Socket socket = factory.createSocket();
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +   
  +   
  +   public Socket createSocket(String host, int port)
  +   throws IOException, UnknownHostException
  +   {
  +      checkFactory();
  +      Socket socket = factory.createSocket(host, port);
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +   
  +
  +   public Socket createSocket(String host, int port, InetAddress clientHost, int clientPort)
  +   throws IOException, UnknownHostException
  +   {
  +      checkFactory();
  +      Socket socket = factory.createSocket(host, port, clientHost, clientPort);
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +
  +   
  +   public Socket createSocket(InetAddress host, int port) throws IOException
  +   {
  +      checkFactory();
  +      Socket socket = factory.createSocket(host, port);
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +
  +   
  +   public Socket createSocket(InetAddress address, int port, InetAddress clientAddress, int clientPort)
  +   throws IOException
  +   {
  +      checkFactory();
  +      Socket socket = factory.createSocket(address, port, clientAddress, clientPort);
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +
  +
  +   public String[] getDefaultCipherSuites()
  +   {
  +      if (factory instanceof SSLSocketFactory)
  +         return ((SSLSocketFactory) factory).getDefaultCipherSuites();
  +      else
  +         return null;
  +   }
  +
  +
  +   public String[] getSupportedCipherSuites()
  +   {
  +      if (factory instanceof SSLSocketFactory)
  +         return ((SSLSocketFactory) factory).getSupportedCipherSuites();
  +      else
  +         return null;
  +   }
  +
  +
  +   public Socket createSocket(Socket s, String host, int port, boolean autoClose) throws IOException
  +   {
  +      if (factory instanceof SSLSocketFactory)
  +      {
  +         Socket socket = ((SSLSocketFactory) factory).createSocket(s, host, port, autoClose);
  +         listener.socketCreated(socket);
  +         return socket;
  +      }
  +      else
  +         return null;
  +   }
  +   
  +  
  +   public SocketFactory getSocketFactory()
  +   {
  +      return factory;
  +   }
  +
  +
  +   public void setSocketFactory(SocketFactory factory)
  +   {
  +      this.factory = factory;
  +   }
  +   
  +   
  +   protected void checkFactory()
  +   {
  +      if (factory == null)
  +         factory = SocketFactory.getDefault();
  +   }
  +}
  
  
  
  1.1.2.1   +177 -0    JBossRemoting/src/main/org/jboss/remoting/socketfactory/Attic/CreationListenerServerSocket.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: CreationListenerServerSocket.java
  ===================================================================
  RCS file: CreationListenerServerSocket.java
  diff -N CreationListenerServerSocket.java
  --- /dev/null	1 Jan 1970 00:00:00 -0000
  +++ CreationListenerServerSocket.java	16 Jan 2007 05:52:56 -0000	1.1.2.1
  @@ -0,0 +1,177 @@
  +/*
  +* JBoss, Home of Professional Open Source
  +* Copyright 2005, JBoss Inc., and individual contributors as indicated
  +* by the @authors tag. See the copyright.txt in the distribution for a
  +* full listing of individual contributors.
  +*
  +* This is free software; you can redistribute it and/or modify it
  +* under the terms of the GNU Lesser General Public License as
  +* published by the Free Software Foundation; either version 2.1 of
  +* the License, or (at your option) any later version.
  +*
  +* This software is distributed in the hope that it will be useful,
  +* but WITHOUT ANY WARRANTY; without even the implied warranty of
  +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  +* Lesser General Public License for more details.
  +*
  +* You should have received a copy of the GNU Lesser General Public
  +* License along with this software; if not, write to the Free
  +* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  +* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  +*/
  +package org.jboss.remoting.socketfactory;
  +
  +import java.io.IOException;
  +import java.net.InetAddress;
  +import java.net.ServerSocket;
  +import java.net.Socket;
  +import java.net.SocketAddress;
  +import java.net.SocketException;
  +import java.nio.channels.ServerSocketChannel;
  +
  +/** 
  + * A CreationListenerServerSocket wraps a ServerSocket to which it delegates
  + * calls to accept(), and when the wrapped ServerSocket creates a Socket in 
  + * accept(), a SocketCreationListener is notified before the Socket is returned.
  + * 
  + * @author <a href="ron.sigal at jboss.com">Ron Sigal</a>
  + * @version $Revision: 1.1.2.1 $
  + * <p>
  + * Copyright Jan 10, 2007
  + * </p>
  + */
  +public class CreationListenerServerSocket extends ServerSocket
  +{
  +   private ServerSocket serverSocket;
  +   private SocketCreationListener listener;
  +
  +   
  +   public CreationListenerServerSocket(ServerSocket serverSocket, SocketCreationListener listener)
  +   throws IOException
  +   {
  +      this.serverSocket = serverSocket;
  +      this.listener = listener;
  +   }
  +
  +   
  +   public void bind(SocketAddress endpoint) throws IOException
  +   {
  +      serverSocket.bind(endpoint);
  +   }
  +   
  +   
  +   public void bind(SocketAddress endpoint, int backlog) throws IOException
  +   {
  +      serverSocket.bind(endpoint, backlog);
  +   }
  +   
  +   
  +   public Socket accept() throws IOException
  +   {
  +      Socket socket = serverSocket.accept();
  +      listener.socketCreated(socket);
  +      return socket;
  +   }
  +
  +
  +   public void close() throws IOException
  +   {
  +      serverSocket.close();
  +   }
  +
  +
  +   public boolean equals(Object obj)
  +   {
  +      return serverSocket.equals(obj);
  +   }
  +
  +
  +   public ServerSocketChannel getChannel()
  +   {
  +      return serverSocket.getChannel();
  +   }
  +
  +
  +   public InetAddress getInetAddress()
  +   {
  +      return serverSocket.getInetAddress();
  +   }
  +
  +
  +   public int getLocalPort()
  +   {
  +      return serverSocket.getLocalPort();
  +   }
  +
  +
  +   public SocketAddress getLocalSocketAddress()
  +   {
  +      return serverSocket.getLocalSocketAddress();
  +   }
  +
  +
  +   public int getReceiveBufferSize() throws SocketException
  +   {
  +      return serverSocket.getReceiveBufferSize();
  +   }
  +
  +
  +   public boolean getReuseAddress() throws SocketException
  +   {
  +      return serverSocket.getReuseAddress();
  +   }
  +
  +
  +   public int getSoTimeout() throws IOException
  +   {
  +      return serverSocket.getSoTimeout();
  +   }
  +
  +
  +   public int hashCode()
  +   {
  +      return serverSocket.hashCode();
  +   }
  +
  +
  +   public boolean isBound()
  +   {
  +      return serverSocket.isBound();
  +   }
  +
  +
  +   public boolean isClosed()
  +   {
  +      return serverSocket.isClosed();
  +   }
  +
  +
  +   public void setPerformancePreferences(int connectionTime, int latency, int bandwidth)
  +   {
  +      serverSocket.setPerformancePreferences(connectionTime, latency, bandwidth);
  +   }
  +
  +
  +   public void setReceiveBufferSize(int size) throws SocketException
  +   {
  +      serverSocket.setReceiveBufferSize(size);
  +   }
  +
  +
  +   public void setReuseAddress(boolean on) throws SocketException
  +   {
  +      serverSocket.setReuseAddress(on);
  +   }
  +
  +
  +   public void setSoTimeout(int timeout) throws SocketException
  +   {
  +      serverSocket.setSoTimeout(timeout);
  +   }
  +
  +
  +   public String toString()
  +   {
  +      return serverSocket.toString();
  +   }
  +}
  
  
  



More information about the jboss-cvs-commits mailing list