diff options
Diffstat (limited to 'mblock/src/lib/qa_mblock_prims.cc')
| -rw-r--r-- | mblock/src/lib/qa_mblock_prims.cc | 331 |
1 files changed, 331 insertions, 0 deletions
diff --git a/mblock/src/lib/qa_mblock_prims.cc b/mblock/src/lib/qa_mblock_prims.cc new file mode 100644 index 000000000..432e819aa --- /dev/null +++ b/mblock/src/lib/qa_mblock_prims.cc @@ -0,0 +1,331 @@ +/* -*- c++ -*- */ +/* + * Copyright 2006 Free Software Foundation, Inc. + * + * This file is part of GNU Radio + * + * GNU Radio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2, or (at your option) + * any later version. + * + * GNU Radio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with GNU Radio; see the file COPYING. If not, write to + * the Free Software Foundation, Inc., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + */ + +#include <qa_mblock_prims.h> +#include <cppunit/TestAssert.h> +#include <mb_mblock.h> +#include <mb_runtime.h> +#include <mb_protocol_class.h> +#include <mb_exception.h> +#include <stdio.h> + +static pmt_t s_cs = pmt_intern("cs"); +static pmt_t s_debug = pmt_intern("debug"); +static pmt_t s_in = pmt_intern("in"); +static pmt_t s_out = pmt_intern("out"); + + +// ================================================================ + +class dp_1 : public mb_mblock +{ +public: + dp_1(); + ~dp_1(); +}; + +dp_1::dp_1() +{ +} + +dp_1::~dp_1(){} + +// ---------------------------------------------------------------- + +class dp_2 : public mb_mblock +{ +public: + dp_2(); + ~dp_2(); +}; + +dp_2::dp_2() +{ + define_port("cs", "cs-protocol", false, mb_port::EXTERNAL); +} + +dp_2::~dp_2(){} + +// ---------------------------------------------------------------- + +class dp_3 : public mb_mblock +{ +public: + dp_3(); + ~dp_3(); +}; + +dp_3::dp_3() +{ + define_port("cs", "cs-protocol", false, mb_port::EXTERNAL); + define_port("cs", "cs-protocol", false, mb_port::EXTERNAL); // duplicate def +} + +dp_3::~dp_3(){} + +// ---------------------------------------------------------------- + +void +qa_mblock_prims::test_define_ports() +{ + mb_runtime_sptr rt = mb_make_runtime(); + // std::vector<mb_port_sptr> intf; + + mb_mblock_sptr mb1 = mb_mblock_sptr(new dp_1()); + // intf = mb1->peer_interface(); + // CPPUNIT_ASSERT_EQUAL(size_t(0), intf.size()); + + // raises runtime_error because of unknown protocol "cs-protocol" + CPPUNIT_ASSERT_THROW(mb_mblock_sptr(new dp_2()), std::runtime_error); + + // define the protocol class + pmt_t pc = mb_make_protocol_class(pmt_intern("cs-protocol"), + pmt_cons(pmt_intern("start"), + pmt_cons(pmt_intern("stop"), + PMT_NIL)), + PMT_NIL); + + // std::cout << "pc = " << pc << '\n'; + + mb_mblock_sptr mb2 = mb_mblock_sptr(new dp_2()); + + // intf = mb2->peer_interface(); + // CPPUNIT_ASSERT_EQUAL(size_t(1), intf.size()); + // CPPUNIT_ASSERT(pmt_eq(s_cs, intf[0]->port_name())); + + + // raises pmt_exception because of duplicate port definition of "cs" + CPPUNIT_ASSERT_THROW(mb_mblock_sptr(new dp_3()), mbe_duplicate_port); + +#if 0 + try { + mb_mblock_sptr mb2 = mb_mblock_sptr(new dp_2()); + } + catch (pmt_exception &e){ + std::cerr << e.msg() << ' ' << e.obj() << '\n'; + } +#endif + +} + +// ================================================================ + +class dc_0 : public mb_mblock +{ +public: + dc_0(); + ~dc_0(); +}; + +dc_0::dc_0() +{ +} + +dc_0::~dc_0() {} + +// ---------------------------------------------------------------- + +class dc_ok : public mb_mblock +{ +public: + dc_ok(); + ~dc_ok(); +}; + +dc_ok::dc_ok() +{ + define_component("c0", mb_mblock_sptr(new dc_0())); + define_component("c1", mb_mblock_sptr(new dc_0())); + define_component("c2", mb_mblock_sptr(new dc_0())); +} + +dc_ok::~dc_ok(){} + +// ---------------------------------------------------------------- + +class dc_not_ok : public mb_mblock +{ +public: + dc_not_ok(); + ~dc_not_ok(); +}; + +dc_not_ok::dc_not_ok() + : mb_mblock() +{ + define_component("c0", mb_mblock_sptr(new dc_0())); + define_component("c0", mb_mblock_sptr(new dc_0())); // duplicate name +} + +dc_not_ok::~dc_not_ok(){} + +// ---------------------------------------------------------------- + +void +qa_mblock_prims::test_define_components() +{ + mb_runtime_sptr rt = mb_make_runtime(); + mb_mblock_sptr mb1 = mb_mblock_sptr(new dc_ok()); // OK + + // raises pmt_exception because of duplicate component definition of "c0" + CPPUNIT_ASSERT_THROW(mb_mblock_sptr(new dc_not_ok()), mbe_duplicate_component); +} + +// ================================================================ + +class tc_norm : public mb_mblock +{ +public: + tc_norm(){ + define_port("data", "i/o", false, mb_port::EXTERNAL); + define_port("norm", "i/o", false, mb_port::EXTERNAL); + define_port("conj", "i/o", true, mb_port::EXTERNAL); + define_port("int", "i/o", false, mb_port::INTERNAL); + } + + ~tc_norm(); +}; + +tc_norm::~tc_norm(){} + +//////////////////////////////////////////////////////////////// + +class tc_0 : public mb_mblock +{ +public: + tc_0(){ + define_port("norm", "i/o", false, mb_port::EXTERNAL); + define_port("conj", "i/o", true, mb_port::EXTERNAL); + define_port("int", "i/o", false, mb_port::INTERNAL); + + define_component("c0", mb_mblock_sptr(new tc_norm())); + define_component("c1", mb_mblock_sptr(new tc_norm())); + define_component("c2", mb_mblock_sptr(new tc_norm())); + define_component("c3", mb_mblock_sptr(new tc_norm())); + define_component("c4", mb_mblock_sptr(new tc_norm())); + define_component("c5", mb_mblock_sptr(new tc_norm())); + + // OK + connect("c0", "norm", "c1", "conj"); + + // No: No such component name + CPPUNIT_ASSERT_THROW(connect("foo", "data", "c1", "norm"), mbe_no_such_component); + + // No: No such port name + CPPUNIT_ASSERT_THROW(connect("c0", "data", "c1", "foo"), mbe_no_such_port); + + // No: already connected + CPPUNIT_ASSERT_THROW(connect("c0", "norm", "c2", "data"), mbe_already_connected); + + // No: already connected + CPPUNIT_ASSERT_THROW(connect("c2", "data", "c0", "norm"), mbe_already_connected); + + // No: incompatible ports + CPPUNIT_ASSERT_THROW(connect("c1", "norm", "c2", "norm"), mbe_incompatible_ports); + + // OK + connect("c1", "norm", "c2", "conj"); + + // No: No such port name + CPPUNIT_ASSERT_THROW(connect("c2", "norm", "self", "foo"), mbe_no_such_port); + + // No: can't connect to child's internal port + CPPUNIT_ASSERT_THROW(connect("c0", "conj", "c2", "int"), mbe_no_such_port); + + // No: can't connect to our own external port + CPPUNIT_ASSERT_THROW(connect("self", "norm", "c0", "conj"), mbe_invalid_port_type); + + // OK: connecting to one of our internal ports + connect("self", "int", "c3", "conj"); + + // ===== Now test disconnecting some stuff ===== + + // Confirm we're already connected + CPPUNIT_ASSERT_THROW(connect("self", "int", "c3", "conj"), mbe_already_connected); + + int nc = nconnections(); + disconnect("self", "int", "c3", "conj"); // disconnect + CPPUNIT_ASSERT_EQUAL(nc-1, nconnections()); + + connect("self", "int", "c3", "conj"); // reconnect + CPPUNIT_ASSERT_EQUAL(nc, nconnections()); + + // confirm we're already connected + CPPUNIT_ASSERT_THROW(connect("self", "int", "c3", "conj"), mbe_already_connected); + + + connect("c0", "conj", "c5", "data"); + connect("c4", "norm", "c5", "conj"); + connect("c4", "conj", "c5", "norm"); + + nc = nconnections(); + disconnect_component("c4"); + CPPUNIT_ASSERT_EQUAL(nc-2, nconnections()); + + disconnect_component("c5"); + CPPUNIT_ASSERT_EQUAL(nc-3, nconnections()); + + disconnect_all(); + CPPUNIT_ASSERT_EQUAL(0, nconnections()); + + } + + ~tc_0(); +}; + +tc_0::~tc_0(){} + +//////////////////////////////////////////////////////////////// + +class tc_1 : public mb_mblock +{ +public: + tc_1(){ + define_component("c0", mb_mblock_sptr(new tc_norm())); + define_component("c1", mb_mblock_sptr(new tc_norm())); + + connect("c0", "norm", "c1", "conj"); + } + + ~tc_1(); +}; + +tc_1::~tc_1(){} + +//////////////////////////////////////////////////////////////// + +void +qa_mblock_prims::test_connect() +{ + // define the protocol class + mb_make_protocol_class(pmt_intern("data"), // name of class + pmt_cons(pmt_intern("data"), PMT_NIL), // in + PMT_NIL); // out + + mb_make_protocol_class(pmt_intern("i/o"), // name of class + pmt_cons(pmt_intern("in"), PMT_NIL), // in + pmt_cons(pmt_intern("out"), PMT_NIL)); // out + + + mb_runtime_sptr rt = mb_make_runtime(); + mb_mblock_sptr mb0 = mb_mblock_sptr(new tc_0()); +} |