Newer
Older
Martin Christoph Hierholzer
committed
/*
* ApplicationModule.cc
*
* Created on: Jun 17, 2016
* Author: Martin Hierholzer
*/
Martin Christoph Hierholzer
committed
#include "ApplicationCore.h"
Martin Christoph Hierholzer
committed
namespace ChimeraTK {
Martin Christoph Hierholzer
committed
/*********************************************************************************************************************/
ApplicationModule::ApplicationModule(
EntityOwner *owner, const std::string &name, const std::string &description,
bool eliminateHierarchy, const std::unordered_set<std::string> &tags)
: ModuleImpl(owner, name, description, eliminateHierarchy, tags) {
if (!dynamic_cast<ModuleGroup *>(owner) &&
!dynamic_cast<Application *>(owner)) {
throw ChimeraTK::logic_error("ApplicationModules must be owned either by "
"ModuleGroups or the Application!");
}
if (name.find_first_of("/") != std::string::npos) {
throw ChimeraTK::logic_error("Module names must not contain slashes: '" +
name + " owned by '" +
owner->getQualifiedName() + "'.");
Martin Christoph Hierholzer
committed
}
Martin Christoph Hierholzer
committed
/*********************************************************************************************************************/
Martin Christoph Hierholzer
committed
// start the module thread
assert(!moduleThread.joinable());
moduleThread = boost::thread(&ApplicationModule::mainLoopWrapper, this);
}
Martin Christoph Hierholzer
committed
Martin Christoph Hierholzer
committed
/*********************************************************************************************************************/
void ApplicationModule::terminate() {
if (moduleThread.joinable()) {
moduleThread.interrupt();
// try joining the thread
while (!moduleThread.try_join_for(boost::chrono::milliseconds(10))) {
// if thread is not yet joined, send interrupt() to all variables.
for (auto &var : getAccessorListRecursive()) {
if (var.getDirection() ==
VariableDirection{VariableDirection::feeding, false})
continue;
var.getAppAccessorNoType().getHighLevelImplElement()->interrupt();
// it may not suffice to send interrupt() once, as the exception might get
// overwritten in the queue, thus we repeat this until the thread was
// joined.
Martin Christoph Hierholzer
committed
}
}
Martin Christoph Hierholzer
committed
Martin Christoph Hierholzer
committed
/*********************************************************************************************************************/
ApplicationModule::~ApplicationModule() { assert(!moduleThread.joinable()); }
Martin Christoph Hierholzer
committed
/*********************************************************************************************************************/
void ApplicationModule::mainLoopWrapper() {
Application::registerThread("AM_" + getName());
Application::testableModeLock("start");
// enter the main loop
std::cout << "mainLoopWrapper" << std::endl;
mainLoop();
Application::testableModeUnlock("terminate");
}
Martin Christoph Hierholzer
committed
} /* namespace ChimeraTK */