1#ifndef INC_GLOWATCHNOTIFYMANAGER_H
2#define INC_GLOWATCHNOTIFYMANAGER_H
59#if defined (__PTHREADS)
61 #include <semaphore.h>
339 #if defined (__PTHREADS)
705 unsigned int uiClientID,
706 const std::string & rstrClientName,
707 const std::string & rstrIPAdress,
708 const std::string & rstrBaseName );
875 const std::string & rsSchemaName,
876 const ObjID & rObjID,
1193 unsigned long ulClassID );
1365 const ObjID & rObjID );
1987 unsigned long ulClassID );
2021 unsigned long ulClassID,
2022 bool bSimulate =
false );
2230 void setWatch( std::stack< ObjID > * pDependObjIdStack,
2233 const ObjID & rObjID );
2302 int unsetWatch( std::stack< ObjID > *& prWNM_ReadDependObjIdStack,
2303 std::stack< ObjID > *& prWNM_WriteDependObjIdStack,
2304 std::stack< ObjID > *& prWNM_DeleteDependObjIdStack,
2305 std::stack< ObjID > *& prWNM_LockDependObjIdStack,
2306 std::stack< ObjID > *& prWNM_UnlockDependObjIdStack,
2309 const ObjID & rObjID,
2310 bool bSimulate =
false );
2401 std::stack< ObjID > *& prWNM_ReadDependObjIdStack,
2402 std::stack< ObjID > *& prWNM_WriteDependObjIdStack,
2403 std::stack< ObjID > *& prWNM_DeleteDependObjIdStack,
2404 std::stack< ObjID > *& prWNM_LockDependObjIdStack,
2405 std::stack< ObjID > *& prWNM_UnlockDependObjIdStack,
2406 std::stack< ObjID > * pDependObjIdStack,
2407 const ObjID & rObjID,
2408 bool bSimulate =
false );
2457 std::stack< ObjID > *& prDependObjIdStack,
2458 std::stack< ObjID > * pDependObjIdStack,
2460 const ObjID & rObjID,
2461 std::list< CommunicatorCallBackIndex * > & rActionList,
2462 bool bSimulate =
false );
2483 void clearList( std::list< DependentObjsWithDeepMode * > * pList );
2659 bool bSimulate =
false );
2973 std::stack< ObjID > * pDependObjIdStack,
3047 std::stack< ObjID > *& prWNM_ReadDependObjIdStack,
3048 std::stack< ObjID > *& prWNM_WriteDependObjIdStack,
3049 std::stack< ObjID > *& prWNM_DeleteDependObjIdStack,
3050 std::stack< ObjID > *& prWNM_LockDependObjIdStack,
3051 std::stack< ObjID > *& prWNM_UnlockDependObjIdStack,
3054 bool bSimulate =
false );
3292 bool bSimulate =
false );
3327 const ObjID & rObjID,
3328 std::stack< ObjID > * pDependObjIdStack,
3405 const ObjID & rObjID,
3406 std::stack< ObjID > *& prWNM_ReadDependObjIdStack,
3407 std::stack< ObjID > *& prWNM_WriteDependObjIdStack,
3408 std::stack< ObjID > *& prWNM_DeleteDependObjIdStack,
3409 std::stack< ObjID > *& prWNM_LockDependObjIdStack,
3410 std::stack< ObjID > *& prWNM_UnlockDependObjIdStack,
3413 bool bSimulate =
false );
3599 bool bSimulate =
false);
3778 bool bSimulate =
false );
4017 #if defined (__PTHREADS)
4144 #if defined (__PTHREADS)
4160 virtual void cleanUp();
4256 unsigned long ulClassID,
4295 const ObjID & rObjID,
4296 std::map<
ObjID,
Record *, std::less<ObjID> > & rDependObjectsMap,
4364 unsigned long ulClassID,
4366 bool bSimulate =
false );
4415 const ObjID & rObjID,
4418 bool bSimulate =
false );
4459 bool bSimulate =
false);
4478 std::list< CommunicatorCallBackIndex * > & rActionList );
4494 std::list< CommunicatorCallBackIndex * > & rActionList );
4520 std::list< Manager::ObjIdWithDepends * > & rInputList );
4545 std::list< ObjID > & rInputList );
4578 void * pOrderObject,
4579 void * pAdditionalInfo );
4669 std::list< CommunicatorCallBackIndex * > & rActionList )
const;
4737 std::list< CommunicatorCallBackIndex * > & rActionList );
4773 unsigned long ulClassID,
4774 bool bAlsoGenerate );
4837 std::stack< ObjID > & rDependObjIdStack,
long long NUM_PTR
Definition EuDef_NULL_PTR.h:93
Header für EuEndlessPThread
Header für RepeatingThread
Header für Manager Manager::Receiver Manager::ObjIdWithDepends Manager::SchemaMapItem
Für jede Bibliothek, hier 'GlobalObjects' gibt es eine Typen-Datei.
Header für WatchSpecification
Basisklasse für einen Thread der seine Arbeit endlos bis zum Abbruch ausführt.
Definition EuEndlessPThread.h:69
Ist ein Mutex, welcher über sein Lock-Modus abgefragt werden kann. Siehe isLocked().
Definition EuPCriticalSection.h:89
Ist ein Mutex, welcher über sein Lock-Modus abgefragt werden kann. Siehe isLocked().
Definition EuCriticalSection.h:94
Basisklasse für einen Thread der seine Arbeit endlos bis zum Abbruch ausführt.
Definition EuRepeatingThread.h:78
OberKlasse von LocalThread, ClientThread und ServerThread, weil diese als Sender und Empfänger (Kommu...
Definition GloCommunicator.h:86
Das Objekt dieser Klasse ist die zentrale Anlaufstelle für Aktionen, welche mit GlobalObjects-Daten z...
Definition GloManager.h:184
Ein Objekt-ID besteht aus der Klassen-ID, einer Datenbank-ID und der eigentlichen eindeutigen ObjektZ...
Definition GloObjID.h:77
Mittels dieser Klasse wird die Kommunikation zwischen der Applikation, welche GlobalObjects nutzt und...
Definition GloOrderMsg.h:77
EnOrderType
Definition GloOrderMsg.h:98
Objekte dieser Klasse transportieren die Daten von den Tabellen ins persistente Objekt und von diesen...
Definition GloRecord.h:101
Überwachungsklasse für AllSets.
Definition GloWatchNotifyManager.h:3104
int unsetWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
void setWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode)
void ClearObjectWatchMap()
unsigned long getClassID() const
std::map< ObjID, ObjectWatch *, std::less< ObjID > > m_ObjectWatchMap
Definition GloWatchNotifyManager.h:3141
ClassWatch(unsigned long ulClassID)
void clearCommunicatorClassNotifyModesMap()
unsigned long m_ulClassID
Definition GloWatchNotifyManager.h:3117
std::size_t getObjectWatchMapCount() const
std::map< CommunicatorCallBackIndex, CommunicatorClassNotifyModes *, std::less< CommunicatorCallBackIndex > > m_CommunicatorClassNotifyModesMap
Definition GloWatchNotifyManager.h:3130
void deleteAllWatches(Communicator *pCommunicator)
int unsetWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, const ObjID &rObjID, std::stack< ObjID > *&prWNM_ReadDependObjIdStack, std::stack< ObjID > *&prWNM_WriteDependObjIdStack, std::stack< ObjID > *&prWNM_DeleteDependObjIdStack, std::stack< ObjID > *&prWNM_LockDependObjIdStack, std::stack< ObjID > *&prWNM_UnlockDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, bool bSimulate=false)
void setWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, const ObjID &rObjID, std::stack< ObjID > *pDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode)
std::size_t getCommunicatorClassNotifyModesMapCount() const
Überwachungsklasse für Client-An- bzw. Abmeldungen.
Definition GloWatchNotifyManager.h:3475
void deleteAllWatches(Communicator *pCommunicator)
std::size_t getCommunicatorClientNotifyModesMapCount() const
int unsetWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
void setWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode)
void clearCommunicatorClientNotifyModesMap()
std::map< CommunicatorCallBackIndex, CommunicatorClientNotifyModes *, std::less< CommunicatorCallBackIndex > > m_CommunicatorClientNotifyModesMap
Definition GloWatchNotifyManager.h:3490
Ist ein eindeutiger Index für Maps von CommunicatorClassNotifyModes und als Index für die statischen ...
Definition GloWatchNotifyManager.h:1122
bool operator>(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackClassIndex(Communicator *pCommunicator, NUM_PTR ipCallBack, unsigned long ulClassID)
bool operator==(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
virtual ~CommunicatorCallBackClassIndex()
CommunicatorCallBackClassIndex()
bool operator<=(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
bool operator!=(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
bool operator>=(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
unsigned long m_ulClassID
Definition GloWatchNotifyManager.h:1135
CommunicatorCallBackClassIndex(Communicator *pCommunicator, NUM_PTR ipCallBack)
unsigned long getClassID()
bool operator<(const CommunicatorCallBackClassIndex &rT) const
Vergleichsoperator.
WatchNotifyManager::CommunicatorCallBackClassIndex & operator=(const CommunicatorCallBackClassIndex &rT)
CommunicatorCallBackClassIndex(const CommunicatorCallBackClassIndex &rT)
Ist ein eindeutiger Index für Maps von CommunicatorClientNotifyModes und als Index für die statischen...
Definition GloWatchNotifyManager.h:1466
CommunicatorCallBackClientIndex(const CommunicatorCallBackClientIndex &rT)
CommunicatorCallBackClientIndex()
bool operator>=(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
virtual ~CommunicatorCallBackClientIndex()
WatchNotifyManager::CommunicatorCallBackClientIndex & operator=(const CommunicatorCallBackClientIndex &rT)
CommunicatorCallBackClientIndex(Communicator *pCommunicator, NUM_PTR ipCallBack)
bool operator<=(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
bool operator!=(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
bool operator==(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
bool operator<(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
bool operator>(const CommunicatorCallBackClientIndex &rT) const
Vergleichsoperator.
Basisklasse eines eindeutiger Index für Maps von abgeleitetn Klassen von CommunicatorNotifyModes und ...
Definition GloWatchNotifyManager.h:944
WatchNotifyManager::CommunicatorCallBackIndex & operator=(const CommunicatorCallBackIndex &rT)
NUM_PTR getCallBackIndex()
NUM_PTR m_ipCallBack
Definition GloWatchNotifyManager.h:970
bool operator<(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackIndex(Communicator *pCommunicator, NUM_PTR ipCallBack)
bool operator>(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
Communicator * getCommunicator()
bool operator!=(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
bool operator>=(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
bool operator<=(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
Communicator * m_pCommunicator
Definition GloWatchNotifyManager.h:957
virtual ~CommunicatorCallBackIndex()
CommunicatorCallBackIndex(const CommunicatorCallBackIndex &rT)
bool operator==(const CommunicatorCallBackIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackIndex()
Ist ein eindeutiger Index für Maps von CommunicatorCallBackIndexReadWriteIndex und als Index für die ...
Definition GloWatchNotifyManager.h:1586
virtual ~CommunicatorCallBackIndexReadWriteIndex()
bool operator<(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
bool operator!=(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackIndexReadWriteIndex(Communicator *pCommunicator, NUM_PTR ipCallBack)
CommunicatorCallBackIndexReadWriteIndex(const CommunicatorCallBackIndexReadWriteIndex &rT)
bool operator==(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
WatchNotifyManager::CommunicatorCallBackIndexReadWriteIndex & operator=(const CommunicatorCallBackIndexReadWriteIndex &rT)
bool operator>=(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
bool operator<=(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackIndexReadWriteIndex()
bool operator>(const CommunicatorCallBackIndexReadWriteIndex &rT) const
Vergleichsoperator.
Ist ein eindeutiger Index für Maps von CommunicatorObjNotifyModes und als Index für die statischen Ak...
Definition GloWatchNotifyManager.h:1294
bool operator>=(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
bool operator!=(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
virtual ~CommunicatorCallBackObjIndex()
ObjID m_ObjID
Definition GloWatchNotifyManager.h:1307
bool operator<(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackObjIndex(Communicator *pCommunicator, NUM_PTR ipCallBack, const ObjID &rObjID)
CommunicatorCallBackObjIndex(const CommunicatorCallBackObjIndex &rT)
CommunicatorCallBackObjIndex()
WatchNotifyManager::CommunicatorCallBackObjIndex & operator=(const CommunicatorCallBackObjIndex &rT)
bool operator>(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
bool operator==(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
bool operator<=(const CommunicatorCallBackObjIndex &rT) const
Vergleichsoperator.
CommunicatorCallBackObjIndex(Communicator *pCommunicator, NUM_PTR ipCallBack)
Überwachungs- bzw. Benachrichtigungs-Modus von AllSets.
Definition GloWatchNotifyManager.h:1842
int unsetWatch(TdWatchNotifyMode tdWatchNotifyMode, unsigned long ulClassID, bool bSimulate=false)
int m_iWNM_LOCK
Definition GloWatchNotifyManager.h:1888
CommunicatorClassNotifyModes(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex)
virtual ~CommunicatorClassNotifyModes()
int m_iWNM_READ
Definition GloWatchNotifyManager.h:1855
int m_iWNM_INSERT
Definition GloWatchNotifyManager.h:1910
void setWatch(TdWatchNotifyMode tdWatchNotifyMode, unsigned long ulClassID)
int m_iWNM_WRITE
Definition GloWatchNotifyManager.h:1866
int m_iWNM_DELETE
Definition GloWatchNotifyManager.h:1877
int m_iWNM_UNLOCK
Definition GloWatchNotifyManager.h:1899
virtual bool hasWatches() const
CommunicatorClassNotifyModes()
Überwachungs- bzw. Benachrichtigungs-Modus von Client An- bzw. Abmeldungen.
Definition GloWatchNotifyManager.h:2507
int unsetWatch(TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
int m_iWNM_CLIENT_CLOSE_BASE
Definition GloWatchNotifyManager.h:2553
int m_iWNM_CLIENT_CONNECT_SERVER
Definition GloWatchNotifyManager.h:2520
virtual bool hasWatches() const
CommunicatorClientNotifyModes(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex)
int m_iWNM_CLIENT_DISCONNECT_SERVER
Definition GloWatchNotifyManager.h:2531
CommunicatorClientNotifyModes()
virtual ~CommunicatorClientNotifyModes()
int m_iWNM_CLIENT_OPEN_BASE
Definition GloWatchNotifyManager.h:2542
void setWatch(TdWatchNotifyMode tdWatchNotifyMode)
Überwachungs- bzw. Benachrichtigungs-Modus für Lese-Index-, Schreibe-Index- und Reindex-Aktionen der ...
Definition GloWatchNotifyManager.h:2684
int m_iWNM_INDEX_REINDEX
Definition GloWatchNotifyManager.h:2719
void setWatch(TdWatchNotifyMode tdWatchNotifyMode)
CommunicatorIndexReadWriteNotifyModes()
virtual bool hasWatches() const
CommunicatorIndexReadWriteNotifyModes(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex)
int unsetWatch(TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
virtual ~CommunicatorIndexReadWriteNotifyModes()
int m_iWNM_INDEX_WRITE
Definition GloWatchNotifyManager.h:2708
int m_iWNM_INDEX_READ
Definition GloWatchNotifyManager.h:2697
Basisklasse der einzelnen Überwachungs- bzw. Benachrichtigungs-Modi.
Definition GloWatchNotifyManager.h:1704
NUM_PTR getCallBackIndex()
CommunicatorCallBackIndex m_CommunicatorCallBackIndex
Definition GloWatchNotifyManager.h:1717
WatchNotifyManager::CommunicatorCallBackIndex & getCommunicatorCallBackIndex()
Communicator * getCommunicator()
virtual bool hasWatches() const =0
CommunicatorNotifyModes()
virtual ~CommunicatorNotifyModes()
CommunicatorNotifyModes(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex)
Überwachungs- bzw. Benachrichtigungs-Modus von Objekten mit deren abhängigen Objekten....
Definition GloWatchNotifyManager.h:2052
void setWatch(std::stack< ObjID > *pDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, const ObjID &rObjID)
std::list< DependentObjsWithDeepMode * > m_WNM_READ
Definition GloWatchNotifyManager.h:2070
int setUnsetWatch(TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, std::stack< ObjID > *&prWNM_ReadDependObjIdStack, std::stack< ObjID > *&prWNM_WriteDependObjIdStack, std::stack< ObjID > *&prWNM_DeleteDependObjIdStack, std::stack< ObjID > *&prWNM_LockDependObjIdStack, std::stack< ObjID > *&prWNM_UnlockDependObjIdStack, std::stack< ObjID > *pDependObjIdStack, const ObjID &rObjID, bool bSimulate=false)
std::list< DependentObjsWithDeepMode * > m_WNM_LOCK
Definition GloWatchNotifyManager.h:2118
virtual bool hasWatches() const
virtual ~CommunicatorObjNotifyModes()
CommunicatorObjNotifyModes()
int unsetWatch(std::stack< ObjID > *&prWNM_ReadDependObjIdStack, std::stack< ObjID > *&prWNM_WriteDependObjIdStack, std::stack< ObjID > *&prWNM_DeleteDependObjIdStack, std::stack< ObjID > *&prWNM_LockDependObjIdStack, std::stack< ObjID > *&prWNM_UnlockDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, const ObjID &rObjID, bool bSimulate=false)
std::list< DependentObjsWithDeepMode * > m_WNM_UNLOCK
Definition GloWatchNotifyManager.h:2134
bool m_bCopyDependObjIdStack
Definition GloWatchNotifyManager.h:2145
std::list< DependentObjsWithDeepMode * > m_WNM_WRITE
Definition GloWatchNotifyManager.h:2086
std::list< DependentObjsWithDeepMode * > m_WNM_DELETE
Definition GloWatchNotifyManager.h:2102
CommunicatorObjNotifyModes(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex)
void clearList(std::list< DependentObjsWithDeepMode * > *pList)
int setWatchCount(std::list< DependentObjsWithDeepMode * > &rWatchCountList, std::stack< ObjID > *&prDependObjIdStack, std::stack< ObjID > *pDependObjIdStack, EnDeepMode eDeepMode, const ObjID &rObjID, std::list< CommunicatorCallBackIndex * > &rActionList, bool bSimulate=false)
Überwachungsklasse für Lese-Index-, Schreibe-Index- und Reindex-Aktionen der Datenbank.
Definition GloWatchNotifyManager.h:3651
void setWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode)
std::map< CommunicatorCallBackIndex, CommunicatorIndexReadWriteNotifyModes *, std::less< CommunicatorCallBackIndex > > m_CommunicatorIndexReadWriteNotifyModesMap
Definition GloWatchNotifyManager.h:3668
int unsetWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
std::size_t getCommunicatorIndexReadWriteNotifyModesMapCount() const
void deleteAllWatches(Communicator *pCommunicator)
void clearCommunicatorIndexReadWriteNotifyModesMap()
Wird für Notify-Infos über Clients in einem Auftrag an den WatchNotifyManager genutzt.
Definition GloWatchNotifyManager.h:594
std::string m_strIPAdress
Definition GloWatchNotifyManager.h:640
WatchNotifyManager::NotifyClientInfo & operator=(const NotifyClientInfo &rT)
virtual ~NotifyClientInfo()
unsigned int m_uiClientID
Definition GloWatchNotifyManager.h:618
SOCKET m_nSocket
Definition GloWatchNotifyManager.h:607
NotifyClientInfo(TdWatchNotifyMode ulNotifyMode, SOCKET nSocket, unsigned int uiClientID, const std::string &rstrClientName, const std::string &rstrIPAdress, const std::string &rstrBaseName)
std::string m_strClientName
Definition GloWatchNotifyManager.h:629
NotifyClientInfo(const NotifyClientInfo &rT)
std::string m_strBaseName
Definition GloWatchNotifyManager.h:651
NotifyClientInfo(TdWatchNotifyMode ulNotifyMode)
Wird für Notify-Infos zum überwachen des Lesens, Schreibens und reindizieren der Indexe in einem Auft...
Definition GloWatchNotifyManager.h:774
int m_iFraction
Definition GloWatchNotifyManager.h:811
std::string m_sSchemaName
Definition GloWatchNotifyManager.h:787
WatchNotifyManager::NotifyIndexReadWriteInfo & operator=(const NotifyIndexReadWriteInfo &rT)
int m_iActions
Definition GloWatchNotifyManager.h:822
NotifyIndexReadWriteInfo(TdWatchNotifyMode ulNotifyMode)
NotifyIndexReadWriteInfo(TdWatchNotifyMode ulNotifyMode, const std::string &rsSchemaName, const ObjID &rObjID, int iFraction, int iActions)
ObjID m_ObjID
Definition GloWatchNotifyManager.h:800
NotifyIndexReadWriteInfo()
virtual ~NotifyIndexReadWriteInfo()
NotifyIndexReadWriteInfo(const NotifyIndexReadWriteInfo &rT)
Basisklasse für unterschiedliche Notify-Infos, welche in einem Auftrag an den WatchNotifyManager genu...
Definition GloWatchNotifyManager.h:364
NotifyInfo(TdWatchNotifyMode ulNotifyMode)
WatchNotifyManager::NotifyInfo & operator=(const NotifyInfo &rT)
NotifyInfo(const NotifyInfo &rT)
TdWatchNotifyMode m_ulNotifyMode
Definition GloWatchNotifyManager.h:377
Wird für Notify-Infos über Objekte in einem Auftrag an den WatchNotifyManager genutzt.
Definition GloWatchNotifyManager.h:470
NotifyObjInfo(const NotifyObjInfo &rT)
ObjID m_ObjID
Definition GloWatchNotifyManager.h:486
NotifyObjInfo(TdWatchNotifyMode ulNotifyMode)
NotifyObjInfo(TdWatchNotifyMode ulNotifyMode, const ObjID &rObjID)
WatchNotifyManager::NotifyObjInfo & operator=(const NotifyObjInfo &rT)
Überwachungsklasse für Objekte.
Definition GloWatchNotifyManager.h:2846
ObjectWatch(const ObjID &rObjID)
ObjID m_ObjID
Definition GloWatchNotifyManager.h:2859
void setWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, std::stack< ObjID > *pDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode)
std::map< CommunicatorCallBackIndex, CommunicatorObjNotifyModes *, std::less< CommunicatorCallBackIndex > > m_CommunicatorObjNotifyModesMap
Definition GloWatchNotifyManager.h:2872
void clearCommunicatorObjNotifyModesMap()
void deleteAllWatches(Communicator *pCommunicator)
int unsetWatch(const CommunicatorCallBackIndex &rCommunicatorCallBackIndex, std::stack< ObjID > *&prWNM_ReadDependObjIdStack, std::stack< ObjID > *&prWNM_WriteDependObjIdStack, std::stack< ObjID > *&prWNM_DeleteDependObjIdStack, std::stack< ObjID > *&prWNM_LockDependObjIdStack, std::stack< ObjID > *&prWNM_UnlockDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, bool bSimulate=false)
Klassen um persistente Objekte überwachen zu können und bei Änderungen die jeweiligen Clients zu bean...
Definition GloWatchNotifyManager.h:344
IndexReadWriteWatch m_IndexReadWriteWatch
Definition GloWatchNotifyManager.h:4066
int setInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, unsigned long ulClassID, TdWatchNotifyMode tdWatchNotifyMode)
void deleteCommunicatorWatches(Communicator *pCommunicator)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_DELETE_List
Definition GloWatchNotifyManager.h:3858
WatchNotifyManager(const WatchNotifyManager &)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_READ_List
Definition GloWatchNotifyManager.h:3830
int setInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, const ObjID &rObjID, std::map< ObjID, Record *, std::less< ObjID > > &rDependObjectsMap, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_INDEX_WRITE_List
Definition GloWatchNotifyManager.h:3984
static void insertAction(CommunicatorCallBackIndex *pCommunicatorCallBackIndex, std::list< CommunicatorCallBackIndex * > &rActionList)
int processWatch(const std::string &rsSchemaName, Communicator *pCommunicator, OrderMsg::EnOrderType eOrderType, void *pOrderObject, void *pAdditionalInfo)
void processWatch(OrderMsg *pOrderMsg)
std::queue< OrderMsg * > m_MsgQueue
Definition GloWatchNotifyManager.h:4077
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_LOCK_List
Definition GloWatchNotifyManager.h:3872
virtual ~WatchNotifyManager()
void deleteCommunicatorWatches(OrderMsg *pOrderMsg)
int unsetInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, const ObjID &rObjID, TdWatchNotifyMode tdWatchNotifyMode, EnDeepMode eDeepMode, bool bSimulate=false)
eut::CriticalSection m_ExclusiveProcessingSection
Definition GloWatchNotifyManager.h:4020
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_WRITE_List
Definition GloWatchNotifyManager.h:3844
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_CLIENT_CLOSEBASE_List
Definition GloWatchNotifyManager.h:3956
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_INDEX_REINDEX_List
Definition GloWatchNotifyManager.h:3998
int unsetInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
int processObjectSetWatch(Communicator *pCommunicator, const WatchSpecification &rWatchSpecification, std::list< Manager::ObjIdWithDepends * > &rInputList)
int setInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, TdWatchNotifyMode tdWatchNotifyMode)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_INDEX_READ_List
Definition GloWatchNotifyManager.h:3970
void processNotify(OrderMsg *pOrderMsg, std::list< CommunicatorCallBackIndex * > &rActionList) const
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_CLIENT_DISCONNECTSERVER_List
Definition GloWatchNotifyManager.h:3928
ClientWatch m_ClientWatch
Definition GloWatchNotifyManager.h:4054
void takeOrder(OrderMsg *pOrderMsg)
void removeClassWatch(unsigned long ulClassID)
WatchNotifyManager & operator=(const WatchNotifyManager &)
WatchNotifyManager(Manager *pMyDBManager)
static void removeAction(CommunicatorCallBackIndex *pCommunicatorCallBackIndex, std::list< CommunicatorCallBackIndex * > &rActionList)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_CLIENT_CONNECTSERVER_List
Definition GloWatchNotifyManager.h:3914
int unsetInternWatch(Communicator *pCommunicator, NUM_PTR ipCallBack, unsigned long ulClassID, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate=false)
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_CLIENT_OPENBASE_List
Definition GloWatchNotifyManager.h:3942
Manager * m_pMyDBManager
Definition GloWatchNotifyManager.h:4032
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_UNLOCK_List
Definition GloWatchNotifyManager.h:3886
virtual void cancel() override
int processObjectUnsetWatch(Communicator *pCommunicator, const WatchSpecification &rWatchSpecification, std::list< ObjID > &rInputList)
void processNotify(OrderMsg *pOrderMsg) const
void deleteAllAction(Communicator *pCommunicator, std::list< CommunicatorCallBackIndex * > &rActionList)
bool getClassWatch(ClassWatch *&prClassWatch, unsigned long ulClassID, bool bAlsoGenerate)
int unsetWatchDependObjects(Communicator *pCommunicator, NUM_PTR ipCallBack, std::stack< ObjID > &rDependObjIdStack, TdWatchNotifyMode tdWatchNotifyMode, bool bSimulate)
virtual void work() override
std::map< unsigned long, ClassWatch *, std::less< unsigned long > > m_ClassWatchMap
Definition GloWatchNotifyManager.h:4043
static std::list< WatchNotifyManager::CommunicatorCallBackIndex * > m_WNM_INSERT_List
Definition GloWatchNotifyManager.h:3900
Um Objekte beobachten zu können, müssen der 'Beobachtungsmodus', die 'Beobachtungstiefe' und das 'Ben...
Definition GloWatchSpecification.h:60
Definition GloAbstractBaseLot.h:42
EnDeepMode
Definition GloTypes.h:247
unsigned long TdWatchNotifyMode
Definition GloTypes.h:543