summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
Diffstat (limited to 'tests')
-rw-r--r--tests/CMakeLists.txt3
-rw-r--r--tests/queue_test_thread.cpp111
-rw-r--r--tests/queue_test_thread.h43
-rw-r--r--tests/test_queue.cpp135
4 files changed, 292 insertions, 0 deletions
diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt
index 95dcd64..a1c88db 100644
--- a/tests/CMakeLists.txt
+++ b/tests/CMakeLists.txt
@@ -24,8 +24,11 @@ SET(CERT_CHECKER_TESTS_SOURCES
${CERT_CHECKER_TESTS_SRC_PATH}/dbfixture.cpp
${CERT_CHECKER_TESTS_SRC_PATH}/colour_log_formatter.cpp
${CERT_CHECKER_TESTS_SRC_PATH}/test_db.cpp
+ ${CERT_CHECKER_TESTS_SRC_PATH}/test_queue.cpp
+ ${CERT_CHECKER_TESTS_SRC_PATH}/queue_test_thread.cpp
# cert-checker
${CERT_CHECKER_SRC_PATH}/app.cpp
+ ${CERT_CHECKER_SRC_PATH}/queue.cpp
# logs
${CERT_CHECKER_SRC_PATH}/log/log.cpp
# dpl
diff --git a/tests/queue_test_thread.cpp b/tests/queue_test_thread.cpp
new file mode 100644
index 0000000..aefc11b
--- /dev/null
+++ b/tests/queue_test_thread.cpp
@@ -0,0 +1,111 @@
+/*
+ * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ * 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.
+ */
+/*
+ * @file queue_test_thread.h
+ * @author Janusz Kozerski (j.kozerski@samsung.com)
+ * @version 1.0
+ * @brief Implementation of class for multi-thread testing Queue
+ */
+
+#include <thread>
+#include <unistd.h>
+
+#include <cchecker/app.h>
+#include <cchecker/queue.h>
+#include <cchecker/log.h>
+
+#include <queue_test_thread.h>
+
+namespace CCHECKER {
+
+#define APPS_COUNT 10
+
+app_t app[APPS_COUNT] = {
+ app_t ("app_id0", "###", 0, {}),
+ app_t ("app_id1", "pkg_id1", 1, {}),
+ app_t ("app_id2", "pkg_id2", 2, {}),
+ app_t ("app_id3", "###", 3, {}),
+ app_t ("app_id4", "###", 4, {}),
+ app_t ("app_id5", "###", 5, {}),
+ app_t ("app_id6", "###", 6, {}),
+ app_t ("app_id7", "###", 7, {}),
+ app_t ("app_id8", "###", 8, {}),
+ app_t ("app_id9", "###", 9, {})
+};
+
+void TestQueue::add_events_th(int number_of_threads)
+{
+ if (number_of_threads < 1) {
+ LogDebug("Too few threads, at least 1 should be used");
+ number_of_threads = 1;
+ }
+
+ m_sent = 0;
+ m_max_events = number_of_threads * 2 * APPS_COUNT;
+
+ LogDebug("Running threads");
+ for (int i=0; i<number_of_threads; i++)
+ std::thread(&TestQueue::add_events, this).detach();
+
+ LogDebug("Running threads done");
+}
+
+void TestQueue::add_events()
+{
+ for (int i = 0; i < APPS_COUNT; i++) {
+ m_queue.push_event(event_t(app[i], event_t::event_type_t::APP_INSTALL));
+ m_sent++;
+ LogDebug("Add event : " << i);
+ }
+
+ for (int i = 0; i < APPS_COUNT; i++) {
+ m_queue.push_event(event_t(app[i], event_t::event_type_t::APP_UNINSTALL));
+ m_sent++;
+ LogDebug("Add event : " << i);
+ }
+}
+
+bool TestQueue::pop_events()
+{
+ int i_install = 0;
+ int i_uninstall = 0;
+ event_t ev;
+
+ LogDebug("Looking events...");
+ do {
+ while(m_queue.pop_event(ev)) {
+ if (ev.event_type == event_t::event_type_t::APP_INSTALL)
+ i_install++;
+ else if (ev.event_type == event_t::event_type_t::APP_UNINSTALL)
+ i_uninstall++;
+ }
+ } while (m_sent < m_max_events);
+
+ // Read all events once again - just for case
+ while(m_queue.pop_event(ev)) {
+ if (ev.event_type == event_t::event_type_t::APP_INSTALL)
+ i_install++;
+ else if (ev.event_type == event_t::event_type_t::APP_UNINSTALL)
+ i_uninstall++;
+ }
+ LogDebug("Found " << i_install + i_uninstall << " events.");
+
+ if (i_install != m_max_events/2 || i_uninstall != m_max_events/2)
+ return false;
+ return true;
+}
+
+} // CCHECKER
diff --git a/tests/queue_test_thread.h b/tests/queue_test_thread.h
new file mode 100644
index 0000000..c2489d5
--- /dev/null
+++ b/tests/queue_test_thread.h
@@ -0,0 +1,43 @@
+/*
+ * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ * 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.
+ */
+/*
+ * @file queue_test_thread.h
+ * @author Janusz Kozerski (j.kozerski@samsung.com)
+ * @version 1.0
+ * @brief Implementation of class for multi-thread testing Queue
+ */
+
+#include <cchecker/queue.h>
+
+namespace CCHECKER {
+
+class TestQueue {
+ public:
+ TestQueue():
+ m_sent(0),
+ m_max_events(0)
+ {};
+ void add_events_th (int number_of_threads);
+ bool pop_events ();
+
+ private:
+ Queue m_queue;
+ int m_sent;
+ int m_max_events;
+ void add_events();
+};
+
+} // CCHECKER
diff --git a/tests/test_queue.cpp b/tests/test_queue.cpp
new file mode 100644
index 0000000..2fe7f3e
--- /dev/null
+++ b/tests/test_queue.cpp
@@ -0,0 +1,135 @@
+/*
+ * Copyright (c) 2015 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ * 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.
+ */
+/*
+ * @file test_queue.cpp
+ * @author Janusz Kozerski (j.kozerski@samsung.com)
+ * @version 1.0
+ * @brief Tests of thread-safe queue
+ */
+
+#include <boost/test/unit_test.hpp>
+#include <string>
+#include <thread>
+
+#include <cchecker/app.h>
+#include <cchecker/log.h>
+#include <cchecker/queue.h>
+
+#include <queue_test_thread.h>
+
+using namespace CCHECKER;
+
+BOOST_FIXTURE_TEST_SUITE(QUEUE_TEST, Queue)
+
+BOOST_AUTO_TEST_CASE(Queue) {
+
+ app_t app1("app_id1", "pkg_id1", 1, {});
+ app_t app2("app_id2", "pkg_id2", 2, {});
+ app_t app3("app_id@", "###", 3, {});
+
+ event_t ev1(app1, event_t::event_type_t::APP_INSTALL);
+ event_t ev2(app1, event_t::event_type_t::APP_UNINSTALL);
+
+ event_t ev3(app2, event_t::event_type_t::APP_INSTALL);
+ event_t ev4(app2, event_t::event_type_t::APP_UNINSTALL);
+
+ event_t ev;
+
+ BOOST_REQUIRE(empty() == true);
+ BOOST_REQUIRE(pop_event(ev) == false);
+ BOOST_REQUIRE(empty() == true);
+ push_event(ev1);
+ BOOST_REQUIRE(empty() == false);
+
+ BOOST_REQUIRE(pop_event(ev) == true);
+ BOOST_REQUIRE(ev1.app.app_id == ev.app.app_id);
+ BOOST_REQUIRE(ev1.app.pkg_id == ev.app.pkg_id);
+ BOOST_REQUIRE(ev1.app.uid == ev.app.uid);
+ // Certs and verified flag aren't used in queue, but can be tested
+ BOOST_REQUIRE(ev1.app.certificates == ev.app.certificates);
+ BOOST_REQUIRE(ev1.app.verified == ev.app.verified);
+ BOOST_REQUIRE(empty() == true);
+
+ push_event(ev2);
+ push_event(ev3);
+ BOOST_REQUIRE(empty() == false);
+
+ BOOST_REQUIRE(pop_event(ev) == true);
+ BOOST_REQUIRE(ev2.app.app_id == ev.app.app_id);
+ BOOST_REQUIRE(ev2.app.pkg_id == ev.app.pkg_id);
+ BOOST_REQUIRE(ev2.app.uid == ev.app.uid);
+ // Certs and verified flag aren't used in queue, but can be tested
+ BOOST_REQUIRE(ev2.app.certificates == ev.app.certificates);
+ BOOST_REQUIRE(ev2.app.verified == ev.app.verified);
+
+
+ BOOST_REQUIRE(pop_event(ev) == true);
+ BOOST_REQUIRE(ev3.app.app_id == ev.app.app_id);
+ BOOST_REQUIRE(ev3.app.pkg_id == ev.app.pkg_id);
+ BOOST_REQUIRE(ev3.app.uid == ev.app.uid);
+ // Certs and verified flag aren't used in queue, but can be tested
+ BOOST_REQUIRE(ev3.app.certificates == ev.app.certificates);
+ BOOST_REQUIRE(ev3.app.verified == ev.app.verified);
+
+ BOOST_REQUIRE(empty() == true);
+ BOOST_REQUIRE(pop_event(ev) == false);
+ push_event(ev4);
+ BOOST_REQUIRE(empty() == false);
+ BOOST_REQUIRE(pop_event(ev) == true);
+ BOOST_REQUIRE(pop_event(ev) == false);
+ BOOST_REQUIRE(pop_event(ev) == false);
+ BOOST_REQUIRE(empty() == true);
+
+ push_event(ev4);
+
+ BOOST_REQUIRE(pop_event(ev) == true);
+ BOOST_REQUIRE(ev4.app.app_id == ev.app.app_id);
+ BOOST_REQUIRE(ev4.app.pkg_id == ev.app.pkg_id);
+ BOOST_REQUIRE(ev4.app.uid == ev.app.uid);
+ // Certs and verified flag aren't used in queue, but can be tested
+ BOOST_REQUIRE(ev4.app.certificates == ev.app.certificates);
+ BOOST_REQUIRE(ev4.app.verified == ev.app.verified);
+
+ BOOST_REQUIRE(pop_event(ev) == false);
+ BOOST_REQUIRE(empty() == true);
+}
+
+BOOST_AUTO_TEST_SUITE_END()
+
+BOOST_FIXTURE_TEST_SUITE(QUEUE_MULTI_THREAD_TEST, TestQueue)
+
+BOOST_AUTO_TEST_CASE(TestQueue) {
+
+ add_events_th (1);
+ BOOST_REQUIRE(pop_events() == true);
+
+ add_events_th (2);
+ BOOST_REQUIRE(pop_events() == true);
+
+ add_events_th (3);
+ BOOST_REQUIRE(pop_events() == true);
+
+ add_events_th (5);
+ BOOST_REQUIRE(pop_events() == true);
+
+ add_events_th (10);
+ BOOST_REQUIRE(pop_events() == true);
+
+ add_events_th (20);
+ BOOST_REQUIRE(pop_events() == true);
+}
+
+BOOST_AUTO_TEST_SUITE_END()
generated by cgit v1.2.3 (git 2.25.1) at 2024-04-16 08:48:02 +0000