diff options
author | sangwan.kwon <sangwan.kwon@samsung.com> | 2016-05-30 14:27:13 +0900 |
---|---|---|
committer | sangwan.kwon <sangwan.kwon@samsung.com> | 2016-05-30 14:35:25 +0900 |
commit | b8ffd7662428b4baff92a0c8271e84c2b55ce47b (patch) | |
tree | cdeecf4ba84a2fb7c852fa6c538a304f2a458196 /tests/queue_test_thread.cpp | |
parent | 30177b747ab42a7cedc5228803e057d05583b1a6 (diff) | |
download | cert-checker-b8ffd7662428b4baff92a0c8271e84c2b55ce47b.tar.gz cert-checker-b8ffd7662428b4baff92a0c8271e84c2b55ce47b.tar.bz2 cert-checker-b8ffd7662428b4baff92a0c8271e84c2b55ce47b.zip |
Apply tizen coding rule
* It depends on cpp rule checker(version 160520)
Change-Id: Ica308e1296be4f3567725fdb004f3bae8a456a0c
Diffstat (limited to 'tests/queue_test_thread.cpp')
-rw-r--r-- | tests/queue_test_thread.cpp | 116 |
1 files changed, 59 insertions, 57 deletions
diff --git a/tests/queue_test_thread.cpp b/tests/queue_test_thread.cpp index b98ddc1..b20f10c 100644 --- a/tests/queue_test_thread.cpp +++ b/tests/queue_test_thread.cpp @@ -34,78 +34,80 @@ 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, {}) + 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; - } + 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; + m_sent = 0; + m_max_events = number_of_threads * 2 * APPS_COUNT; + LogDebug("Running threads"); - LogDebug("Running threads"); - for (int i=0; i<number_of_threads; i++) - std::thread(&TestQueue::add_events, this).detach(); + for (int i = 0; i < number_of_threads; i++) + std::thread(&TestQueue::add_events, this).detach(); - LogDebug("Running threads done"); + 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); - } + 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; + 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 |