MAKVrExchange::DtQueueManager Class Reference

A DtQueueManager is responsible for creating and deleting all Shared memory Queues used by the portal. More...

Public Types
typedef void(*	MessageCbFcn )(const DtPortalMessage &message, void *usr)

Public Member Functions
	DtQueueManager (DtU32 numberOfBucketsInQueue, DtU32 payloadSizePerBucket, int port, DtU16 brokerId, const DtString &objectQueueName, const DtString &interactionQueueName, const DtString &controlQueueName)
	The Default CTOR to create a DtQueueManager.
virtual	~DtQueueManager ()
	Destructor.
virtual void	send (DtPortalControlMessage &message)
virtual void	tick ()
	This class must be periodically ticked, no messages are read however, the queues are just drained.
virtual void	requestBrokerShutdown ()
	Sends out a message asking all brokers to exit.
virtual void	requestBrokerRestart (bool shouldMapMessagesOneToOne)
	Sends out a message asking all running brokers to restart.
virtual int	connectedBrokerCount ()
	Returns the number of known connected brokers.
virtual void	pruneBrokerSocketMap ()
	This is called after a requestBrokerShutdown() call to prune dead brokers from the internal counter.
Message Queue Accessors
The following functions allow access to the individual message queues
virtual DtSubscribableMessageQueue *	getControlMessageQueue ()
virtual DtSubscribableMessageQueue *	getInteractionMessageQueue ()
virtual DtSubscribableMessageQueue *	getObjectMessageQueue ()

Static Public Member Functions
static DtQueueManager *	create (DtU32 numberOfBucketsInQueue, DtU32 payloadSizePerBucket, int port, DtU16 theBrokerId, const DtString &objectQueueName, const DtString &interactionQueueName, const DtString &controlQueueName)
	A static function to create a Queue Manager.

Protected Types
typedef std::map< int, DtInetTcpSocket * >	BrokerSocketMap
typedef std::map < DtInetTcpSocket *, int >	UnknownSocketMap

Protected Member Functions
virtual void	addSocket (DtInetTcpSocket *sock)
	adds a socket to the unknown list
virtual void	removeSocket (DtInetTcpSocket *sock)
	removes knowledge of a socket cleanly
virtual void	removeUnknownSocket (DtInetTcpSocket *sock)
	Removes socket from unknown list.
virtual void	processUnknownSockets ()
	tries to move sockets from the unknown list to the known list, by attempting to read the broker Id from the socket
virtual void	testKnownSockets ()
	tests if the known sockets are still connected.
void	drainSockets ()
	Drains all known sockets so that we don't have memory leaks, or sockets that fill up.
virtual DtU8	getUnusedBrokerID ()

Static Protected Member Functions
static bool	addSocketCb (DtInetSocket *sock, void *usr)
static bool	removeSocketCb (DtInetSocket *sock, void *usr)

Protected Attributes
const DtU16	theBrokerId
DtU32	myControlSerialNumber
int	myTickCountForSocketTest
int	myTicksBeforeSocketTest
DtPortalMessageFactory	myMessageFactory
DtMemoryManager	myMemoryManager
DtSubscribableMessageQueue *	myControlMessageQueue
DtSubscribableMessageQueue *	myInteractionMessageQueue
DtSubscribableMessageQueue *	myObjectMessageQueue
DtInetSocketMgr *	myTcpSocketManager
DtClock	myClock
DtTime	myLastHeartbeatTime
BrokerSocketMap	myBrokerSocketMap
UnknownSocketMap	myUnknownBrokerSocketList

Private Member Functions
	DtQueueManager (const DtQueueManager &other)
	Copy Ctor Not implemented – Class Not Copyable.
DtQueueManager &	operator= (const DtQueueManager &other)
	Assignment Operator Not implemented – Class Not Copyable.

Detailed Description

A DtQueueManager is responsible for creating and deleting all Shared memory Queues used by the portal.

The portal must run one instance of the DtQueueManager. This class is responsible for creating and initializing all shared memory message queues used by the MAK Portal. When the instance is destroyed it will send a message to shutdown all brokers, and clean up the queues It also maintains a TCP Socket connection to all the brokers, which can monitor the Socket for a shutdown of the DtQueueManager, or vice versa

Member Typedef Documentation

typedef void(* MAKVrExchange::DtQueueManager::MessageCbFcn)(const DtPortalMessage &message, void *usr)

typedef std::map<int,DtInetTcpSocket*> MAKVrExchange::DtQueueManager::BrokerSocketMap

protected

typedef std::map<DtInetTcpSocket*,int> MAKVrExchange::DtQueueManager::UnknownSocketMap

protected

Constructor & Destructor Documentation

MAKVrExchange::DtQueueManager::DtQueueManager	(	DtU32	numberOfBucketsInQueue,
		DtU32	payloadSizePerBucket,
		int	port,
		DtU16	brokerId,
		const DtString &	objectQueueName,
		const DtString &	interactionQueueName,
		const DtString &	controlQueueName
	)

The Default CTOR to create a DtQueueManager.

Parameters

port	- the port to listen for brokers on if set to 0 then no port will be opened. The portal will still work, but brokers will not be able to know if the portal has died

virtual MAKVrExchange::DtQueueManager::~DtQueueManager ( )

virtual

Destructor.

The destructor will send a message to shutdown all brokers, then pause for one second to give them time to exit. If the user wants a more orderly shutdown the functions requestBrokerShutdown(), connectedBrokerCount() and pruneBrokerSocketMap() should be used.

MAKVrExchange::DtQueueManager::DtQueueManager ( const DtQueueManager &  other )

private

Copy Ctor Not implemented – Class Not Copyable.

Member Function Documentation

virtual void MAKVrExchange::DtQueueManager::send ( DtPortalControlMessage &  message )

virtual

virtual void MAKVrExchange::DtQueueManager::tick ( )

virtual

This class must be periodically ticked, no messages are read however, the queues are just drained.

virtual void MAKVrExchange::DtQueueManager::requestBrokerShutdown ( )

virtual

Sends out a message asking all brokers to exit.

Called from destructor but may also be called at anytime. Exit from this call does not mean that all brokers have shut down.

virtual void MAKVrExchange::DtQueueManager::requestBrokerRestart ( bool  shouldMapMessagesOneToOne )

virtual

Sends out a message asking all running brokers to restart.

Called when a portal setting changes that requires all brokers to restart in order to take change into effect. Takes argument about whether restarted broker should use one to one mapping

virtual int MAKVrExchange::DtQueueManager::connectedBrokerCount ( )

virtual

Returns the number of known connected brokers.

This can be called after requestBrokerShutdown() to determine if any brokers have actualy shutdown. A count of zero indicates no connected brokers. The user must be sure all shutdown sockets are properly cleaned by calling pruneBrokerSocketMap() before calling connectedBrokerCount().

virtual void MAKVrExchange::DtQueueManager::pruneBrokerSocketMap ( )

virtual

This is called after a requestBrokerShutdown() call to prune dead brokers from the internal counter.

This must be called to insure connectedBrokerCount() is valid.

virtual DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::getControlMessageQueue ( )

inlinevirtual

virtual DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::getInteractionMessageQueue ( )

inlinevirtual

virtual DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::getObjectMessageQueue ( )

inlinevirtual

static DtQueueManager* MAKVrExchange::DtQueueManager::create ( DtU32  numberOfBucketsInQueue, DtU32  payloadSizePerBucket, int  port, DtU16  theBrokerId, const DtString &  objectQueueName, const DtString &  interactionQueueName, const DtString &  controlQueueName  )

static

A static function to create a Queue Manager.

virtual void MAKVrExchange::DtQueueManager::addSocket ( DtInetTcpSocket *  sock )

protectedvirtual

adds a socket to the unknown list

virtual void MAKVrExchange::DtQueueManager::removeSocket ( DtInetTcpSocket *  sock )

protectedvirtual

removes knowledge of a socket cleanly

virtual void MAKVrExchange::DtQueueManager::removeUnknownSocket ( DtInetTcpSocket *  sock )

protectedvirtual

Removes socket from unknown list.

virtual void MAKVrExchange::DtQueueManager::processUnknownSockets ( )

protectedvirtual

tries to move sockets from the unknown list to the known list, by attempting to read the broker Id from the socket

virtual void MAKVrExchange::DtQueueManager::testKnownSockets ( )

protectedvirtual

tests if the known sockets are still connected.

If not, it sends a message to the control queue of a broker failure

void MAKVrExchange::DtQueueManager::drainSockets ( )

protected

Drains all known sockets so that we don't have memory leaks, or sockets that fill up.

This discards all info, and should be called AFTER processUnknownSockets.

static bool MAKVrExchange::DtQueueManager::addSocketCb ( DtInetSocket *  sock, void *  usr  )

staticprotected

static bool MAKVrExchange::DtQueueManager::removeSocketCb ( DtInetSocket *  sock, void *  usr  )

staticprotected

virtual DtU8 MAKVrExchange::DtQueueManager::getUnusedBrokerID ( )

protectedvirtual

DtQueueManager& MAKVrExchange::DtQueueManager::operator= ( const DtQueueManager &  other )

private

Assignment Operator Not implemented – Class Not Copyable.

Member Data Documentation

const DtU16 MAKVrExchange::DtQueueManager::theBrokerId

protected

DtU32 MAKVrExchange::DtQueueManager::myControlSerialNumber

protected

int MAKVrExchange::DtQueueManager::myTickCountForSocketTest

protected

int MAKVrExchange::DtQueueManager::myTicksBeforeSocketTest

protected

DtPortalMessageFactory MAKVrExchange::DtQueueManager::myMessageFactory

protected

DtMemoryManager MAKVrExchange::DtQueueManager::myMemoryManager

protected

DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::myControlMessageQueue

protected

DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::myInteractionMessageQueue

protected

DtSubscribableMessageQueue* MAKVrExchange::DtQueueManager::myObjectMessageQueue

protected

DtInetSocketMgr* MAKVrExchange::DtQueueManager::myTcpSocketManager

protected

DtClock MAKVrExchange::DtQueueManager::myClock

protected

DtTime MAKVrExchange::DtQueueManager::myLastHeartbeatTime

protected

BrokerSocketMap MAKVrExchange::DtQueueManager::myBrokerSocketMap

protected

UnknownSocketMap MAKVrExchange::DtQueueManager::myUnknownBrokerSocketList

protected

---

The documentation for this class was generated from the following file:

• queueManager.h