directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: r326489 [2/2] - in /directory/network/trunk/src/java/org/apache/mina/transport: socket/nio/ socket/nio/support/ vmpipe/ vmpipe/support/
Date Wed, 19 Oct 2005 08:56:38 GMT
Copied: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java
(from r326451, directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java
Wed Oct 19 01:56:19 2005
@@ -16,7 +16,7 @@
  *   limitations under the License.
  *
  */
-package org.apache.mina.transport.socket.nio;
+package org.apache.mina.transport.socket.nio.support;
 
 import java.net.SocketAddress;
 import java.nio.channels.SelectionKey;
@@ -33,6 +33,7 @@
 import org.apache.mina.common.support.BaseIoSession;
 import org.apache.mina.common.support.IoSessionFilterChain;
 import org.apache.mina.common.support.IoSessionManagerFilterChain;
+import org.apache.mina.transport.socket.nio.SocketSessionConfig;
 import org.apache.mina.util.Queue;
 
 /**
@@ -41,7 +42,7 @@
  * @author Trustin Lee (trustin@apache.org)
  * @version $Rev$, $Date$
  */
-class SocketSession extends BaseIoSession implements IoSession
+public class SocketSession extends BaseIoSession implements IoSession
 {
     private final IoSessionManagerFilterChain managerFilterChain;
     
@@ -66,13 +67,13 @@
     /**
      * Creates a new instance.
      */
-    SocketSession( IoSessionManagerFilterChain managerFilterChain,
+    public SocketSession( IoSessionManagerFilterChain managerFilterChain,
                    SocketChannel ch, IoHandler defaultHandler )
     {
         this.managerFilterChain = managerFilterChain;
         this.filterChain = new IoSessionFilterChain( this, managerFilterChain );
         this.ch = ch;
-        this.config = new SocketSessionConfig( this );
+        this.config = new SocketSessionConfigImpl( this );
         this.writeRequestQueue = new Queue();
         this.handler = defaultHandler;
         this.remoteAddress = ch.socket().getRemoteSocketAddress();
@@ -109,7 +110,7 @@
         return handler;
     }
     
-    public void notifyClose()
+    void notifyClose()
     {
         closeFuture.setClosed( true );
     }

Added: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java?rev=326489&view=auto
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java
(added)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java
Wed Oct 19 01:56:19 2005
@@ -0,0 +1,146 @@
+/*
+ *   @(#) $Id: SocketSessionConfig.java 326451 2005-10-19 08:07:09Z trustin $
+ *
+ *   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.mina.transport.socket.nio.support;
+
+import java.net.SocketException;
+
+import org.apache.mina.common.IoSession;
+import org.apache.mina.common.IoSessionConfig;
+import org.apache.mina.common.support.BaseIoSessionConfig;
+import org.apache.mina.transport.socket.nio.SocketAcceptor;
+import org.apache.mina.transport.socket.nio.SocketConnector;
+import org.apache.mina.transport.socket.nio.SocketSessionConfig;
+
+/**
+ * A {@link IoSessionConfig} for socket transport (TCP/IP).
+ * You can downcast {@link IoSessionConfig} instance returned by
+ * {@link IoSession#getConfig()} if you've created datagram session
+ * using {@link SocketAcceptor} or {@link SocketConnector}.
+ * 
+ * @author Trustin Lee (trustin@apache.org)
+ * @version $Rev: 326451 $, $Date: 2005-10-19 17:07:09 +0900 (수, 19 10 2005) $,
+ */
+class SocketSessionConfigImpl extends BaseIoSessionConfig implements SocketSessionConfig
+{
+    private static final int DEFAULT_READ_BUFFER_SIZE = 1024;
+
+    private final SocketSession session;
+    
+    private int readBufferSize = DEFAULT_READ_BUFFER_SIZE;
+
+    SocketSessionConfigImpl( SocketSession session )
+    {
+        this.session = session;
+    }
+
+    public boolean getKeepAlive() throws SocketException
+    {
+        return session.getChannel().socket().getKeepAlive();
+    }
+
+    public void setKeepAlive( boolean on ) throws SocketException
+    {
+        session.getChannel().socket().setKeepAlive( on );
+    }
+
+    public boolean getOOBInline() throws SocketException
+    {
+        return session.getChannel().socket().getOOBInline();
+    }
+
+    public void setOOBInline( boolean on ) throws SocketException
+    {
+        session.getChannel().socket().setOOBInline( on );
+    }
+
+    public boolean getReuseAddress() throws SocketException
+    {
+        return session.getChannel().socket().getReuseAddress();
+    }
+
+    public void setReuseAddress( boolean on ) throws SocketException
+    {
+        session.getChannel().socket().setReuseAddress( on );
+    }
+
+    public int getSoLinger() throws SocketException
+    {
+        return session.getChannel().socket().getSoLinger();
+    }
+
+    public void setSoLinger( boolean on, int linger ) throws SocketException
+    {
+        session.getChannel().socket().setSoLinger( on, linger );
+    }
+
+    public boolean getTcpNoDelay() throws SocketException
+    {
+        return session.getChannel().socket().getTcpNoDelay();
+    }
+
+    public void setTcpNoDelay( boolean on ) throws SocketException
+    {
+        session.getChannel().socket().setTcpNoDelay( on );
+    }
+
+    public int getTrafficClass() throws SocketException
+    {
+        return session.getChannel().socket().getTrafficClass();
+    }
+
+    public void setTrafficClass( int tc ) throws SocketException
+    {
+        session.getChannel().socket().setTrafficClass( tc );
+    }
+
+    public int getSendBufferSize() throws SocketException
+    {
+        return session.getChannel().socket().getSendBufferSize();
+    }
+
+    public void setSendBufferSize( int size ) throws SocketException
+    {
+        session.getChannel().socket().setSendBufferSize( size );
+    }
+
+    public int getReceiveBufferSize() throws SocketException
+    {
+        return session.getChannel().socket().getReceiveBufferSize();
+    }
+
+    public void setReceiveBufferSize( int size ) throws SocketException
+    {
+        session.getChannel().socket().setReceiveBufferSize( size );
+    }
+    
+    public int getSessionReceiveBufferSize()
+    {
+        return readBufferSize;
+    }
+    
+    public void setSessionReceiveBufferSize( int size )
+    {
+        if( size <= 0 )
+        {
+            throw new IllegalArgumentException( "Invalid session receive buffer size: " +
size );
+        }
+        
+        this.readBufferSize = size;
+    }
+}
\ No newline at end of file

Copied: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java
(from r326451, directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java
Wed Oct 19 01:56:19 2005
@@ -1,4 +1,4 @@
-package org.apache.mina.transport.socket.nio;
+package org.apache.mina.transport.socket.nio.support;
 
 import org.apache.mina.common.ByteBuffer;
 import org.apache.mina.common.IoFilterChain;
@@ -13,9 +13,9 @@
  * 
  * @author The Apache Directory Project
  */
-class SocketSessionManagerFilterChain extends IoSessionManagerFilterChain {
+public class SocketSessionManagerFilterChain extends IoSessionManagerFilterChain {
 
-    SocketSessionManagerFilterChain( IoSessionManager manager )
+    public SocketSessionManagerFilterChain( IoSessionManager manager )
     {
         super( manager );
     }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java?rev=326489&r1=326488&r2=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java
Wed Oct 19 01:56:19 2005
@@ -13,6 +13,9 @@
 import org.apache.mina.common.IoSessionManagerConfig;
 import org.apache.mina.common.support.BaseIoAcceptor;
 import org.apache.mina.common.support.BaseIoAcceptorConfig;
+import org.apache.mina.transport.vmpipe.support.VmPipe;
+import org.apache.mina.transport.vmpipe.support.VmPipeFilter;
+import org.apache.mina.transport.vmpipe.support.VmPipeSessionManagerFilterChain;
 
 /**
  * Binds the specified {@link IoHandler} to the specified
@@ -61,7 +64,7 @@
             }
 
             boundHandlers.put( address, 
-                               new Entry( this,
+                               new VmPipe( this,
                                           ( VmPipeAddress ) address,
                                           filterChain,
                                           handler ) );
@@ -97,27 +100,5 @@
     public IoFilterChain getFilterChain()
     {
         return filterChain;
-    }
-
-    static class Entry
-    {
-        final VmPipeAcceptor acceptor;
-        
-        final VmPipeAddress address;
-
-        final VmPipeSessionManagerFilterChain managerFilterChain;
-
-        final IoHandler handler;
-        
-        private Entry( VmPipeAcceptor acceptor,
-                       VmPipeAddress address,
-                       VmPipeSessionManagerFilterChain managerFilterChain,
-                       IoHandler handler )
-        {
-            this.acceptor = acceptor;
-            this.address = address;
-            this.managerFilterChain = managerFilterChain;
-            this.handler = handler;
-        }
     }
 }

Modified: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java?rev=326489&r1=326488&r2=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
Wed Oct 19 01:56:19 2005
@@ -13,7 +13,11 @@
 import org.apache.mina.common.IoSessionManagerConfig;
 import org.apache.mina.common.support.BaseIoConnectorConfig;
 import org.apache.mina.common.support.BaseIoSessionManager;
-import org.apache.mina.transport.vmpipe.VmPipeAcceptor.Entry;
+import org.apache.mina.transport.vmpipe.support.VmPipe;
+import org.apache.mina.transport.vmpipe.support.VmPipeFilter;
+import org.apache.mina.transport.vmpipe.support.VmPipeIdleStatusChecker;
+import org.apache.mina.transport.vmpipe.support.VmPipeSession;
+import org.apache.mina.transport.vmpipe.support.VmPipeSessionManagerFilterChain;
 import org.apache.mina.util.AnonymousSocketAddress;
 
 /**
@@ -72,7 +76,7 @@
             throw new IllegalArgumentException(
                                                 "address must be VmPipeAddress." );
 
-        Entry entry = ( Entry ) VmPipeAcceptor.boundHandlers.get( address );
+        VmPipe entry = ( VmPipe ) VmPipeAcceptor.boundHandlers.get( address );
         if( entry == null )
             throw new IOException( "Endpoint unavailable: " + address );
 
@@ -82,7 +86,7 @@
                                                    handler,
                                                    entry );
 
-        VmPipeIdleStatusChecker.INSTANCE.addSession( session );
+        VmPipeIdleStatusChecker.getInstance().addSession( session );
         ConnectFuture future = new ConnectFuture();
         future.setSession( session );
         return future;

Added: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java?rev=326489&view=auto
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
(added)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
Wed Oct 19 01:56:19 2005
@@ -0,0 +1,47 @@
+/*
+ * @(#) $Id$
+ */
+package org.apache.mina.transport.vmpipe.support;
+
+import org.apache.mina.common.IoHandler;
+import org.apache.mina.transport.vmpipe.VmPipeAcceptor;
+import org.apache.mina.transport.vmpipe.VmPipeAddress;
+
+public class VmPipe
+{
+    private final VmPipeAcceptor acceptor;
+    private final VmPipeAddress address;
+    private final VmPipeSessionManagerFilterChain managerFilterChain;
+    private final IoHandler handler;
+    
+    public VmPipe( VmPipeAcceptor acceptor,
+                   VmPipeAddress address,
+                   VmPipeSessionManagerFilterChain managerFilterChain,
+                   IoHandler handler )
+    {
+        this.acceptor = acceptor;
+        this.address = address;
+        this.managerFilterChain = managerFilterChain;
+        this.handler = handler;
+    }
+
+    public VmPipeAcceptor getAcceptor()
+    {
+        return acceptor;
+    }
+
+    public VmPipeAddress getAddress()
+    {
+        return address;
+    }
+
+    public IoHandler getHandler()
+    {
+        return handler;
+    }
+
+    public VmPipeSessionManagerFilterChain getManagerFilterChain()
+    {
+        return managerFilterChain;
+    }
+}
\ No newline at end of file

Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java
(from r326410, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java&r1=326410&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java
Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
 /*
  * @(#) $Id$
  */
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
 
 import org.apache.mina.common.IdleStatus;
 import org.apache.mina.common.IoFilterAdapter;
@@ -13,7 +13,7 @@
  * @author Trustin Lee (trustin@apache.org)
  * @version $Rev$, $Date$
  */
-class VmPipeFilter extends IoFilterAdapter
+public class VmPipeFilter extends IoFilterAdapter
 {
     public void messageReceived( NextFilter nextFilter,
                                  IoSession session, Object message )

Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java
(from r326410, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java&r1=326410&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java
Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
 /*
  * @(#) $Id$
  */
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
 
 import java.util.IdentityHashMap;
 import java.util.Iterator;
@@ -16,9 +16,14 @@
  * @author Trustin Lee (trustin@apache.org)
  * @version $Rev$, $Date$
  */
-class VmPipeIdleStatusChecker
+public class VmPipeIdleStatusChecker
 {
-    static final VmPipeIdleStatusChecker INSTANCE = new VmPipeIdleStatusChecker();
+    private static final VmPipeIdleStatusChecker INSTANCE = new VmPipeIdleStatusChecker();
+    
+    public static VmPipeIdleStatusChecker getInstance()
+    {
+        return INSTANCE;
+    }
 
     private final Map sessions = new IdentityHashMap(); // will use as a set
 
@@ -29,7 +34,7 @@
         worker.start();
     }
 
-    void addSession( VmPipeSession session )
+    public void addSession( VmPipeSession session )
     {
         synchronized( sessions )
         {

Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java
(from r326451, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java
Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
 /*
  * @(#) $Id$
  */
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
 
 import java.io.IOException;
 import java.net.SocketAddress;
@@ -18,7 +18,7 @@
 import org.apache.mina.common.support.IoSessionFilterChain;
 import org.apache.mina.filter.codec.ProtocolDecoder;
 import org.apache.mina.filter.codec.ProtocolEncoder;
-import org.apache.mina.transport.vmpipe.VmPipeAcceptor.Entry;
+import org.apache.mina.transport.vmpipe.VmPipeSessionConfig;
 import org.apache.mina.util.ExceptionUtil;
 
 /**
@@ -27,7 +27,7 @@
  * @author Trustin Lee (trustin@apache.org)
  * @version $Rev$, $Date$
  */
-class VmPipeSession extends BaseIoSession implements IoSession
+public class VmPipeSession extends BaseIoSession implements IoSession
 {
     private final SocketAddress localAddress;
 
@@ -50,14 +50,14 @@
     /**
      * Constructor for client-side session.
      */
-    VmPipeSession( Object lock, SocketAddress localAddress,
+    public VmPipeSession( Object lock, SocketAddress localAddress,
                    VmPipeSessionManagerFilterChain managerFilterChain,
                    IoHandler handler,
-                   Entry remoteEntry ) throws IOException
+                   VmPipe remoteEntry ) throws IOException
     {
         this.lock = lock;
         this.localAddress = localAddress;
-        this.remoteAddress = remoteEntry.address;
+        this.remoteAddress = remoteEntry.getAddress();
         this.handler = handler;
         this.filterChain = new IoSessionFilterChain( this, managerFilterChain );
         this.managerFilterChain = managerFilterChain;
@@ -67,11 +67,11 @@
         // initialize remote session
         try
         {
-            remoteEntry.handler.sessionCreated( remoteSession );
+            remoteEntry.getHandler().sessionCreated( remoteSession );
         }
         catch( Throwable t )
         {
-            remoteEntry.acceptor.getExceptionMonitor().exceptionCaught( remoteEntry.acceptor,
t );
+            remoteEntry.getAcceptor().getExceptionMonitor().exceptionCaught( remoteEntry.getAcceptor(),
t );
             IOException e = new IOException( "Failed to initialize remote session." );
             e.initCause( t );
             throw e;
@@ -87,21 +87,21 @@
             ExceptionUtil.throwException( t );
         }
 
-        remoteEntry.managerFilterChain.sessionOpened( remoteSession );
+        remoteEntry.getManagerFilterChain().sessionOpened( remoteSession );
         managerFilterChain.sessionOpened( this );
     }
 
     /**
      * Constructor for server-side session.
      */
-    VmPipeSession( VmPipeSession remoteSession, Entry entry )
+    private VmPipeSession( VmPipeSession remoteSession, VmPipe entry )
     {
         this.lock = remoteSession.lock;
         this.localAddress = remoteSession.remoteAddress;
         this.remoteAddress = remoteSession.localAddress;
-        this.handler = entry.handler;
-        this.managerFilterChain = entry.managerFilterChain;
-        this.filterChain = new IoSessionFilterChain( this, entry.managerFilterChain );
+        this.handler = entry.getHandler();
+        this.managerFilterChain = entry.getManagerFilterChain();
+        this.filterChain = new IoSessionFilterChain( this, entry.getManagerFilterChain()
);
         this.remoteSession = remoteSession;
     }
     

Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java
(from r326451, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java
(original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java
Wed Oct 19 01:56:19 2005
@@ -1,13 +1,13 @@
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
 
 import org.apache.mina.common.IoSession;
 import org.apache.mina.common.IoSessionManager;
 import org.apache.mina.common.IoFilter.WriteRequest;
 import org.apache.mina.common.support.IoSessionManagerFilterChain;
 
-class VmPipeSessionManagerFilterChain extends IoSessionManagerFilterChain {
+public class VmPipeSessionManagerFilterChain extends IoSessionManagerFilterChain {
 
-    VmPipeSessionManagerFilterChain( IoSessionManager manager )
+    public VmPipeSessionManagerFilterChain( IoSessionManager manager )
     {
         super( manager );
     }



Mime
View raw message