diff options
Diffstat (limited to 'qpid/cpp/src/tests/StoreStatus.cpp')
-rw-r--r-- | qpid/cpp/src/tests/StoreStatus.cpp | 117 |
1 files changed, 117 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/StoreStatus.cpp b/qpid/cpp/src/tests/StoreStatus.cpp new file mode 100644 index 0000000000..43d4cfd920 --- /dev/null +++ b/qpid/cpp/src/tests/StoreStatus.cpp @@ -0,0 +1,117 @@ +/* + * + * Copyright (c) 2006 The Apache Software Foundation + * + * Licensed 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 "test_tools.h" +#include "qpid/cluster/StoreStatus.h" +#include "qpid/framing/Uuid.h" +#include <boost/assign.hpp> +#include <boost/filesystem/operations.hpp> + +using namespace std; +using namespace qpid::cluster; +using namespace qpid::framing; +using namespace qpid::framing::cluster; +using namespace boost::assign; +using namespace boost::filesystem; + + +namespace qpid { +namespace tests { + +QPID_AUTO_TEST_SUITE(StoreStatusTestSuite) + +const char* TEST_DIR = "StoreStatus.tmp"; + +struct TestDir { + TestDir() { + remove_all(TEST_DIR); + create_directory(TEST_DIR); + } + ~TestDir() { + remove_all(TEST_DIR); + } +}; + +QPID_AUTO_TEST_CASE(testLoadEmpty) { + TestDir td; + StoreStatus ss(TEST_DIR); + BOOST_CHECK_EQUAL(ss.getState(), STORE_STATE_NO_STORE); + BOOST_CHECK(!ss.getClusterId()); + BOOST_CHECK(!ss.getShutdownId()); + ss.load(); + BOOST_CHECK_EQUAL(ss.getState(), STORE_STATE_EMPTY_STORE); + BOOST_CHECK(!ss.getShutdownId()); +} + +QPID_AUTO_TEST_CASE(testSaveLoadDirty) { + TestDir td; + Uuid clusterId = Uuid(true); + StoreStatus ss(TEST_DIR); + ss.load(); + ss.setClusterId(clusterId); + ss.dirty(); + BOOST_CHECK_EQUAL(ss.getState(), STORE_STATE_DIRTY_STORE); + + StoreStatus ss2(TEST_DIR); + ss2.load(); + BOOST_CHECK_EQUAL(ss2.getState(), STORE_STATE_DIRTY_STORE); + BOOST_CHECK_EQUAL(ss2.getClusterId(), clusterId); + BOOST_CHECK(!ss2.getShutdownId()); +} + +QPID_AUTO_TEST_CASE(testSaveLoadClean) { + TestDir td; + Uuid clusterId = Uuid(true); + Uuid shutdownId = Uuid(true); + StoreStatus ss(TEST_DIR); + ss.load(); + ss.setClusterId(clusterId); + ss.clean(shutdownId); + BOOST_CHECK_EQUAL(ss.getState(), STORE_STATE_CLEAN_STORE); + + StoreStatus ss2(TEST_DIR); + ss2.load(); + BOOST_CHECK_EQUAL(ss2.getState(), STORE_STATE_CLEAN_STORE); + BOOST_CHECK_EQUAL(ss2.getClusterId(), clusterId); + BOOST_CHECK_EQUAL(ss2.getShutdownId(), shutdownId); +} + +QPID_AUTO_TEST_CASE(testMarkDirty) { + // Save clean then mark to dirty. + TestDir td; + Uuid clusterId = Uuid(true); + Uuid shutdownId = Uuid(true); + StoreStatus ss(TEST_DIR); + ss.load(); + ss.setClusterId(clusterId); + ss.dirty(); + ss.clean(shutdownId); + ss.dirty(); + + StoreStatus ss2(TEST_DIR); + ss2.load(); + BOOST_CHECK_EQUAL(ss2.getState(), STORE_STATE_DIRTY_STORE); + BOOST_CHECK_EQUAL(ss2.getClusterId(), clusterId); + BOOST_CHECK(!ss2.getShutdownId()); +} + +QPID_AUTO_TEST_SUITE_END() + + }} // namespace qpid::tests |