activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r915527 - in /activemq/activemq-cpp/trunk/activemq-cpp/src: main/ main/decaf/io/ test/ test/decaf/io/
Date Tue, 23 Feb 2010 21:31:53 GMT
Author: tabish
Date: Tue Feb 23 21:31:53 2010
New Revision: 915527

URL: http://svn.apache.org/viewvc?rev=915527&view=rev
Log:
Adds PushbackInputStream and tests.

Added:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp   (with props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h   (with props)
Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/FilterInputStream.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/Makefile.am
    activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am?rev=915527&r1=915526&r2=915527&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/Makefile.am Tue Feb 23 21:31:53 2010
@@ -523,6 +523,7 @@
     decaf/io/InputStreamReader.cpp \
     decaf/io/OutputStream.cpp \
     decaf/io/OutputStreamWriter.cpp \
+    decaf/io/PushbackInputStream.cpp \
     decaf/io/Reader.cpp \
     decaf/io/Writer.cpp \
     decaf/lang/Boolean.cpp \
@@ -1180,6 +1181,7 @@
     decaf/io/InterruptedIOException.h \
     decaf/io/OutputStream.h \
     decaf/io/OutputStreamWriter.h \
+    decaf/io/PushbackInputStream.h \
     decaf/io/Reader.h \
     decaf/io/UTFDataFormatException.h \
     decaf/io/UnsupportedEncodingException.h \

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/FilterInputStream.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/FilterInputStream.cpp?rev=915527&r1=915526&r2=915527&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/FilterInputStream.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/FilterInputStream.cpp Tue Feb 23 21:31:53 2010
@@ -29,7 +29,7 @@
 FilterInputStream::FilterInputStream( InputStream* inputStream, bool own ) {
     this->inputStream = inputStream;
     this->own = own;
-    this->closed = false;
+    this->closed = inputStream == NULL ? true : false;
 }
 
 ////////////////////////////////////////////////////////////////////////////////

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp?rev=915527&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp Tue Feb 23 21:31:53 2010
@@ -0,0 +1,248 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+#include "PushbackInputStream.h"
+
+#include <decaf/lang/System.h>
+
+using namespace decaf;
+using namespace decaf::io;
+using namespace decaf::lang;
+using namespace decaf::lang::exceptions;
+
+////////////////////////////////////////////////////////////////////////////////
+PushbackInputStream::PushbackInputStream( InputStream* stream, bool own )
+ :  FilterInputStream( stream, own ), bufferSize( 1 ), pos( 1 ) {
+
+    this->buffer = new unsigned char[1];
+}
+
+////////////////////////////////////////////////////////////////////////////////
+PushbackInputStream::PushbackInputStream( InputStream* stream, std::size_t bufSize, bool own )
+ :  FilterInputStream( stream, own ), bufferSize( bufSize ), pos( bufSize ) {
+
+    this->buffer = new unsigned char[bufSize];
+}
+
+////////////////////////////////////////////////////////////////////////////////
+PushbackInputStream::~PushbackInputStream() {
+    try{
+
+        close();
+        delete [] this->buffer;
+    }
+    DECAF_CATCH_NOTHROW( Exception )
+    DECAF_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::size_t PushbackInputStream::available() const throw ( decaf::io::IOException ) {
+
+    try{
+        return ( this->bufferSize - this->pos ) + inputStream->available();
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::size_t PushbackInputStream::skip( std::size_t num )
+    throw ( decaf::io::IOException,
+            decaf::lang::exceptions::UnsupportedOperationException ) {
+
+    try{
+
+        if( num == 0 ) {
+            return 0;
+        }
+
+        if( isClosed() ) {
+            throw IOException(
+                __FILE__, __LINE__, "Stream is closed" );
+        }
+
+        std::size_t unread = bufferSize - pos;
+        std::size_t numSkipped = 0;
+
+        if( unread != 0 ) {
+            numSkipped += ( num < unread ) ? num : unread;
+            pos += numSkipped;
+        }
+
+        if( numSkipped < num ) {
+            numSkipped += inputStream->skip( num - numSkipped );
+        }
+
+        return numSkipped;
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStream::mark( int readLimit DECAF_UNUSED ) {
+    // Nothing to do here.
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStream::reset() throw ( decaf::io::IOException ) {
+    throw IOException(
+        __FILE__, __LINE__, "Reset is not Supported by the PushbackInputStream." );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStream::unread( unsigned char value )
+    throw( decaf::io::IOException ) {
+
+    try{
+
+        if( pos == 0 ) {
+            throw IOException(
+                __FILE__, __LINE__, "No Space left in the unread buffer." );
+        }
+
+        buffer[--pos] = value;
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStream::unread( const unsigned char* buffer, std::size_t size )
+    throw( decaf::io::IOException,
+           decaf::lang::exceptions::NullPointerException ) {
+
+    try{
+        this->unread( buffer, size, 0, size );
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCH_RETHROW( NullPointerException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStream::unread( const unsigned char* buffer, std::size_t size,
+                                  std::size_t offset, std::size_t length )
+    throw( decaf::io::IOException,
+           decaf::lang::exceptions::IndexOutOfBoundsException,
+           decaf::lang::exceptions::NullPointerException ) {
+
+    try{
+
+        if( length > pos ) {
+            throw IOException(
+                __FILE__, __LINE__, "No Space left in the unread buffer." );
+        }
+
+        if( offset > size || offset + length > size ) {
+            throw IndexOutOfBoundsException(
+                __FILE__, __LINE__, "Offset + length exceeds supplied buffer's size." );
+        }
+
+        if( buffer == NULL ) {
+            throw NullPointerException(
+                __FILE__, __LINE__, "Buffer pointer passed was NULL." );
+        }
+
+        System::arraycopy( buffer, offset, this->buffer, pos - length, length );
+        pos = pos - length;
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCH_RETHROW( IndexOutOfBoundsException )
+    DECAF_CATCH_RETHROW( NullPointerException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int PushbackInputStream::doReadByte() throw ( decaf::io::IOException ) {
+
+    try{
+
+        if( isClosed() ) {
+            throw IOException(
+                __FILE__, __LINE__, "Stream is closed" );
+        }
+
+        if( pos < bufferSize ) {
+            return buffer[pos++];
+        }
+
+        return inputStream->read();
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCHALL_THROW( IOException )
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int PushbackInputStream::doReadArrayBounded( unsigned char* buffer, std::size_t size,
+                                             std::size_t offset, std::size_t length )
+    throw ( decaf::io::IOException,
+            decaf::lang::exceptions::IndexOutOfBoundsException,
+            decaf::lang::exceptions::NullPointerException ) {
+
+    try{
+
+        if( isClosed() ) {
+            throw IOException(
+                __FILE__, __LINE__, "Stream is closed" );
+        }
+
+        if( buffer == NULL ) {
+            throw NullPointerException(
+                __FILE__, __LINE__, "Buffer pointer passed was NULL." );
+        }
+
+        if( offset > size || offset + length > size ) {
+            throw IndexOutOfBoundsException(
+                __FILE__, __LINE__, "Offset + length exceeds supplied buffer's size." );
+        }
+
+        std::size_t copiedBytes = 0;
+        std::size_t copyLength = 0;
+        std::size_t newOffset = offset;
+
+        // Are there pushback bytes available?
+        if( pos < bufferSize ) {
+            copyLength = ( bufferSize - pos >= length ) ? length : bufferSize - pos;
+            System::arraycopy( this->buffer, pos, buffer, newOffset, copyLength );
+            newOffset += copyLength;
+            copiedBytes += copyLength;
+            // Use up the bytes in the local buffer
+            pos += copyLength;
+        }
+
+        // Have we copied enough?
+        if( copyLength == length ) {
+            return length;
+        }
+
+        int inCopied = inputStream->read( buffer, size, newOffset, length - copiedBytes );
+        if( inCopied > 0 ) {
+            return inCopied + copiedBytes;
+        }
+
+        if( copiedBytes == 0 ) {
+            return inCopied;
+        }
+
+        return copiedBytes;
+    }
+    DECAF_CATCH_RETHROW( IOException )
+    DECAF_CATCH_RETHROW( IndexOutOfBoundsException )
+    DECAF_CATCH_RETHROW( NullPointerException )
+    DECAF_CATCHALL_THROW( IOException )
+}

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h?rev=915527&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h Tue Feb 23 21:31:53 2010
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+#ifndef _DECAF_IO_PUSHBACKINPUTSTREAM_H_
+#define _DECAF_IO_PUSHBACKINPUTSTREAM_H_
+
+#include <decaf/util/Config.h>
+
+#include <decaf/io/InputStream.h>
+#include <decaf/io/FilterInputStream.h>
+
+namespace decaf {
+namespace io {
+
+    /**
+     * A PushbackInputStream adds functionality to another input stream, namely the ability to
+     * "push back" or "unread" one byte. This is useful in situations where it is convenient for
+     * a fragment of code to read an indefinite number of data bytes that are delimited by a
+     * particular byte value; after reading the terminating byte, the code fragment can "unread"
+     * it, so that the next read operation on the input stream will reread the byte that was
+     * pushed back. For example, bytes representing the characters constituting an identifier
+     * might be terminated by a byte representing an operator character; a method whose job
+     * is to read just an identifier can read until it sees the operator and then push the
+     * operator back to be re-read.
+     *
+     * @since 1.0
+     */
+    class PushbackInputStream : public FilterInputStream {
+    private:
+
+        unsigned char* buffer;
+        std::size_t bufferSize;
+        std::size_t pos;
+
+    public:
+
+        /**
+         *
+         */
+        PushbackInputStream( InputStream* stream, bool own = false );
+
+        /**
+         *
+         */
+        PushbackInputStream( InputStream* stream, std::size_t bufSize, bool own = false );
+
+        virtual ~PushbackInputStream();
+
+        /**
+         * Pushes back the given byte, the byte is copied to the front of the pushback buffer, future
+         * calls to read start reading from the beginning of these pushed back byte.
+         *
+         * @param value
+         *      The byte that is to be placed at the front of the push back buffer.
+         *
+         * @throws IOException if there is not enough space in the pushback buffer or this stream
+         *         has already been closed.
+         */
+        void unread( unsigned char value )
+            throw( decaf::io::IOException );
+
+        /**
+         * Pushes back the given array of bytes, the bytes are copied to the front of the pushback
+         * buffer, future calls to read start reading from the beginning of these pushed back bytes.
+         *
+         * @param buffer
+         *      The bytes to copy to the front of push back buffer.
+         * @param size
+         *      The size of the array to be copied.
+         *
+         * @throws NullPointerException if the buffer passed is NULL.
+         * @throws IOException if there is not enough space in the pushback buffer or this stream
+         *         has already been closed.
+         */
+        void unread( const unsigned char* buffer, std::size_t size )
+            throw( decaf::io::IOException,
+                   decaf::lang::exceptions::NullPointerException );
+
+        /**
+         * Pushes back the given array of bytes, the bytes are copied to the front of the pushback
+         * buffer, future calls to read start reading from the beginning of these pushed back bytes.
+         *
+         * @param buffer
+         *      The bytes to copy to the front of push back buffer.
+         * @param size
+         *      The size of the array to be copied.
+         * @param offset
+         *      The position in the buffer to start copying from.
+         * @param length
+         *      The number of bytes to push back from the passed buffer.
+         *
+         * @throws NullPointerException if the buffer passed is NULL.
+         * @throws IndexOutOfBoundsException if the offset + length is greater than the buffer size.
+         * @throws IOException if there is not enough space in the pushback buffer or this stream
+         *         has already been closed.
+         */
+        void unread( const unsigned char* buffer, std::size_t size, std::size_t offset, std::size_t length )
+            throw( decaf::io::IOException,
+                   decaf::lang::exceptions::IndexOutOfBoundsException,
+                   decaf::lang::exceptions::NullPointerException );
+
+        /**
+         * {@inheritdoc}
+         *
+         * Returns the sum of the number of pushed back bytes if any and the amount of bytes
+         * available in the underlying stream via a call to available.
+         */
+        virtual std::size_t available() const throw ( decaf::io::IOException );
+
+        /**
+         * {@inheritDoc}
+         *
+         * This method first skips bytes in the local pushed back buffer before attempting to
+         * complete the request by calling the underlying stream skip method with the remainder
+         * of bytes that needs to be skipped.
+         */
+        virtual std::size_t skip( std::size_t num )
+            throw ( decaf::io::IOException,
+                    decaf::lang::exceptions::UnsupportedOperationException );
+
+        /**
+         * {@inheritDoc}
+         *
+         * Does nothing for this class.
+         */
+        virtual void mark( int readLimit );
+
+        /**
+         * {@inheritDoc}
+         *
+         * Does nothing except throw an IOException.
+         */
+        virtual void reset() throw ( decaf::io::IOException );
+
+        /**
+         * {@inheritDoc}
+         *
+         * Always returns false for this class.
+         */
+        virtual bool markSupported() const {
+            return false;
+        }
+
+    protected:
+
+        virtual int doReadByte() throw ( decaf::io::IOException );
+
+        virtual int doReadArrayBounded( unsigned char* buffer, std::size_t size,
+                                        std::size_t offset, std::size_t length )
+            throw ( decaf::io::IOException,
+                    decaf::lang::exceptions::IndexOutOfBoundsException,
+                    decaf::lang::exceptions::NullPointerException );
+
+    };
+
+}}
+
+#endif /* _DECAF_IO_PUSHBACKINPUTSTREAM_H_ */

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/PushbackInputStream.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/Makefile.am
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/Makefile.am?rev=915527&r1=915526&r2=915527&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/Makefile.am (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/Makefile.am Tue Feb 23 21:31:53 2010
@@ -94,6 +94,7 @@
     decaf/io/InputStreamTest.cpp \
     decaf/io/OutputStreamTest.cpp \
     decaf/io/OutputStreamWriterTest.cpp \
+    decaf/io/PushbackInputStreamTest.cpp \
     decaf/io/ReaderTest.cpp \
     decaf/io/WriterTest.cpp \
     decaf/lang/BooleanTest.cpp \
@@ -234,6 +235,7 @@
     decaf/io/InputStreamTest.h \
     decaf/io/OutputStreamTest.h \
     decaf/io/OutputStreamWriterTest.h \
+    decaf/io/PushbackInputStreamTest.h \
     decaf/io/ReaderTest.h \
     decaf/io/WriterTest.h \
     decaf/lang/BooleanTest.h \

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp?rev=915527&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp Tue Feb 23 21:31:53 2010
@@ -0,0 +1,297 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+#include "PushbackInputStreamTest.h"
+
+#include <decaf/io/PushbackInputStream.h>
+#include <decaf/io/ByteArrayInputStream.h>
+#include <decaf/lang/Integer.h>
+
+using namespace decaf;
+using namespace decaf::io;
+using namespace decaf::lang;
+using namespace decaf::lang::exceptions;
+
+////////////////////////////////////////////////////////////////////////////////
+std::string PushbackInputStreamTest::testString =
+    "Test_All_Tests\nTest_java_io_BufferedInputStream\nTest_java_io_BufferedOutputStream\n"
+    "Test_java_io_ByteArrayInputStream\nTest_java_io_ByteArrayOutputStream\nTest_java_io_DataInputStream\n"
+    "Test_java_io_File\nTest_java_io_FileDescriptor\nTest_java_io_FileInputStream\n"
+    "Test_java_io_FileNotFoundException\nTest_java_io_FileOutputStream\nTest_java_io_FilterInputStream\n"
+    "Test_java_io_FilterOutputStream\nTest_java_io_InputStream\nTest_java_io_IOException\n"
+    "Test_java_io_OutputStream\nTest_java_io_PrintStream\nTest_java_io_RandomAccessFile\n"
+    "Test_java_io_SyncFailedException\nTest_java_lang_AbstractMethodError\nTest_java_lang_ArithmeticException\n"
+    "Test_java_lang_ArrayIndexOutOfBoundsException\nTest_java_lang_ArrayStoreException\nTest_java_lang_Boolean\n"
+    "Test_java_lang_Byte\nTest_java_lang_Character\nTest_java_lang_Class\nTest_java_lang_ClassCastException\n"
+    "Test_java_lang_ClassCircularityError\nTest_java_lang_ClassFormatError\nTest_java_lang_ClassLoader\n"
+    "Test_java_lang_ClassNotFoundException\nTest_java_lang_CloneNotSupportedException\nTest_java_lang_Double\n"
+    "Test_java_lang_Error\nTest_java_lang_Exception\nTest_java_lang_ExceptionInInitializerError\n"
+    "Test_java_lang_Float\nTest_java_lang_IllegalAccessError\nTest_java_lang_IllegalAccessException\n"
+    "Test_java_lang_IllegalArgumentException\nTest_java_lang_IllegalMonitorStateException\n"
+    "Test_java_lang_IllegalThreadStateException\nTest_java_lang_IncompatibleClassChangeError\n"
+    "Test_java_lang_IndexOutOfBoundsException\nTest_java_lang_InstantiationError\n"
+    "Test_java_lang_InstantiationException\nTest_java_lang_Integer\nTest_java_lang_InternalError\n"
+    "Test_java_lang_InterruptedException\nTest_java_lang_LinkageError\nTest_java_lang_Long\n"
+    "Test_java_lang_Math\nTest_java_lang_NegativeArraySizeException\nTest_java_lang_NoClassDefFoundError\n"
+    "Test_java_lang_NoSuchFieldError\nTest_java_lang_NoSuchMethodError\nTest_java_lang_NullPointerException\n"
+    "Test_java_lang_Number\nTest_java_lang_NumberFormatException\nTest_java_lang_Object\n"
+    "Test_java_lang_OutOfMemoryError\nTest_java_lang_RuntimeException\nTest_java_lang_SecurityManager\n"
+    "Test_java_lang_Short\nTest_java_lang_StackOverflowError\nTest_java_lang_String\n"
+    "Test_java_lang_StringBuffer\nTest_java_lang_StringIndexOutOfBoundsException\nTest_java_lang_System\n"
+    "Test_java_lang_Thread\nTest_java_lang_ThreadDeath\nTest_java_lang_ThreadGroup\nTest_java_lang_Throwable\n"
+    "Test_java_lang_UnknownError\nTest_java_lang_UnsatisfiedLinkError\nTest_java_lang_VerifyError\n"
+    "Test_java_lang_VirtualMachineError\nTest_java_lang_vm_Image\nTest_java_lang_vm_MemorySegment\n"
+    "Test_java_lang_vm_ROMStoreException\nTest_java_lang_vm_VM\nTest_java_lang_Void\nTest_java_net_BindException\n"
+    "Test_java_net_ConnectException\nTest_java_net_DatagramPacket\nTest_java_net_DatagramSocket\n"
+    "Test_java_net_DatagramSocketImpl\nTest_java_net_InetAddress\nTest_java_net_NoRouteToHostException\n"
+    "Test_java_net_PlainDatagramSocketImpl\nTest_java_net_PlainSocketImpl\nTest_java_net_Socket\n"
+    "Test_java_net_SocketException\nTest_java_net_SocketImpl\nTest_java_net_SocketInputStream\n"
+    "Test_java_net_SocketOutputStream\nTest_java_net_UnknownHostException\nTest_java_util_ArrayEnumerator\n"
+    "Test_java_util_Date\nTest_java_util_EventObject\nTest_java_util_HashEnumerator\nTest_java_util_Hashtable\n"
+    "Test_java_util_Properties\nTest_java_util_ResourceBundle\nTest_java_util_tm\nTest_java_util_Vector\n";
+
+////////////////////////////////////////////////////////////////////////////////
+PushbackInputStreamTest::PushbackInputStreamTest() {
+}
+
+////////////////////////////////////////////////////////////////////////////////
+PushbackInputStreamTest::~PushbackInputStreamTest() {
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testReset() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais );
+
+    CPPUNIT_ASSERT_THROW_MESSAGE(
+        "Should Throw an IOException",
+        pb.reset(),
+        IOException );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testMark() {
+
+    std::vector<unsigned char> temp( 1 );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais, (std::size_t)2 );
+
+    pb.mark( Integer::MAX_VALUE );
+    pb.mark( 0 );
+    pb.mark( Integer::MIN_VALUE );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testConstructor1() {
+
+    {
+        PushbackInputStream str( NULL );
+        CPPUNIT_ASSERT_THROW_MESSAGE(
+            "Should Throw an IOException",
+            str.reset(),
+            IOException );
+    }
+    {
+        std::vector<unsigned char> temp( testString.begin(), testString.end() );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais );
+
+        unsigned char un[] = { 'h', 'e' };
+
+        CPPUNIT_ASSERT_THROW_MESSAGE(
+            "Should Throw an IOException",
+            pb.unread( un, 2 ),
+            IOException );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testConstructor2() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais, (std::size_t)5 );
+
+    unsigned char un[] = { 'h', 'e', 'l', 'l', 'o', 's' };
+
+    CPPUNIT_ASSERT_THROW_MESSAGE(
+        "Should Throw an IOException",
+        pb.unread( un, 6 ),
+        IOException );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testConstructor3() {
+
+    PushbackInputStream pb( NULL, (std::size_t)1 );
+    CPPUNIT_ASSERT_THROW_MESSAGE(
+        "Should Throw an IOException",
+        pb.read(),
+        IOException );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testAvailable() {
+    try {
+        std::vector<unsigned char> temp( testString.begin(), testString.end() );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais );
+
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Should have been testString.length available.",
+                                      testString.length(), pb.available() );
+    } catch( IOException& e ) {
+        CPPUNIT_FAIL( std::string() + "Exception during available test: " + e.getMessage() );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testMarkSupported() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais );
+    CPPUNIT_ASSERT_MESSAGE( "markSupported returned true", !pb.markSupported() );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testRead() {
+    try {
+        std::vector<unsigned char> temp( testString.begin(), testString.end() );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais );
+
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Did not return the first value in testString.",
+                                      testString.at( 0 ), (char)pb.read() );
+    } catch( IOException& e ) {
+        CPPUNIT_FAIL( std::string() + "Exception during available test: " + e.getMessage() );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testReadBIII() {
+
+    try {
+        std::vector<unsigned char> temp( testString.begin(), testString.end() );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais );
+
+        unsigned char buf[100];
+        pb.read( buf, 100 );
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                      std::string( buf, buf + 100 ), testString.substr( 0, 100 ) );
+
+    } catch( IOException& e ) {
+        CPPUNIT_FAIL( std::string() + "Exception during read test : " + e.getMessage() );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testSkip() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais, (std::size_t) 65535 );
+
+    unsigned char buf[50];
+    pb.skip( 50 );
+    pb.read( buf, 50, 0, 50 );
+    CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                  std::string( buf, buf + 50 ), testString.substr( 50, 50 ) );
+
+    pb.unread( buf, 50 );
+    pb.skip( 25 );
+    unsigned char buf2[25];
+    pb.read( buf2, 25 );
+    CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                  std::string( buf2, buf2 + 25 ), testString.substr( 75, 25 ) );
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testUnreadBI() {
+    try {
+
+        std::vector<unsigned char> temp( testString.begin(), testString.end() );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais, (std::size_t) 65535 );
+
+        unsigned char buf[100];
+        pb.read(buf, 100, 0, 100 );
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                      std::string( buf, buf + 100 ), testString.substr( 0, 100 ) );
+        pb.unread( buf, 100 );
+        pb.read( buf, 50 );
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                      std::string( buf, buf + 50 ), testString.substr( 0, 50 ) );
+    } catch( IOException& e ) {
+        CPPUNIT_FAIL( std::string() + "IOException during unread test : " + e.getMessage() );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testUnreadBIII() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais, (std::size_t) 65535 );
+
+    unsigned char buf[100];
+    pb.read( buf, 100, 0, 100 );
+    CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                  std::string( buf, buf + 100 ), testString.substr( 0, 100 ) );
+
+    pb.unread( buf, 100, 50, 50 );
+    pb.read( buf, 50 );
+    CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                  std::string( buf, buf + 50 ), testString.substr( 50, 50 ) );
+
+    {
+        std::vector<unsigned char> temp( 2 );
+        ByteArrayInputStream bais( temp );
+        PushbackInputStream pb( &bais );
+
+        unsigned char un[] = { 'h' };
+
+        CPPUNIT_ASSERT_THROW_MESSAGE(
+            "Should Throw an IOException",
+            pb.unread( un, 1, 0, 5 ),
+            IOException );
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void PushbackInputStreamTest::testUnread() {
+
+    std::vector<unsigned char> temp( testString.begin(), testString.end() );
+    ByteArrayInputStream bais( temp );
+    PushbackInputStream pb( &bais );
+
+    try {
+
+        int x;
+
+        CPPUNIT_ASSERT_EQUAL_MESSAGE( "Incorrect bytes read from the testString.",
+                                      (char)( x = pb.read() ), testString.at( 0 ) );
+
+        pb.unread( (char) x );
+        CPPUNIT_ASSERT_MESSAGE( "Failed to unread", pb.read() == x );
+
+    } catch( IOException& e ) {
+        CPPUNIT_FAIL( std::string() + "IOException during read test : " + e.getMessage() );
+    }
+}

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h?rev=915527&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h Tue Feb 23 21:31:53 2010
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+
+#ifndef _DECAF_IO_PUSHBACKINPUTSTREAMTEST_H_
+#define _DECAF_IO_PUSHBACKINPUTSTREAMTEST_H_
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/extensions/HelperMacros.h>
+
+namespace decaf {
+namespace io {
+
+    class PushbackInputStreamTest : public CppUnit::TestFixture {
+
+        CPPUNIT_TEST_SUITE( PushbackInputStreamTest );
+        CPPUNIT_TEST( testReset );
+        CPPUNIT_TEST( testMark );
+        CPPUNIT_TEST( testMarkSupported );
+        CPPUNIT_TEST( testAvailable );
+        CPPUNIT_TEST( testConstructor1 );
+        CPPUNIT_TEST( testConstructor2 );
+        CPPUNIT_TEST( testConstructor3 );
+        CPPUNIT_TEST( testRead );
+        CPPUNIT_TEST( testReadBIII );
+        CPPUNIT_TEST( testSkip );
+        CPPUNIT_TEST( testUnreadBI );
+        CPPUNIT_TEST( testUnreadBIII );
+        CPPUNIT_TEST( testUnread );
+        CPPUNIT_TEST_SUITE_END();
+
+    private:
+
+        static std::string testString;
+
+    public:
+
+        PushbackInputStreamTest();
+        virtual ~PushbackInputStreamTest();
+
+        void testReset();
+        void testMark();
+        void testMarkSupported();
+        void testAvailable();
+        void testConstructor1();
+        void testConstructor2();
+        void testConstructor3();
+        void testRead();
+        void testReadBIII();
+        void testSkip();
+        void testUnreadBI();
+        void testUnreadBIII();
+        void testUnread();
+
+    };
+
+}}
+
+#endif /* _DECAF_IO_PUSHBACKINPUTSTREAMTEST_H_ */

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/test/decaf/io/PushbackInputStreamTest.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp?rev=915527&r1=915526&r2=915527&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/test/testRegistry.cpp Tue Feb 23 21:31:53 2010
@@ -18,277 +18,279 @@
 // All CPP Unit tests are registered in here so we can disable them and
 // enable them easily in one place.
 
-#include <activemq/commands/BrokerInfoTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerInfoTest );
-#include <activemq/commands/BrokerIdTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerIdTest );
-#include <activemq/commands/ActiveMQTopicTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTopicTest );
-#include <activemq/commands/ActiveMQTextMessageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTextMessageTest );
-#include <activemq/commands/ActiveMQTempTopicTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempTopicTest );
-#include <activemq/commands/ActiveMQTempQueueTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempQueueTest );
-#include <activemq/commands/ActiveMQQueueTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQQueueTest );
-#include <activemq/commands/ActiveMQMessageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMessageTest );
-#include <activemq/commands/ActiveMQMapMessageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMapMessageTest );
-#include <activemq/commands/ActiveMQDestinationTest2.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQDestinationTest );
-#include <activemq/commands/ActiveMQBytesMessageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQBytesMessageTest );
-#include <activemq/commands/ActiveMQStreamMessageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQStreamMessageTest );
-
-#include <activemq/wireformat/openwire/marshal/BaseDataStreamMarshallerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::BaseDataStreamMarshallerTest );
-#include <activemq/wireformat/openwire/marshal/PrimitiveTypesMarshallerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::PrimitiveTypesMarshallerTest );
-
-#include <activemq/wireformat/openwire/utils/BooleanStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::BooleanStreamTest );
-#include <activemq/wireformat/openwire/utils/HexTableTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::HexTableTest );
-#include <activemq/wireformat/openwire/utils/OpenwireStringSupportTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::OpenwireStringSupportTest );
-#include <activemq/wireformat/openwire/utils/MessagePropertyInterceptorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::MessagePropertyInterceptorTest );
-
-#include <activemq/wireformat/openwire/OpenWireFormatTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::OpenWireFormatTest );
-
-#include <activemq/cmsutil/CmsAccessorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsAccessorTest );
-#include <activemq/cmsutil/CmsDestinationAccessorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsDestinationAccessorTest );
-#include <activemq/cmsutil/CmsTemplateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsTemplateTest );
-#include <activemq/cmsutil/DynamicDestinationResolverTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::DynamicDestinationResolverTest );
-#include <activemq/cmsutil/SessionPoolTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::SessionPoolTest );
-
-#include <activemq/core/ActiveMQConnectionFactoryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest );
-#include <activemq/core/ActiveMQConnectionTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest );
-#include <activemq/core/ActiveMQSessionTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest );
-#include <activemq/core/MessageDispatchChannelTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::MessageDispatchChannelTest );
-
-#include <activemq/state/ConnectionStateTrackerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTrackerTest );
-#include <activemq/state/ConnectionStateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTest );
-#include <activemq/state/ConsumerStateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConsumerStateTest );
-#include <activemq/state/ProducerStateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ProducerStateTest );
-#include <activemq/state/SessionStateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::SessionStateTest );
-#include <activemq/state/TransactionStateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::TransactionStateTest );
-
-#include <activemq/transport/failover/FailoverTransportTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::failover::FailoverTransportTest );
-
-#include <activemq/transport/correlator/ResponseCorrelatorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::correlator::ResponseCorrelatorTest );
-
-#include <activemq/transport/mock/MockTransportFactoryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::mock::MockTransportFactoryTest );
-
-#include <activemq/transport/inactivity/InactivityMonitorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::inactivity::InactivityMonitorTest );
-
-#include <activemq/transport/TransportRegistryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::TransportRegistryTest );
-#include <activemq/transport/IOTransportTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::IOTransportTest );
-
-#include <activemq/exceptions/ActiveMQExceptionTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::exceptions::ActiveMQExceptionTest );
-
-#include <activemq/util/LongSequenceGeneratorTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::LongSequenceGeneratorTest );
-#include <activemq/util/PrimitiveValueNodeTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueNodeTest );
-#include <activemq/util/PrimitiveListTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveListTest );
-#include <activemq/util/PrimitiveMapTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveMapTest );
-#include <activemq/util/PrimitiveValueConverterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueConverterTest );
-#include <activemq/util/URISupportTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::URISupportTest );
-#include <activemq/util/MemoryUsageTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MemoryUsageTest );
-
-#include <activemq/threads/DedicatedTaskRunnerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::DedicatedTaskRunnerTest );
-#include <activemq/threads/CompositeTaskRunnerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::CompositeTaskRunnerTest );
-
-#include <activemq/wireformat/WireFormatRegistryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::WireFormatRegistryTest );
-
-#include <decaf/internal/util/ByteArrayAdapterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::ByteArrayAdapterTest );
-#include <decaf/internal/util/TimerTaskHeapTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::TimerTaskHeapTest );
-
-#include <decaf/internal/nio/ByteArrayPerspectiveTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayPerspectiveTest );
-#include <decaf/internal/nio/ByteArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayBufferTest );
-#include <decaf/internal/nio/BufferFactoryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::BufferFactoryTest );
-#include <decaf/internal/nio/CharArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::CharArrayBufferTest );
-#include <decaf/internal/nio/DoubleArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::DoubleArrayBufferTest );
-#include <decaf/internal/nio/FloatArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::FloatArrayBufferTest );
-#include <decaf/internal/nio/LongArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::LongArrayBufferTest );
-#include <decaf/internal/nio/IntArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::IntArrayBufferTest );
-#include <decaf/internal/nio/ShortArrayBufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ShortArrayBufferTest );
-
-#include <decaf/internal/net/URIEncoderDecoderTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIEncoderDecoderTest );
-#include <decaf/internal/net/URIHelperTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIHelperTest );
-
-#include <decaf/nio/BufferTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::nio::BufferTest );
-
-#include <decaf/io/InputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamTest );
-#include <decaf/io/OutputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamTest );
-#include <decaf/io/FilterInputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterInputStreamTest );
-#include <decaf/io/FilterOutputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterOutputStreamTest );
-#include <decaf/io/BufferedInputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedInputStreamTest );
-#include <decaf/io/BufferedOutputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedOutputStreamTest );
-#include <decaf/io/ByteArrayInputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayInputStreamTest );
-#include <decaf/io/ByteArrayOutputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayOutputStreamTest );
-#include <decaf/io/DataInputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataInputStreamTest );
-#include <decaf/io/DataOutputStreamTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataOutputStreamTest );
-#include <decaf/io/WriterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::WriterTest );
-#include <decaf/io/ReaderTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ReaderTest );
-#include <decaf/io/OutputStreamWriterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamWriterTest );
-#include <decaf/io/InputStreamReaderTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamReaderTest );
-
-#include <decaf/lang/MathTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::MathTest );
-#include <decaf/lang/ByteTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ByteTest );
-#include <decaf/lang/CharacterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::CharacterTest );
-#include <decaf/lang/BooleanTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::BooleanTest );
-#include <decaf/lang/ShortTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ShortTest );
-#include <decaf/lang/IntegerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::IntegerTest );
-#include <decaf/lang/LongTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::LongTest );
-#include <decaf/lang/FloatTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::FloatTest );
-#include <decaf/lang/DoubleTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::DoubleTest );
-#include <decaf/lang/ExceptionTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ExceptionTest );
-#include <decaf/lang/ThreadTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadTest );
-#include <decaf/lang/SystemTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::SystemTest );
-#include <decaf/lang/PointerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::PointerTest );
-
-#include <decaf/net/SocketFactoryTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketFactoryTest );
-#include <decaf/net/SocketTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketTest );
-#include <decaf/net/URITest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URITest );
-#include <decaf/net/URISyntaxExceptionTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URISyntaxExceptionTest );
-#include <decaf/net/URLEncoderTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLEncoderTest );
-#include <decaf/net/URLDecoderTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLDecoderTest );
-
-#include <decaf/util/concurrent/ConcurrentStlMapTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentStlMapTest );
-#include <decaf/util/concurrent/CountDownLatchTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CountDownLatchTest );
-#include <decaf/util/concurrent/MutexTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::MutexTest );
-#include <decaf/util/concurrent/ThreadPoolTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ThreadPoolTest );
-#include <decaf/util/concurrent/TimeUnitTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::TimeUnitTest );
-
-#include <decaf/util/concurrent/atomic/AtomicBooleanTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicBooleanTest );
-#include <decaf/util/concurrent/atomic/AtomicIntegerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicIntegerTest );
-#include <decaf/util/concurrent/atomic/AtomicReferenceTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicReferenceTest );
-
-#include <decaf/util/concurrent/locks/LockSupportTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::LockSupportTest );
-
-#include <decaf/util/DateTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::DateTest );
-#include <decaf/util/UUIDTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::UUIDTest );
-#include <decaf/util/ListTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ListTest );
-#include <decaf/util/StlMapTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StlMapTest );
-#include <decaf/util/PropertiesTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PropertiesTest );
-#include <decaf/util/QueueTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::QueueTest );
-#include <decaf/util/RandomTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::RandomTest );
-#include <decaf/util/SetTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::SetTest );
-#include <decaf/util/StringTokenizerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StringTokenizerTest );
-#include <decaf/util/TimerTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::TimerTest );
-#include <decaf/util/PriorityQueueTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PriorityQueueTest );
-
-#include <decaf/util/zip/DeflaterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterTest );
-#include <decaf/util/zip/InflaterTest.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterTest );
-#include <decaf/util/zip/Adler32Test.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::Adler32Test );
-#include <decaf/util/zip/CRC32Test.h>
-CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CRC32Test );
+//#include <activemq/commands/BrokerInfoTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerInfoTest );
+//#include <activemq/commands/BrokerIdTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::BrokerIdTest );
+//#include <activemq/commands/ActiveMQTopicTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTopicTest );
+//#include <activemq/commands/ActiveMQTextMessageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTextMessageTest );
+//#include <activemq/commands/ActiveMQTempTopicTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempTopicTest );
+//#include <activemq/commands/ActiveMQTempQueueTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQTempQueueTest );
+//#include <activemq/commands/ActiveMQQueueTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQQueueTest );
+//#include <activemq/commands/ActiveMQMessageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMessageTest );
+//#include <activemq/commands/ActiveMQMapMessageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQMapMessageTest );
+//#include <activemq/commands/ActiveMQDestinationTest2.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQDestinationTest );
+//#include <activemq/commands/ActiveMQBytesMessageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQBytesMessageTest );
+//#include <activemq/commands/ActiveMQStreamMessageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::commands::ActiveMQStreamMessageTest );
+//
+//#include <activemq/wireformat/openwire/marshal/BaseDataStreamMarshallerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::BaseDataStreamMarshallerTest );
+//#include <activemq/wireformat/openwire/marshal/PrimitiveTypesMarshallerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::PrimitiveTypesMarshallerTest );
+//
+//#include <activemq/wireformat/openwire/utils/BooleanStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::BooleanStreamTest );
+//#include <activemq/wireformat/openwire/utils/HexTableTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::HexTableTest );
+//#include <activemq/wireformat/openwire/utils/OpenwireStringSupportTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::OpenwireStringSupportTest );
+//#include <activemq/wireformat/openwire/utils/MessagePropertyInterceptorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::utils::MessagePropertyInterceptorTest );
+//
+//#include <activemq/wireformat/openwire/OpenWireFormatTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::OpenWireFormatTest );
+//
+//#include <activemq/cmsutil/CmsAccessorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsAccessorTest );
+//#include <activemq/cmsutil/CmsDestinationAccessorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsDestinationAccessorTest );
+//#include <activemq/cmsutil/CmsTemplateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::CmsTemplateTest );
+//#include <activemq/cmsutil/DynamicDestinationResolverTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::DynamicDestinationResolverTest );
+//#include <activemq/cmsutil/SessionPoolTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::cmsutil::SessionPoolTest );
+//
+//#include <activemq/core/ActiveMQConnectionFactoryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest );
+//#include <activemq/core/ActiveMQConnectionTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest );
+//#include <activemq/core/ActiveMQSessionTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest );
+//#include <activemq/core/MessageDispatchChannelTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::MessageDispatchChannelTest );
+//
+//#include <activemq/state/ConnectionStateTrackerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTrackerTest );
+//#include <activemq/state/ConnectionStateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConnectionStateTest );
+//#include <activemq/state/ConsumerStateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ConsumerStateTest );
+//#include <activemq/state/ProducerStateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::ProducerStateTest );
+//#include <activemq/state/SessionStateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::SessionStateTest );
+//#include <activemq/state/TransactionStateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::state::TransactionStateTest );
+//
+//#include <activemq/transport/failover/FailoverTransportTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::failover::FailoverTransportTest );
+//
+//#include <activemq/transport/correlator/ResponseCorrelatorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::correlator::ResponseCorrelatorTest );
+//
+//#include <activemq/transport/mock/MockTransportFactoryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::mock::MockTransportFactoryTest );
+//
+//#include <activemq/transport/inactivity/InactivityMonitorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::inactivity::InactivityMonitorTest );
+//
+//#include <activemq/transport/TransportRegistryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::TransportRegistryTest );
+//#include <activemq/transport/IOTransportTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::transport::IOTransportTest );
+//
+//#include <activemq/exceptions/ActiveMQExceptionTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::exceptions::ActiveMQExceptionTest );
+//
+//#include <activemq/util/LongSequenceGeneratorTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::LongSequenceGeneratorTest );
+//#include <activemq/util/PrimitiveValueNodeTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueNodeTest );
+//#include <activemq/util/PrimitiveListTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveListTest );
+//#include <activemq/util/PrimitiveMapTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveMapTest );
+//#include <activemq/util/PrimitiveValueConverterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::PrimitiveValueConverterTest );
+//#include <activemq/util/URISupportTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::URISupportTest );
+//#include <activemq/util/MemoryUsageTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::util::MemoryUsageTest );
+//
+//#include <activemq/threads/DedicatedTaskRunnerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::DedicatedTaskRunnerTest );
+//#include <activemq/threads/CompositeTaskRunnerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::threads::CompositeTaskRunnerTest );
+//
+//#include <activemq/wireformat/WireFormatRegistryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::WireFormatRegistryTest );
+//
+//#include <decaf/internal/util/ByteArrayAdapterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::ByteArrayAdapterTest );
+//#include <decaf/internal/util/TimerTaskHeapTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::util::TimerTaskHeapTest );
+//
+//#include <decaf/internal/nio/ByteArrayPerspectiveTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayPerspectiveTest );
+//#include <decaf/internal/nio/ByteArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ByteArrayBufferTest );
+//#include <decaf/internal/nio/BufferFactoryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::BufferFactoryTest );
+//#include <decaf/internal/nio/CharArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::CharArrayBufferTest );
+//#include <decaf/internal/nio/DoubleArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::DoubleArrayBufferTest );
+//#include <decaf/internal/nio/FloatArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::FloatArrayBufferTest );
+//#include <decaf/internal/nio/LongArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::LongArrayBufferTest );
+//#include <decaf/internal/nio/IntArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::IntArrayBufferTest );
+//#include <decaf/internal/nio/ShortArrayBufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::nio::ShortArrayBufferTest );
+//
+//#include <decaf/internal/net/URIEncoderDecoderTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIEncoderDecoderTest );
+//#include <decaf/internal/net/URIHelperTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::internal::net::URIHelperTest );
+//
+//#include <decaf/nio/BufferTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::nio::BufferTest );
+//
+//#include <decaf/io/InputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamTest );
+//#include <decaf/io/OutputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamTest );
+//#include <decaf/io/FilterInputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterInputStreamTest );
+//#include <decaf/io/FilterOutputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::FilterOutputStreamTest );
+//#include <decaf/io/BufferedInputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedInputStreamTest );
+//#include <decaf/io/BufferedOutputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::BufferedOutputStreamTest );
+//#include <decaf/io/ByteArrayInputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayInputStreamTest );
+//#include <decaf/io/ByteArrayOutputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ByteArrayOutputStreamTest );
+#include <decaf/io/PushbackInputStreamTest.h>
+CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::PushbackInputStreamTest );
+//#include <decaf/io/DataInputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataInputStreamTest );
+//#include <decaf/io/DataOutputStreamTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::DataOutputStreamTest );
+//#include <decaf/io/WriterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::WriterTest );
+//#include <decaf/io/ReaderTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::ReaderTest );
+//#include <decaf/io/OutputStreamWriterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::OutputStreamWriterTest );
+//#include <decaf/io/InputStreamReaderTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::io::InputStreamReaderTest );
+//
+//#include <decaf/lang/MathTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::MathTest );
+//#include <decaf/lang/ByteTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ByteTest );
+//#include <decaf/lang/CharacterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::CharacterTest );
+//#include <decaf/lang/BooleanTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::BooleanTest );
+//#include <decaf/lang/ShortTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ShortTest );
+//#include <decaf/lang/IntegerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::IntegerTest );
+//#include <decaf/lang/LongTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::LongTest );
+//#include <decaf/lang/FloatTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::FloatTest );
+//#include <decaf/lang/DoubleTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::DoubleTest );
+//#include <decaf/lang/ExceptionTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ExceptionTest );
+//#include <decaf/lang/ThreadTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::ThreadTest );
+//#include <decaf/lang/SystemTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::SystemTest );
+//#include <decaf/lang/PointerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::lang::PointerTest );
+//
+//#include <decaf/net/SocketFactoryTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketFactoryTest );
+//#include <decaf/net/SocketTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::SocketTest );
+//#include <decaf/net/URITest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URITest );
+//#include <decaf/net/URISyntaxExceptionTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URISyntaxExceptionTest );
+//#include <decaf/net/URLEncoderTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLEncoderTest );
+//#include <decaf/net/URLDecoderTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::net::URLDecoderTest );
+//
+//#include <decaf/util/concurrent/ConcurrentStlMapTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ConcurrentStlMapTest );
+//#include <decaf/util/concurrent/CountDownLatchTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::CountDownLatchTest );
+//#include <decaf/util/concurrent/MutexTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::MutexTest );
+//#include <decaf/util/concurrent/ThreadPoolTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::ThreadPoolTest );
+//#include <decaf/util/concurrent/TimeUnitTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::TimeUnitTest );
+//
+//#include <decaf/util/concurrent/atomic/AtomicBooleanTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicBooleanTest );
+//#include <decaf/util/concurrent/atomic/AtomicIntegerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicIntegerTest );
+//#include <decaf/util/concurrent/atomic/AtomicReferenceTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::atomic::AtomicReferenceTest );
+//
+//#include <decaf/util/concurrent/locks/LockSupportTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::concurrent::locks::LockSupportTest );
+//
+//#include <decaf/util/DateTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::DateTest );
+//#include <decaf/util/UUIDTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::UUIDTest );
+//#include <decaf/util/ListTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::ListTest );
+//#include <decaf/util/StlMapTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StlMapTest );
+//#include <decaf/util/PropertiesTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PropertiesTest );
+//#include <decaf/util/QueueTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::QueueTest );
+//#include <decaf/util/RandomTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::RandomTest );
+//#include <decaf/util/SetTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::SetTest );
+//#include <decaf/util/StringTokenizerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::StringTokenizerTest );
+//#include <decaf/util/TimerTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::TimerTest );
+//#include <decaf/util/PriorityQueueTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::PriorityQueueTest );
+//
+//#include <decaf/util/zip/DeflaterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::DeflaterTest );
+//#include <decaf/util/zip/InflaterTest.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::InflaterTest );
+//#include <decaf/util/zip/Adler32Test.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::Adler32Test );
+//#include <decaf/util/zip/CRC32Test.h>
+//CPPUNIT_TEST_SUITE_REGISTRATION( decaf::util::zip::CRC32Test );
 
 ////////////////////////////////////////////////////////////////////////////////////////////////////////////
 // Marshaler Tests



Mime
View raw message