diff options
author | Alan Conway <aconway@apache.org> | 2008-04-03 22:19:47 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2008-04-03 22:19:47 +0000 |
commit | 83026d0f664b69cc8ed74b1ed52df212f0a66ab7 (patch) | |
tree | 757296a69f9499afb5e11202e9a89846c682b985 /cpp/src/tests/serialize.cpp | |
parent | 39c9c45c38d82914324cbdf4c89d5ad92d9f8e6d (diff) | |
download | qpid-python-83026d0f664b69cc8ed74b1ed52df212f0a66ab7.tar.gz |
qpid/Serializer.h, qpid/amqp_0_10/Codec.h:
- serializer enforces overrunning encode/decode limits.
tests/amqp_0_10: Moved unit tests for amqp_0_10 namespace into amqp_0_10 directory.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@644533 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/serialize.cpp')
-rw-r--r-- | cpp/src/tests/serialize.cpp | 234 |
1 files changed, 0 insertions, 234 deletions
diff --git a/cpp/src/tests/serialize.cpp b/cpp/src/tests/serialize.cpp deleted file mode 100644 index 386f721338..0000000000 --- a/cpp/src/tests/serialize.cpp +++ /dev/null @@ -1,234 +0,0 @@ -/* - * - * 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 "unit_test.h" -#include "qpid/amqp_0_10/built_in_types.h" -#include "qpid/amqp_0_10/Codec.h" -#include "qpid/amqp_0_10/PackedCodec.h" -#include "qpid/amqp_0_10/specification.h" -#include "qpid/amqp_0_10/ControlHolder.h" -#include "qpid/amqp_0_10/Frame.h" -#include "qpid/amqp_0_10/Map.h" - -#include <boost/test/test_case_template.hpp> -#include <boost/type_traits/is_arithmetic.hpp> -#include <boost/utility/enable_if.hpp> -#include <boost/mpl/vector.hpp> -#include <boost/mpl/back_inserter.hpp> -#include <boost/mpl/copy.hpp> -#include <boost/mpl/empty_sequence.hpp> -#include <iterator> -#include <string> -#include <iostream> -#include <netinet/in.h> - -// Missing operators needed for tests. -namespace boost { -template <class T, size_t N> -std::ostream& operator<<(std::ostream& out, const array<T,N>& a) { - std::ostream_iterator<T> o(out, " "); - std::copy(a.begin(), a.end(), o); - return out; -} -} // boost - -namespace qpid { -namespace sys { - -std::ostream& operator<<(std::ostream& out, const AbsTime& t) { - return out << t.timeValue(); -} -} - -} // qpid - -QPID_AUTO_TEST_SUITE(SerializeTestSuite) - -using namespace std; -namespace mpl=boost::mpl; -using namespace qpid::amqp_0_10; -using qpid::framing::in_place; - -template <class A, class B> struct concat2 { typedef typename mpl::copy<B, typename mpl::back_inserter<A> >::type type; }; -template <class A, class B, class C> struct concat3 { typedef typename concat2<A, typename concat2<B, C>::type>::type type; }; -template <class A, class B, class C, class D> struct concat4 { typedef typename concat2<A, typename concat3<B, C, D>::type>::type type; }; - -typedef mpl::vector<Boolean, Char, Int32, Int64, Int8, Uint16, CharUtf32, Uint32, Uint64, Bin8, Uint8>::type IntegralTypes; -typedef mpl::vector<Bin1024, Bin128, Bin16, Bin256, Bin32, Bin40, Bin512, Bin64, Bin72>::type BinTypes; -typedef mpl::vector<Double, Float>::type FloatTypes; -typedef mpl::vector<SequenceNo, Uuid, Datetime, Dec32, Dec64> FixedSizeClassTypes; -typedef mpl::vector<Map, Vbin8, Str8Latin, Str8, Str8Utf16, Vbin16, Str16Latin, Str16, Str16Utf16, Vbin32> VariableSizeTypes; - -typedef concat4<IntegralTypes, BinTypes, FloatTypes, FixedSizeClassTypes>::type FixedSizeTypes; -typedef concat2<FixedSizeTypes, VariableSizeTypes>::type AllTypes; - -// TODO aconway 2008-02-20: should test 64 bit integrals for order also. -BOOST_AUTO_TEST_CASE(testNetworkByteOrder) { - string data; - - uint32_t l = 0x11223344; - Codec::encode(std::back_inserter(data))(l); - uint32_t enc=reinterpret_cast<const uint32_t&>(*data.data()); - uint32_t l2 = ntohl(enc); - BOOST_CHECK_EQUAL(l, l2); - - data.clear(); - uint16_t s = 0x1122; - Codec::encode(std::back_inserter(data))(s); - uint32_t s2 = ntohs(*reinterpret_cast<const uint32_t*>(data.data())); - BOOST_CHECK_EQUAL(s, s2); -} - -// Assign test values to the various types. -void testValue(bool& b) { b = true; } -void testValue(Bit&) { } -template <class T> typename boost::enable_if<boost::is_arithmetic<T> >::type testValue(T& n) { n=42; } -void testValue(CharUtf32& c) { c = 43; } -void testValue(long long& l) { l = 0x012345; } -void testValue(Datetime& dt) { dt = qpid::sys::now(); } -void testValue(Uuid& uuid) { uuid=Uuid(true); } -template <class E, class M> void testValue(Decimal<E,M>& d) { d.exponent=2; d.mantissa=0x1122; } -void testValue(SequenceNo& s) { s = 42; } -template <size_t N> void testValue(Bin<N>& a) { a.assign(42); } -template <class T, class S, int Unique> void testValue(SerializableString<T, S, Unique>& s) { - char msg[]="foobar"; - s.assign(msg, msg+sizeof(msg)); -} -void testValue(Str16& s) { s = "the quick brown fox jumped over the lazy dog"; } -void testValue(Str8& s) { s = "foobar"; } -void testValue(Map& m) { m["s"] = Str8("foobar"); m["b"] = true; m["c"] = uint16_t(42); } - -//typedef mpl::vector<Str8, Str16>::type TestTypes; -BOOST_AUTO_TEST_CASE_TEMPLATE(testEncodeDecode, T, AllTypes) -{ - string data; - T t; - testValue(t); - Codec::encode(std::back_inserter(data))(t); - - BOOST_CHECK_EQUAL(Codec::size(t), data.size()); - - T t2; - Codec::decode(data.begin())(t2); - BOOST_CHECK_EQUAL(t,t2); -} - -struct TestMe { - bool encoded, decoded; - char value; - TestMe(char v) : encoded(), decoded(), value(v) {} - template <class S> void encode(S& s) const { - const_cast<TestMe*>(this)->encoded=true; s(value); - } - template <class S> void decode(S& s) { decoded=true; s(value); } - template <class S> void serialize(S& s) { s.split(*this); } -}; - -BOOST_AUTO_TEST_CASE(testSplit) { - string data; - TestMe t1('x'); - Codec::encode(std::back_inserter(data))(t1); - BOOST_CHECK(t1.encoded); - BOOST_CHECK(!t1.decoded); - BOOST_CHECK_EQUAL(data, "x"); - - TestMe t2('y'); - Codec::decode(data.begin())(t2); - BOOST_CHECK(!t2.encoded); - BOOST_CHECK(t2.decoded); - BOOST_CHECK_EQUAL(t2.value, 'x'); -} - -BOOST_AUTO_TEST_CASE(testControlEncodeDecode) { - string data; - Control::Holder h(in_place<connection::Tune>(1,2,3,4)); - Codec::encode(std::back_inserter(data))(h); - - BOOST_CHECK_EQUAL(data.size(), Codec::size(h)); - - Codec::Decoder<string::iterator> decode(data.begin()); - Control::Holder h2; - decode(h2); - - BOOST_REQUIRE(h2.get()); - BOOST_CHECK_EQUAL(h2.get()->getClassCode(), connection::CODE); - BOOST_CHECK_EQUAL(h2.get()->getCode(), uint8_t(connection::Tune::CODE)); - connection::Tune& tune=static_cast<connection::Tune&>(*h2.get()); - BOOST_CHECK_EQUAL(tune.channelMax, 1u); - BOOST_CHECK_EQUAL(tune.maxFrameSize, 2u); - BOOST_CHECK_EQUAL(tune.heartbeatMin, 3u); - BOOST_CHECK_EQUAL(tune.heartbeatMax, 4u); -} - -BOOST_AUTO_TEST_CASE(testFrameEncodeDecode) { - static const int overhead=12; - string data; - Frame r, c; - char d1[]="abcdefg"; - r.refer(d1, d1+sizeof(d1)); - r.setFlags(Frame::FIRST_FRAME); - r.setType(CONTROL); - r.setChannel(32); - r.setTrack(1); - char d2[]="01234567"; - c.copy(d2, d2+sizeof(d2)); - - BOOST_CHECK_EQUAL(overhead+sizeof(d1), Codec::size(r)); - BOOST_CHECK_EQUAL(overhead+sizeof(d2), Codec::size(c)); - Codec::encode(std::back_inserter(data))(r)(c); - BOOST_CHECK_EQUAL(data.size(), Codec::size(r)+Codec::size(c)); - - FrameHeader fh; - std::string::iterator i = Codec::decode(data.begin())(fh).pos(); - size_t s = fh.size(); - BOOST_CHECK_EQUAL(s, sizeof(d1)); - BOOST_CHECK_EQUAL(std::string(i, i+s), std::string(d1, d1+s)); - - - Frame f1, f2; - Codec::decode(data.begin())(f1)(f2); - BOOST_CHECK_EQUAL(f1.size(), sizeof(d1)); - BOOST_CHECK_EQUAL(std::string(f1.begin(), f1.size()), - std::string(d1, sizeof(d1))); - BOOST_CHECK_EQUAL(f1.size(), r.size()); - BOOST_CHECK_EQUAL(f1.getFlags(), Frame::FIRST_FRAME); - BOOST_CHECK_EQUAL(f1.getType(), CONTROL); - BOOST_CHECK_EQUAL(f1.getChannel(), 32); - BOOST_CHECK_EQUAL(f1.getTrack(), 1); - - BOOST_CHECK_EQUAL(f2.size(), c.size()); - BOOST_CHECK_EQUAL(std::string(f2.begin(), f2.end()), - std::string(d2, d2+sizeof(d2))); - -} - -BOOST_AUTO_TEST_CASE(testPackedCodec) { - int i=-1, j=-1, k=-1, l=-1; - std::string data; - Codec::encode(std::back_inserter(data))(1)(3); - PackedCodec::decode(0x5, Codec::decode(data.begin()))(i)(j)(k)(l); - BOOST_CHECK_EQUAL(i, 1); - BOOST_CHECK_EQUAL(j, 0); - BOOST_CHECK_EQUAL(k, 3); - BOOST_CHECK_EQUAL(l, 0); -} - -QPID_AUTO_TEST_SUITE_END() |