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 #ifdef __GXX_EXPERIMENTAL_CXX0X__
  30 #define auto_ptr unique_ptr
  31 #define MOVE(X) std::move(X)
  32 #else
  33 #define MOVE(X) X
  34 #endif
  35
  36 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_1 )
  37 {
  38     dsp_queue_interpreter interpreter(1);
  39
  40     bool runnable = interpreter.init_tick();
  41     BOOST_REQUIRE(!runnable);
  42 }
  43
  44 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_2 )
  45 {
  46     dsp_queue_interpreter interpreter(1);
  47
  48     bool runnable = interpreter.init_tick();
  49     if (runnable)
  50         interpreter.tick(0);
  51 }
  52
  53 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_3 )
  54 {
  55     dsp_queue_interpreter interpreter(1);
  56
  57     std::auto_ptr<dsp_thread_queue> q (new dsp_thread_queue(1));
  58
  59     dsp_thread_queue_item * item = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 0);
  60
  61     q->add_initially_runnable(item);
  62
  63     interpreter.reset_queue(MOVE(q));
  64
  65     bool runnable = interpreter.init_tick();
  66     BOOST_REQUIRE(runnable);
  67
  68     interpreter.tick(0);
  69
  70     BOOST_REQUIRE_EQUAL(item->get_job().i, 1);
  71 }
  72
  73 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_4 )
  74 {
  75     dsp_queue_interpreter interpreter(1);
  76
  77     std::auto_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
  78
  79     dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
  80
  81     dsp_thread_queue_item::successor_list sl(1);
  82     sl[0] = item1;
  83
  84     dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
  85     q->add_initially_runnable(item2);
  86
  87     interpreter.reset_queue(MOVE(q));
  88
  89     bool runnable = interpreter.init_tick();
  90     BOOST_REQUIRE(runnable);
  91     interpreter.tick(0);
  92
  93     BOOST_REQUIRE_EQUAL(item1->get_job().i, 1);
  94     BOOST_REQUIRE_EQUAL(item2->get_job().i, 1);
  95 }
  96
  97 BOOST_AUTO_TEST_CASE( dsp_thread_queue_test_5 )
  98 {
  99     dsp_queue_interpreter interpreter(1);
 100
 101     {
 102         std::auto_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
 103
 104         dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
 105
 106         dsp_thread_queue_item::successor_list sl(1);
 107         sl[0] = item1;
 108
 109         dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 110
 111         q->add_initially_runnable(item2);
 112
 113         interpreter.reset_queue(MOVE(q));
 114
 115         for (int i = 0; i != 2; ++i) {
 116             bool runnable = interpreter.init_tick();
 117             BOOST_REQUIRE(runnable);
 118             interpreter.tick(0);
 119         }
 120         BOOST_REQUIRE_EQUAL(item1->get_job().i, 2);
 121         BOOST_REQUIRE_EQUAL(item2->get_job().i, 2);
 122     }
 123
 124     {
 125         std::auto_ptr<dsp_thread_queue> q (new dsp_thread_queue(2));
 126
 127         dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, dsp_thread_queue_item::successor_list(), 1);
 128
 129         dsp_thread_queue_item::successor_list sl(1);
 130         sl[0] = item1;
 131
 132         dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 133
 134         q->add_initially_runnable(item2);
 135
 136         interpreter.reset_queue(MOVE(q));
 137
 138         for (int i = 0; i != 2; ++i) {
 139             bool runnable = interpreter.init_tick();
 140             BOOST_REQUIRE(runnable);
 141             interpreter.tick(0);
 142         }
 143         BOOST_REQUIRE_EQUAL(item1->get_job().i, 2);
 144         BOOST_REQUIRE_EQUAL(item2->get_job().i, 2);
 145     }
 146 }