svn commit: r161857 - directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java

[tr...@apache.org]

Author: trustin
Date: Tue Apr 19 01:50:39 2005
New Revision: 161857

URL: http://svn.apache.org/viewcvs?view=rev&rev=161857
Log:
Added ByteBufferProxy

Added:
    directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java   (with props)
Modified:
    directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java

Modified: directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java?view=diff&r1=161856&r2=161857
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/common/ByteBuffer.java Tue Apr 19 01:50:39 2005
@@ -1,5 +1,20 @@
 /*
- * @(#) $Id$
+ *   @(#) $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.common;
 
@@ -48,7 +63,7 @@
  * </pre>
  * 
  * @author Trustin Lee (trustin@apache.org)
- * @version $Rev$, $Date$,
+ * @version $Rev$, $Date$
  */
 public abstract class ByteBuffer
 {

Added: directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java?view=auto&rev=161857
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java (added)
+++ directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java Tue Apr 19 01:50:39 2005
@@ -0,0 +1,439 @@
+/*
+ *   @(#) $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.common;
+
+import java.io.FilterOutputStream;
+import java.nio.ByteOrder;
+import java.nio.CharBuffer;
+import java.nio.DoubleBuffer;
+import java.nio.FloatBuffer;
+import java.nio.IntBuffer;
+import java.nio.LongBuffer;
+import java.nio.ShortBuffer;
+import java.nio.charset.CharsetDecoder;
+import java.nio.charset.CharsetEncoder;
+
+/**
+ * A {@link ByteBuffer} that wraps a buffer and proxies any operations to it.
+ * <p>
+ * You can think this class like a {@link FilterOutputStream}.  All operations
+ * are proxied by default so that you can extend this class and override existing
+ * operations selectively.  You can introduce new operations, too.
+ * <p>
+ * Please note that you have to implement {@link ByteBuffer#duplicate()},
+ * {@link ByteBuffer#slice()}, and {@link ByteBuffer#asReadOnlyBuffer()}.
+ * It is because <tt>ByteBufferProxy</tt> itself cannot instantiate
+ * the class you extended.
+ * 
+ * @author Trustin Lee (trustin@apache.org)
+ * @version $Rev$, $Date$
+ */
+public abstract class ByteBufferProxy extends ByteBuffer {
+
+    /**
+     * The buffer proxied by this proxy.
+     */
+    protected final ByteBuffer buf;
+    
+    /**
+     * Create a new instance.
+     * @param buf the buffer to be proxied
+     */
+    protected ByteBufferProxy( ByteBuffer buf )
+    {
+        if( buf == null )
+        {
+            throw new NullPointerException( "buf" );
+        }
+        this.buf = buf;
+    }
+
+    public void acquire() {
+        buf.acquire();
+    }
+
+    public void release() {
+        buf.release();
+    }
+    
+    public boolean isDirect()
+    {
+        return buf.isDirect();
+    }
+    
+    public boolean isReadOnly()
+    {
+        return buf.isReadOnly();
+    }
+
+    public java.nio.ByteBuffer buf() {
+        return buf.buf();
+    }
+
+    public int capacity() {
+        return buf.capacity();
+    }
+
+    public int position() {
+        return buf.position();
+    }
+
+    public ByteBuffer position(int newPosition) {
+        buf.position( newPosition );
+        return this;
+    }
+
+    public int limit() {
+        return buf.limit();
+    }
+
+    public ByteBuffer limit(int newLimit) {
+        buf.limit( newLimit );
+        return this;
+    }
+
+    public ByteBuffer mark() {
+        buf.mark();
+        return this;
+    }
+
+    public ByteBuffer reset() {
+        buf.reset();
+        return this;
+    }
+
+    public ByteBuffer clear() {
+        buf.clear();
+        return this;
+    }
+
+    public ByteBuffer flip() {
+        buf.flip();
+        return this;
+    }
+
+    public ByteBuffer rewind() {
+        buf.rewind();
+        return this;
+    }
+
+    public int remaining() {
+        return buf.remaining();
+    }
+
+    public boolean hasRemaining() {
+        return buf.hasRemaining();
+    }
+
+    public byte get() {
+        return buf.get();
+    }
+
+    public short getUnsigned() {
+        return buf.getUnsigned();
+    }
+
+    public ByteBuffer put(byte b) {
+        buf.put( b );
+        return this;
+    }
+
+    public byte get(int index) {
+        return buf.get( index );
+    }
+
+    public short getUnsigned(int index) {
+        return buf.getUnsigned( index );
+    }
+
+    public ByteBuffer put(int index, byte b) {
+        buf.put( index, b );
+        return this;
+    }
+
+    public ByteBuffer get(byte[] dst, int offset,
+            int length) {
+        buf.get( dst, offset, length );
+        return this;
+    }
+
+    public ByteBuffer get(byte[] dst) {
+        buf.get( dst );
+        return this;
+    }
+
+    public ByteBuffer put(ByteBuffer src) {
+        buf.put( src );
+        return this;
+    }
+
+    public ByteBuffer put(java.nio.ByteBuffer src) {
+        buf.put( src );
+        return this;
+    }
+
+    public ByteBuffer put(byte[] src, int offset,
+            int length) {
+        buf.put( src, offset, length );
+        return this;
+    }
+
+    public ByteBuffer put(byte[] src) {
+        buf.put( src );
+        return this;
+    }
+
+    public ByteBuffer compact() {
+        buf.compact();
+        return this;
+    }
+
+    public String toString() {
+        return buf.toString();
+    }
+
+    public int hashCode() {
+        return buf.hashCode();
+    }
+
+    public boolean equals(Object ob) {
+        return buf.equals( ob );
+    }
+
+    public int compareTo(ByteBuffer that) {
+        return buf.compareTo( that );
+    }
+
+    public ByteOrder order() {
+        return buf.order();
+    }
+
+    public ByteBuffer order(ByteOrder bo) {
+        buf.order( bo );
+        return this;
+    }
+
+    public char getChar() {
+        return buf.getChar();
+    }
+
+    public ByteBuffer putChar(char value) {
+        buf.putChar( value );
+        return this;
+    }
+
+    public char getChar(int index) {
+        return buf.getChar( index );
+    }
+
+    public ByteBuffer putChar(int index, char value) {
+        buf.putChar( index, value );
+        return this;
+    }
+
+    public CharBuffer asCharBuffer() {
+        return buf.asCharBuffer();
+    }
+
+    public short getShort() {
+        return buf.getShort();
+    }
+
+    public int getUnsignedShort() {
+        return buf.getUnsignedShort();
+    }
+
+    public ByteBuffer putShort(short value) {
+        buf.putShort( value );
+        return this;
+    }
+
+    public short getShort(int index) {
+        return buf.getShort( index );
+    }
+
+    public int getUnsignedShort(int index) {
+        return buf.getUnsignedShort( index );
+    }
+
+    public ByteBuffer putShort(int index, short value) {
+        buf.putShort( index, value );
+        return this;
+    }
+
+    public ShortBuffer asShortBuffer() {
+        return buf.asShortBuffer();
+    }
+
+    public int getInt() {
+        return buf.getInt();
+    }
+
+    public long getUnsignedInt() {
+        return buf.getUnsignedInt();
+    }
+
+    public ByteBuffer putInt(int value) {
+        buf.putInt( value );
+        return this;
+    }
+
+    public int getInt(int index) {
+        return buf.getInt( index );
+    }
+
+    public long getUnsignedInt(int index) {
+        return buf.getUnsignedInt( index );
+    }
+
+    public ByteBuffer putInt(int index, int value) {
+        buf.putInt( index, value );
+        return this;
+    }
+
+    public IntBuffer asIntBuffer() {
+        return buf.asIntBuffer();
+    }
+
+    public long getLong() {
+        return buf.getLong();
+    }
+
+    public ByteBuffer putLong(long value) {
+        buf.putLong( value );
+        return this;
+    }
+
+    public long getLong(int index) {
+        return buf.getLong( index );
+    }
+
+    public ByteBuffer putLong(int index, long value) {
+        buf.putLong( index, value );
+        return this;
+    }
+
+    public LongBuffer asLongBuffer() {
+        return buf.asLongBuffer();
+    }
+
+    public float getFloat() {
+        return buf.getFloat();
+    }
+
+    public ByteBuffer putFloat(float value) {
+        buf.putFloat( value );
+        return this;
+    }
+
+    public float getFloat(int index) {
+        return buf.getFloat( index );
+    }
+
+    public ByteBuffer putFloat(int index, float value) {
+        buf.putFloat( index, value );
+        return this;
+    }
+
+    public FloatBuffer asFloatBuffer() {
+        return buf.asFloatBuffer();
+    }
+
+    public double getDouble() {
+        return buf.getDouble();
+    }
+
+    public ByteBuffer putDouble(double value) {
+        buf.putDouble( value );
+        return this;
+    }
+
+    public double getDouble(int index) {
+        return buf.getDouble( index );
+    }
+
+    public ByteBuffer putDouble(int index, double value) {
+        buf.putDouble( index, value );
+        return this;
+    }
+
+    public DoubleBuffer asDoubleBuffer() {
+        return buf.asDoubleBuffer();
+    }
+
+    public String getHexDump() {
+        return buf.getHexDump();
+    }
+
+    public ByteBuffer getString(CharBuffer out,
+            int fieldSize, CharsetDecoder decoder) {
+        buf.getString( out, fieldSize, decoder );
+        return this;
+    }
+
+    public String getString(int fieldSize, CharsetDecoder decoder) {
+        return buf.getString( fieldSize, decoder );
+    }
+
+    public ByteBuffer putString(CharBuffer in,
+            int fieldSize, CharsetEncoder encoder) {
+        buf.putString( in, fieldSize, encoder );
+        return this;
+    }
+
+    public ByteBuffer putString(CharSequence in,
+            int fieldSize, CharsetEncoder encoder) {
+        buf.putString( in, fieldSize, encoder );
+        return this;
+    }
+
+    public ByteBuffer skip(int size) {
+        buf.skip( size );
+        return this;
+    }
+
+    public ByteBuffer fill(byte value, int size) {
+        buf.fill( value, size );
+        return this;
+    }
+
+    public ByteBuffer fillAndReset(byte value, int size) {
+        buf.fillAndReset( value, size );
+        return this;
+    }
+
+    public ByteBuffer fill(int size) {
+        buf.fill( size );
+        return this;
+    }
+
+    public ByteBuffer fillAndReset(int size) {
+        buf.fillAndReset( size );
+        return this;
+    }
+
+    public ByteBuffer fork() {
+        buf.fork();
+        return this;
+    }
+
+    public ByteBuffer fork(int newCapacity) {
+        buf.fork( newCapacity );
+        return this;
+    }
+}

Propchange: directory/network/trunk/src/java/org/apache/mina/common/ByteBufferProxy.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision