[rhmessaging-commits] rhmessaging commits: r1263 - store/trunk/cpp/tests/jrnl.
Author: kpvdr
Date: 2007-11-07 15:03:15 -0500 (Wed, 07 Nov 2007)
New Revision: 1263
Added:
store/trunk/cpp/tests/jrnl/JournalSystemTests.hpp
Log:
OOPS! (need I add more?)
Added: store/trunk/cpp/tests/jrnl/JournalSystemTests.hpp
===================================================================
--- store/trunk/cpp/tests/jrnl/JournalSystemTests.hpp (rev 0)
+++ store/trunk/cpp/tests/jrnl/JournalSystemTests.hpp 2007-11-07 20:03:15 UTC (rev 1263)
@@ -0,0 +1,92 @@
+/**
+* \file JournalSystemTests.hpp
+*
+* Red Hat Messaging - Message Journal
+*
+* This file contains header files for the journal unit tests.
+*
+* Copyright 2007 Red Hat, Inc.
+*
+* This file is part of Red Hat Messaging.
+*
+* Red Hat Messaging is free software; you can redistribute it and/or
+* modify it under the terms of the GNU Lesser General Public
+* License as published by the Free Software Foundation; either
+* version 2.1 of the License, or (at your option) any later version.
+*
+* This library is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this library; if not, write to the Free Software
+* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
+* USA
+*
+* The GNU Lesser General Public License is available in the file COPYING.
+*/
+
+#ifndef JournalSystemTests_hpp
+#define JournalSystemTests_hpp
+
+#include "../test_plugin.h"
+#include <jrnl/jcntl.hpp>
+
+class JournalSystemTests : public CppUnit::TestCase
+{
+ CPPUNIT_TEST_SUITE(JournalSystemTests);
+ CPPUNIT_TEST(InstantiationTest);
+ CPPUNIT_TEST(InitializationTest);
+ CPPUNIT_TEST(EmptyRecoverTest);
+ CPPUNIT_TEST(EnqueueTest);
+ CPPUNIT_TEST(RecoverReadTest);
+ CPPUNIT_TEST(RecoveredReadTest);
+ CPPUNIT_TEST(RecoveredDequeueTest);
+ CPPUNIT_TEST(HeaderFlagsTest);
+// CPPUNIT_TEST(ComplexRecoveryTest1);
+ CPPUNIT_TEST_SUITE_END();
+
+ std::string msg;
+ std::string xid;
+ void* mbuff;
+ size_t msize;
+ void* xidbuff;
+ size_t xidsize;
+ bool transientFlag;
+ bool externalFlag;
+
+public:
+ void InstantiationTest();
+ void InitializationTest();
+ void EmptyRecoverTest();
+ void EnqueueTest();
+ void RecoverReadTest();
+ void RecoveredReadTest();
+ void RecoveredDequeueTest();
+ void HeaderFlagsTest();
+ void ComplexRecoveryTest1();
+
+private:
+ void enq_msg(rhm::journal::jcntl* jc, const std::string msg, const bool transient);
+ void enq_extern_msg(rhm::journal::jcntl* jc, const bool transient);
+ void enq_txn_msg(rhm::journal::jcntl* jc, const std::string msg, const std::string
xid,
+ const bool transient);
+ void enq_extern_txn_msg(rhm::journal::jcntl* jc, const std::string xid, const bool
transient);
+ void deq_msg(rhm::journal::jcntl* jc, u_int64_t rid);
+ void deq_txn_msg(rhm::journal::jcntl* jc, u_int64_t rid, const std::string xid);
+ void txn_abort(rhm::journal::jcntl* jc, const std::string xid);
+ void txn_commit(rhm::journal::jcntl* jc, const std::string xid);
+ char* read_msg(rhm::journal::jcntl* jc);
+ bool handle_jcntl_response(rhm::journal::iores res, rhm::journal::jcntl* jc,
+ unsigned& aio_sleep_cnt, rhm::journal::data_tok* dtp);
+ static std::string& create_msg(std::string& s, int msg_num, int len);
+ static std::string& create_xid(std::string& s, int msg_num, int len);
+ void cleanMessage();
+};
+
+// Make this test suite a plugin.
+CPPUNIT_PLUGIN_IMPLEMENT();
+CPPUNIT_TEST_SUITE_REGISTRATION(JournalSystemTests);
+
+#endif