Das Objekt dieser Klasse ist die zentrale Anlaufstelle für Aktionen, welche mit GlobalObjects-Daten zu tun haben. Mehr ...

#include <GloManager.h>

Klassendiagramm für glo::Manager:

[Legende]

Klassen
struct	ObjIdWithDepends
	Eine Struktur um die Objekt-ID eines persistenten Objekts mit den Datensätzen der abhängigen Objekte (abhängig bedeutet; sollen mitgespeichert, mitgelöscht, mitüberwacht, mitgesperrt etc. werden) abzubilden. Mehr ...

class	Receiver
	Ist die Gegenstelle bzw. der Kommunikator, welcher mit dem Manager kommuniziert. Bei dem Mehrbenutzbetrieb kann es mehrere Gegenstellen bzw. Kommunikatoren geben. Mehr ...

class	SchemaMapItem
	Objekte dieser Klasse repräsentieren eine geöffnete Datenbank. Es gibt für jede geöffnete Datenbank ein Objekt dieser Klasse. Mehr ...

Öffentliche Methoden
void	getAllClients (std::vector< ClientInfo > &rClientInfoVector, std::string *psSchemaName=0) const

void	getKnownBases (std::vector< std::string > &rKnownBasesVector) const

RealIndexPool *	getRealIndexPool ()

std::string	getSchemaPath () const

bool	isBaseOpen (Communicator *pCommunicator)

int	takeOrder (OrderMsg *pOrderMsg)

Öffentliche Methoden geerbt von eut::RepeatingThread
	RepeatingThread ()

virtual	~RepeatingThread ()

virtual void	cancel ()

virtual void	finishBreak ()

int	getBreakCounter ()

bool	isInExclusiveAccess () const

void	setExclusiveAccess ()

void	signalInput ()

virtual int	start ()

RepeatingThread::STATUS	status () const

virtual void	takeABreak ()

bool	testCancel ()

void	unsetExclusiveAccess ()

void	waitForInput ()

Öffentliche, statische Methoden
static Manager *	create (const std::string &rsSchemaPath, const std::vector< std::string > &rAllowedSchemes)

static int	destroy ()

static Manager *	getAvailableInstance ()

static ShowLevel	getShowLevel ()

static void	setActionVisualiser (ManagerActionVisualiser *pActionVisualiser)

static void	setShowLevel (ShowLevel ulLevel)

static void	showAction (const OrderMsg *pOrderMsg, const std::string &rsActiontype, const std::string &rsActionString, char cSE)

static void	showActionString (const std::string &sActionString)

static void	showOrderAction (OrderMsg *pOrderMsg, char cSE)

static void	showReaderAction (OrderMsg *pOrderMsg, const std::string &rsActionString, char cSE)

static void	showTransactionAction (OrderMsg *pOrderMsg, const std::string &rsActionString, char cSE)

static void	showWriterAction (OrderMsg *pOrderMsg, const std::string &rsActionString, char cSE)

Geschützte Methoden
	Manager ()

	Manager (const std::string &rsSchemaPath, const std::vector< std::string > &rAllowedSchemes)

virtual	~Manager ()

int	checkAllRecordIndices (int iCheckStatus, const SchemaInterface &rSchema, const std::map< ObjID, Record *, std::less< ObjID > > &rRecordMap, IndexPool &rGloIndexPool) const

void	closeBase (OrderMsg *pOrderMsg)

void	compressBase (OrderMsg *pOrderMsg)

int	createSchemaInterface (SchemaInterface *&prNewSchemaInterface, const std::string &rsSchemaName) const

void	deleteAllObjectsInReceiverMap ()

void	deleteAllObjectsInSchemaMap ()

void	deleteCommunicatorWatches (OrderMsg *pOrderMsg)

void	getAllClients (OrderMsg *pOrderMsg) const

void	getAllDataTypes (OrderMsg *pOrderMsg) const

void	getAllKnownBases (OrderMsg *pOrderMsg) const

void	getAllTransactionIndexPools (std::vector< TransactionIndexPool * > &rTransactionIndexPoolVector, std::string psSchemaName=0, Communicator pWithoutThisCommunicator=0) const

void	getBaseOrSubClassInfos (OrderMsg *pOrderMsg) const

void	getClassInfo (OrderMsg *pOrderMsg) const

void	getDataTypeLimits (OrderMsg *pOrderMsg) const

void	getDependRecords (std::map< ObjID, Record , std::less< ObjID > > &rDependRecordMap, Record &rSourceRecord, const TableReaderInterface &rTableReaderInterface, EnDeepMode eDeepMode, TransactionOwner pCommunicatorWithTreadID=nullptr) const

void	getDependRecordsRecursive (std::map< ObjID, Record , std::less< ObjID > > &rDependRecordMap, Record &rSourceRecord, const TableReaderInterface &rTableReaderInterface, EnDeepMode eDeepMode, TransactionOwner pCommunicatorWithTreadID=nullptr) const

std::size_t	getNumberReceiver () const

std::size_t	getNumberReceiver (std::string sSchemaName) const

Manager::Receiver *	getReceiver (Communicator *pCommunicator)

int	getRecord (Record &prRetVal, const glo::ObjID &rObjID, const TableReaderInterface &rTableReaderInterface, TransactionOwner pCommunicatorWithTreadID=nullptr) const

SchemaInterface *	getSchemaInterface (const std::string &rsSchemaName) const

Manager::SchemaMapItem *	getSchemaMapItem (const std::string &rsSchemaName) const

void	insertInKnownBases (const std::vector< std::string > &rNewSchemes)

int	lockBaseExclusive (std::ofstream *&prLockFile, const SchemaInterface &rSchemaInterface)

void	openBase (OrderMsg *pOrderMsg)

void	processDisconnectedClient (OrderMsg *pOrderMsg)

void	processNewConnectedClient (OrderMsg *pOrderMsg)

void	processObjectNotify (TdWatchNotifyMode nWatchNotifyMode, const ObjID &rObjID, Communicator *pCommunicator, const std::string &rsSchemaName)

void	processObjectNotify (TdWatchNotifyMode nWatchNotifyMode, const std::list< ObjID > &rObjIDList, Communicator *pCommunicator, const std::string &rsSchemaName)

void	reindexBase (OrderMsg *pOrderMsg)

void	releaseStrIndexesFromTransactionStepList (std::list< TransactionManager::TransactionBase * > &rTransactionStepList, std::string &rsSchemaName)

void	removeCommunicator (OrderMsg pOrderMsg, WatchNotifyManager pWatchNotifyManager=0)

void	repairBase (OrderMsg *pOrderMsg)

int	sendABORTtoTransactionManager (const TransactionOwner &rCommunicatorWithTreadID, std::string sSchemaName)

int	sendBEGINtoTransactionManager (const TransactionOwner &rCommunicatorWithTreadID)

int	sendCOMMITtoTransactionManager (const TransactionOwner &rCommunicatorWithTreadID, std::string sSchemaName, std::map< ObjID, Record , std::less< ObjID > > pInputDataRecordMap)

void	sendToLockManager (OrderMsg *pOrderMsg)

int	sendToLockManager (OrderMsg::EnOrderType eOrderType, SchemaInterface pSchema, std::list< ObjID > pObjectIDsToBeLocked, LockSpecification *pLockSpec, const TransactionOwner &rCommunicatorWithTreadID)

void	sendToReaderThread (OrderMsg *pOrderMsg)

void	sendToTransactionManager (OrderMsg *pOrderMsg)

void	sendToWatchNotifyManager (OrderMsg *pOrderMsg)

void	sendToWriter (OrderMsg *pOrderMsg)

void	switchOffAllRecieverReader ()

void	switchOffRecieverReader (std::string sSchemaName)

void	switchOnAllRecieverReader ()

void	switchOnRecieverReader (std::string sSchemaName)

int	transactionManagerSetTransactionStep (const SchemaInterface &rSchema, const TransactionOwner &rCommunicatorWithTreadID, TransactionManager::EnStoreDelete eStoreOrDelete, Record *pRecord)

void	unlockTransactionStepList (std::list< TransactionManager::TransactionBase * > &rTransactionStepList, const TransactionOwner &rCommunicatorWithTreadID, const std::string &rsSchemaName, TransactionIndexPool *pTransactionIndexPool, bool bDelete)

virtual void	work () override

Geschützte Methoden geerbt von eut::RepeatingThread
ORDER	getOrder ()

STATUS	getStatus ()

void	setStatus (STATUS eStatus)

void	threadWork ()

void	toOrder (ORDER eOrder)

Private Methoden
	Manager (const Manager &)

Manager &	operator= (const Manager &)

Private Attribute
bool	m_bWorkingExclusiv

std::map< SOCKET, ClientInfo, std::less< SOCKET > >	m_ConnectedClientsMap

std::vector< std::string >	m_KnownSchemes

eut::CriticalSection	m_LocalCriticalSection

std::queue< OrderMsg * >	m_MsgQueue

LockManager *	m_pLockManager

RealIndexPool *	m_pRealIndexPool

TransactionManager *	m_pTransactionManager

WatchNotifyManager *	m_pWatchNotifyManager

std::map< Communicator , Receiver , std::less< Communicator * > >	m_ReceiverMap

std::map< std::string, SchemaMapItem *, std::less< std::string > >	m_SchemaMap

std::string	m_strSchemaPath

unsigned int	m_uiCommunicatorID

Statische, private Attribute
static ManagerActionVisualiser *	m_pActionVisualiser

static Manager *	m_pInstance

static ShowLevel	m_ulShowLevel

static int	ms_iReferenceCounter

Freundbeziehungen
class	LockManager

class	OrderMsg

class	TableWriterInterface

class	TcpServerReceiver

class	WatchNotifyManager

Weitere Geerbte Elemente
Öffentliche Typen geerbt von eut::RepeatingThread
enum	EuTHREADERROR { EuTHREAD_ERR_NO_THREAD = -10301 , EuTHREAD_ERR_THREAD_ALREADY_WORKING = -10302 , EuTHREAD_ERR_THREAD_BREAK_COUNT_LESS_THAN_ZERO = -10303 , EuTHREAD_ERR_UNKNOWN = -10400 }
	Fehlerbereich = -10301 bis -10400 Mehr ...

enum	ORDER { eUNDEFINED , eDO_WORK , eEXIT }

enum	STATUS { eAT_THE_START , eWORKING , ePAUSING , eENDING , eCOMPLETED }

Öffentliche Attribute geerbt von eut::RepeatingThread
std::string	m_strDebugInfo

Ausführliche Beschreibung

Das Objekt dieser Klasse ist die zentrale Anlaufstelle für Aktionen, welche mit GlobalObjects-Daten zu tun haben.

Es darf nur ein Objekt dieser Klasse geben (Singleton), welches über Helferobjekte auf die Tabellen über die Schema bzw. Tabellen-Schnittstellen zugreift.

Holt aus den Tabellen Datensätze und liefert diese an anfragende Base(s) bzw. wartet auf Aktionsereignisse seiner Bases.

Speichert, ändert bzw. löscht in Tabellen die Datensätze.

instanziiert einen LockManager und einen ObjektWatcher.

Es wird einmalig ein Writer-Thread für jede Datenbank und für jeden Client ein Reader-Thread instanziiert.

Die einzelnen Writer- und Reader-Threads arbeiten jeweils eine eigene Nachrichten-Queue ab.

Es wird ein IndexPool instantiert, welcher für alle genutzten Bases einen Index aufbaut, die von den Readern und Writern genutzt werden können.

Wenn der Writer schreiben möchte, werden alle Reader-Threads angehalten und warten bis der Writer fertig ist.

Wenn ein neuer CommunicaterThread instanziiert wird, wird in einer Liste von Schemata das geforderte Schema geholt, kopiert und dann dem CommunicaterThread im Konstruktor übergeben. Wenn es noch kein Schema geben sollte, wird eines instanziiert und zusätzlich in die Liste der Schemas eingefügt. Somit braucht das Schema nicht bei jedem Gebrauch neu ein gelesen werden.

Copyright: © 2010 Helmut Jakoby

Autor: Helmut Jakoby

Beschreibung der Konstruktoren und Destruktoren

◆ Manager() [1/3]

glo::Manager::Manager ( )

protected

Der Standard-Konstruktor steht nicht zur Verfügung.

◆ Manager() [2/3]

glo::Manager::Manager	(	const std::string &	rsSchemaPath,
		const std::vector< std::string > &	rAllowedSchemes )

protected

Konstruktor mit Parameterübergabe; darf nur von Manager::create (...) aufgerufen werden..

Parameter

[in]	rsSchemaPath	Der Datei-Pfad wo die Schemadateien zu finden sind (z.B. "C:/Pfad/").
[in]	rAllowedSchemes	Die bekannten Schemata bzw. deren Bezeichnungen.

Ausnahmebehandlung

eut::ErrorNException Bei einem Fehler wird eine Exception geworfen.

◆ ~Manager()

virtual glo::Manager::~Manager ( )

protectedvirtual

Destruktor.

◆ Manager() [3/3]

glo::Manager::Manager ( const Manager & )

private

Der Copy-Konstruktor steht niccht zur Verfügung.

Dokumentation der Elementfunktionen

◆ checkAllRecordIndices()

int glo::Manager::checkAllRecordIndices	(	int	iCheckStatus,
		const SchemaInterface &	rSchema,
		const std::map< ObjID, Record *, std::less< ObjID > > &	rRecordMap,
		IndexPool &	rGloIndexPool ) const

protected

Wenn iCheckStatus & 1 wird geprüft, ob die Objekt-IDs in den Record's in der rRecordMap im SchemaIndex des übergebenen SchemaInterface alle im übergebenen IndexPool als NICHT gelöscht geführt werden.
Wenn iCheckStatus & 2 werden für jeden Record's in der rRecordMap ggf. vorhandene StringIndexe ermittelt und in die Record's in der rRecordMap übertragen.
Wenn iCheckStatus & 4 wird geprüft ob alle Record's in der rRecordMap in Bezug auf ggf. definierte eindeutige Indexe gespeichert werden können.

Parameter

[in]	iCheckStatus	Der Checkstatus, siehe Methodenbeschreibung.
[in]	rSchema	Das betroffene Schema bzw. die Datenbank.
[in]	rRecordMap	Die Menge der Record's, deren ObjID geprüft werden.
[in]	rGloIndexPool	Der IndexPool, in dem die Prüfung stattfindet.

Rückgabe: Eine Rückgabe < 0 zeigt einen Fehler an, also eine Prüfung ist fehlgeschlagen.

Siehe auch: Record::getAllIndexStrings(), Record::insertInAllIndexStrings (...), Record::getIndexString (...) und Record::m_IndexStrNameTupleVector).

◆ closeBase()

void glo::Manager::closeBase ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, eine bestimmte Datenbank zu schliessen (die Informationen sind im Auftrag). Entfernt den entsprechenden Reader bzw. dekrementiert den Referenzzähler eines vorhanden Readers des, im Auftrag übergebenen, Kommunikator.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eCLOSE_BASE

◆ compressBase()

void glo::Manager::compressBase ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, eine bestimmte Datenbank zu komprimieren. Es wird die Datenbank nach dem Komprimieren neu indiziert.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Achtung: Das gewünschte wird nur gelingen, wenn die Datenbank von keiner Instanz geöffnet ist.
Ohne vorheriges Verbinden (siehe auch PrivateBase::connect() ) scheitert die Methode.

Siehe auch: OrderMsg::eCOMPRESS_BASE

◆ create()

static Manager * glo::Manager::create	(	const std::string &	rsSchemaPath,
		const std::vector< std::string > &	rAllowedSchemes )

static

Instanziierungsfunktion. Da es sich bei Manager um eine Singleton-Class handelt, wird diese von dieser Methode einmalig instanziiert und dann nur noch der Pointer auf die Instanz geliefert.

Parameter

[in]	rsSchemaPath	Der Datei-Pfad wo die Schemadateien zu finden sind (z.B. "C:/Pfad/").
[in]	rAllowedSchemes	Die bekannten Schemata bzw. deren Bezeichnungen.

Rückgabe: Zeiger auf die einzige Instanz dieser Klasse.

Ausnahmebehandlung

eut::ErrorNException Bei einem Fehler wird eine Exception geworfen.

Achtung: Die gelieferte Instanz muss mit Manager::destroy() aus dem Speicher entfernt werden.

◆ createSchemaInterface()

int glo::Manager::createSchemaInterface	(	SchemaInterface *&	prNewSchemaInterface,
		const std::string &	rsSchemaName ) const

protected

Liefert einen Zeiger auf ein neu instanziiertes SchemaInterface mit der übergebenen Bezeichnung, wenn es existiert.

Parameter

[in,out]	prNewSchemaInterface	Zeiger auf ein neu erstelltes SchemaInterface.
[in]	rsSchemaName	Die Bezeichnung des Schemas bzw. der Datenbank.

Rückgabe: Eine Rückgabe < 0 zeigt einen Fehler an.

Achtung: Die aufrufende Instanz muss das gelieferte Objekt aus dem Speicher entfernen.

◆ deleteAllObjectsInReceiverMap()

void glo::Manager::deleteAllObjectsInReceiverMap ( )

protected

Entfernt alle Elemente in m_ReceiverMap und aus dem Speicher.

◆ deleteAllObjectsInSchemaMap()

void glo::Manager::deleteAllObjectsInSchemaMap ( )

protected

Entfernt alle Elemente in der m_SchemaMap und aus dem Speicher.

◆ deleteCommunicatorWatches()

void glo::Manager::deleteCommunicatorWatches ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, alle Beobachtungen eines bestimmten Kommunikators (ersichtlich aus dem übergebenen Auftrag) über den m_pWatchNotifyManager zu entfernen.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eDELETE_COMMUNICATOR_WATCHES

◆ destroy()

static int glo::Manager::destroy ( )

static

Wenn die aufrufende Instanz die letzte mit einer Referenz auf die einzige Instanz von Manager ist, wird diese Instanz von Manager aus dem Speicher entfernt.

Rückgabe: Rückgabe ist die Anzahl der Noch-Referenzen auf diese Instanz.

◆ getAllClients() [1/2]

void glo::Manager::getAllClients ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, alle ClientInfo's im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_ALL_CLIENTS

◆ getAllClients() [2/2]

void glo::Manager::getAllClients	(	std::vector< ClientInfo > &	rClientInfoVector,
		std::string *	psSchemaName = 0 ) const

Liefert alle angemeldeten Kommunikatoren.

Parameter

[in,out]	rClientInfoVector	Die angemeldeten Kommunikatoren mit ihrer Kommunikator-ID und der Bezeichnung der geöffneten Datenbank.
[in]	psSchemaName	Wenn ein Zeiger auf eine Schemabezeichnung übergeben wird, werden nur die Kommunikatoren geliefert, welche die Datenbank mit dieser Schemabezeichnung geöffnet haben.

Siehe auch: OrderMsg::eGET_ALL_CLIENTS

◆ getAllDataTypes()

void glo::Manager::getAllDataTypes ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, alle unterstützten DatenTypen mit deren Max- und Min-Werten (LimitRecord) im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_ALL_DEFAULT_LIMITS

◆ getAllKnownBases()

void glo::Manager::getAllKnownBases ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, die Bezeichnungen aller bekannten Schemata bzw. Datenbanken, im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_ALL_BASES

◆ getAllTransactionIndexPools()

void glo::Manager::getAllTransactionIndexPools	(	std::vector< TransactionIndexPool * > &	rTransactionIndexPoolVector,
		std::string *	psSchemaName = 0,
		Communicator *	pWithoutThisCommunicator = 0 ) const

protected

Liefert die TransactionIndexPool's aus allen Receiver in der m_ReceiverMap, wenn diese einen TransactionIndexPool haben.

Parameter

[in,out]	rTransactionIndexPoolVector	Die TransactionIndexPool's.
[in]	psSchemaName	Wenn dieser Zeiger übergeben, dann werden nur die TransactionIndexPool's, deren Clients bei der korrespondierenden Datenbank angemeldet sind, geliefert.
[in]	pWithoutThisCommunicator	Wenn dieser Zeiger übergeben, wird dessen evtl. vorhandener TransactionIndexPool nicht geliefert.

Achtung: Die in rTransactionIndexPoolVector gelieferten TransactionIndexPool's dürfen von der aufrufenden Instanz nicht aus dem Speicher entfernt werden.

◆ getAvailableInstance()

static Manager * glo::Manager::getAvailableInstance ( )

static

Liefert eine Instanz von Manager, wenn vorhanden. Es wird der Referenzzähler inkrementiert.

Rückgabe: Zeiger auf die einzige Instanz dieser Klasse.

Achtung: Die gelieferte Instanz muss mit Manager::destroy() aus dem Speicher entfernt werden.

◆ getBaseOrSubClassInfos()

void glo::Manager::getBaseOrSubClassInfos ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, die Klasseninformation (ClassInfo) einer Klasse, je nach Parameter im Auftrag, alle oder nur die direkten Unter- bzw. Oberklassen im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_SUBCLASS_INFOS
OrderMsg::eGET_BASECLASS_INFOS
OrderMsg::eGET_ALL_SUBCLASS_INFOS
OrderMsg::eGET_ALL_BASECLASS_INFOS
OrderMsg::eGET_ALL_CLASS_INFOS

◆ getClassInfo()

void glo::Manager::getClassInfo ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, eine Klasseninformation mit einer bestimmten Klassen-ID, welche im Auftrag mitgeleifert wird, im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_CLASSINFO_BY_CLASSID, OrderMsg::eGET_CLASSINFO_BY_CLASSNAME, OrderMsg::eIS_KNOWN_CLASSID, OrderMsg::eIS_SUPER_CLASS_FROM

◆ getDataTypeLimits()

void glo::Manager::getDataTypeLimits ( OrderMsg * pOrderMsg ) const

protected

Verarbeitet den Auftrag, von einem unterstützten DatenTypen (ClassInfoAttribute::Type) die Max- und Min-Werten (LimitRecord) im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ).

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eGET_DATATYPE_LIMITS

◆ getDependRecords()

void glo::Manager::getDependRecords	(	std::map< ObjID, Record *, std::less< ObjID > > &	rDependRecordMap,
		Record &	rSourceRecord,
		const TableReaderInterface &	rTableReaderInterface,
		EnDeepMode	eDeepMode,
		TransactionOwner *	pCommunicatorWithTreadID = nullptr ) const

protected

Liefert alle abhängigen Datensätze in rDependRecordMap vom rSourceRecord in Abhängigkeit vom eDeepMode aus den Tabellen bzw. vom glo::TransactionManager.

Parameter

[in,out]	rDependRecordMap	Der Container mit den abhängigen Datensätzen.
[in]	rSourceRecord	Der Datensatz, dessen abhängigen Datensätze erwartet werden.
[in]	rTableReaderInterface	Der Tabellen-Leser.
[in]	eDeepMode	Der Aktionstiefenmodus.
[in]	pCommunicatorWithTreadID	Wenn ein Kommunikator mit Thread-ID übergeben wird, werden zu lesende Datensätze (in der Recursion) vorzugsweise aus der aktuellen Transaktion geholt und erst wenn dort nicht vorhanden, aus den Tabellen.

Zu beachten: Ist durch eine lokale eut::CriticalSection abgesichert.

◆ getDependRecordsRecursive()

void glo::Manager::getDependRecordsRecursive	(	std::map< ObjID, Record *, std::less< ObjID > > &	rDependRecordMap,
		Record &	rSourceRecord,
		const TableReaderInterface &	rTableReaderInterface,
		EnDeepMode	eDeepMode,
		TransactionOwner *	pCommunicatorWithTreadID = nullptr ) const

protected

Liefert alle abhängigen Datensätze in rDependRecordMap vom rSourceRecord in Abhängigkeit vom eDeepMode aus den Tabellen bzw. vom glo::TransactionManager.

Parameter

[in,out]	rDependRecordMap	Der Container mit den abhängigen Datensätzen.
[in]	rSourceRecord	Der Datensatz, dessen abhängigen Datensätze erwartet werden.
[in]	rTableReaderInterface	Der Tabellen-Leser.
[in]	eDeepMode	Der Aktionstiefenmodus.
[in]	pCommunicatorWithTreadID	Wenn ein Kommunikator mit Thread-ID übergeben wird, werden zu lesende Datensätze (in der Recursion) vorzugsweise aus der aktuellen Transaktion geholt und erst wenn dort nicht vorhanden, aus den Tabellen.

Zu beachten: Für Glo-Entwickler: Ist in GloRecordAttributeFunctions.cpp implementiert, damit Erweiterungen von Datensatz-Attributen dort gesammelt vorgenommen werden können.

◆ getKnownBases()

void glo::Manager::getKnownBases ( std::vector< std::string > & rKnownBasesVector ) const

Kopiert die Bezeichnungen aller bekannten Schemata bzw. Datenbanken, in übergebenen Vector.

Parameter

[in,out] rKnownBasesVector die Bezeichnungen aller bekannten Schemata bzw. Datenbanken.

Siehe auch: OrderMsg::eGET_ALL_BASES

◆ getNumberReceiver() [1/2]

std::size_t glo::Manager::getNumberReceiver ( ) const

protected

Liefert die Anzahl der Receiver in der m_ReceiverMap.

Rückgabe: Die Anzahl der Receiver.

◆ getNumberReceiver() [2/2]

std::size_t glo::Manager::getNumberReceiver ( std::string sSchemaName ) const

protected

Liefert die Anzahl der Receiver in der m_ReceiverMap, deren Kommunikator an eine bestimmte Datenbank angemeldet sind.

Parameter

[in] sSchemaName Die Bezeichnung des Schemas bzw. der Datenbank.

Rückgabe: Die Anzahl der Receiver.

◆ getRealIndexPool()

RealIndexPool * glo::Manager::getRealIndexPool ( )

Liefert den realen IndexPool.

Rückgabe: Der reale IndexPool.

Achtung: Die aufrufende Instanz darf das gelieferte Objekt nicht aus dem Speicher entfernen. Es lebt nur so lange wie dieses Objekt.

◆ getReceiver()

Manager::Receiver * glo::Manager::getReceiver ( Communicator * pCommunicator )

protected

Liefert einen Receiver mit Referenz auf einen bestimmten Kommunikator aus der m_ReceiverMap.

Parameter

[in] pCommunicator Der Kommunikator.

Rückgabe: Der gefundene Receiver, wenn vorhanden.

Achtung: Das gelieferte Objekt darf von der aufrufernden Instanz nicht aus dem Speicher entfernt werden.

◆ getRecord()

int glo::Manager::getRecord	(	Record *&	prRetVal,
		const glo::ObjID &	rObjID,
		const TableReaderInterface &	rTableReaderInterface,
		TransactionOwner *	pCommunicatorWithTreadID = nullptr ) const

protected

Liefert einen Datensatz aus den Tabellen bzw. vom glo::TransactionManager mit übergebener Objekt-ID.

Parameter

[in,out]	prRetVal	Der Datensatz.
[in]	rObjID	Die Objekt-ID des Datensatzes.
[in]	rTableReaderInterface	Der Tabellen-Leser.
[in]	pCommunicatorWithTreadID	Wenn ein Kommunikator mit Thread-ID übergeben wird, wird der zu lesende Datensatz vorzugsweise aus der aktuellen Transaktion geholt und erst wenn dort nicht vorhanden, aus den Tabellen.

Rückgabe: Eine Rückgabe < 0 zeigt einen Fehler an.

Achtung: Die aufrufende Instanz muss den evtl. gelieferten Datensatz mittels Record::forget() aus dem Speicher entfernen.

◆ getSchemaInterface()

SchemaInterface * glo::Manager::getSchemaInterface ( const std::string & rsSchemaName ) const

protected

Liefert einen Zeiger auf ein SchemaInterface mit der übergebenen Bezeichnung aus der m_SchemaMap.

Parameter

[in] rsSchemaName Die Bezeichnung des Schemas bzw. der Datenbank.

Rückgabe: Das gefundene SchemaInterface, ansonsten 0.

Achtung: Die aufrufende Instanz darf das gelieferte Objekt nicht aus dem Speicher entfernen.

◆ getSchemaMapItem()

Manager::SchemaMapItem * glo::Manager::getSchemaMapItem ( const std::string & rsSchemaName ) const

protected

Liefert einen Zeiger auf ein SchemaMapItem mit der übergebenen Bezeichnung seines Schemas aus der m_SchemaMap.

Parameter

[in] rsSchemaName Die Bezeichnung des Schemas bzw. der Datenbank.

Rückgabe: Das gefundene SchemaMapItem, ansonsten 0.

Achtung: Die aufrufende Instanz darf das gelieferte Objekt nicht aus dem Speicher entfernen.

◆ getSchemaPath()

std::string glo::Manager::getSchemaPath ( ) const

Liefert den Datei-Pfad wo die Schemadatei zu finden ist.

Rückgabe: Vollständige Pfadbezeichnung (z.B. "C:/Pfad/").

◆ getShowLevel()

static ShowLevel glo::Manager::getShowLevel ( )

static

Liefert die Anzeigeeinstellung.

Rückgabe: Die Anzeigeeinstellung.

◆ insertInKnownBases()

void glo::Manager::insertInKnownBases ( const std::vector< std::string > & rNewSchemes )

protected

Fügt übergebene Datenbanknamen in m_KnownSchemes ein, wenn noch nicht vorhanden.

Parameter

[in] rNewSchemes Die Bezeichnung des Schemas bzw. der Datenbank.

◆ isBaseOpen()

bool glo::Manager::isBaseOpen ( Communicator * pCommunicator )

Prüft, ob übergebener Kommunikator eine Datenbank geöffnet hat bzw. ob ein entsprechender Receiver in der m_ReceiverMap vorhanden ist.

Rückgabe: Liefert true, wenn übergebener Kommunikator eine Datenbank geöffnet hat.

◆ lockBaseExclusive()

int glo::Manager::lockBaseExclusive	(	std::ofstream *&	prLockFile,
		const SchemaInterface &	rSchemaInterface )

protected

Liefert, wenn noch nicht geöffnet, das LockFile der Datenbank, ersichtlich aus dem übergebenen rSchemaInterface.

Parameter

[in,out]	prLockFile	Das einmalig geöffnete LockFile.
[in]	rSchemaInterface	Das Schema, dessen Datenbank durch das LogFile gesperrt werden soll.

Rückgabe: Eine Rückgabe < 0 zeigt einen Fehler an, z.B. ERR_BASE_LOCKED wenn Datei schon gelockt.

Achtung: Das gelieferte Objekt muss von der aufrufenden Instanz aus dem Speicher entfernt werden.

◆ openBase()

void glo::Manager::openBase ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, eine bestimmte Datenbank zu öffnen (die Informationen sind im Auftrag) und die Kommunikator-ID im Auftrag einzufügen (siehe auch OrderMsg::setOrderResult (...) ). Instanziiert einen Reader bzw. erhöht den Referenzzähler eines vorhanden Readers für, im Auftrag übergebenen, Kommunikator.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eOPEN_BASE

◆ operator=()

Manager & glo::Manager::operator= ( const Manager & )

private

Der Zuweisungsoperator steht nicht zur Verfügung.

◆ processDisconnectedClient()

void glo::Manager::processDisconnectedClient ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, einen Client (ersichtlich aus dem übergebenen Auftrag) aus seineer m_ConnectedClientsMap zu entfernen.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eDISCONNECTED_CLIENT

◆ processNewConnectedClient()

void glo::Manager::processNewConnectedClient ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, einen neuen Client (ersichtlich aus dem übergebenen Auftrag) in seine m_ConnectedClientsMap einzufügen.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eNEW_CONNECTED_CLIENT

◆ processObjectNotify() [1/2]

void glo::Manager::processObjectNotify	(	TdWatchNotifyMode	nWatchNotifyMode,
		const ObjID &	rObjID,
		Communicator *	pCommunicator,
		const std::string &	rsSchemaName )

protected

Initiiert über seine m_MsgQueue ein Notify im m_pWatchNotifyManager, welches ein Objekt betrifft.

Parameter

[in]	nWatchNotifyMode	Der Überwachungsmodus.
[in]	rObjID	Die Objekt-ID des betroffenen Objekts.
[in]	pCommunicator	Der Kommunikator.
[in]	rsSchemaName	Der Schemaname wird für das Benachrichtigen gebraucht.

◆ processObjectNotify() [2/2]

void glo::Manager::processObjectNotify	(	TdWatchNotifyMode	nWatchNotifyMode,
		const std::list< ObjID > &	rObjIDList,
		Communicator *	pCommunicator,
		const std::string &	rsSchemaName )

protected

Initiiert über seine m_MsgQueue Notify's im m_pWatchNotifyManager, welches die Objekte mit den Objekt-IDs aus rObjIDList betrifft.

Parameter

[in]	nWatchNotifyMode	Der Überwachungsmodus.
[in]	rObjIDList	Die Objekt-IDs der betroffenen Objekte.
[in]	pCommunicator	Der Kommunikator.
[in]	rsSchemaName	Der Schemaname wird für das Benachrichtigen gebraucht.

◆ reindexBase()

void glo::Manager::reindexBase ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, eine bestimmte Datenbank zu reindizieren.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Achtung: Das gewünschte wird nur gelingen, wenn die Datenbank von keiner Instanz geöffnet ist.
Ohne vorheriges Verbinden (siehe auch PrivateBase::connect() ) scheitert die Methode.

Siehe auch: OrderMsg::eREINDEX_BASE

◆ releaseStrIndexesFromTransactionStepList()

void glo::Manager::releaseStrIndexesFromTransactionStepList	(	std::list< TransactionManager::TransactionBase * > &	rTransactionStepList,
		std::string &	rsSchemaName )

protected

Es werden alle reservierten String-Indexe im RealIndexPool und allen TransactionIndexPool's freigegeben, die von den TransactionManager::TransactionStep's im Parameter rTransactionStepList reserviert wurden.

Parameter

[in]	rTransactionStepList	Die Liste mit den TransactionManager::TransactionPoint's und TransactionManager::TransactionStep's (der Transaktionsverlauf).
[in]	rsSchemaName	Bezeichnung des Schemas bzw. der Datenbank.

Siehe auch: IndexPool::releaseObjStrIdTuple (...)

◆ removeCommunicator()

void glo::Manager::removeCommunicator	(	OrderMsg *	pOrderMsg,
		WatchNotifyManager *	pWatchNotifyManager = 0 )

protected

Verarbeitet den Auftrag, einen bestimmten Kommunikator (ersichtlich aus dem übergebenen Auftrag) zu entfernen. Das bedeutet, dass alle noch nicht verarbeiteten Auftrage des Kommunikatores verworfen werden.

Parameter

[in,out]	pOrderMsg	Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.
[in]	pWatchNotifyManager	Wenn ein Zeiger auf einen WatchNotifyManager übergeben wird, werden auch dort noch vorhandene Aufträge storniert.

Siehe auch: OrderMsg::eCLOSE_BASE
OrderMsg::eDELETE_COMMUNICATOR_WATCHES
OrderMsg::eNOTIFY_CLIENT

◆ repairBase()

void glo::Manager::repairBase ( OrderMsg * pOrderMsg )

protected

Verarbeitet den Auftrag, eine bestimmte Datenbank zu reparieren.

Siehe auch: Base::repairsBase (...)

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Achtung: Das gewünschte wird nur gelingen, wenn die Datenbank von keiner Instanz geöffnet ist.
Ohne vorheriges Verbinden (siehe auch PrivateBase::connect() ) scheitert die Methode.

Siehe auch: OrderMsg::eREPAIR_BASE

◆ sendABORTtoTransactionManager()

int glo::Manager::sendABORTtoTransactionManager	(	const TransactionOwner &	rCommunicatorWithTreadID,
		std::string	sSchemaName )

protected

Lässt den glo::TransactionManager den Abbruch einer Transaktion eines Kommunikators verarbeiten.
Wird von void sendToTransactionManager(OrderMsg*) aufgerufen

Parameter

[in]	rCommunicatorWithTreadID	Der beauftragende Kommunikator mit Thread-ID.
[in]	sSchemaName	Die Bezeichnung des Schemas bzw. der Datenbank.

Rückgabe: Ein Rückgabewert < 0 zeigt einen Fehler an.

◆ sendBEGINtoTransactionManager()

int glo::Manager::sendBEGINtoTransactionManager ( const TransactionOwner & rCommunicatorWithTreadID )

protected

Lässt den glo::TransactionManager den Start einer Transaktion eines Kommunikators verarbeiten.
Wird von void sendToTransactionManager(OrderMsg*) aufgerufen

Parameter

[in] rCommunicatorWithTreadID Der beauftragende Kommunikator mit Thread-ID.

Rückgabe: Ein Rückgabewert < 0 zeigt einen Fehler an.

◆ sendCOMMITtoTransactionManager()

int glo::Manager::sendCOMMITtoTransactionManager	(	const TransactionOwner &	rCommunicatorWithTreadID,
		std::string	sSchemaName,
		std::map< ObjID, Record , std::less< ObjID > >	pInputDataRecordMap )

protected

Lässt den glo::TransactionManager den Abschluss einer Transaktion eines Kommunikators verarbeiten.
Wird von void sendToTransactionManager(OrderMsg*) aufgerufen

Parameter

[in]	rCommunicatorWithTreadID	Der beauftragende Kommunikator mit Thread-ID.
[in]	sSchemaName	Die Bezeichnung des Schemas bzw. der Datenbank.
[in]	pInputDataRecordMap	Wenn nicht nullptr, dann sind dort Records mit Attributen ohne Datei-Position drinn, die gesetzt werden.

Rückgabe: Ein Rückgabewert < 0 zeigt einen Fehler an.

◆ sendToLockManager() [1/2]

void glo::Manager::sendToLockManager ( OrderMsg * pOrderMsg )

protected

Verarbeitet einen Auftrag für den LockManager in m_pLockManager.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eLOCK
OrderMsg::eUNLOCK
OrderMsg::eIS_LOCKED
OrderMsg::eIS_ALLOWED
OrderMsg::eGET_PROCESSING_POSSIBILITIES

◆ sendToLockManager() [2/2]

int glo::Manager::sendToLockManager	(	OrderMsg::EnOrderType	eOrderType,
		SchemaInterface *	pSchema,
		std::list< ObjID > *	pObjectIDsToBeLocked,
		LockSpecification *	pLockSpec,
		const TransactionOwner &	rCommunicatorWithTreadID )

protected

Verarbeitet einen Auftrag für den LockManager in m_pLockManager.

Parameter

[in]	eOrderType	Der Typ der Abbarbeitung. Erlaubt sind: OrderMsg::eLOCK OrderMsg::eUNLOCK OrderMsg::eIS_LOCKED OrderMsg::eIS_ALLOWED OrderMsg::eGET_PROCESSING_POSSIBILITIES
[in]	pSchema	Das Schema der Datanbank.
[in]	pObjectIDsToBeLocked	Die Liste der Objekt-IDs der Objekte, die gesperrt werden sollen.
[in]	pLockSpec	Der 'Lock-Modus' und die 'Sperrtiefe'.
[in]	rCommunicatorWithTreadID	Der beauftragende Kommunikator mit Thread-ID.

◆ sendToReaderThread()

void glo::Manager::sendToReaderThread ( OrderMsg * pOrderMsg )

protected

Verarbeitet einen Auftrag für einen Receiver aus der m_ReceiverMap bzw. auch für den TransactionManager in m_pTransactionManager.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

◆ sendToTransactionManager()

void glo::Manager::sendToTransactionManager ( OrderMsg * pOrderMsg )

protected

Verarbeitet einen Auftrag für den TransactionManager in m_pTransactionManager.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eSTORE
OrderMsg::eDELETE
OrderMsg::eBEGIN_TRANSACTION
OrderMsg::eCOMMIT_TRANSACTION
OrderMsg::eABORT_TRANSACTION

◆ sendToWatchNotifyManager()

void glo::Manager::sendToWatchNotifyManager ( OrderMsg * pOrderMsg )

protected

Verarbeitet einen Auftrag für den WatchNotifyManager in m_pWatchNotifyManager.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eWATCH_OBJECT
OrderMsg::eUNWATCH_OBJECT
OrderMsg::eWATCH_CLASS
OrderMsg::eUNWATCH_CLASS
OrderMsg::eWATCH_CLIENT
OrderMsg::eUNWATCH_CLIENT
OrderMsg::eWATCH_INDEX_READWRITE
OrderMsg::eUNWATCH_INDEX_READWRITE
OrderMsg::ePROCESS_NOTIFY

◆ sendToWriter()

void glo::Manager::sendToWriter ( OrderMsg * pOrderMsg )

protected

Verarbeitet einen Auftrag für einen TableWriterInterface über das SchemaMapItem in der m_SchemaMap bzw. für den TransactionManager in m_pTransactionManager.

Wenn ein Auftrag an das TableWriterInterface, werden zuerst alle ReaderThreads angehalten, dann der Auftrag bearbeitet um danach wieder die ReaderThreads wieder gestartet.

Parameter

[in,out] pOrderMsg Der zu bearbeitende Auftrag. Evtl. auftretenden Fehler werden im Auftrag eingetragen.

Siehe auch: OrderMsg::eASSIGN

◆ setActionVisualiser()

static void glo::Manager::setActionVisualiser ( ManagerActionVisualiser * pActionVisualiser )

static

Übernimmt ein Anzeigeobjekt um seine Aktionen in Abhängigkeit vom m_ulShowLevel anzeigen zu lassen.

Parameter

[in] pActionVisualiser Das Anzeigeobjekt.

Achtung: Das übergebene Anzeigeobjekt geht in den Besitz dieses Objekts über, darf ergo von übergender Instanz nicht mehr aus dem Speicher entfernt werden, dieses erledigt diese Instanz.

◆ setShowLevel()

static void glo::Manager::setShowLevel ( ShowLevel ulLevel )

static

Setzt die Anzeigeeinstellung.

Parameter

[in] ulLevel Die Anzeigeeinstellung.

◆ showAction()

static void glo::Manager::showAction	(	const OrderMsg *	pOrderMsg,
		const std::string &	rsActiontype,
		const std::string &	rsActionString,
		char	cSE )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser eine Auftragsaktion anzeigen, wenn es vorhanden ist.

Parameter

[in]	pOrderMsg	Der Auftrag mit der Kommunikator-ID und der Kommunikator-Bezeichnung für die Anzeige.
[in]	rsActiontype	Der Typ der Anzeige als String.
[in]	rsActionString	Die Aktion als String.
[in]	cSE	Ein Zusatz wie z.B. eine Richtungsanmzeige (z.B. '<' oder '>').

◆ showActionString()

static void glo::Manager::showActionString ( const std::string & sActionString )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser den übergebenen String anzeigen, wenn es vorhanden ist.

Parameter

[in] sActionString Der anzuzeigende Text,

◆ showOrderAction()

static void glo::Manager::showOrderAction	(	OrderMsg *	pOrderMsg,
		char	cSE )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser eine Auftragsaktion anzeigen, wenn es vorhanden ist.

Parameter

[in]	pOrderMsg	Der Auftrag mit der Kommunikator-ID und der Kommunikator-Bezeichnung für die Anzeige.
[in]	cSE	Ein Zusatz wie z.B. eine Richtungsanmzeige (z.B. '<' oder '>')

◆ showReaderAction()

static void glo::Manager::showReaderAction	(	OrderMsg *	pOrderMsg,
		const std::string &	rsActionString,
		char	cSE )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser, wenn es existiert, eine Leseaktion in der Datenbank anzeiegn.

Parameter

[in]	pOrderMsg	Der Auftrag mit der Kommunikator-ID und der Kommunikator-Bezeichnung für die Anzeige.
[in]	rsActionString	Die Aktion als String.
[in]	cSE	Ein Zusatz wie z.B. eine Richtungsanmzeige (z.B. '<' oder '>')

◆ showTransactionAction()

static void glo::Manager::showTransactionAction	(	OrderMsg *	pOrderMsg,
		const std::string &	rsActionString,
		char	cSE )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser, wenn es existiert, eine Transaktion-Aktion in der Datenbank anzeiegn.

Parameter

[in]	pOrderMsg	Der Auftrag mit der Kommunikator-ID und der Kommunikator-Bezeichnung für die Anzeige.
[in]	rsActionString	Die Aktion als String.
[in]	cSE	Ein Zusatz wie z.B. eine Richtungsanmzeige (z.B. '[', ']' oder 'X')

◆ showWriterAction()

static void glo::Manager::showWriterAction	(	OrderMsg *	pOrderMsg,
		const std::string &	rsActionString,
		char	cSE )

static

Lässt das Anzeigeobjekt in m_pActionVisualiser, wenn es existiert, eine Schreibaktion in der Datenbank anzeiegn.

Parameter

[in]	pOrderMsg	Der Auftrag mit der Kommunikator-ID und der Kommunikator-Bezeichnung für die Anzeige.
[in]	rsActionString	Die Aktion als String.
[in]	cSE	Ein Zusatz wie z.B. eine Richtungsanmzeige (z.B. '<' oder '>')

◆ switchOffAllRecieverReader()

void glo::Manager::switchOffAllRecieverReader ( )

protected

Läßt alle Receiver in der m_ReceiverMap eine Pause einlegen.

◆ switchOffRecieverReader()

void glo::Manager::switchOffRecieverReader ( std::string sSchemaName )

protected

Läßt alle Receiver in der Manager::m_ReceiverMap, deren Kommunikator an eine bestimmte Datenbank angemeldet sind, eine Pause einlegen.

Wird u.a. genutzt, um wärend der Lesepause Daten in die Tabellen zu schreiben.

Parameter

[in] sSchemaName Die Bezeichnung des Schemas bzw. der Datenbank.

◆ switchOnAllRecieverReader()

void glo::Manager::switchOnAllRecieverReader ( )

protected

Läßt alle Receiver in der m_ReceiverMap eine Pause beenden.

◆ switchOnRecieverReader()

void glo::Manager::switchOnRecieverReader ( std::string sSchemaName )

protected

Läßt alle Receiver in der m_ReceiverMap, deren Kommunikator an eine bestimmte Datenbank angemeldet sind, eine Pause beenden.

Parameter

[in] sSchemaName Die Bezeichnung des Schemas bzw. der Datenbank.

◆ takeOrder()

int glo::Manager::takeOrder ( OrderMsg * pOrderMsg )

Übernimmt einen Auftrag.

Parameter

[in] pOrderMsg Der abzuarbeitende Auftrag.

◆ transactionManagerSetTransactionStep()

int glo::Manager::transactionManagerSetTransactionStep	(	const SchemaInterface &	rSchema,
		const TransactionOwner &	rCommunicatorWithTreadID,
		TransactionManager::EnStoreDelete	eStoreOrDelete,
		Record *	pRecord )

protected

Setzt einen Transaktionstep aus sendToTransactionManager (...) im m_pTransactionManager.

Parameter

[in]	rSchema	Das Schema der betroffene Datenbank.
[in]	TransactionOwner	Der betroffene Kommunikator mit Thread-ID.
[in]	eStoreOrDelete	Speichern oder Löschen.
[in]	pRecord	Der Datensatz, welcher in der Transaktion gespeichert bzw. gelöscht werden soll.

Rückgabe: Eine Rückgabe < 0 zeigt einen Fehler an.

Siehe auch: TransactionManager->setTransactionStep (...)

◆ unlockTransactionStepList()

void glo::Manager::unlockTransactionStepList	(	std::list< TransactionManager::TransactionBase * > &	rTransactionStepList,
		const TransactionOwner &	rCommunicatorWithTreadID,
		const std::string &	rsSchemaName,
		TransactionIndexPool *	pTransactionIndexPool,
		bool	bDelete )

protected

Es werden alle gelockten Datensätze in der rTransactionStepList im m_pLockManager freigegeben.

Parameter

[in]	rTransactionStepList	Die Liste mit den TransactionManager::TransactionPoint's und TransactionManager::TransactionStep's (der Transaktionsverlauf).
[in]	rCommunicatorWithTreadID	Der Kommunikatore mit Thread-ID, welcher die Transaktion 'besitzt'. Wird hier zum Sperren der Datensätze benötigt.
[in]	rsSchemaName	Bezeichnung des Schemas bzw. der Datenbank.
[in]	pTransactionIndexPool	Sollte ein Zeiger auf ein TransactionIndexPool übergeben sein, wird dort die Objekt-ID eines gelöschten Objekts entfernt.
[in]	bDelete	Wenn bDelete true, wird der jeweilige TransactionManager::TransactionStep aus dem Speicher entfernt und damit der enthaltene Record 'vergessen'.

Siehe auch: LockManager::unlockObject (...)
TransactionIndexPool::removeTransactionDeletedObjID (...)

◆ work()

virtual void glo::Manager::work ( )

overrideprotectedvirtual

Diese Methode wird als Thread ausgeführt. Es wird die Nachrichten-Queue nach Aufträgen abgefragt (es wird 'geschlafen' bis eine Nachricht in die Queue gestellt wird) und nach Auswertung des Auftrags eine passende Methode aufgerufen.

Implementiert eut::RepeatingThread.

Freunde und bezugnehmende Symbol-Dokumentation

◆ LockManager

friend class LockManager

friend

◆ OrderMsg

friend class OrderMsg

friend

◆ TableWriterInterface

friend class TableWriterInterface

friend

◆ TcpServerReceiver

friend class TcpServerReceiver

friend

◆ WatchNotifyManager

friend class WatchNotifyManager

friend

Dokumentation der Datenelemente

◆ m_bWorkingExclusiv

bool glo::Manager::m_bWorkingExclusiv

private

Wird true, wenn eine Datenbank geschlossen wird. Dann werden Aufträge erstmal nicht mehr abgearbeitet bis wieder false.

◆ m_ConnectedClientsMap

std::map< SOCKET, ClientInfo , std::less< SOCKET > > glo::Manager::m_ConnectedClientsMap

private

Liste der Komunikatoren, welche mit dem Server verbunden sind.

◆ m_KnownSchemes

std::vector<std::string> glo::Manager::m_KnownSchemes

private

Die bekannten Schemata bzw. deren Bezeichnungen.

◆ m_LocalCriticalSection

eut::CriticalSection glo::Manager::m_LocalCriticalSection

private

Um einen Thread-sicheren Zugriff auf die Elemente des Manager zu gewährleistenn, wird über diese lokale CriticalSection der Zugriff synchronisiert.

◆ m_MsgQueue

std::queue< OrderMsg * > glo::Manager::m_MsgQueue

private

Die Queue mit den abzuarbeitenden Aufträgen.

◆ m_pActionVisualiser

ManagerActionVisualiser* glo::Manager::m_pActionVisualiser

staticprivate

Das Anzeigenausgabe-Objekt.

◆ m_pInstance

Manager* glo::Manager::m_pInstance

staticprivate

Statischer Zeiger auf einzige Instanz dieser Klasse.

◆ m_pLockManager

LockManager* glo::Manager::m_pLockManager

private

Verwaltet die Sperren der einzelnen Objekte.

◆ m_pRealIndexPool

RealIndexPool* glo::Manager::m_pRealIndexPool

private

Verwaltet die Indizes der einzelnen geöffneten Datenbanken.

◆ m_pTransactionManager

TransactionManager* glo::Manager::m_pTransactionManager

private

Verwaltet die Transaktionen der einzelnen Komunikatoren.

◆ m_pWatchNotifyManager

WatchNotifyManager* glo::Manager::m_pWatchNotifyManager

private

Verwaltet die Überwachungen der einzelnen Komunikatoren.

◆ m_ReceiverMap

std::map< Communicator *, Receiver * , std::less< Communicator * > > glo::Manager::m_ReceiverMap

private

Liste der Komunikatoren mit geöffneter Datenbank, welche mit dem Manager kommunizieren.

◆ m_SchemaMap

std::map< std::string, SchemaMapItem *, std::less< std::string > > glo::Manager::m_SchemaMap

private

Die SchemaInterfaces in einem SchemaMapItem, sortiert nach der Schemabezeichnung bzw. dem Datenbanknamen.

◆ m_strSchemaPath

std::string glo::Manager::m_strSchemaPath

private

Der Datei-Pfad wo die Schemadateien zu finden sind (z.B. "C:/Pfad/").

◆ m_uiCommunicatorID

unsigned int glo::Manager::m_uiCommunicatorID

private

Wird hochgezählt und jedem anmeldenden Kommunikator als ID übergeben.

◆ m_ulShowLevel

ShowLevel glo::Manager::m_ulShowLevel

staticprivate

Die Anzeigenausgabe-Einstellung.

◆ ms_iReferenceCounter

int glo::Manager::ms_iReferenceCounter

staticprivate

Der Referenzzähler auf die einzige Instanz dieser Klasse.

Die Dokumentation für diese Klasse wurde erzeugt aufgrund der Datei:

GloManager.h

Klassen

Öffentliche Methoden

Öffentliche, statische Methoden

Geschützte Methoden

Private Methoden

Private Attribute

Statische, private Attribute

Freundbeziehungen

Weitere Geerbte Elemente

Ausführliche Beschreibung

Beschreibung der Konstruktoren und Destruktoren

◆ Manager() [1/3]

◆ Manager() [2/3]

◆ ~Manager()

◆ Manager() [3/3]

Dokumentation der Elementfunktionen

◆ checkAllRecordIndices()

◆ closeBase()

◆ compressBase()

◆ create()

◆ createSchemaInterface()

◆ deleteAllObjectsInReceiverMap()

◆ deleteAllObjectsInSchemaMap()

◆ deleteCommunicatorWatches()

◆ destroy()

◆ getAllClients() [1/2]

◆ getAllClients() [2/2]

◆ getAllDataTypes()

◆ getAllKnownBases()

◆ getAllTransactionIndexPools()

◆ getAvailableInstance()

◆ getBaseOrSubClassInfos()

◆ getClassInfo()

◆ getDataTypeLimits()

◆ getDependRecords()

◆ getDependRecordsRecursive()

◆ getKnownBases()

◆ getNumberReceiver() [1/2]

◆ getNumberReceiver() [2/2]

◆ getRealIndexPool()

◆ getReceiver()

◆ getRecord()

◆ getSchemaInterface()

◆ getSchemaMapItem()

◆ getSchemaPath()

◆ getShowLevel()

◆ insertInKnownBases()

◆ isBaseOpen()

◆ lockBaseExclusive()

◆ openBase()

◆ operator=()

◆ processDisconnectedClient()

◆ processNewConnectedClient()

◆ processObjectNotify() [1/2]

◆ processObjectNotify() [2/2]

◆ reindexBase()

◆ releaseStrIndexesFromTransactionStepList()

◆ removeCommunicator()

◆ repairBase()

◆ sendABORTtoTransactionManager()

◆ sendBEGINtoTransactionManager()

◆ sendCOMMITtoTransactionManager()

◆ sendToLockManager() [1/2]

◆ sendToLockManager() [2/2]

◆ sendToReaderThread()

◆ sendToTransactionManager()

◆ sendToWatchNotifyManager()

◆ sendToWriter()

◆ setActionVisualiser()

◆ setShowLevel()

◆ showAction()

◆ showActionString()

◆ showOrderAction()

◆ showReaderAction()

◆ showTransactionAction()

◆ showWriterAction()

◆ switchOffAllRecieverReader()

◆ switchOffRecieverReader()

◆ switchOnAllRecieverReader()

◆ switchOnRecieverReader()