[rhmessaging-commits] rhmessaging commits: r1263 - store/trunk/cpp/tests/jrnl.

[rhmessaging-commits at lists.jboss.org]

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