ichthyo/LUMIERA.clone
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

start and stop the Dispatcher for running the function(integration) test

Browse source 
need also to start and stop the interface registry,
since by policy we do not run the application framework itself
for execution of the test suite; thus if some test actually needs
an application service, it must be started/stopped manually
This commit is contained in:
Fischlurch 2017-01-11 05:01:47 +01:00
parent 3cc3f69471
commit 8a0f26c787
2 changed files with 43 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/45controller.tests
View file

@ -125,3 +125,8 @@ END
TEST "Dispatcher command queue" CommandQueue_test <<END
return: 0
END
TEST "Dispatcher function test" SessionCommandFunction_test <<END
return: 0
END

45
tests/core/proc/control/session-command-function-test.cpp
View file

@ -23,6 +23,10 @@
#include "lib/test/run.hpp"
#include "lib/test/test-helper.hpp"
extern "C" {
#include "common/interfaceregistry.h"
}
#include "proc/control/proc-dispatcher.hpp"
#include "proc/control/command-def.hpp"
#include "gui/ctrl/command-handler.hpp"
@ -31,9 +35,10 @@
#include "lib/time/timecode.hpp"
#include "lib/format-obj.hpp"
#include "lib/symbol.hpp"
//#include "lib/util.hpp"
#include "lib/util.hpp"
//#include <cstdlib>
#include <string>
namespace proc {
@ -50,8 +55,9 @@ namespace test {
using lib::time::Duration;
using lib::time::Offset;
using lib::Symbol;
// using util::isnil;
using util::isnil;
using util::toString;
using std::string;
namespace { // test fixture...
@ -129,25 +135,50 @@ namespace test {
virtual void
run (Arg)
{
lumiera_interfaceregistry_init();
lumiera::throwOnError();
startDispatcher();
perform_simpleInvocation();
perform_messageInvocation();
perform_massivelyParallel();
// perform_simpleInvocation();
// perform_messageInvocation();
// perform_massivelyParallel();
stopDispatcher();
lumiera_interfaceregistry_destroy();
}
/** @test start the session loop thread, similar
* to what the »session subsystem« does
* @note we are _not_ actually starting the subsystem
* @see facade.cpp
*/
void
startDispatcher()
{
UNIMPLEMENTED ("start the session loop thread");
CHECK (not ProcDispatcher::instance().isRunning());
ProcDispatcher::instance().start ([&] (string* problemMessage)
{
CHECK (isnil (*problemMessage));
thread_has_ended = true;
});
CHECK (ProcDispatcher::instance().isRunning());
CHECK (not thread_has_ended);
}
bool thread_has_ended{false};
void
stopDispatcher()
{
UNIMPLEMENTED ("stop the session loop thread");
CHECK (ProcDispatcher::instance().isRunning());
ProcDispatcher::instance().requestStop();
usleep(10000);
CHECK (not ProcDispatcher::instance().isRunning());
CHECK (thread_has_ended);
}