#include <MonitorCollectorImpl.h>
Public Member Functions | |
MonitorCollectorImpl (const ACE_CString &name, maci::ContainerServices *containerServices) | |
~MonitorCollectorImpl () | |
void | initialize () |
void | cleanUp () |
void | registerNonCollocatedMonitoredDevice (const char *componentName, const char *serialNumber) |
void | registerCollocatedMonitoredDevice (const char *componentName, const char *serialNumber) |
void | registerMonitoredDevice (const char *componentName, const char *serialNumber) |
void | registerNonCollocatedMonitoredDeviceWithMultipleSerial (const char *componentName, const TMCDB::propertySerialNumberSeq &serialNumbers) |
void | registerCollocatedMonitoredDeviceWithMultipleSerial (const char *componentName, const TMCDB::propertySerialNumberSeq &serialNumbers) |
void | registerMonitoredDeviceWithMultipleSerial (const char *componentName, const TMCDB::propertySerialNumberSeq &serialNumbers) |
void | deregisterMonitoredDevice (const char *componentName) |
void | startMonitoring (const char *componentName) |
void | stopMonitoring (const char *componentName) |
TMCDB::MonitorDataBlocks * | getMonitorData () |
void | set_archiving_interval (const char *componentName, const char *propertyName, ACS::TimeInterval time) |
void | suppress_archiving (const char *componentName, const char *propertyName) |
void | enable_archiving (const char *componentName, const char *propertyName) |
Private Member Functions | |
void | registerMonitoredComponentWithSerial (const char *componentName, const char *serialNumber, bool checkCollocation) |
common method for: implementation of IDL registerNonCollocatedMonitoredDevice and registerCollocatedMonitoredDevice | |
void | registerMonitoredComponentWithMultipleSerial (const char *componentName, const TMCDB::propertySerialNumberSeq &serialNumbers, bool checkCollocation) |
common method for: implementation of IDL registerNonCollocatedMonitoredDeviceWithMultipleSerial and registerCollocatedMonitoredDeviceWithMultipleSerial | |
MonitorComponent * | registerMonitoredComponent (const char *componentName, bool checkCollocation=true) |
Private Attributes | |
ACE_Hash_Map_Manager < ACE_CString, MonitorComponent *, ACE_Recursive_Thread_Mutex > | monitorComponents_m |
ACE_Recursive_Thread_Mutex | mcMutex_m |
unsigned int | numOfComponents_m |
protection for monitorComponents_m and related stuff | |
maci::ContainerServices * | contServ_m |
number of registered devices | |
MonitorArchiver::Controller_var | archiveMonitorController_m |
here we hold reference to Archive monitor controller |
Monitor collector implementation
TMCDB::MonitorCollectorImpl::MonitorCollectorImpl | ( | const ACE_CString & | name, | |
maci::ContainerServices * | containerServices | |||
) |
TMCDB::MonitorCollectorImpl::~MonitorCollectorImpl | ( | ) |
void TMCDB::MonitorCollectorImpl::cleanUp | ( | ) | [virtual] |
Called after the last functional call to the component has finished. The component should then orderly release resources etc. If this method is overwritten in a subclass, the developer has to make sure that all cleanup performed by the implementation of the base class take place. The best way to do this is to call the implementation of the base itself explicitly, as would be done implicitly in a destructor chain.
Reimplemented from acscomponent::ACSComponentImpl.
void TMCDB::MonitorCollectorImpl::deregisterMonitoredDevice | ( | const char * | componentName | ) |
void TMCDB::MonitorCollectorImpl::enable_archiving | ( | const char * | componentName, | |
const char * | propertyName | |||
) |
TMCDB::MonitorDataBlocks* TMCDB::MonitorCollectorImpl::getMonitorData | ( | ) |
void TMCDB::MonitorCollectorImpl::initialize | ( | ) | [virtual] |
Called to give the component time to initialize itself. For instance, the component could retrieve connections, read in configuration files/parameters, build up in-memory tables, ... Called before execute. In fact, this method might be called quite some time before functional requests can be sent to the component. Must be implemented as a synchronous (blocking) call.
Reimplemented from acscomponent::ACSComponentImpl.
void TMCDB::MonitorCollectorImpl::registerCollocatedMonitoredDevice | ( | const char * | componentName, | |
const char * | serialNumber | |||
) |
void TMCDB::MonitorCollectorImpl::registerCollocatedMonitoredDeviceWithMultipleSerial | ( | const char * | componentName, | |
const TMCDB::propertySerialNumberSeq & | serialNumbers | |||
) |
MonitorComponent* TMCDB::MonitorCollectorImpl::registerMonitoredComponent | ( | const char * | componentName, | |
bool | checkCollocation = true | |||
) | [private] |
registers a device for single and multiple serial devices/components The mrthod is called by: registerMonitoredComponentWithSerial and registerMonitoredComponentWithMultipleSerial
void TMCDB::MonitorCollectorImpl::registerMonitoredComponentWithMultipleSerial | ( | const char * | componentName, | |
const TMCDB::propertySerialNumberSeq & | serialNumbers, | |||
bool | checkCollocation | |||
) | [private] |
common method for: implementation of IDL registerNonCollocatedMonitoredDeviceWithMultipleSerial and registerCollocatedMonitoredDeviceWithMultipleSerial
void TMCDB::MonitorCollectorImpl::registerMonitoredComponentWithSerial | ( | const char * | componentName, | |
const char * | serialNumber, | |||
bool | checkCollocation | |||
) | [private] |
common method for: implementation of IDL registerNonCollocatedMonitoredDevice and registerCollocatedMonitoredDevice
void TMCDB::MonitorCollectorImpl::registerMonitoredDevice | ( | const char * | componentName, | |
const char * | serialNumber | |||
) |
void TMCDB::MonitorCollectorImpl::registerMonitoredDeviceWithMultipleSerial | ( | const char * | componentName, | |
const TMCDB::propertySerialNumberSeq & | serialNumbers | |||
) |
void TMCDB::MonitorCollectorImpl::registerNonCollocatedMonitoredDevice | ( | const char * | componentName, | |
const char * | serialNumber | |||
) |
void TMCDB::MonitorCollectorImpl::registerNonCollocatedMonitoredDeviceWithMultipleSerial | ( | const char * | componentName, | |
const TMCDB::propertySerialNumberSeq & | serialNumbers | |||
) |
void TMCDB::MonitorCollectorImpl::set_archiving_interval | ( | const char * | componentName, | |
const char * | propertyName, | |||
ACS::TimeInterval | time | |||
) |
void TMCDB::MonitorCollectorImpl::startMonitoring | ( | const char * | componentName | ) |
void TMCDB::MonitorCollectorImpl::stopMonitoring | ( | const char * | componentName | ) |
void TMCDB::MonitorCollectorImpl::suppress_archiving | ( | const char * | componentName, | |
const char * | propertyName | |||
) |
MonitorArchiver::Controller_var TMCDB::MonitorCollectorImpl::archiveMonitorController_m [private] |
here we hold reference to Archive monitor controller
number of registered devices
pointer to container services
ACE_Recursive_Thread_Mutex TMCDB::MonitorCollectorImpl::mcMutex_m [private] |
ACE_Hash_Map_Manager<ACE_CString, MonitorComponent*, ACE_Recursive_Thread_Mutex> TMCDB::MonitorCollectorImpl::monitorComponents_m [private] |
unsigned int TMCDB::MonitorCollectorImpl::numOfComponents_m [private] |
protection for monitorComponents_m and related stuff