You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by ak...@apache.org on 2006/02/12 06:51:22 UTC
svn commit: r377135 [21/36] - in /directory/sandbox/akarasulu/rc1:
apacheds/core-plugin/src/main/java/org/apache/directory/server/core/tools/schema/
apacheds/core-plugin/src/test/java/org/apache/directory/server/core/tools/schema/
apacheds/core-shared/...
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeSession.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeSession.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeFilterChain.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeFilterChain.java
------------------------------------------------------------------------------
--- svn:keywords (added)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -0,0 +1,4 @@
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/AnonymousSocketAddress.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/AnonymousSocketAddress.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/AvailablePortFinder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/AvailablePortFinder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/BlockingQueue.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/BlockingQueue.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/ByteBufferUtil.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/ByteBufferUtil.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/CharsetUtil.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/CharsetUtil.java
------------------------------------------------------------------------------
--- svn:keywords (added)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -0,0 +1,4 @@
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/IdentityHashSet.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/IdentityHashSet.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/Queue.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/Queue.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/SessionLog.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/SessionLog.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/SessionUtil.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/SessionUtil.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/Stack.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/main/java/org/apache/mina/util/Stack.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/ByteBufferTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/ByteBufferTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Modified: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java
URL: http://svn.apache.org/viewcvs/directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java?rev=377135&r1=377134&r2=377135&view=diff
==============================================================================
--- directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java (original)
+++ directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java Sat Feb 11 21:50:03 2006
@@ -1,5 +1,5 @@
/*
- * @(#) $Id: ExceptionMonitor.java 326586 2005-10-19 15:50:29Z trustin $
+ * @(#) $Id$
*
* Copyright 2004 The Apache Software Foundation
*
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java
------------------------------------------------------------------------------
--- svn:keywords (added)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -0,0 +1,4 @@
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/FutureTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/FutureTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/IoFilterChainTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/IoFilterChainTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/TransportTypeTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/common/TransportTypeTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Modified: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java
URL: http://svn.apache.org/viewcvs/directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java?rev=377135&r1=377134&r2=377135&view=diff
==============================================================================
--- directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java (original)
+++ directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java Sat Feb 11 21:50:03 2006
@@ -1,525 +1,525 @@
-/*
- * @(#) $Id$
- *
- * 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.filter;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.InetSocketAddress;
-import java.net.SocketAddress;
-import java.security.MessageDigest;
-import java.util.Random;
-
-import junit.framework.TestCase;
-
-import org.apache.mina.common.ByteBuffer;
-import org.apache.mina.common.IdleStatus;
-import org.apache.mina.common.IoHandlerAdapter;
-import org.apache.mina.common.IoSession;
-import org.apache.mina.common.TransportType;
-import org.apache.mina.common.IoFilter.NextFilter;
-import org.apache.mina.common.IoFilter.WriteRequest;
-import org.apache.mina.registry.Service;
-import org.apache.mina.registry.ServiceRegistry;
-import org.apache.mina.registry.SimpleServiceRegistry;
-import org.apache.mina.transport.socket.nio.SocketAcceptor;
-import org.apache.mina.transport.socket.nio.SocketConnector;
-import org.apache.mina.util.AvailablePortFinder;
-import org.easymock.AbstractMatcher;
-import org.easymock.MockControl;
-
-/**
- * Tests {@link StreamWriteFilter}.
- *
- * @author The Apache Directory Project (dev@directory.apache.org)
- * @version $Rev$, $Date$
- */
-public class StreamWriteFilterTest extends TestCase {
- MockControl mockSession;
- MockControl mockNextFilter;
- IoSession session;
- NextFilter nextFilter;
-
- protected void setUp() throws Exception
- {
- super.setUp();
-
- /*
- * Create the mocks.
- */
- mockSession = MockControl.createControl( IoSession.class );
- mockNextFilter = MockControl.createControl( NextFilter.class );
- session = ( IoSession ) mockSession.getMock();
- nextFilter = ( NextFilter ) mockNextFilter.getMock();
-
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( null );
- }
-
- public void testWriteEmptyStream() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
-
- InputStream stream = new ByteArrayInputStream( new byte[ 0 ] );
- WriteRequest writeRequest = new WriteRequest( stream );
-
- /*
- * Record expectations
- */
- nextFilter.messageSent( session, stream );
-
- /*
- * Replay.
- */
- mockNextFilter.replay();
- mockSession.replay();
-
- filter.filterWrite( nextFilter, session, writeRequest );
-
- /*
- * Verify.
- */
- mockNextFilter.verify();
- mockSession.verify();
-
- assertTrue( writeRequest.getFuture().isWritten() );
- }
-
- /**
- * Tests that the filter just passes objects which aren't InputStreams
- * through to the next filter.
- */
- public void testWriteNonStreamMessage() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
-
- Object message = new Object();
- WriteRequest writeRequest = new WriteRequest( message );
-
- /*
- * Record expectations
- */
- nextFilter.filterWrite( session, writeRequest );
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( null );
- nextFilter.messageSent( session, message );
-
- /*
- * Replay.
- */
- mockNextFilter.replay();
- mockSession.replay();
-
- filter.filterWrite( nextFilter, session, writeRequest );
- filter.messageSent( nextFilter, session, message );
-
- /*
- * Verify.
- */
- mockNextFilter.verify();
- mockSession.verify();
-
- assertTrue( writeRequest.getFuture().isWritten() );
- }
-
- /**
- * Tests when the contents of the stream fits into one write buffer.
- */
- public void testWriteSingleBufferStream() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
-
- byte[] data = new byte[] { 1, 2, 3, 4 };
-
- InputStream stream = new ByteArrayInputStream( data );
- WriteRequest writeRequest = new WriteRequest( stream );
-
- /*
- * Record expectations
- */
- session.setAttribute( StreamWriteFilter.CURRENT_STREAM, stream );
- mockSession.setReturnValue(null);
- session.setAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE, writeRequest.getFuture() );
- mockSession.setReturnValue(null);
- nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( data ) ) );
- mockNextFilter.setMatcher( new WriteRequestMatcher() );
-
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- session.removeAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- session.removeAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE );
- mockSession.setReturnValue( writeRequest.getFuture() );
- nextFilter.messageSent( session, stream );
-
- /*
- * Replay.
- */
- mockNextFilter.replay();
- mockSession.replay();
-
- filter.filterWrite( nextFilter, session, writeRequest );
- filter.messageSent( nextFilter, session, data );
-
- /*
- * Verify.
- */
- mockNextFilter.verify();
- mockSession.verify();
-
- assertTrue( writeRequest.getFuture().isWritten() );
- }
-
- /**
- * Tests when the contents of the stream doesn't fit into one write buffer.
- */
- public void testWriteSeveralBuffersStream() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
- filter.setWriteBufferSize( 4 );
-
- byte[] data = new byte[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
- byte[] chunk1 = new byte[] { 1, 2, 3, 4 };
- byte[] chunk2 = new byte[] { 5, 6, 7, 8 };
- byte[] chunk3 = new byte[] { 9, 10 };
-
- InputStream stream = new ByteArrayInputStream( data );
- WriteRequest writeRequest = new WriteRequest( stream );
-
- /*
- * Record expectations
- */
- session.setAttribute( StreamWriteFilter.CURRENT_STREAM, stream );
- mockSession.setReturnValue(null);
- session.setAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE, writeRequest.getFuture() );
- mockSession.setReturnValue(null);
- nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk1 ) ) );
- mockNextFilter.setMatcher( new WriteRequestMatcher() );
-
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk2 ) ) );
-
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk3 ) ) );
-
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- session.removeAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
- session.removeAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE );
- mockSession.setReturnValue( writeRequest.getFuture() );
- nextFilter.messageSent( session, stream );
-
- /*
- * Replay.
- */
- mockNextFilter.replay();
- mockSession.replay();
-
- filter.filterWrite( nextFilter, session, writeRequest );
- filter.messageSent( nextFilter, session, chunk1 );
- filter.messageSent( nextFilter, session, chunk2 );
- filter.messageSent( nextFilter, session, chunk3 );
-
- /*
- * Verify.
- */
- mockNextFilter.verify();
- mockSession.verify();
-
- assertTrue( writeRequest.getFuture().isWritten() );
- }
-
- public void testWriteWhileWriteInProgress() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
-
- InputStream stream = new ByteArrayInputStream( new byte[ 5 ] );
-
- /*
- * Record expectations
- */
- mockSession.reset();
- session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
- mockSession.setReturnValue( stream );
-
- /*
- * Replay.
- */
- mockNextFilter.replay();
- mockSession.replay();
-
- try
- {
- filter.filterWrite( nextFilter, session, new WriteRequest( new Object() ) );
- fail( "Alreday processing a stream. IllegalStateException expected." );
- }
- catch ( IllegalStateException ise )
- {
- }
-
- /*
- * Verify.
- */
- mockNextFilter.verify();
- mockSession.verify();
- }
-
- /**
- * Tests that {@link StreamWriteFilter#setWriteBufferSize(int)} checks the
- * specified size.
- */
- public void testSetWriteBufferSize() throws Exception
- {
- StreamWriteFilter filter = new StreamWriteFilter();
-
- try
- {
- filter.setWriteBufferSize( 0 );
- fail( "0 writeBuferSize specified. IllegalArgumentException expected." );
- }
- catch ( IllegalArgumentException iae )
- {
- }
-
- try
- {
- filter.setWriteBufferSize( -100 );
- fail( "Negative writeBuferSize specified. IllegalArgumentException expected." );
- }
- catch ( IllegalArgumentException iae )
- {
- }
-
- filter.setWriteBufferSize( 1 );
- assertEquals( 1, filter.getWriteBufferSize() );
- filter.setWriteBufferSize( 1024 );
- assertEquals( 1024, filter.getWriteBufferSize() );
- }
-
- public void testWriteUsingSocketTransport() throws Exception
- {
- ServiceRegistry reg = new SimpleServiceRegistry();
- ( ( SocketAcceptor ) reg.getAcceptor( TransportType.SOCKET ) ).setReuseAddress( true );
- SocketAddress address = new InetSocketAddress( "localhost", AvailablePortFinder.getNextAvailable() );
- Service service = new Service( "stream", TransportType.SOCKET, address );
-
- SocketConnector connector = new SocketConnector();
- connector.getFilterChain().addFirst( "threadPool", new ThreadPoolFilter() );
-
- FixedRandomInputStream stream = new FixedRandomInputStream( 4 * 1024 * 1024 );
-
- SenderHandler sender = new SenderHandler( stream );
- ReceiverHandler receiver = new ReceiverHandler( stream.size );
-
- reg.bind( service, sender );
-
- synchronized( sender.lock )
- {
- synchronized( receiver.lock )
- {
- connector.connect( address, receiver );
-
- sender.lock.wait();
- receiver.lock.wait();
- }
- }
-
- reg.unbindAll();
-
- assertEquals( stream.bytesRead, receiver.bytesRead );
- assertEquals( stream.size, receiver.bytesRead );
- byte[] expectedMd5 = stream.digest.digest();
- byte[] actualMd5 = receiver.digest.digest();
- assertEquals( expectedMd5.length, actualMd5.length );
- for( int i = 0; i < expectedMd5.length; i++ )
- {
- assertEquals( expectedMd5[ i ], actualMd5[ i ] );
- }
- }
-
- private static class FixedRandomInputStream extends InputStream
- {
- long size;
- long bytesRead = 0;
- Random random = new Random();
- MessageDigest digest;
-
- public FixedRandomInputStream( long size ) throws Exception
- {
- this.size = size;
- digest = MessageDigest.getInstance( "MD5" );
- }
-
- public int read() throws IOException
- {
- if ( isAllWritten() )
- return -1;
- bytesRead++;
- byte b = ( byte ) random.nextInt( 255 );
- digest.update( b );
- return b;
- }
-
- public long getBytesRead()
- {
- return bytesRead;
- }
-
- public long getSize()
- {
- return size;
- }
-
- public boolean isAllWritten()
- {
- return bytesRead >= size;
- }
- }
-
- private static class SenderHandler extends IoHandlerAdapter
- {
- Object lock = new Object();
- InputStream inputStream;
- StreamWriteFilter streamWriteFilter = new StreamWriteFilter();
-
- public SenderHandler( InputStream inputStream )
- {
- this.inputStream = inputStream;
- }
-
- public void sessionCreated(IoSession session) throws Exception {
- super.sessionCreated( session );
- session.getFilterChain().addLast( "codec", streamWriteFilter );
- }
-
- public void sessionOpened(IoSession session) throws Exception {
- session.write( inputStream );
- }
-
- public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
-
- public void sessionClosed( IoSession session ) throws Exception
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
-
- public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
-
- public void messageSent( IoSession session, Object message ) throws Exception
- {
- if( message == inputStream )
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
- }
- }
-
- private static class ReceiverHandler extends IoHandlerAdapter
- {
- Object lock = new Object();
- long bytesRead = 0;
- long size = 0;
- MessageDigest digest;
-
- public ReceiverHandler( long size ) throws Exception
- {
- this.size = size;
- digest = MessageDigest.getInstance( "MD5" );
- }
-
- public void sessionCreated( IoSession session ) throws Exception
- {
- super.sessionCreated(session);
-
- session.setIdleTime( IdleStatus.READER_IDLE, 5 );
- }
-
- public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
- {
- session.close();
- }
-
- public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
-
- public void sessionClosed( IoSession session ) throws Exception
- {
- synchronized( lock )
- {
- lock.notifyAll();
- }
- }
-
- public void messageReceived( IoSession session, Object message ) throws Exception
- {
- ByteBuffer buf = ( ByteBuffer ) message;
- while( buf.hasRemaining() )
- {
- digest.update( buf.get() );
- bytesRead++;
- }
- if( bytesRead >= size )
- {
- session.close();
- }
- }
- }
-
- public static class WriteRequestMatcher extends AbstractMatcher
- {
- protected boolean argumentMatches( Object expected, Object actual )
- {
- if( expected instanceof WriteRequest && expected instanceof WriteRequest )
- {
- WriteRequest w1 = ( WriteRequest ) expected;
- WriteRequest w2 = ( WriteRequest ) actual;
-
- return w1.getMessage().equals( w2.getMessage() )
- && w1.getFuture().isWritten() == w2.getFuture().isWritten();
- }
- return super.argumentMatches( expected, actual );
- }
- }
-}
+/*
+ * @(#) $Id$
+ *
+ * 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.filter;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+import java.security.MessageDigest;
+import java.util.Random;
+
+import junit.framework.TestCase;
+
+import org.apache.mina.common.ByteBuffer;
+import org.apache.mina.common.IdleStatus;
+import org.apache.mina.common.IoHandlerAdapter;
+import org.apache.mina.common.IoSession;
+import org.apache.mina.common.TransportType;
+import org.apache.mina.common.IoFilter.NextFilter;
+import org.apache.mina.common.IoFilter.WriteRequest;
+import org.apache.mina.registry.Service;
+import org.apache.mina.registry.ServiceRegistry;
+import org.apache.mina.registry.SimpleServiceRegistry;
+import org.apache.mina.transport.socket.nio.SocketAcceptor;
+import org.apache.mina.transport.socket.nio.SocketConnector;
+import org.apache.mina.util.AvailablePortFinder;
+import org.easymock.AbstractMatcher;
+import org.easymock.MockControl;
+
+/**
+ * Tests {@link StreamWriteFilter}.
+ *
+ * @author The Apache Directory Project (dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class StreamWriteFilterTest extends TestCase {
+ MockControl mockSession;
+ MockControl mockNextFilter;
+ IoSession session;
+ NextFilter nextFilter;
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ /*
+ * Create the mocks.
+ */
+ mockSession = MockControl.createControl( IoSession.class );
+ mockNextFilter = MockControl.createControl( NextFilter.class );
+ session = ( IoSession ) mockSession.getMock();
+ nextFilter = ( NextFilter ) mockNextFilter.getMock();
+
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( null );
+ }
+
+ public void testWriteEmptyStream() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+
+ InputStream stream = new ByteArrayInputStream( new byte[ 0 ] );
+ WriteRequest writeRequest = new WriteRequest( stream );
+
+ /*
+ * Record expectations
+ */
+ nextFilter.messageSent( session, stream );
+
+ /*
+ * Replay.
+ */
+ mockNextFilter.replay();
+ mockSession.replay();
+
+ filter.filterWrite( nextFilter, session, writeRequest );
+
+ /*
+ * Verify.
+ */
+ mockNextFilter.verify();
+ mockSession.verify();
+
+ assertTrue( writeRequest.getFuture().isWritten() );
+ }
+
+ /**
+ * Tests that the filter just passes objects which aren't InputStreams
+ * through to the next filter.
+ */
+ public void testWriteNonStreamMessage() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+
+ Object message = new Object();
+ WriteRequest writeRequest = new WriteRequest( message );
+
+ /*
+ * Record expectations
+ */
+ nextFilter.filterWrite( session, writeRequest );
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( null );
+ nextFilter.messageSent( session, message );
+
+ /*
+ * Replay.
+ */
+ mockNextFilter.replay();
+ mockSession.replay();
+
+ filter.filterWrite( nextFilter, session, writeRequest );
+ filter.messageSent( nextFilter, session, message );
+
+ /*
+ * Verify.
+ */
+ mockNextFilter.verify();
+ mockSession.verify();
+
+ assertTrue( writeRequest.getFuture().isWritten() );
+ }
+
+ /**
+ * Tests when the contents of the stream fits into one write buffer.
+ */
+ public void testWriteSingleBufferStream() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+
+ byte[] data = new byte[] { 1, 2, 3, 4 };
+
+ InputStream stream = new ByteArrayInputStream( data );
+ WriteRequest writeRequest = new WriteRequest( stream );
+
+ /*
+ * Record expectations
+ */
+ session.setAttribute( StreamWriteFilter.CURRENT_STREAM, stream );
+ mockSession.setReturnValue(null);
+ session.setAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE, writeRequest.getFuture() );
+ mockSession.setReturnValue(null);
+ nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( data ) ) );
+ mockNextFilter.setMatcher( new WriteRequestMatcher() );
+
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ session.removeAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ session.removeAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE );
+ mockSession.setReturnValue( writeRequest.getFuture() );
+ nextFilter.messageSent( session, stream );
+
+ /*
+ * Replay.
+ */
+ mockNextFilter.replay();
+ mockSession.replay();
+
+ filter.filterWrite( nextFilter, session, writeRequest );
+ filter.messageSent( nextFilter, session, data );
+
+ /*
+ * Verify.
+ */
+ mockNextFilter.verify();
+ mockSession.verify();
+
+ assertTrue( writeRequest.getFuture().isWritten() );
+ }
+
+ /**
+ * Tests when the contents of the stream doesn't fit into one write buffer.
+ */
+ public void testWriteSeveralBuffersStream() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+ filter.setWriteBufferSize( 4 );
+
+ byte[] data = new byte[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
+ byte[] chunk1 = new byte[] { 1, 2, 3, 4 };
+ byte[] chunk2 = new byte[] { 5, 6, 7, 8 };
+ byte[] chunk3 = new byte[] { 9, 10 };
+
+ InputStream stream = new ByteArrayInputStream( data );
+ WriteRequest writeRequest = new WriteRequest( stream );
+
+ /*
+ * Record expectations
+ */
+ session.setAttribute( StreamWriteFilter.CURRENT_STREAM, stream );
+ mockSession.setReturnValue(null);
+ session.setAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE, writeRequest.getFuture() );
+ mockSession.setReturnValue(null);
+ nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk1 ) ) );
+ mockNextFilter.setMatcher( new WriteRequestMatcher() );
+
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk2 ) ) );
+
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ nextFilter.filterWrite( session, new WriteRequest( ByteBuffer.wrap( chunk3 ) ) );
+
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ session.removeAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+ session.removeAttribute( StreamWriteFilter.INITIAL_WRITE_FUTURE );
+ mockSession.setReturnValue( writeRequest.getFuture() );
+ nextFilter.messageSent( session, stream );
+
+ /*
+ * Replay.
+ */
+ mockNextFilter.replay();
+ mockSession.replay();
+
+ filter.filterWrite( nextFilter, session, writeRequest );
+ filter.messageSent( nextFilter, session, chunk1 );
+ filter.messageSent( nextFilter, session, chunk2 );
+ filter.messageSent( nextFilter, session, chunk3 );
+
+ /*
+ * Verify.
+ */
+ mockNextFilter.verify();
+ mockSession.verify();
+
+ assertTrue( writeRequest.getFuture().isWritten() );
+ }
+
+ public void testWriteWhileWriteInProgress() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+
+ InputStream stream = new ByteArrayInputStream( new byte[ 5 ] );
+
+ /*
+ * Record expectations
+ */
+ mockSession.reset();
+ session.getAttribute( StreamWriteFilter.CURRENT_STREAM );
+ mockSession.setReturnValue( stream );
+
+ /*
+ * Replay.
+ */
+ mockNextFilter.replay();
+ mockSession.replay();
+
+ try
+ {
+ filter.filterWrite( nextFilter, session, new WriteRequest( new Object() ) );
+ fail( "Alreday processing a stream. IllegalStateException expected." );
+ }
+ catch ( IllegalStateException ise )
+ {
+ }
+
+ /*
+ * Verify.
+ */
+ mockNextFilter.verify();
+ mockSession.verify();
+ }
+
+ /**
+ * Tests that {@link StreamWriteFilter#setWriteBufferSize(int)} checks the
+ * specified size.
+ */
+ public void testSetWriteBufferSize() throws Exception
+ {
+ StreamWriteFilter filter = new StreamWriteFilter();
+
+ try
+ {
+ filter.setWriteBufferSize( 0 );
+ fail( "0 writeBuferSize specified. IllegalArgumentException expected." );
+ }
+ catch ( IllegalArgumentException iae )
+ {
+ }
+
+ try
+ {
+ filter.setWriteBufferSize( -100 );
+ fail( "Negative writeBuferSize specified. IllegalArgumentException expected." );
+ }
+ catch ( IllegalArgumentException iae )
+ {
+ }
+
+ filter.setWriteBufferSize( 1 );
+ assertEquals( 1, filter.getWriteBufferSize() );
+ filter.setWriteBufferSize( 1024 );
+ assertEquals( 1024, filter.getWriteBufferSize() );
+ }
+
+ public void testWriteUsingSocketTransport() throws Exception
+ {
+ ServiceRegistry reg = new SimpleServiceRegistry();
+ ( ( SocketAcceptor ) reg.getAcceptor( TransportType.SOCKET ) ).setReuseAddress( true );
+ SocketAddress address = new InetSocketAddress( "localhost", AvailablePortFinder.getNextAvailable() );
+ Service service = new Service( "stream", TransportType.SOCKET, address );
+
+ SocketConnector connector = new SocketConnector();
+ connector.getFilterChain().addFirst( "threadPool", new ThreadPoolFilter() );
+
+ FixedRandomInputStream stream = new FixedRandomInputStream( 4 * 1024 * 1024 );
+
+ SenderHandler sender = new SenderHandler( stream );
+ ReceiverHandler receiver = new ReceiverHandler( stream.size );
+
+ reg.bind( service, sender );
+
+ synchronized( sender.lock )
+ {
+ synchronized( receiver.lock )
+ {
+ connector.connect( address, receiver );
+
+ sender.lock.wait();
+ receiver.lock.wait();
+ }
+ }
+
+ reg.unbindAll();
+
+ assertEquals( stream.bytesRead, receiver.bytesRead );
+ assertEquals( stream.size, receiver.bytesRead );
+ byte[] expectedMd5 = stream.digest.digest();
+ byte[] actualMd5 = receiver.digest.digest();
+ assertEquals( expectedMd5.length, actualMd5.length );
+ for( int i = 0; i < expectedMd5.length; i++ )
+ {
+ assertEquals( expectedMd5[ i ], actualMd5[ i ] );
+ }
+ }
+
+ private static class FixedRandomInputStream extends InputStream
+ {
+ long size;
+ long bytesRead = 0;
+ Random random = new Random();
+ MessageDigest digest;
+
+ public FixedRandomInputStream( long size ) throws Exception
+ {
+ this.size = size;
+ digest = MessageDigest.getInstance( "MD5" );
+ }
+
+ public int read() throws IOException
+ {
+ if ( isAllWritten() )
+ return -1;
+ bytesRead++;
+ byte b = ( byte ) random.nextInt( 255 );
+ digest.update( b );
+ return b;
+ }
+
+ public long getBytesRead()
+ {
+ return bytesRead;
+ }
+
+ public long getSize()
+ {
+ return size;
+ }
+
+ public boolean isAllWritten()
+ {
+ return bytesRead >= size;
+ }
+ }
+
+ private static class SenderHandler extends IoHandlerAdapter
+ {
+ Object lock = new Object();
+ InputStream inputStream;
+ StreamWriteFilter streamWriteFilter = new StreamWriteFilter();
+
+ public SenderHandler( InputStream inputStream )
+ {
+ this.inputStream = inputStream;
+ }
+
+ public void sessionCreated(IoSession session) throws Exception {
+ super.sessionCreated( session );
+ session.getFilterChain().addLast( "codec", streamWriteFilter );
+ }
+
+ public void sessionOpened(IoSession session) throws Exception {
+ session.write( inputStream );
+ }
+
+ public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+
+ public void sessionClosed( IoSession session ) throws Exception
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+
+ public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+
+ public void messageSent( IoSession session, Object message ) throws Exception
+ {
+ if( message == inputStream )
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+ }
+ }
+
+ private static class ReceiverHandler extends IoHandlerAdapter
+ {
+ Object lock = new Object();
+ long bytesRead = 0;
+ long size = 0;
+ MessageDigest digest;
+
+ public ReceiverHandler( long size ) throws Exception
+ {
+ this.size = size;
+ digest = MessageDigest.getInstance( "MD5" );
+ }
+
+ public void sessionCreated( IoSession session ) throws Exception
+ {
+ super.sessionCreated(session);
+
+ session.setIdleTime( IdleStatus.READER_IDLE, 5 );
+ }
+
+ public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
+ {
+ session.close();
+ }
+
+ public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+
+ public void sessionClosed( IoSession session ) throws Exception
+ {
+ synchronized( lock )
+ {
+ lock.notifyAll();
+ }
+ }
+
+ public void messageReceived( IoSession session, Object message ) throws Exception
+ {
+ ByteBuffer buf = ( ByteBuffer ) message;
+ while( buf.hasRemaining() )
+ {
+ digest.update( buf.get() );
+ bytesRead++;
+ }
+ if( bytesRead >= size )
+ {
+ session.close();
+ }
+ }
+ }
+
+ public static class WriteRequestMatcher extends AbstractMatcher
+ {
+ protected boolean argumentMatches( Object expected, Object actual )
+ {
+ if( expected instanceof WriteRequest && expected instanceof WriteRequest )
+ {
+ WriteRequest w1 = ( WriteRequest ) expected;
+ WriteRequest w2 = ( WriteRequest ) actual;
+
+ return w1.getMessage().equals( w2.getMessage() )
+ && w1.getFuture().isWritten() == w2.getFuture().isWritten();
+ }
+ return super.argumentMatches( expected, actual );
+ }
+ }
+}
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/StreamWriteFilterTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/ThreadPoolFilterRegressionTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/ThreadPoolFilterRegressionTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/CumulativeProtocolDecoderTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/CumulativeProtocolDecoderTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineDecoderTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineDecoderTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineEncoderTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineEncoderTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/handler/chain/ChainedIoHandlerTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/handler/chain/ChainedIoHandlerTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/handler/demux/DemuxingIoHandlerTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/handler/demux/DemuxingIoHandlerTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/AbstractBindTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/AbstractBindTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/AbstractTrafficControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/AbstractTrafficControlTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramBindTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramBindTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramTrafficControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramTrafficControlTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/SocketBindTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/SocketBindTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/SocketTrafficControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/socket/nio/SocketTrafficControlTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeBindTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeBindTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeTrafficControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeTrafficControlTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
+Rev
+Revision
+Date
Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/CharsetUtilTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/CharsetUtilTest.java
------------------------------------------------------------------------------
--- svn:keywords (added)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -0,0 +1,4 @@
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/IoFilterImpl.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/IoFilterImpl.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/QueueTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/core/src/test/java/org/apache/mina/util/QueueTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/EchoProtocolHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/EchoProtocolHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/Main.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/Main.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/BogusSSLContextFactory.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/BogusSSLContextFactory.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/BogusTrustManagerFactory.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/BogusTrustManagerFactory.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/SSLServerSocketFactory.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/SSLServerSocketFactory.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/SSLSocketFactory.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/echoserver/ssl/SSLSocketFactory.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/httpserver/HttpProtocolHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/httpserver/HttpProtocolHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/httpserver/Main.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/httpserver/Main.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/netcat/Main.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/netcat/Main.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/netcat/NetCatProtocolHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/netcat/NetCatProtocolHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/reverser/Main.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/reverser/Main.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/reverser/ReverseProtocolHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/reverser/ReverseProtocolHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/Client.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/Client.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/ClientSessionHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/ClientSessionHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/Server.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/Server.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/ServerSessionHandler.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/ServerSessionHandler.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AbstractMessageDecoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AbstractMessageDecoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AbstractMessageEncoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AbstractMessageEncoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AddMessageDecoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AddMessageDecoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AddMessageEncoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/AddMessageEncoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/Constants.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/Constants.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/ResultMessageDecoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/ResultMessageDecoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/ResultMessageEncoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/ResultMessageEncoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/SumUpProtocolCodecFactory.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/codec/SumUpProtocolCodecFactory.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/AbstractMessage.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/AbstractMessage.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/AddMessage.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/AddMessage.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/ResultMessage.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/sumup/message/ResultMessage.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/Main.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/Main.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/TennisBall.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/TennisBall.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/TennisPlayer.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/main/java/org/apache/mina/examples/tennis/TennisPlayer.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/AbstractTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/AbstractTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/AcceptorTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/AcceptorTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/ConnectorTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/examples/src/test/java/org/apache/mina/examples/echoserver/ConnectorTest.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id
Modified: directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java
URL: http://svn.apache.org/viewcvs/directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java?rev=377135&r1=377134&r2=377135&view=diff
==============================================================================
--- directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java (original)
+++ directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java Sat Feb 11 21:50:03 2006
@@ -1,53 +1,53 @@
-/*
- * @(#) $Id$
- */
-package org.apache.mina.filter.codec.asn1;
-
-import org.apache.directory.shared.asn1.codec.DecoderException;
-import org.apache.directory.shared.asn1.codec.stateful.DecoderCallback;
-import org.apache.directory.shared.asn1.codec.stateful.StatefulDecoder;
-import org.apache.mina.common.ByteBuffer;
-import org.apache.mina.common.IoSession;
-import org.apache.mina.filter.codec.ProtocolDecoder;
-import org.apache.mina.filter.codec.ProtocolDecoderOutput;
-
-/**
- * Adapts {@link StatefulDecoder} to MINA <tt>ProtocolDecoder</tt>
- *
- * @author Trustin Lee (trustin@apache.org)
- * @version $Rev$, $Date$,
- */
-public class Asn1CodecDecoder implements ProtocolDecoder
-{
-
- private final StatefulDecoder decoder;
-
- private final DecoderCallbackImpl callback = new DecoderCallbackImpl();
-
- public Asn1CodecDecoder( StatefulDecoder decoder )
- {
- decoder.setCallback( callback );
- this.decoder = decoder;
- }
-
- public void decode( IoSession session, ByteBuffer in,
- ProtocolDecoderOutput out ) throws DecoderException
- {
- callback.decOut = out;
- decoder.decode( in.buf() );
- }
-
- public void dispose( IoSession session ) throws Exception
- {
- }
-
- private class DecoderCallbackImpl implements DecoderCallback
- {
- private ProtocolDecoderOutput decOut;
-
- public void decodeOccurred( StatefulDecoder decoder, Object decoded )
- {
- decOut.write( decoded );
- }
- }
+/*
+ * @(#) $Id$
+ */
+package org.apache.mina.filter.codec.asn1;
+
+import org.apache.directory.shared.asn1.codec.DecoderException;
+import org.apache.directory.shared.asn1.codec.stateful.DecoderCallback;
+import org.apache.directory.shared.asn1.codec.stateful.StatefulDecoder;
+import org.apache.mina.common.ByteBuffer;
+import org.apache.mina.common.IoSession;
+import org.apache.mina.filter.codec.ProtocolDecoder;
+import org.apache.mina.filter.codec.ProtocolDecoderOutput;
+
+/**
+ * Adapts {@link StatefulDecoder} to MINA <tt>ProtocolDecoder</tt>
+ *
+ * @author Trustin Lee (trustin@apache.org)
+ * @version $Rev$, $Date$,
+ */
+public class Asn1CodecDecoder implements ProtocolDecoder
+{
+
+ private final StatefulDecoder decoder;
+
+ private final DecoderCallbackImpl callback = new DecoderCallbackImpl();
+
+ public Asn1CodecDecoder( StatefulDecoder decoder )
+ {
+ decoder.setCallback( callback );
+ this.decoder = decoder;
+ }
+
+ public void decode( IoSession session, ByteBuffer in,
+ ProtocolDecoderOutput out ) throws DecoderException
+ {
+ callback.decOut = out;
+ decoder.decode( in.buf() );
+ }
+
+ public void dispose( IoSession session ) throws Exception
+ {
+ }
+
+ private class DecoderCallbackImpl implements DecoderCallback
+ {
+ private ProtocolDecoderOutput decOut;
+
+ public void decodeOccurred( StatefulDecoder decoder, Object decoded )
+ {
+ decOut.write( decoded );
+ }
+ }
}
Propchange: directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: directory/sandbox/akarasulu/rc1/mina/filter-codec-asn1/src/main/java/org/apache/mina/filter/codec/asn1/Asn1CodecDecoder.java
------------------------------------------------------------------------------
--- svn:keywords (original)
+++ svn:keywords Sat Feb 11 21:50:03 2006
@@ -1 +1,4 @@
-HeadURL Id LastChangedBy LastChangedDate LastChangedRevision
+Rev
+Revision
+Date
+Id