| addSocket(DtInetTcpSocket *sock) | MAKVrExchange::DtQueueManager | protectedvirtual |
| addSocketCb(DtInetSocket *sock, void *usr) | MAKVrExchange::DtQueueManager | protectedstatic |
| BrokerSocketMap typedef | MAKVrExchange::DtQueueManager | protected |
| connectedBrokerCount() | MAKVrExchange::DtQueueManager | virtual |
| create(DtU32 numberOfBucketsInQueue, DtU32 payloadSizePerBucket, int port, DtU16 theBrokerId, const DtString &objectQueueName, const DtString &interactionQueueName, const DtString &controlQueueName) | MAKVrExchange::DtQueueManager | static |
| drainSockets() | MAKVrExchange::DtQueueManager | protected |
| DtQueueManager(DtU32 numberOfBucketsInQueue, DtU32 payloadSizePerBucket, int port, DtU16 brokerId, const DtString &objectQueueName, const DtString &interactionQueueName, const DtString &controlQueueName) | MAKVrExchange::DtQueueManager | |
| DtQueueManager(const DtQueueManager &other) | MAKVrExchange::DtQueueManager | private |
| getControlMessageQueue() | MAKVrExchange::DtQueueManager | inlinevirtual |
| getInteractionMessageQueue() | MAKVrExchange::DtQueueManager | inlinevirtual |
| getObjectMessageQueue() | MAKVrExchange::DtQueueManager | inlinevirtual |
| getUnusedBrokerID() | MAKVrExchange::DtQueueManager | protectedvirtual |
| MessageCbFcn typedef | MAKVrExchange::DtQueueManager | |
| myBrokerId | MAKVrExchange::DtQueueManager | protected |
| myBrokerSocketMap | MAKVrExchange::DtQueueManager | protected |
| myClock | MAKVrExchange::DtQueueManager | protected |
| myControlMessageQueue | MAKVrExchange::DtQueueManager | protected |
| myControlSerialNumber | MAKVrExchange::DtQueueManager | protected |
| myInteractionMessageQueue | MAKVrExchange::DtQueueManager | protected |
| myLastHeartbeatTime | MAKVrExchange::DtQueueManager | protected |
| myMemoryManager | MAKVrExchange::DtQueueManager | protected |
| myMessageFactory | MAKVrExchange::DtQueueManager | protected |
| myObjectMessageQueue | MAKVrExchange::DtQueueManager | protected |
| myTcpSocketManager | MAKVrExchange::DtQueueManager | protected |
| myTickCountForSocketTest | MAKVrExchange::DtQueueManager | protected |
| myTicksBeforeSocketTest | MAKVrExchange::DtQueueManager | protected |
| myUnknownBrokerSocketList | MAKVrExchange::DtQueueManager | protected |
| operator=(const DtQueueManager &other) | MAKVrExchange::DtQueueManager | private |
| processUnknownSockets() | MAKVrExchange::DtQueueManager | protectedvirtual |
| pruneBrokerSocketMap() | MAKVrExchange::DtQueueManager | virtual |
| removeSocket(DtInetTcpSocket *sock) | MAKVrExchange::DtQueueManager | protectedvirtual |
| removeSocketCb(DtInetSocket *sock, void *usr) | MAKVrExchange::DtQueueManager | protectedstatic |
| removeUnknownSocket(DtInetTcpSocket *sock) | MAKVrExchange::DtQueueManager | protectedvirtual |
| requestBrokerRestart(bool shouldMapMessagesOneToOne) | MAKVrExchange::DtQueueManager | virtual |
| requestBrokerShutdown() | MAKVrExchange::DtQueueManager | virtual |
| searchForLicFile() | MAKVrExchange::DtQueueManager | protectedstatic |
| send(DtPortalControlMessage &message, bool global=false) | MAKVrExchange::DtQueueManager | virtual |
| testKnownSockets() | MAKVrExchange::DtQueueManager | protectedvirtual |
| tick() | MAKVrExchange::DtQueueManager | virtual |
| UnknownSocketMap typedef | MAKVrExchange::DtQueueManager | protected |
| ~DtQueueManager() | MAKVrExchange::DtQueueManager | virtual |
