testsuite/supernova/server_dsp_thread_test.cpp

   1 #include <boost/test/unit_test.hpp>
   2
   3 #include <vector>
   4
   5 #include "dsp_thread_queue/dsp_thread.hpp"
   6 #include "server/memory_pool.hpp"
   7
   8 namespace
   9 {
  10
  11 volatile int gint;
  12
  13 struct dummy_runnable
  14 {
  15     dummy_runnable(void):
  16         i(0)
  17     {}
  18
  19     void operator()(uint dummy)
  20     {
  21         ++i;
  22
  23         for (int j = 0; j != 1000; ++j)
  24         {
  25             int l = gint;
  26             l += 1;
  27             gint = l;
  28         }
  29     }
  30
  31     int i;
  32 };
  33
  34 dummy_runnable dummy;
  35 }
  36
  37 template <typename Alloc>
  38 void run_test_1(void)
  39 {
  40     nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> t(1);
  41 }
  42
  43 BOOST_AUTO_TEST_CASE( dsp_thread_test_1 )
  44 {
  45     nova::rt_pool.init(1024*1024*128);
  46     run_test_1<std::allocator<void*> >();
  47     run_test_1<nova::rt_pool_allocator<void*> >();
  48 }
  49
  50 template <typename Alloc>
  51 void run_test_2(void)
  52 {
  53     nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> t(5);
  54     t.start_threads();
  55     t.terminate_threads();
  56 }
  57
  58
  59 BOOST_AUTO_TEST_CASE( dsp_thread_test_2 )
  60 {
  61     run_test_2<std::allocator<void*> >();
  62     run_test_2<nova::rt_pool_allocator<void*> >();
  63 }
  64
  65 template <typename Alloc>
  66 void run_test_3(void)
  67 {
  68     nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> t(2);
  69     t.start_threads();
  70     t.run();
  71     t.terminate_threads();
  72 }
  73
  74 BOOST_AUTO_TEST_CASE( dsp_thread_test_3 )
  75 {
  76     run_test_3<std::allocator<void*> >();
  77     run_test_3<nova::rt_pool_allocator<void*> >();
  78 }
  79
  80 template <typename Alloc>
  81 void run_test_4(void)
  82 {
  83     typedef typename nova::dsp_thread_queue_item<dummy_runnable, Alloc> dsp_thread_queue_item;
  84     typedef typename nova::dsp_thread_queue<dummy_runnable, Alloc> dsp_thread_queue;
  85
  86     typedef typename nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> dsp_threads;
  87     typedef std::unique_ptr<dsp_thread_queue> dsp_thread_queue_ptr;
  88
  89     dsp_threads t(1);
  90     t.start_threads();
  91
  92     dsp_thread_queue_ptr q (new dsp_thread_queue(2));
  93
  94     dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, typename dsp_thread_queue_item::successor_list(), 1);
  95
  96     typename dsp_thread_queue_item::successor_list sl(1);
  97     sl[0] = item1;
  98
  99     dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 100     q->add_initially_runnable(item2);
 101
 102     t.reset_queue(std::move(q));
 103
 104     t.run();
 105
 106     t.terminate_threads();
 107
 108     BOOST_REQUIRE_EQUAL(item1->get_job().i, 1);
 109     BOOST_REQUIRE_EQUAL(item2->get_job().i, 1);
 110
 111 }
 112
 113
 114 BOOST_AUTO_TEST_CASE( dsp_thread_test_4 )
 115 {
 116     run_test_4<std::allocator<void*> >();
 117     run_test_4<nova::rt_pool_allocator<void*> >();
 118 }
 119
 120 template <typename Alloc>
 121 void run_test_5(void)
 122 {
 123     typedef nova::dsp_thread_queue_item<dummy_runnable, Alloc> dsp_thread_queue_item;
 124     typedef nova::dsp_thread_queue<dummy_runnable, Alloc> dsp_thread_queue;
 125     typedef nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> dsp_threads;
 126
 127     typedef std::unique_ptr<dsp_thread_queue> dsp_thread_queue_ptr;
 128
 129     dsp_threads t(2);
 130     t.start_threads();
 131
 132     dsp_thread_queue_ptr q (new dsp_thread_queue(5));
 133
 134     dsp_thread_queue_item * item1 = q->allocate_queue_item(dummy, typename dsp_thread_queue_item::successor_list(), 4);
 135
 136     typename dsp_thread_queue_item::successor_list sl(1);
 137     sl[0] = item1;
 138
 139     dsp_thread_queue_item * item2 = q->allocate_queue_item(dummy, sl, 0);
 140     q->add_initially_runnable(item2);
 141
 142     dsp_thread_queue_item * item3 = q->allocate_queue_item(dummy, sl, 0);
 143     q->add_initially_runnable(item3);
 144
 145     dsp_thread_queue_item * item4 = q->allocate_queue_item(dummy, sl, 0);
 146     q->add_initially_runnable(item4);
 147
 148     dsp_thread_queue_item * item5 = q->allocate_queue_item(dummy, sl, 0);
 149     q->add_initially_runnable(item5);
 150
 151     t.reset_queue(std::move(q));
 152
 153     t.run();
 154
 155     t.terminate_threads();
 156
 157     BOOST_REQUIRE_EQUAL(item1->get_job().i, 1);
 158     BOOST_REQUIRE_EQUAL(item2->get_job().i, 1);
 159     BOOST_REQUIRE_EQUAL(item3->get_job().i, 1);
 160     BOOST_REQUIRE_EQUAL(item4->get_job().i, 1);
 161     BOOST_REQUIRE_EQUAL(item5->get_job().i, 1);
 162 }
 163
 164
 165
 166 BOOST_AUTO_TEST_CASE( dsp_thread_test_5 )
 167 {
 168     run_test_5<std::allocator<void*> >();
 169     run_test_5<nova::rt_pool_allocator<void*> >();
 170 }
 171
 172 template <typename Alloc>
 173 void run_test_6(void)
 174 {
 175     typedef nova::dsp_thread_queue_item<dummy_runnable, Alloc> dsp_thread_queue_item;
 176     typedef nova::dsp_thread_queue<dummy_runnable, Alloc> dsp_thread_queue;
 177     typedef nova::dsp_threads<dummy_runnable, nova::nop_thread_init, Alloc> dsp_threads;
 178
 179     typedef std::unique_ptr<dsp_thread_queue> dsp_thread_queue_ptr;
 180
 181     dsp_threads t(2);
 182     t.start_threads();
 183
 184     dsp_thread_queue_ptr q (new dsp_thread_queue(20));
 185
 186     std::vector<dsp_thread_queue_item*> items;
 187
 188     for (int i = 0; i != 20; ++i)
 189     {
 190         items.push_back(q->allocate_queue_item(dummy, typename dsp_thread_queue_item::successor_list(), 0));
 191         q->add_initially_runnable(items.back());
 192     }
 193
 194     t.reset_queue(std::move(q));
 195
 196     const int iterations = 10000;
 197
 198     for (int i = 0; i != iterations; ++i)
 199     {
 200         for (int item = 0; item != 20; ++item)
 201             BOOST_REQUIRE_EQUAL(items[item]->get_job().i, i);
 202         t.run();
 203     }
 204
 205     t.terminate_threads();
 206
 207     for (int i = 0; i != 20; ++i)
 208         BOOST_REQUIRE_EQUAL(items[i]->get_job().i, iterations);
 209 }
 210
 211 BOOST_AUTO_TEST_CASE( dsp_thread_test_6 )
 212 {
 213     run_test_6<std::allocator<void*> >();
 214     run_test_6<nova::rt_pool_allocator<void*> >();
 215 }