ports_test.cpp
Go to the documentation of this file.
00001 /***************************************************************************
00002   tag: Peter Soetens  Mon Jun 26 13:26:02 CEST 2006  generictask_test.cpp
00003 
00004                         generictask_test_3.cpp -  description
00005                            -------------------
00006     begin                : Mon June 26 2006
00007     copyright            : (C) 2006 Peter Soetens
00008     email                : peter.soetens@fmtc.be
00009 
00010  ***************************************************************************
00011  *                                                                         *
00012  *   This program is free software; you can redistribute it and/or modify  *
00013  *   it under the terms of the GNU General Public License as published by  *
00014  *   the Free Software Foundation; either version 2 of the License, or     *
00015  *   (at your option) any later version.                                   *
00016  *                                                                         *
00017  ***************************************************************************/
00018 
00019 #include "unit.hpp"
00020 #include <InputPort.hpp>
00021 #include <OutputPort.hpp>
00022 
00023 #include <TaskContext.hpp>
00024 #include <extras/SlaveActivity.hpp>
00025 #include <extras/SequentialActivity.hpp>
00026 #include <extras/SimulationActivity.hpp>
00027 #include <extras/SimulationThread.hpp>
00028 
00029 #include <boost/function_types/function_type.hpp>
00030 #include <OperationCaller.hpp>
00031 
00032 using namespace std;
00033 using namespace RTT;
00034 using namespace RTT::detail;
00035 
00036 
00037 class EventPortsTC : public TaskContext
00038 {
00039 public:
00040     bool had_event;
00041     int  nb_events;
00042     EventPortsTC(): TaskContext("eptc") { resetStats(); }
00043     void updateHook()
00044     {
00045         nb_events++;
00046         had_event = true;
00047     }
00048     void resetStats() {
00049         nb_events = 0;
00050         had_event = false;
00051     }
00052 };
00053 
00057 class PortsTestFixture
00058 {
00059 public:
00060     TaskContext* tc;
00061     EventPortsTC* tce;
00062     EventPortsTC* tc2;
00063     ActivityInterface* tsim;
00064     ActivityInterface* stsim;
00065 
00066     PortInterface* signalled_port;
00067     void new_data_listener(PortInterface* port)
00068     {
00069         signalled_port = port;
00070     }
00071 
00072 public:
00073     PortsTestFixture()
00074     {
00075         tc =  new TaskContext( "root", TaskContext::Stopped );
00076         tce = new EventPortsTC();
00077         tc2 = new EventPortsTC();
00078         tce->setActivity( new SequentialActivity() );
00079         tc2->setActivity( new SequentialActivity() );
00080         tc->setActivity( new SimulationActivity(0.001) );
00081         tsim = tc->getActivity();
00082         stsim = tc->getActivity();
00083         SimulationThread::Instance()->stop();
00084     }
00085 
00086     ~PortsTestFixture()
00087     {
00088     //     if ( tc->getPeer("programs") )
00089     //         delete tc->getPeer("programs");
00090         tsim->stop();
00091         stsim->stop();
00092         delete tc;
00093         delete tce;
00094         delete tc2;
00095     }
00096 };
00097 
00098 
00099 // Registers the fixture into the 'registry'
00100 BOOST_FIXTURE_TEST_SUITE(  PortsTestSuite,  PortsTestFixture )
00101 
00102 BOOST_AUTO_TEST_CASE( testPortTaskInterface )
00103 {
00104     InputPort<int> rp1("Port1");
00105     OutputPort<int> wp1("Port1");
00106     InputPort<int> rp2("Port2");
00107     OutputPort<int> wp2("Port2");
00108 
00109     tc->ports()->addPort( wp1 );
00110     tc->ports()->addPort( rp2 );
00111 
00112     // check adding same port twice.
00113     tc->ports()->addPort( wp1 );
00114     {
00115         // also check adding different port with same name.
00116         InputPort<double> other_rp("Port1");
00117         tc->ports()->addPort( other_rp );
00118         // port will *not* autoremove itself... so do removePort or a crash will follow.
00119         tc->ports()->removePort( other_rp.getName() );
00120     }
00121 
00122     // We're adding the above ports to another TC as well.
00123     // This is not supported behavior, as it will 'overtake' ownership,
00124      {
00125         auto_ptr<TaskContext> tc1(new TaskContext( "tc", TaskContext::Stopped ));
00126         auto_ptr<TaskContext> tc2(new TaskContext( "tc2", TaskContext::Stopped ));
00127 
00128         tc1->ports()->addPort( rp1 );
00129         tc1->ports()->addPort( wp2 );
00130         tc2->ports()->addPort( rp2 );
00131         tc2->ports()->addPort( wp1 );
00132 
00133         BOOST_CHECK( tc1->connectPorts(tc2.get()) );
00134         BOOST_CHECK( wp1.connected() );
00135         BOOST_CHECK( rp1.connected() );
00136         wp1.write(2);
00137         int value = 0;
00138         BOOST_CHECK( rp1.read(value) );
00139         BOOST_CHECK_EQUAL(2, value);
00140 
00141         BOOST_CHECK( wp2.connected() );
00142         BOOST_CHECK( rp2.connected() );
00143         wp2.write(3);
00144         value = 0;
00145         BOOST_CHECK( rp2.read(value) );
00146         BOOST_CHECK_EQUAL(3, value);
00147     }
00148 
00149     // Tasks have been destroyed, but the ports not. Automatic disconnection
00150     // is done when port objects are disconnected
00151     BOOST_CHECK( rp1.connected() );
00152     BOOST_CHECK( rp2.connected() );
00153     BOOST_CHECK( wp1.connected() );
00154     BOOST_CHECK( wp2.connected() );
00155 
00156     // mandatory
00157     tc->ports()->removePort( wp1.getName() );
00158     tc->ports()->removePort( rp2.getName() );
00159 }
00160 
00161 BOOST_AUTO_TEST_CASE(testPortConnectionInitialization)
00162 {
00163     OutputPort<int> wp("WriterName", true);
00164     InputPort<int> rp("ReaderName", ConnPolicy::data(true));
00165 
00166     BOOST_CHECK( wp.createConnection(rp) );
00167     int value = 0;
00168     BOOST_CHECK( !rp.read(value) );
00169     BOOST_CHECK( !wp.getLastWrittenValue(value) );
00170     wp.write(10);
00171     BOOST_CHECK( rp.read(value) );
00172     BOOST_CHECK_EQUAL( 10, value );
00173 
00174     wp.disconnect(&rp);
00175     BOOST_CHECK( !wp.connected() );
00176     BOOST_CHECK( !rp.connected() );
00177 
00178     value = 0;
00179     BOOST_CHECK( wp.getLastWrittenValue(value) );
00180     BOOST_CHECK_EQUAL( 10, value );
00181     BOOST_CHECK_EQUAL( 10, wp.getLastWrittenValue() );
00182 
00183     value = 0;
00184     BOOST_CHECK( wp.createConnection(rp) );
00185     BOOST_CHECK( rp.read(value) );
00186     BOOST_CHECK_EQUAL( 10, value );
00187     //wp.disconnect();
00188 }
00189 
00190 BOOST_AUTO_TEST_CASE(testPortSimpleConnections)
00191 {
00192     OutputPort<int> wp("WriterName");
00193     InputPort<int> rp("ReaderName", ConnPolicy::data(ConnPolicy::LOCK_FREE, false));
00194 
00195     BOOST_CHECK( !wp.connected() );
00196     BOOST_CHECK( !rp.connected() );
00197     {
00198         int value;
00199         BOOST_CHECK( !rp.read(value) );
00200         wp.write(value); // just checking if is works or if it crashes
00201     }
00202 
00203     BOOST_REQUIRE( wp.createConnection(rp) );
00204     BOOST_CHECK( wp.connected() );
00205     BOOST_CHECK( rp.connected() );
00206 
00207     {
00208         int value = 0;
00209         BOOST_CHECK( !rp.read(value) );
00210         wp.write(1);
00211         BOOST_CHECK( rp.read(value) );
00212         BOOST_CHECK( 1 == value );
00213     }
00214 
00215     rp.clear();
00216     {
00217         int value = 0;
00218         BOOST_CHECK( !rp.read(value) );
00219         wp.write(1);
00220         BOOST_CHECK( rp.read(value) );
00221         BOOST_CHECK( 1 == value );
00222     }
00223 
00224     // Try disconnecting starting at the writer. Disconnecting from the reader
00225     // will be done later
00226     wp.disconnect();
00227     BOOST_CHECK( !wp.connected() );
00228     BOOST_CHECK( !rp.connected() );
00229     {
00230         int value;
00231         wp.write(value);
00232         BOOST_CHECK( !rp.read(value) );
00233     }
00234     wp.disconnect(); // calling it when not connected should be fine as well
00235 
00236     {
00237         int value = 0;
00238         BOOST_CHECK( !rp.read(value) );
00239         wp.createBufferConnection(rp, 4);
00240         BOOST_CHECK( !rp.read(value) );
00241         wp.write(1);
00242         wp.write(2);
00243         wp.write(3);
00244         wp.write(4);
00245         wp.write(5);
00246         BOOST_CHECK_EQUAL(0, value);
00247         BOOST_CHECK( rp.read(value) );
00248         BOOST_CHECK_EQUAL(1, value);
00249         BOOST_CHECK( rp.read(value) );
00250         BOOST_CHECK_EQUAL(2, value);
00251 
00252         rp.clear();
00253         BOOST_CHECK_EQUAL( rp.read(value), NoData );
00254         wp.write(10);
00255         wp.write(20);
00256         BOOST_CHECK( rp.read(value) );
00257         BOOST_CHECK_EQUAL(10, value);
00258         BOOST_CHECK( rp.read(value) );
00259         BOOST_CHECK_EQUAL(20, value);
00260         BOOST_CHECK_EQUAL( rp.read(value), OldData );
00261     }
00262 
00263     // Try disconnecting from the reader this time
00264     rp.disconnect();
00265     BOOST_CHECK( !wp.connected() );
00266     BOOST_CHECK( !rp.connected() );
00267     {
00268         int value;
00269         wp.write(value);
00270         BOOST_CHECK( !rp.read(value) );
00271     }
00272     rp.disconnect(); // calling it when not connected should be fine as well
00273 
00274     // Test automatic disconnection because of port destruction
00275     {
00276         InputPort<int> rp("ReaderName", ConnPolicy::data());
00277         BOOST_CHECK(wp.createConnection(rp));
00278         BOOST_CHECK( wp.connected() );
00279         BOOST_CHECK( rp.connected() );
00280     }
00281     BOOST_CHECK( !wp.connected() );
00282 }
00283 
00284 BOOST_AUTO_TEST_CASE(testPortOneWriterThreeReaders)
00285 {
00286     OutputPort<int> wp("W");
00287     InputPort<int> rp1("R1", ConnPolicy::data());
00288     InputPort<int> rp2("R2", ConnPolicy::buffer(4));
00289     InputPort<int> rp3("R3", ConnPolicy::data());
00290 
00291     wp.createConnection(rp1);
00292     BOOST_CHECK( wp.connected() );
00293     BOOST_CHECK( rp1.connected() );
00294     BOOST_CHECK( !rp2.connected() );
00295     BOOST_CHECK( !rp3.connected() );
00296     wp.createConnection(rp2);
00297     BOOST_CHECK( wp.connected() );
00298     BOOST_CHECK( rp1.connected() );
00299     BOOST_CHECK( rp2.connected() );
00300     BOOST_CHECK( !rp3.connected() );
00301     wp.createConnection(rp3);
00302     BOOST_CHECK( wp.connected() );
00303     BOOST_CHECK( rp1.connected() );
00304     BOOST_CHECK( rp2.connected() );
00305     BOOST_CHECK( rp3.connected() );
00306 
00307     wp.write(10);
00308     wp.write(15);
00309     wp.write(20);
00310     wp.write(25);
00311     wp.write(30);
00312 
00313     int value = 0;
00314     BOOST_CHECK( rp1.read(value));
00315     BOOST_CHECK_EQUAL(30, value);
00316 
00317     BOOST_CHECK( rp2.read(value));
00318     BOOST_CHECK_EQUAL(10, value);
00319     BOOST_CHECK( rp2.read(value));
00320     BOOST_CHECK_EQUAL(15, value);
00321     BOOST_CHECK( rp2.read(value));
00322     BOOST_CHECK_EQUAL(20, value);
00323     BOOST_CHECK( rp2.read(value));
00324     BOOST_CHECK_EQUAL(25, value);
00325     BOOST_CHECK_EQUAL( rp2.read(value), OldData);
00326 
00327     BOOST_CHECK( rp3.read(value));
00328     BOOST_CHECK_EQUAL(30, value);
00329 
00330     // Now removes only the buffer port
00331     wp.disconnect(&rp2);
00332     BOOST_CHECK_EQUAL( rp2.read(value), NoData );
00333     BOOST_CHECK( wp.connected() );
00334     BOOST_CHECK( rp1.connected() );
00335     BOOST_CHECK( !rp2.connected() );
00336     BOOST_CHECK( rp3.connected() );
00337 
00338     wp.write(10);
00339     BOOST_CHECK( rp1.read(value));
00340     BOOST_CHECK_EQUAL(10, value);
00341     BOOST_CHECK( rp3.read(value));
00342     BOOST_CHECK_EQUAL(10, value);
00343 
00344     // And finally the other ports as well
00345     wp.disconnect(&rp1);
00346     wp.disconnect(&rp3);
00347     BOOST_CHECK( !wp.connected() );
00348     BOOST_CHECK( !rp1.connected() );
00349     BOOST_CHECK( !rp2.connected() );
00350     BOOST_CHECK( !rp3.connected() );
00351     BOOST_CHECK_EQUAL( rp1.read(value), NoData );
00352     BOOST_CHECK_EQUAL( rp2.read(value), NoData );
00353     BOOST_CHECK_EQUAL( rp3.read(value), NoData );
00354 }
00355 
00356 BOOST_AUTO_TEST_CASE(testPortThreeWritersOneReader)
00357 {
00358     OutputPort<int> wp1("W1");
00359     OutputPort<int> wp2("W2");
00360     OutputPort<int> wp3("W3");
00361     InputPort<int> rp("R", ConnPolicy::buffer(4));
00362 
00363     wp1.createConnection(rp);
00364     BOOST_CHECK( wp1.connected() );
00365     BOOST_CHECK( rp.connected() );
00366     BOOST_CHECK( !wp2.connected() );
00367     BOOST_CHECK( !wp3.connected() );
00368     wp2.createConnection(rp);
00369     BOOST_CHECK( rp.connected() );
00370     BOOST_CHECK( wp1.connected() );
00371     BOOST_CHECK( wp2.connected() );
00372     BOOST_CHECK( !wp3.connected() );
00373     wp3.createConnection(rp);
00374     BOOST_CHECK( rp.connected() );
00375     BOOST_CHECK( wp1.connected() );
00376     BOOST_CHECK( wp2.connected() );
00377     BOOST_CHECK( wp3.connected() );
00378 
00379     wp1.write(10);
00380     wp1.write(20);
00381     wp1.write(30);
00382     wp1.write(40);
00383     wp1.write(50);
00384 
00385     wp2.write(12);
00386     wp2.write(22);
00387     wp2.write(32);
00388     wp2.write(42);
00389     wp2.write(52);
00390 
00391     wp3.write(13);
00392     wp3.write(23);
00393     wp3.write(33);
00394     wp3.write(43);
00395     wp3.write(53);
00396 
00397     int value = 0;
00398     BOOST_CHECK( rp.read(value));
00399     BOOST_CHECK_EQUAL(10, value);
00400     BOOST_CHECK( rp.read(value));
00401     BOOST_CHECK_EQUAL(20, value);
00402     BOOST_CHECK( rp.read(value));
00403     BOOST_CHECK_EQUAL(30, value);
00404     BOOST_CHECK( rp.read(value));
00405     BOOST_CHECK_EQUAL(40, value);
00406 
00407     // Now removes the middle writer
00408     wp2.disconnect(&rp);
00409     BOOST_CHECK( rp.connected() );
00410     BOOST_CHECK( wp1.connected() );
00411     BOOST_CHECK( !wp2.connected() );
00412     BOOST_CHECK( wp3.connected() );
00413 
00414     // write one more sample
00415     wp1.write(60);
00416     BOOST_CHECK( rp.read(value));
00417     BOOST_CHECK_EQUAL(60, value);
00418 
00419     // now check if wp3's connection is used:
00420     BOOST_CHECK( rp.read(value));
00421     BOOST_CHECK_EQUAL(13, value);
00422     BOOST_CHECK( rp.read(value));
00423     BOOST_CHECK_EQUAL(23, value);
00424 
00425     // in the middle adding a sample
00426     wp1.write(70);
00427 
00428     BOOST_CHECK( rp.read(value));
00429     BOOST_CHECK_EQUAL(33, value);
00430     BOOST_CHECK( rp.read(value));
00431     BOOST_CHECK_EQUAL(43, value);
00432 
00433     // now the in the middle sample shows up
00434     BOOST_CHECK_EQUAL( rp.read(value), NewData );
00435     BOOST_CHECK_EQUAL(70, value);
00436     value = 0;
00437     BOOST_CHECK_EQUAL( rp.read(value), OldData );
00438     BOOST_CHECK_EQUAL(70, value);
00439 
00440     // And finally the other ports as well
00441     rp.disconnect(&wp1);
00442     rp.disconnect(&wp3);
00443     BOOST_CHECK( !rp.connected() );
00444     BOOST_CHECK( !wp1.connected() );
00445     BOOST_CHECK( !wp2.connected() );
00446     BOOST_CHECK( !wp3.connected() );
00447     BOOST_CHECK_EQUAL( rp.read(value), NoData );
00448 }
00449 
00450 BOOST_AUTO_TEST_CASE( testPortObjects)
00451 {
00452     OutputPort<double> wp1("Write");
00453     InputPort<double>  rp1("Read");
00454 
00455     tc->ports()->addPort( wp1 );
00456     tc->ports()->addPort( rp1 );
00457 
00458     // Check if ports were added as objects as well
00459     BOOST_CHECK( tc->provides("Write") != 0 );
00460     BOOST_CHECK( tc->provides("Read") != 0 );
00461 
00462     // Set initial value
00463     wp1.write( 1.0 );
00464 
00465     // Connect ports.
00466     wp1.createConnection( rp1 );
00467 
00468     // Test OperationCallers set/get
00469     OperationCaller<void(double const&)> mset;
00470     OperationCaller<FlowStatus(double&)> mget;
00471 
00472     mset = tc->provides("Write")->getOperation("write");
00473     BOOST_CHECK( mset.ready() );
00474 
00475     mget = tc->provides("Read")->getOperation("read");
00476     BOOST_CHECK( mget.ready() );
00477 
00478     mset( 3.991 );
00479 
00480     double get_value = 0;
00481     BOOST_CHECK( mget(get_value) );
00482     BOOST_CHECK_CLOSE( 3.991, get_value, 0.001 );
00483 
00485     tc->ports()->removePort("Read");
00486     BOOST_CHECK( tc->provides()->hasService("Read") == 0 );
00487     BOOST_CHECK( tc->ports()->getPort("Read") == 0 );
00488 
00489     tc->ports()->removePort("Write");
00490     BOOST_CHECK( tc->provides()->hasService("Write") == 0 );
00491     BOOST_CHECK( tc->ports()->getPort("Write") == 0 );
00492 }
00493 
00494 #ifdef ORO_SIGNALLING_PORTS
00495 BOOST_AUTO_TEST_CASE(testPortSignalling)
00496 {
00497     OutputPort<double> wp1("Write");
00498     InputPort<double>  rp1("Read");
00499 
00500     Handle hl( rp1.getNewDataOnPortEvent()->setup(
00501                 boost::bind(&PortsTestFixture::new_data_listener, this, _1) ) );
00502     hl.connect();
00503 
00504     wp1.createConnection(rp1, ConnPolicy::data());
00505     signalled_port = 0;
00506     wp1.write(0.1);
00507     BOOST_CHECK(&rp1 == signalled_port);
00508 
00509     wp1.disconnect();
00510     wp1.createConnection(rp1, ConnPolicy::buffer(2));
00511     signalled_port = 0;
00512     wp1.write(0.1);
00513     BOOST_CHECK(&rp1 == signalled_port);
00514     signalled_port = 0;
00515     wp1.write(0.1);
00516     BOOST_CHECK(&rp1 == signalled_port);
00517     signalled_port = 0;
00518     wp1.write(0.1);
00519     BOOST_CHECK(0 == signalled_port);
00520 }
00521 #endif
00522 
00523 BOOST_AUTO_TEST_CASE(testPortAddRemove)
00524 {
00525     OutputPort<double>* wp1 = new OutputPort<double>("Write");
00526     InputPort<double>*  rp1 = new InputPort<double>("Read");
00527     InputPort<double>*  ep1 = new InputPort<double>("ERead");
00528     TaskContext tc("tc");
00529     tc.addPort( *wp1 );
00530     tc.addEventPort( *rp1, boost::bind(&PortsTestFixture::new_data_listener, this, _1) );
00531     tc.addEventPort( *ep1 );
00532 
00533     wp1->createConnection(*rp1, ConnPolicy::data());
00534     wp1->createConnection(*ep1, ConnPolicy::data());
00535 
00536     tc.start();
00537     wp1->write(0.1);
00538     tc.stop();
00539 
00540     tc.ports()->removePort("Write");
00541     tc.ports()->removePort("Read");
00542     tc.ports()->removePort("ERead");
00543     BOOST_CHECK(wp1->getInterface() == 0);
00544     BOOST_CHECK(rp1->getInterface() == 0);
00545     BOOST_CHECK(ep1->getInterface() == 0);
00546 
00547     wp1->write(0.1);
00548 
00549     delete wp1;
00550     delete rp1;
00551     delete ep1;
00552 
00553     tc.start();
00554     tc.stop();
00555 
00556     wp1 = new OutputPort<double>("Write");
00557     rp1 = new InputPort<double>("Read");
00558     ep1 = new InputPort<double>("ERead");
00559 
00560     tc.addPort( *wp1 );
00561     tc.addEventPort( *rp1, boost::bind(&PortsTestFixture::new_data_listener, this, _1) );
00562     tc.addEventPort( *ep1 );
00563 
00564     wp1->createConnection(*rp1, ConnPolicy::data());
00565     wp1->createConnection(*ep1, ConnPolicy::data());
00566 
00567     tc.start();
00568     wp1->write(0.1);
00569     tc.stop();
00570 
00571     tc.ports()->removePort("Write");
00572     tc.ports()->removePort("Read");
00573     tc.ports()->removePort("ERead");
00574 
00575     wp1->write(0.1);
00576 
00577     delete wp1;
00578     delete rp1;
00579     delete ep1;
00580 
00581     tc.start();
00582     tc.stop();
00583 }
00584 
00585 BOOST_AUTO_TEST_CASE(testEventPortSignalling)
00586 {
00587     OutputPort<double> wp1("Write");
00588     InputPort<double>  rp1("Read");
00589 
00590     tce->start();
00591     tce->resetStats();
00592 
00593     tce->addEventPort(rp1,boost::bind(&PortsTestFixture::new_data_listener, this, _1) );
00594 
00595 
00596 
00597     wp1.createConnection(rp1, ConnPolicy::data());
00598     signalled_port = 0;
00599     wp1.write(0.1);
00600     BOOST_CHECK(&rp1 == signalled_port);
00601     BOOST_CHECK(tce->had_event);
00602     tce->resetStats();
00603 
00604     wp1.disconnect();
00605     wp1.createConnection(rp1, ConnPolicy::buffer(2));
00606     // send two items into the buffer
00607     signalled_port = 0;
00608     wp1.write(0.1);
00609     BOOST_CHECK(&rp1 == signalled_port);
00610     BOOST_CHECK(tce->had_event);
00611     tce->resetStats();
00612     signalled_port = 0;
00613     wp1.write(0.1);
00614     BOOST_CHECK(&rp1 == signalled_port);
00615     BOOST_CHECK(tce->had_event);
00616     tce->resetStats();
00617     signalled_port = 0;
00618     // test buffer full:
00619     wp1.write(0.1);
00620     BOOST_CHECK(0 == signalled_port);
00621     BOOST_CHECK( !tce->had_event);
00622     tce->resetStats();
00623 
00624     // mandatory
00625     tce->ports()->removePort( rp1.getName() );
00626 }
00627 
00628 BOOST_AUTO_TEST_CASE(testPlainPortNotSignalling)
00629 {
00630     OutputPort<double> wp1("Write");
00631     InputPort<double>  rp1("Read");
00632 
00633     tce->start();
00634     tce->resetStats();
00635 
00636     tce->addPort(rp1);
00637 
00638     wp1.createConnection(rp1, ConnPolicy::data());
00639     wp1.write(0.1);
00640     BOOST_CHECK( !tce->had_event );
00641     tce->resetStats();
00642 
00643     wp1.disconnect();
00644     wp1.createConnection(rp1, ConnPolicy::buffer(2));
00645     wp1.write(0.1);
00646     BOOST_CHECK( !tce->had_event );
00647 
00648     // mandatory
00649     tce->ports()->removePort( rp1.getName() );
00650 }
00651 
00652 BOOST_AUTO_TEST_CASE(testPortDataSource)
00653 {
00654     OutputPort<int> wp1("Write");
00655     auto_ptr<InputPortInterface> reader(dynamic_cast<InputPortInterface*>(wp1.antiClone()));
00656     BOOST_CHECK(wp1.connectTo(&*reader, ConnPolicy::buffer(2)));
00657 
00658     DataSource<int>::shared_ptr source = static_cast< DataSource<int>* >(reader->getDataSource());
00659     BOOST_CHECK(source);
00660 
00661     BOOST_CHECK(!source->evaluate());
00662     wp1.write(10);
00663     wp1.write(20);
00664     // value is still null when not get()/evaluate()
00665     BOOST_CHECK_EQUAL(0, source->value());
00666 
00667     // read a sample:
00668     BOOST_CHECK(source->evaluate());
00669     BOOST_CHECK_EQUAL(10, source->value());
00670     BOOST_CHECK_EQUAL(10, source->value());
00671 
00672     // get a sample (=evaluate+value):
00673     BOOST_CHECK_EQUAL(20, source->get());
00674 
00675     // buffer empty, but value remains same as old:
00676     BOOST_CHECK(!source->evaluate());
00677     BOOST_CHECK_EQUAL(0, source->get());
00678     BOOST_CHECK_EQUAL(20, source->value());
00679 }
00680 
00681 BOOST_AUTO_TEST_SUITE_END()
00682 


rtt
Author(s): RTT Developers
autogenerated on Sat Jun 8 2019 18:46:17