Fix export, which has been broken since the boost::signals2 changes. Also update...

[ardour.git] / libs / audiographer / tests / general / threader_test.cc

diff --git a/libs/audiographer/tests/general/threader_test.cc b/libs/audiographer/tests/general/threader_test.cc
new file mode 100644 (file)
index 0000000..c599d87
--- /dev/null
+++ b/libs/audiographer/tests/general/threader_test.cc
@@ -0,0 +1,156 @@
+#include "tests/utils.h"
+
+#include "audiographer/general/threader.h"
+
+using namespace AudioGrapher;
+
+class ThreaderTest : public CppUnit::TestFixture
+{
+  CPPUNIT_TEST_SUITE (ThreaderTest);
+  CPPUNIT_TEST (testProcess);
+  CPPUNIT_TEST (testRemoveOutput);
+  CPPUNIT_TEST (testClearOutputs);
+  CPPUNIT_TEST (testExceptions);
+  CPPUNIT_TEST_SUITE_END ();
+
+  public:
+       void setUp()
+       {
+               frames = 128;
+               random_data = TestUtils::init_random_data (frames, 1.0);
+               
+               zero_data = new float[frames];
+               memset (zero_data, 0, frames * sizeof(float));
+               
+               thread_pool = new Glib::ThreadPool (3);
+               threader.reset (new Threader<float> (*thread_pool));
+               
+               sink_a.reset (new VectorSink<float>());
+               sink_b.reset (new VectorSink<float>());
+               sink_c.reset (new VectorSink<float>());
+               sink_d.reset (new VectorSink<float>());
+               sink_e.reset (new VectorSink<float>());
+               sink_f.reset (new VectorSink<float>());
+               
+               throwing_sink.reset (new ThrowingSink<float>());
+       }
+
+       void tearDown()
+       {
+               delete [] random_data;
+               delete [] zero_data;
+               
+               thread_pool->shutdown();
+               delete thread_pool;
+       }
+
+       void testProcess()
+       {
+               threader->add_output (sink_a);
+               threader->add_output (sink_b);
+               threader->add_output (sink_c);
+               threader->add_output (sink_d);
+               threader->add_output (sink_e);
+               threader->add_output (sink_f);
+               
+               ProcessContext<float> c (random_data, frames, 1);
+               threader->process (c);
+               
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_a->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_b->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_c->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_d->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_e->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_f->get_array(), frames));
+       }
+       
+       void testRemoveOutput()
+       {
+               threader->add_output (sink_a);
+               threader->add_output (sink_b);
+               threader->add_output (sink_c);
+               threader->add_output (sink_d);
+               threader->add_output (sink_e);
+               threader->add_output (sink_f);
+               
+               ProcessContext<float> c (random_data, frames, 1);
+               threader->process (c);
+               
+               // Remove a, b and f
+               threader->remove_output (sink_a);
+               threader->remove_output (sink_b);
+               threader->remove_output (sink_f);
+               
+               ProcessContext<float> zc (zero_data, frames, 1);
+               threader->process (zc);
+               
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_a->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_b->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(zero_data, sink_c->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(zero_data, sink_d->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(zero_data, sink_e->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_f->get_array(), frames));
+       }
+       
+       void testClearOutputs()
+       {
+               threader->add_output (sink_a);
+               threader->add_output (sink_b);
+               threader->add_output (sink_c);
+               threader->add_output (sink_d);
+               threader->add_output (sink_e);
+               threader->add_output (sink_f);
+               
+               ProcessContext<float> c (random_data, frames, 1);
+               threader->process (c);
+               
+               threader->clear_outputs();
+               ProcessContext<float> zc (zero_data, frames, 1);
+               threader->process (zc);
+               
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_a->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_b->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_c->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_d->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_e->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_f->get_array(), frames));
+       }
+       
+       void testExceptions()
+       {
+               threader->add_output (sink_a);
+               threader->add_output (sink_b);
+               threader->add_output (sink_c);
+               threader->add_output (throwing_sink);
+               threader->add_output (sink_e);
+               threader->add_output (throwing_sink);
+               
+               ProcessContext<float> c (random_data, frames, 1);
+               CPPUNIT_ASSERT_THROW (threader->process (c), Exception);
+               
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_a->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_b->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_c->get_array(), frames));
+               CPPUNIT_ASSERT (TestUtils::array_equals(random_data, sink_e->get_array(), frames));
+       }
+
+  private:
+       Glib::ThreadPool * thread_pool;
+       
+       boost::shared_ptr<Threader<float> > threader;
+       boost::shared_ptr<VectorSink<float> > sink_a;
+       boost::shared_ptr<VectorSink<float> > sink_b;
+       boost::shared_ptr<VectorSink<float> > sink_c;
+       boost::shared_ptr<VectorSink<float> > sink_d;
+       boost::shared_ptr<VectorSink<float> > sink_e;
+       boost::shared_ptr<VectorSink<float> > sink_f;
+       
+       boost::shared_ptr<ThrowingSink<float> > throwing_sink;
+
+       float * random_data;
+       float * zero_data;
+       nframes_t frames;
+};
+
+CPPUNIT_TEST_SUITE_REGISTRATION (ThreaderTest);
+