ChimeraTK-ApplicationCore
04.01.00
|
#include <Application.h>
Public Member Functions | |
Application (const std::string &name) | |
The constructor takes the application name as an argument. More... | |
~Application () override | |
void | shutdown () override |
This will remove the global pointer to the instance and allows creating another instance afterwards. More... | |
void | initialise () override |
void | optimiseUnmappedVariables (const std::set< std::string > &names) override |
void | run () override |
Execute the module. More... | |
Model::RootProxy | getModel () |
Return the root of the application model. More... | |
void | generateXML () |
Instead of running the application, just initialise it and output the published variables to an XML file. More... | |
void | generateDOT () |
Instead of running the application, just initialise it and output the published variables to a DOT file. More... | |
void | enableTestableMode () |
Enable the testable mode. More... | |
detail::TestableMode & | getTestableMode () |
Get the TestableMode control object of this application. More... | |
void | debugMakeConnections () |
Enable debug output for the ConnectionMaker. More... | |
ModuleType | getModuleType () const override |
Return the module type of this module, or in case of a VirtualModule the module type this VirtualModule was derived from. More... | |
std::string | getQualifiedName () const override |
Get the fully qualified name of the module instance, i.e. More... | |
std::string | getFullDescription () const override |
Obtain the full description including the full description of the owner. More... | |
void | enableVariableDebugging (const VariableNetworkNode &node) |
Enable debug output for a given variable. More... | |
void | enableDebugDataLoss () |
Enable debug output for lost data. More... | |
boost::shared_ptr< DeviceManager > | getDeviceManager (const std::string &aliasOrCDD) |
Return the DeviceManager for the given alias name or CDD. More... | |
LifeCycleState | getLifeCycleState () const |
Get the current LifeCycleState of the application. More... | |
VersionNumber | getStartVersion () const |
Return the start version. More... | |
ApplicationModule * | getVersionInfoProvider () |
void | setVersionInfoProvider (ApplicationModule *provider) |
size_t | getCircularNetworkInvalidityCounter (size_t circularNetworkHash) const |
ConfigReader & | getConfigReader () |
Public Member Functions inherited from ChimeraTK::ModuleGroup | |
ModuleGroup (ModuleGroup *owner, const std::string &name, const std::string &description, const std::unordered_set< std::string > &tags={}) | |
Constructor: Create ModuleGroup by the given name with the given description and register it with its owner. More... | |
ModuleGroup ()=default | |
Default constructor to allow late initialisation of module groups. More... | |
ModuleGroup (ModuleGroup &&other) noexcept | |
Move constructor. More... | |
ModuleGroup & | operator= (ModuleGroup &&other) noexcept |
Move assignment. More... | |
ModuleType | getModuleType () const override |
Return the module type of this module, or in case of a VirtualModule the module type this VirtualModule was derived from. More... | |
ChimeraTK::Model::ModuleGroupProxy | getModel () |
Return the application model proxy representing this module. More... | |
std::string | getVirtualQualifiedName () const override |
void | unregisterModule (Module *module) override |
Unregister another module as a sub-module. More... | |
Public Member Functions inherited from ChimeraTK::Module | |
Module (EntityOwner *owner, const std::string &name, const std::string &description, const std::unordered_set< std::string > &tags={}) | |
Constructor: Create Module by the given name with the given description and register it with its owner. More... | |
Module ()=default | |
Default constructor: Allows late initialisation of modules (e.g. More... | |
~Module () override | |
Destructor. More... | |
Module (Module &&other) noexcept | |
Move constructor. More... | |
Module & | operator= (Module &&other) noexcept |
Move assignment operator. More... | |
virtual void | prepare () |
Prepare the execution of the module. More... | |
virtual void | terminate () |
Terminate the module. More... | |
ChimeraTK::ReadAnyGroup | readAnyGroup () |
Create a ChimeraTK::ReadAnyGroup for all readable variables in this Module. More... | |
void | readAll (bool includeReturnChannels=false) |
Read all readable variables in the group. More... | |
void | readAllNonBlocking (bool includeReturnChannels=false) |
Just call readNonBlocking() on all readable variables in the group. More... | |
void | readAllLatest (bool includeReturnChannels=false) |
Just call readLatest() on all readable variables in the group. More... | |
void | writeAll (bool includeReturnChannels=false) |
Just call write() on all writable variables in the group. More... | |
void | writeAllDestructively (bool includeReturnChannels=false) |
Just call writeDestructively() on all writable variables in the group. More... | |
std::string | getQualifiedName () const override |
Get the fully qualified name of the module instance, i.e. More... | |
std::string | getFullDescription () const override |
Obtain the full description including the full description of the owner. More... | |
void | setOwner (EntityOwner *newOwner) |
Set a new owner. More... | |
EntityOwner * | getOwner () const |
VersionNumber | getCurrentVersionNumber () const override |
Return the current version number which has been received with the last push-type read operation. More... | |
void | setCurrentVersionNumber (VersionNumber version) override |
Set the current version number. More... | |
DataValidity | getDataValidity () const override |
Return the data validity flag. More... | |
void | incrementDataFaultCounter () override |
Set the data validity flag to fault and increment the fault counter. More... | |
void | decrementDataFaultCounter () override |
Decrement the fault counter and set the data validity flag to ok if the counter has reached 0. More... | |
std::list< EntityOwner * > | getInputModulesRecursively (std::list< EntityOwner * > startList) override |
Use pointer to the module as unique identifier. More... | |
size_t | getCircularNetworkHash () const override |
Get the ID of the circular dependency network (0 if none). More... | |
Module * | findApplicationModule () |
Find ApplicationModule owner. More... | |
void | disable () |
Disable the module such that it is not part of the Application. More... | |
Public Member Functions inherited from ChimeraTK::EntityOwner | |
EntityOwner (std::string name, std::string description, std::unordered_set< std::string > tags={}) | |
Constructor: Create EntityOwner by the given name with the given description. More... | |
EntityOwner () | |
Default constructor just for late initialisation. More... | |
virtual | ~EntityOwner ()=default |
Virtual destructor to make the type polymorphic. More... | |
EntityOwner (EntityOwner &&other) noexcept | |
Move constructor. More... | |
EntityOwner (const EntityOwner &other)=delete | |
EntityOwner & | operator= (EntityOwner &&other) noexcept |
Move assignment operator. More... | |
EntityOwner & | operator= (const EntityOwner &other)=delete |
const std::string & | getName () const |
Get the name of the module instance. More... | |
std::string | getQualifiedNameWithType () const |
Get the fully qualified name of the module instance, followed by the C++ data type (in pointy brackets) More... | |
const std::string & | getDescription () const |
Get the description of the module instance. More... | |
std::list< VariableNetworkNode > | getAccessorList () const |
Obtain the list of accessors/variables directly associated with this instance. More... | |
std::list< Module * > | getSubmoduleList () const |
Obtain the list of submodules associated with this instance. More... | |
std::list< VariableNetworkNode > | getAccessorListRecursive () const |
Obtain the list of accessors/variables associated with this instance and any submodules. More... | |
std::list< Module * > | getSubmoduleListRecursive () const |
Obtain the list of submodules associated with this instance and any submodules. More... | |
void | registerAccessor (VariableNetworkNode accessor) |
Called inside the constructor of Accessor: adds the accessor to the list. More... | |
void | unregisterAccessor (const VariableNetworkNode &accessor) |
Called inside the destructor of Accessor: removes the accessor from the list. More... | |
void | registerModule (Module *module, bool addTags=true) |
Register another module as a sub-module. More... | |
void | addTag (const std::string &tag) |
Add a tag to all Application-type nodes inside this group. More... | |
void | dump (const std::string &prefix="", std::ostream &stream=std::cout) const |
Print the full hierarchy to given stream. More... | |
bool | hasReachedTestableMode () |
Check whether this module has declared that it reached the testable mode. More... | |
template<typename T > | |
std::string | constant (T value) |
Create a variable name which will be automatically connected with a constant value. More... | |
Static Public Member Functions | |
static Application & | getInstance () |
Obtain instance of the application. More... | |
static bool | hasInstance () |
Check whether an instance of Application currently exists. More... | |
static void | registerThread (const std::string &name) |
Register the thread in the application system and give it a name. More... | |
static void | incrementDataLossCounter (const std::string &name) |
Increment counter for how many write() operations have overwritten unread data. More... | |
static size_t | getAndResetDataLossCounter () |
Return the current value of the data loss counter and (atomically) reset it to 0. More... | |
Static Public Member Functions inherited from ChimeraTK::Module | |
static ConfigReader & | appConfig () |
Obtain the ConfigReader instance of the application. More... | |
Protected Member Functions | |
VersionNumber | getCurrentVersionNumber () const override |
Return the current version number which has been received with the last push-type read operation. More... | |
void | setCurrentVersionNumber (VersionNumber) override |
Set the current version number. More... | |
DataValidity | getDataValidity () const override |
Return the data validity flag. More... | |
void | incrementDataFaultCounter () override |
Set the data validity flag to fault and increment the fault counter. More... | |
void | decrementDataFaultCounter () override |
Decrement the fault counter and set the data validity flag to ok if the counter has reached 0. More... | |
std::list< EntityOwner * > | getInputModulesRecursively ([[maybe_unused]] std::list< EntityOwner * > startList) override |
size_t | getCircularNetworkHash () const override |
Get the ID of the circular dependency network (0 if none). More... | |
Protected Attributes | |
Model::RootProxy | _model |
The model of the application. More... | |
ConnectionMaker | _cm {*this} |
Helper class to create connections. More... | |
std::list< boost::shared_ptr< InternalModule > > | _internalModuleList |
List of InternalModules. More... | |
std::map< std::string, boost::shared_ptr< DeviceManager > > | _deviceManagerMap |
Map of DeviceManagers. More... | |
bool | _testFacilityRunApplicationCalled {false} |
Flag which is set by the TestFacility in runApplication() at the beginning. More... | |
bool | _initialiseCalled {false} |
Flag whether initialise() has been called already, to make sure it doesn't get called twice. More... | |
bool | _runCalled {false} |
Flag whether run() has been called already, to make sure it doesn't get called twice. More... | |
bool | _enableDebugMakeConnections {false} |
Flag if debug output is enabled for creation of the variable connections. More... | |
std::map< size_t, size_t > | _pvIdMap |
Map from ProcessArray uniqueId to the variable ID for control system variables. More... | |
detail::CircularDependencyDetector | _circularDependencyDetector |
detail::TestableMode | _testableMode |
std::unordered_set< const void * > | _debugMode_variableList |
List of variables for which debug output was requested via enableVariableDebugging(). More... | |
std::atomic< size_t > | _dataLossCounter {0} |
Counter for how many write() operations have overwritten unread data. More... | |
bool | _debugDataLoss {false} |
Flag whether to debug data loss (as counted with the data loss counter). More... | |
std::atomic< LifeCycleState > | _lifeCycleState {LifeCycleState::initialisation} |
Life-cycle state of the application. More... | |
VersionNumber | _startVersion |
Version number used at application start, e.g. More... | |
ApplicationModule * | _versionInfoProvider {nullptr} |
std::map< size_t, std::atomic< uint64_t > > | _circularNetworkInvalidityCounters |
Map of atomic invalidity counters for each circular dependency network. More... | |
std::map< size_t, std::list< EntityOwner * > > | _circularDependencyNetworks |
The networks of circular dependencies, reachable by their hash, which serves as unique ID. More... | |
std::shared_ptr< Logger > | _logger {Logger::getSharedPtr()} |
Shared Pointer to central logger instance. More... | |
std::shared_ptr< ConfigReader > | _configReader |
Manager for Python-based ApplicationModules. More... | |
ConfigReader * | _defaultConfigReader {nullptr} |
Protected Attributes inherited from ChimeraTK::Module | |
EntityOwner * | _owner {nullptr} |
Owner of this instance. More... | |
Protected Attributes inherited from ChimeraTK::EntityOwner | |
std::string | _name |
The name of this instance. More... | |
std::string | _description |
The description of this instance. More... | |
std::list< VariableNetworkNode > | _accessorList |
List of accessors owned by this instance. More... | |
std::list< Module * > | _moduleList |
List of modules owned by this instance. More... | |
std::unordered_set< std::string > | _tags |
List of tags to be added to all accessors and modules inside this module. More... | |
std::atomic< bool > | _testableModeReached {false} |
Flag used by the testable mode to identify whether a thread within the EntityOwner has reached the point where the testable mode lock is acquired. More... | |
Friends | |
class | Module |
class | VariableNetwork |
class | VariableNetworkNode |
class | VariableNetworkGraphDumpingVisitor |
class | VariableNetworkModuleGraphDumpingVisitor |
class | XMLGeneratorVisitor |
struct | StatusAggregator |
struct | detail::TestableMode |
class | NetworkVisitor |
class | ConnectionMaker |
template<typename UserType > | |
class | Accessor |
template<typename UserType > | |
class | ExceptionHandlingDecorator |
class | TestFacility |
template<typename UserType > | |
class | DebugPrintAccessorDecorator |
template<typename UserType > | |
class | MetaDataPropagatingRegisterDecorator |
class | ApplicationModule |
struct | detail::CircularDependencyDetector |
struct | ConfigReader |
Additional Inherited Members | |
Public Types inherited from ChimeraTK::EntityOwner | |
enum | ModuleType { ModuleType::ApplicationModule, ModuleType::ModuleGroup, ModuleType::VariableGroup, ModuleType::ControlSystem, ModuleType::Device, ModuleType::Invalid } |
Static Public Attributes inherited from ChimeraTK::EntityOwner | |
static constexpr std::string_view | namePrefixConstant {"/@CONST@"} |
Prefix for constants created by constant(). More... | |
Definition at line 48 of file Application.h.
|
explicit |
The constructor takes the application name as an argument.
The name must have a non-zero length and must not contain any spaces or special characters. Use only alphanumeric characters and underscores.
Definition at line 25 of file Application.cc.
|
override |
Definition at line 64 of file Application.cc.
|
inline |
Enable debug output for the ConnectionMaker.
Definition at line 128 of file Application.h.
|
inlineoverrideprotectedvirtual |
Decrement the fault counter and set the data validity flag to ok if the counter has reached 0.
This function will be called by all input accessors when receiving the an ok update if the previous update was faulty. The caller of this function must ensure that calles to this function are paired to a previous call to incrementDataFaultCounter().
Implements ChimeraTK::EntityOwner.
Definition at line 315 of file Application.h.
|
inline |
Enable debug output for lost data.
This will print to stdout every time data is lost in internal queues as it is counted with the DataLossCounter module. Do not enable in production environments. Do not call after initialisation phase of application.
Definition at line 148 of file Application.h.
void Application::enableTestableMode | ( | ) |
Enable the testable mode.
This allows to step-wise run the application using testableMode.step(). The application will start in paused state.
This function must be called before the application is initialised (i.e. before the call to initialise()).
Note: Enabling the testable mode will have a significant impact on the performance, since it will prevent any module threads to run at the same time!
Definition at line 74 of file Application.cc.
|
inline |
Enable debug output for a given variable.
Definition at line 139 of file Application.h.
void Application::generateDOT | ( | ) |
Instead of running the application, just initialise it and output the published variables to a DOT file.
Definition at line 254 of file Application.cc.
void Application::generateXML | ( | ) |
Instead of running the application, just initialise it and output the published variables to an XML file.
Definition at line 244 of file Application.cc.
|
static |
Return the current value of the data loss counter and (atomically) reset it to 0.
Definition at line 96 of file Application.cc.
|
inlineoverrideprotectedvirtual |
Get the ID of the circular dependency network (0 if none).
This information is only available after the Application has finalised all connections.
Implements ChimeraTK::EntityOwner.
Definition at line 323 of file Application.h.
|
inline |
Definition at line 179 of file Application.h.
|
inline |
|
inlineoverrideprotectedvirtual |
Return the current version number which has been received with the last push-type read operation.
Implements ChimeraTK::EntityOwner.
Definition at line 299 of file Application.h.
|
inlineoverrideprotectedvirtual |
Return the data validity flag.
If any This function will be called by all output accessors in their write functions.
Implements ChimeraTK::EntityOwner.
Definition at line 307 of file Application.h.
boost::shared_ptr< DeviceManager > Application::getDeviceManager | ( | const std::string & | aliasOrCDD | ) |
Return the DeviceManager for the given alias name or CDD.
If none exists so far, it will be created.
Definition at line 267 of file Application.cc.
|
inlineoverridevirtual |
Obtain the full description including the full description of the owner.
Implements ChimeraTK::EntityOwner.
Definition at line 134 of file Application.h.
|
inlineoverrideprotected |
Definition at line 319 of file Application.h.
|
static |
Obtain instance of the application.
Will throw an exception if called before the instance has been created by the control system adapter, or if the instance is not based on the Application class.
Definition at line 261 of file Application.cc.
|
inline |
Get the current LifeCycleState of the application.
Definition at line 169 of file Application.h.
|
inline |
Return the root of the application model.
Definition at line 78 of file Application.h.
|
inlineoverridevirtual |
Return the module type of this module, or in case of a VirtualModule the module type this VirtualModule was derived from.
Implements ChimeraTK::EntityOwner.
Definition at line 130 of file Application.h.
|
inlineoverridevirtual |
Get the fully qualified name of the module instance, i.e.
the name containing all module names further up in the hierarchy.
Implements ChimeraTK::EntityOwner.
Definition at line 132 of file Application.h.
|
inline |
Return the start version.
The start version is the VersionNumber which all modules have initially (before receiving any data from push-type inputs).
Definition at line 175 of file Application.h.
|
inline |
Get the TestableMode control object of this application.
Definition at line 117 of file Application.h.
|
inline |
|
inlinestatic |
Check whether an instance of Application currently exists.
Definition at line 99 of file Application.h.
|
inlineoverrideprotectedvirtual |
Set the data validity flag to fault and increment the fault counter.
This function will be called by all input accessors when receiving the a faulty update if the previous update was ok. The caller of this function must ensure that calls to this function are paired to a subsequent call to decrementDataFaultCounter().
Implements ChimeraTK::EntityOwner.
Definition at line 311 of file Application.h.
|
static |
Increment counter for how many write() operations have overwritten unread data.
This function is normally not called by used code.
Definition at line 87 of file Application.cc.
|
override |
Definition at line 106 of file Application.cc.
|
override |
Definition at line 123 of file Application.cc.
|
static |
Register the thread in the application system and give it a name.
This should be done for all threads used by the application to help with debugging.
Definition at line 81 of file Application.cc.
|
overridevirtual |
Execute the module.
Reimplemented from ChimeraTK::Module.
Definition at line 134 of file Application.cc.
|
inlineoverrideprotectedvirtual |
Set the current version number.
This function is called by the push-type input accessors in their read functions.
Implements ChimeraTK::EntityOwner.
Definition at line 303 of file Application.h.
|
inline |
|
override |
This will remove the global pointer to the instance and allows creating another instance afterwards.
This is mostly useful for writing tests, as it allows to run several applications sequentially in the same executable.
Note that any ApplicationModules etc. owned by this Application are no longer valid after destroying the Application and must be destroyed as well (or at least no longer used).
Definition at line 207 of file Application.cc.
|
friend |
Definition at line 206 of file Application.h.
|
friend |
Definition at line 295 of file Application.h.
|
friend |
Definition at line 297 of file Application.h.
|
friend |
Definition at line 203 of file Application.h.
|
friend |
Definition at line 292 of file Application.h.
|
friend |
Definition at line 296 of file Application.h.
|
friend |
Definition at line 201 of file Application.h.
|
friend |
Definition at line 209 of file Application.h.
|
friend |
Definition at line 294 of file Application.h.
|
friend |
Definition at line 194 of file Application.h.
|
friend |
Definition at line 202 of file Application.h.
|
friend |
Definition at line 200 of file Application.h.
|
friend |
Definition at line 289 of file Application.h.
|
friend |
Definition at line 195 of file Application.h.
|
friend |
Definition at line 197 of file Application.h.
|
friend |
Definition at line 198 of file Application.h.
|
friend |
Definition at line 196 of file Application.h.
|
friend |
Definition at line 199 of file Application.h.
|
protected |
Definition at line 240 of file Application.h.
|
protected |
The networks of circular dependencies, reachable by their hash, which serves as unique ID.
Definition at line 270 of file Application.h.
|
protected |
Map of atomic invalidity counters for each circular dependency network.
The key is the hash of network which serves as a unique identifier. The invalidity counter is atomic so it can be accessed from all modules in the network.
Definition at line 266 of file Application.h.
|
protected |
Helper class to create connections.
Definition at line 215 of file Application.h.
|
protected |
Manager for Python-based ApplicationModules.
The Application-default config reader instance
Definition at line 286 of file Application.h.
|
protected |
Counter for how many write() operations have overwritten unread data.
Definition at line 249 of file Application.h.
|
protected |
Flag whether to debug data loss (as counted with the data loss counter).
Definition at line 252 of file Application.h.
|
protected |
List of variables for which debug output was requested via enableVariableDebugging().
Stored is the unique id of the VariableNetworkNode.
Definition at line 246 of file Application.h.
|
protected |
Definition at line 287 of file Application.h.
|
protected |
Map of DeviceManagers.
The alias name resp. CDD is the key.
Definition at line 221 of file Application.h.
|
protected |
Flag if debug output is enabled for creation of the variable connections.
Definition at line 234 of file Application.h.
|
protected |
Flag whether initialise() has been called already, to make sure it doesn't get called twice.
Definition at line 228 of file Application.h.
|
protected |
List of InternalModules.
Definition at line 218 of file Application.h.
|
protected |
Life-cycle state of the application.
Definition at line 255 of file Application.h.
|
protected |
Shared Pointer to central logger instance.
Keeping this here prevents the Logger to be destroyed before the application.
Definition at line 276 of file Application.h.
|
protected |
The model of the application.
Definition at line 212 of file Application.h.
|
protected |
Map from ProcessArray uniqueId to the variable ID for control system variables.
This is required for the TestFacility.
Definition at line 238 of file Application.h.
|
protected |
Flag whether run() has been called already, to make sure it doesn't get called twice.
Definition at line 231 of file Application.h.
|
protected |
Version number used at application start, e.g.
to propagate initial values
Definition at line 258 of file Application.h.
|
protected |
Definition at line 241 of file Application.h.
|
protected |
Flag which is set by the TestFacility in runApplication() at the beginning.
This is used to make sure runApplication() is called by the TestFacility and not manually.
Definition at line 225 of file Application.h.
|
protected |
Definition at line 260 of file Application.h.