testsuite/supernova/server_dsp_thread_queue_test.cpp

   1 #include <boost/test/unit_test.hpp>
   2
   3 #include "dsp_thread_queue/dsp_thread_queue.hpp"
   4
   5 namespace
   6 {
   7
   8 struct dummy_runnable
   9 {
  10     dummy_runnable(void):
  11         i(0)
  12     {}
  13
  14     void operator()(unsigned int dummy)
  15     {
  16         ++i;
  17     }
  18
  19     int i;
  20 };
  21
  22 dummy_runnable dummy;
  23 }
  24
  25 typedef nova::dsp_queue_interpreter<dummy_runnable> dsp_queue_interpreter;
  26 typedef nova::dsp_thread_queue_item<dummy_runnable> dsp_thread_queue_item;
  27 typedef nova::dsp_thread_queue<dummy_runnable> dsp_thread_queue;
  28
  29 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_1 )
  30 {
  31     dsp_queue_interpreter interpreter(1);
  32
  33     bool runnable = interpreter.init_tick();
  34     BOOST_REQUIRE(!runnable);
  35 }
  36
  37 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_2 )
  38 {
  39     dsp_queue_interpreter interpreter(1);
  40
  41     bool runnable = interpreter.init_tick();
  42     if (runnable)
  43         interpreter.tick(0);
  44 }
  45
  46 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_3 )
  47 {
  48     dsp_queue_interpreter interpreter(1);
  49
  50     std::unique_ptr<dsp_thread_queue> q (new dsp_thread_queue(1));
  51
  52     dsp_thread_queue_item * item = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 0);
  53
  54     q->add_initially_runnable(item);
  55
  56     interpreter.reset_queue(std::move(q));
  57
  58     bool runnable = interpreter.init_tick();
  59     BOOST_REQUIRE(runnable);
  60
  61     interpreter.tick(0);
  62
  63     BOOST_REQUIRE_EQUAL(item->get_job().i, 1);
  64 }
  65
  66 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_4 )
  67 {
  68     dsp_queue_interpreter interpreter(1);
  69
  70     std::unique_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
  71
  72     dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
  73
  74     dsp_thread_queue_item::successor_list sl(1);
  75     sl[0] = item1;
  76
  77     dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
  78     q->add_initially_runnable(item2);
  79
  80     interpreter.reset_queue(std::move(q));
  81
  82     bool runnable = interpreter.init_tick();
  83     BOOST_REQUIRE(runnable);
  84     interpreter.tick(0);
  85
  86     BOOST_REQUIRE_EQUAL(item1->get_job().i, 1);
  87     BOOST_REQUIRE_EQUAL(item2->get_job().i, 1);
  88 }
  89
  90 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_5 )
  91 {
  92     dsp_queue_interpreter interpreter(1);
  93
  94     {
  95         std::unique_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
  96
  97         dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
  98
  99         dsp_thread_queue_item::successor_list sl(1);
 100         sl[0] = item1;
 101
 102         dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 103
 104         q->add_initially_runnable(item2);
 105
 106         interpreter.reset_queue(std::move(q));
 107
 108         for (int i = 0; i != 2; ++i) {
 109             bool runnable = interpreter.init_tick();
 110             BOOST_REQUIRE(runnable);
 111             interpreter.tick(0);
 112         }
 113         BOOST_REQUIRE_EQUAL(item1->get_job().i, 2);
 114         BOOST_REQUIRE_EQUAL(item2->get_job().i, 2);
 115     }
 116
 117     {
 118         std::unique_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
 119
 120         dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
 121
 122         dsp_thread_queue_item::successor_list sl(1);
 123         sl[0] = item1;
 124
 125         dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 126
 127         q->add_initially_runnable(item2);
 128
 129         interpreter.reset_queue(std::move(q));
 130
 131         for (int i = 0; i != 2; ++i) {
 132             bool runnable = interpreter.init_tick();
 133             BOOST_REQUIRE(runnable);
 134             interpreter.tick(0);
 135         }
 136         BOOST_REQUIRE_EQUAL(item1->get_job().i, 2);
 137         BOOST_REQUIRE_EQUAL(item2->get_job().i, 2);
 138     }
 139 }