testsuite/supernova/osc_server_test.cpp

   1 #include <boost/test/unit_test.hpp>
   2
   3 #include "utilities/osc_server.hpp"
   4 #include "nova-tt/semaphore.hpp"
   5
   6 using namespace nova;
   7
   8 namespace {
   9 struct osc_test_responder:
  10     public osc_responder
  11 {
  12     osc_test_responder(void):
  13         i(0), sem(0)
  14     {}
  15
  16     void run(osc::ReceivedMessageArgumentIterator begin,
  17              osc::ReceivedMessageArgumentIterator const & end)
  18     {
  19         ++i;
  20         sem.post();
  21     }
  22
  23     int i;
  24     semaphore sem;
  25 };
  26 }
  27
  28 BOOST_AUTO_TEST_CASE( network_thread_test )
  29 {
  30     network_thread thread;
  31 }
  32
  33 BOOST_AUTO_TEST_CASE( osc_server_test_1 )
  34 {
  35     osc_server server(12321);
  36 }
  37
  38 BOOST_AUTO_TEST_CASE( osc_server_test_2 )
  39 {
  40     osc_server server(12321);
  41     std::unique_ptr<osc_test_responder> resp (new osc_test_responder());
  42     server.add_responder("/foo", resp.get());
  43     server.remove_responder("/foo", resp.get());
  44 }
  45
  46 BOOST_AUTO_TEST_CASE( osc_server_test_3 )
  47 {
  48     std::unique_ptr<osc_test_responder> resp (new osc_test_responder());
  49     {
  50         osc_server server(12321);
  51
  52         server.add_responder("/foo", resp.get());
  53
  54         {
  55             using namespace boost::asio::ip;
  56
  57             boost::asio::io_service io_service;
  58
  59             udp::resolver resolver(io_service);
  60             udp::resolver::query query(udp::v4(), "localhost", "12321");
  61             udp::endpoint receiver_endpoint = *resolver.resolve(query);
  62
  63             udp::socket socket(io_service);
  64             socket.open(udp::v4());
  65             socket.send_to(boost::asio::buffer("/foo\0\0\0", 8), receiver_endpoint);
  66         }
  67
  68         resp->sem.wait();
  69
  70         server.remove_responder("/foo", resp.get());
  71     }
  72
  73     BOOST_REQUIRE_EQUAL(resp->i, 1);
  74 }