activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r452053 [17/17] - in /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/ main/activemq/connector/openwire/marshal/ main/activemq/connector/openwire/marshal/V2...
Date Mon, 02 Oct 2006 14:30:22 GMT
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.cpp
(added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.cpp
Mon Oct  2 07:30:10 2006
@@ -0,0 +1,21 @@
+/*
+ * 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 "DataInputStreamTest.h"
+
+CPPUNIT_TEST_SUITE_REGISTRATION( activemq::io::DataInputStreamTest );
+

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

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.h
(added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataInputStreamTest.h
Mon Oct  2 07:30:10 2006
@@ -0,0 +1,129 @@
+/*
+ * 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 ACTIVEMQ_IO_DATAINPUTSTREAMTEST_H_
+#define ACTIVEMQ_IO_DATAINPUTSTREAMTEST_H_
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/extensions/HelperMacros.h>
+
+#include <activemq/exceptions/ActiveMQException.h>
+#include <activemq/io/BufferedInputStream.h>
+#include <activemq/io/ByteArrayInputStream.h>
+#include <activemq/util/Endian.h>
+#include <activemq/io/DataInputStream.h>
+
+#ifdef min
+#undef min
+#endif
+
+#include <algorithm>
+
+namespace activemq{
+namespace io{
+	
+	class DataInputStreamTest : public CppUnit::TestFixture {
+		
+	  CPPUNIT_TEST_SUITE( DataInputStreamTest );
+	  CPPUNIT_TEST( test );
+	  CPPUNIT_TEST_SUITE_END();
+			
+	public:
+	
+		virtual void setUp(){};	
+	 	virtual void tearDown(){};
+		void test(){
+			
+			unsigned char buffer[1000];			
+			int ix = 0;	
+			
+			unsigned char byteVal = (unsigned char)'T';
+			uint16_t shortVal = 5;
+			uint32_t intVal = 10000;
+			uint64_t longVal = 1000000000;
+			float floatVal = 10.0f;
+			double doubleVal = 100.0;
+			unsigned char arrayVal[3] = {
+				'a', 'b', 'c'
+			};
+			
+			int size = sizeof(char);
+			memcpy( (char*)(buffer+ix), (char*)&byteVal, size );
+			ix += size;
+			
+			size = sizeof(uint16_t);
+			uint16_t tempShort = util::Endian::byteSwap(shortVal);
+			memcpy( (char*)(buffer+ix), (char*)&tempShort, size );
+			ix += size;
+			
+			size = sizeof(uint32_t);
+			uint32_t tempInt = util::Endian::byteSwap(intVal);
+			memcpy( (char*)(buffer+ix), (char*)&tempInt, size );
+			ix += size;
+			
+			size = sizeof(uint64_t);
+			uint64_t tempLong = util::Endian::byteSwap(longVal);
+			memcpy( (char*)(buffer+ix), (char*)&tempLong, size );
+			ix += size;
+			
+			size = sizeof(float);
+			float tempFloat = util::Endian::byteSwap(floatVal);
+			memcpy( (char*)(buffer+ix), (char*)&tempFloat, size );
+			ix += size;
+			
+			size = sizeof(double);
+			double tempDouble = util::Endian::byteSwap(doubleVal);
+			memcpy( (char*)(buffer+ix), (char*)&tempDouble, size );
+			ix += size;
+			
+			size = 3;
+			memcpy( (char*)(buffer+ix), (char*)&arrayVal, size );
+			ix += size;
+
+			// Create the stream with the buffer we just wrote to.
+			ByteArrayInputStream myStream( buffer, 1000 );
+			DataInputStream reader( &myStream );
+			
+			byteVal = reader.readByte();
+			CPPUNIT_ASSERT( byteVal == (unsigned char)'T' );
+			
+			shortVal = reader.readShort();
+			CPPUNIT_ASSERT( shortVal == 5 );
+			
+			intVal = reader.readInt();
+			CPPUNIT_ASSERT( intVal == 10000 );
+			
+			longVal = reader.readLong();
+			CPPUNIT_ASSERT( longVal == 1000000000 );
+			
+			floatVal = reader.readFloat();
+			CPPUNIT_ASSERT( floatVal == 10.0f );
+			
+			doubleVal = reader.readDouble();
+			CPPUNIT_ASSERT( doubleVal == 100.0 );
+			
+			reader.read( arrayVal, 0, 3 );
+			CPPUNIT_ASSERT( arrayVal[0] == 'a' );
+			CPPUNIT_ASSERT( arrayVal[1] == 'b' );
+			CPPUNIT_ASSERT( arrayVal[2] == 'c' );
+		}
+
+	};
+	
+}}
+
+#endif /*ACTIVEMQ_IO_DATAINPUTSTREAMTEST_H_*/

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

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.cpp
(added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.cpp
Mon Oct  2 07:30:10 2006
@@ -0,0 +1,21 @@
+/*
+ * 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 "DataOutputStreamTest.h"
+
+CPPUNIT_TEST_SUITE_REGISTRATION( activemq::io::DataOutputStreamTest );
+

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

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h
(added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test/activemq/io/DataOutputStreamTest.h
Mon Oct  2 07:30:10 2006
@@ -0,0 +1,98 @@
+/*
+ * 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 ACTIVEMQ_IO_DATAOUTPUTSTREAMTEST_H_
+#define ACTIVEMQ_IO_DATAOUTPUTSTREAMTEST_H_
+
+#include <cppunit/TestFixture.h>
+#include <cppunit/extensions/HelperMacros.h>
+
+#include <activemq/util/Endian.h>
+#include <activemq/io/DataOutputStream.h>
+#include <activemq/io/ByteArrayOutputStream.h>
+
+namespace activemq{
+namespace io{
+	
+	class DataOutputStreamTest : public CppUnit::TestFixture {
+		
+	  CPPUNIT_TEST_SUITE( DataOutputStreamTest );
+	  CPPUNIT_TEST( test );
+	  CPPUNIT_TEST_SUITE_END();
+	  
+	public:
+	
+		virtual void setUp(){};	
+	 	virtual void tearDown(){};
+		void test(){
+			
+			unsigned char byteVal = (unsigned char)'T';
+			uint16_t shortVal = 5;
+			uint32_t intVal = 10000;
+			uint64_t longVal = 1000000000;
+			float floatVal = 10.0f;
+			double doubleVal = 100.0;
+			unsigned char arrayVal[3] = {
+				'a', 'b', 'c'
+			};
+			
+			// Create the stream with the buffer we just wrote to.
+			ByteArrayOutputStream myStream;
+			DataOutputStream writer( &myStream );
+			
+			writer.writeByte( byteVal );
+			writer.writeShort( shortVal );
+			writer.writeInt( intVal );
+			writer.writeLong( longVal );
+			writer.writeFloat( floatVal );
+			writer.writeDouble( doubleVal );
+			writer.write( arrayVal, 3 );
+			
+			
+			const unsigned char* buffer = myStream.getByteArray();
+			int ix = 0;
+			
+			unsigned char tempByte = buffer[ix];
+			CPPUNIT_ASSERT( tempByte == byteVal );
+			ix += sizeof( tempByte );
+
+			uint16_t tempShort = util::Endian::byteSwap( *(uint16_t*)(buffer+ix) );
+			CPPUNIT_ASSERT( tempShort == shortVal );
+			ix += sizeof( tempShort );
+			
+			uint32_t tempInt = util::Endian::byteSwap( *(uint32_t*)(buffer+ix) );
+			CPPUNIT_ASSERT( tempInt == intVal );
+			ix += sizeof( tempInt );
+			
+			uint64_t tempLong = util::Endian::byteSwap( *(uint64_t*)(buffer+ix) );
+			CPPUNIT_ASSERT( tempLong == longVal );
+			ix += sizeof( tempLong );
+			
+			float tempFloat = util::Endian::byteSwap( *(float*)(buffer+ix) );
+			CPPUNIT_ASSERT( tempFloat == floatVal );
+			ix += sizeof( tempFloat );
+			
+			double tempDouble = util::Endian::byteSwap( *(double*)(buffer+ix) );
+			CPPUNIT_ASSERT( tempDouble == doubleVal );
+			ix += sizeof( tempDouble );
+		}
+
+	};
+	
+}}
+
+#endif /*ACTIVEMQ_IO_DATAOUTPUTSTREAMTEST_H_*/

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



Mime
View raw message