#include <DbWatcher.h>
Public Types | |
enum | WatchOptions { ReturnDataSet = 1, ReturnCursorXml = 2 } |
![]() | |
typedef WorkItemPool < NotificationObject > | NotificationPool |
Public Member Functions | |
DbWatcher (void(*callback)(const NotificationObject *), const bool fullObjectNotif=false) | |
DbWatcher (NotificationPool *notificationPool, const bool fullObjectNotif=false) | |
DbWatcher (NotificationPool *notificationPool, const ConnectionString &connectionString, bool fullObjectNotif=false) | |
~DbWatcher () | |
void | setConnectionString (const ConnectionString &connectionString) |
void | setFullObjectNotification (const bool newValue) |
void | setSelectSPName (const string &spName) |
string | getSelectSPName () const |
void | setProvider (const string &provider) |
DatabaseProvider::PROVIDER_TYPE | getProvider () const |
void | setWatchOptions (int options) |
void | setDatabaseToXMLTrimm (const bool trimmOption) |
![]() | |
void | setCallback (void(*callback)(const NotificationObject *)) |
void | setNotificationPool (NotificationPool *notificationPool) |
void | setIdleCallback (void(*callback)(void), unsigned int seconds) |
virtual | ~AbstractWatcher () |
void | setEnableRaisingEvents (bool val) |
void | setObjectPrepareMethod (void *(*prepareCallback)(void *)) |
void | setNotificationType (const NotificationObject::NotificationType notifType) |
pthread_t | getThreadId () |
void | waitForExit () |
![]() | |
void | registerCounter (const string &ownerTypeName, const string &counterName, const InstrumentedObject *iobject) |
Protected Member Functions | |
void | internalScan () |
![]() | |
AbstractWatcher (NotificationPool *notificationPool, void *(*prepareCallback)(void *object)=NULL) | |
AbstractWatcher (void(*callback)(const NotificationObject *), void *(*prepareCallback)(void *object)=NULL) | |
![]() | |
InstrumentedObject () | |
virtual | ~InstrumentedObject () |
string | InternalGetCounters () const |
Private Attributes | |
int | m_WatchOptions |
bool | m_FullObjectNotif |
string | m_SelectSPName |
DatabaseProvider::PROVIDER_TYPE | m_DatabaseProvider |
ConnectionString | m_ConnectionString |
bool | m_DatabaseToXmlTrimmOption |
Additional Inherited Members | |
![]() | |
static unsigned int | GetIntrumentedInstanceNo () |
static void | RemoveAllCounters () |
static string | Report () |
static string | Collect () |
![]() | |
static InstrumentedObject | Instance |
static pthread_mutex_t | ObjMutex = PTHREAD_MUTEX_INITIALIZER |
![]() | |
void(* | m_Callback )(const NotificationObject *notification) |
void *(* | m_PrepareCallback )(void *object) |
void(* | m_IdleCallback )(void) |
pthread_t | m_ScanThreadId |
bool | m_Enabled |
NotificationObject::NotificationType | m_NotificationType |
unsigned int | m_IdleTimeout |
NotificationPool * | m_NotificationPool |
![]() | |
map< string, unsigned long > | m_Counters |
map< string, const InstrumentedObject * > | m_RegisteredObjects |
unsigned int | m_RegisterCounter |
vector< string > | m_CollectedReports |
|
explicit |
|
explicit |
DbWatcher::DbWatcher | ( | NotificationPool * | notificationPool, |
const ConnectionString & | connectionString, | ||
bool | fullObjectNotif = false |
||
) |
DbWatcher::~DbWatcher | ( | ) |
DatabaseProvider::PROVIDER_TYPE DbWatcher::getProvider | ( | ) | const |
string DbWatcher::getSelectSPName | ( | ) | const |
|
protectedvirtual |
Implements FinTP::AbstractWatcher.
void DbWatcher::setConnectionString | ( | const ConnectionString & | connectionString | ) |
|
inline |
|
inline |
void DbWatcher::setProvider | ( | const string & | provider | ) |
void DbWatcher::setSelectSPName | ( | const string & | spName | ) |
|
inline |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |