You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/07/19 10:27:42 UTC
svn commit: r557522 [2/2] - in /incubator/qpid/trunk/qpid/cpp:
gentools/src/org/apache/qpid/gentools/ perftest/ src/ src/qpid/broker/
src/qpid/framing/ src/tests/
Added: incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp?view=auto&rev=557522
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp (added)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp Thu Jul 19 01:27:36 2007
@@ -0,0 +1,108 @@
+/*
+ *
+ * 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 "qpid_test_plugin.h"
+#include <iostream>
+#include "qpid/framing/SequenceNumber.h"
+
+using namespace qpid::framing;
+
+class SequenceNumberTest : public CppUnit::TestCase
+{
+ CPPUNIT_TEST_SUITE(SequenceNumberTest);
+ CPPUNIT_TEST(testIncrementPostfix);
+ CPPUNIT_TEST(testIncrementPrefix);
+ CPPUNIT_TEST(testWrapAround);
+ CPPUNIT_TEST_SUITE_END();
+
+ public:
+
+ void testIncrementPostfix()
+ {
+ SequenceNumber a;
+ SequenceNumber b;
+ CPPUNIT_ASSERT(!(a > b));
+ CPPUNIT_ASSERT(!(b < a));
+ CPPUNIT_ASSERT(a == b);
+
+ SequenceNumber c = a++;
+ CPPUNIT_ASSERT(a > b);
+ CPPUNIT_ASSERT(b < a);
+ CPPUNIT_ASSERT(a != b);
+ CPPUNIT_ASSERT(c < a);
+ CPPUNIT_ASSERT(a != c);
+
+ b++;
+ CPPUNIT_ASSERT(!(a > b));
+ CPPUNIT_ASSERT(!(b < a));
+ CPPUNIT_ASSERT(a == b);
+ CPPUNIT_ASSERT(c < b);
+ CPPUNIT_ASSERT(b != c);
+ }
+
+ void testIncrementPrefix()
+ {
+ SequenceNumber a;
+ SequenceNumber b;
+ CPPUNIT_ASSERT(!(a > b));
+ CPPUNIT_ASSERT(!(b < a));
+ CPPUNIT_ASSERT(a == b);
+
+ SequenceNumber c = ++a;
+ CPPUNIT_ASSERT(a > b);
+ CPPUNIT_ASSERT(b < a);
+ CPPUNIT_ASSERT(a != b);
+ CPPUNIT_ASSERT(a == c);
+
+ ++b;
+ CPPUNIT_ASSERT(!(a > b));
+ CPPUNIT_ASSERT(!(b < a));
+ CPPUNIT_ASSERT(a == b);
+ }
+
+ void testWrapAround()
+ {
+ const uint32_t max = 0xFFFFFFFF;
+ SequenceNumber a(max - 10);
+ SequenceNumber b(max - 5);
+
+ //increment until b wraps around
+ for (int i = 0; i < 6; i++) {
+ CPPUNIT_ASSERT(++a < ++b);//test prefix
+ }
+ //verify we have wrapped around
+ CPPUNIT_ASSERT(a.getValue() > b.getValue());
+ //keep incrementing until a also wraps around
+ for (int i = 0; i < 6; i++) {
+ CPPUNIT_ASSERT(a++ < b++);//test postfix
+ }
+ //let a 'catch up'
+ for (int i = 0; i < 5; i++) {
+ a++;
+ }
+ CPPUNIT_ASSERT(a == b);
+ CPPUNIT_ASSERT(++a > b);
+ }
+};
+
+// Make this test suite a plugin.
+CPPUNIT_PLUGIN_IMPLEMENT();
+CPPUNIT_TEST_SUITE_REGISTRATION(SequenceNumberTest);
Propchange: incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/qpid/trunk/qpid/cpp/src/tests/SequenceNumberTest.cpp
------------------------------------------------------------------------------
svn:keywords = Rev Date
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/TxAckTest.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/TxAckTest.cpp?view=diff&rev=557522&r1=557521&r2=557522
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/TxAckTest.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/TxAckTest.cpp Thu Jul 19 01:27:36 2007
@@ -69,8 +69,7 @@
{
for(int i = 0; i < 10; i++){
Message::shared_ptr msg(
- new BasicMessage(0, "exchange", "routing_key", false, false,
- MockChannel::basicGetBody()));
+ new BasicMessage(0, "exchange", "routing_key", false, false));
msg->setHeader(AMQHeaderBody::shared_ptr(new AMQHeaderBody(BASIC)));
msg->getHeaderProperties()->setDeliveryMode(PERSISTENT);
messages.push_back(msg);
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/TxPublishTest.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/TxPublishTest.cpp?view=diff&rev=557522&r1=557521&r2=557522
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/TxPublishTest.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/TxPublishTest.cpp Thu Jul 19 01:27:36 2007
@@ -69,8 +69,7 @@
TxPublishTest() :
queue1(new Queue("queue1", false, &store, 0)),
queue2(new Queue("queue2", false, &store, 0)),
- msg(new BasicMessage(0, "exchange", "routing_key", false, false,
- MockChannel::basicGetBody())),
+ msg(new BasicMessage(0, "exchange", "routing_key", false, false)),
op(msg)
{
msg->setHeader(AMQHeaderBody::shared_ptr(new AMQHeaderBody(BASIC)));