MessageTransceiverThread Member List

This is the complete list of members for MessageTransceiverThread, including all inherited members.

AddNewConnectSession(const ip_address &targetIPAddress, uint16 port, const ThreadWorkerSessionRef &optSessionRef, uint64 autoReconnectDelay=MUSCLE_TIME_NEVER)MessageTransceiverThread [virtual]
AddNewConnectSession(const ip_address &targetIPAddress, uint16 port, uint64 autoReconnectDelay=MUSCLE_TIME_NEVER)MessageTransceiverThread [inline]
AddNewConnectSession(const String &targetHostName, uint16 port, const ThreadWorkerSessionRef &optSessionRef, bool expandLocalhost=false, uint64 autoReconnectDelay=MUSCLE_TIME_NEVER)MessageTransceiverThread [virtual]
AddNewConnectSession(const String &targetHostName, uint16 port, bool expandLocalhost=false, uint64 autoReconnectDelay=MUSCLE_TIME_NEVER)MessageTransceiverThread [inline]
AddNewSession(const SocketRef &socket, const ThreadWorkerSessionRef &optSessionRef)MessageTransceiverThread [virtual]
AddNewSession(const SocketRef &socket)MessageTransceiverThread [inline]
AddNewSession()MessageTransceiverThread [inline]
CloseSockets()Thread [protected]
CreateDefaultSessionFactory()MessageTransceiverThread [protected, virtual]
CreateDefaultWorkerSession()MessageTransceiverThread [protected, virtual]
CreateReflectServer()MessageTransceiverThread [protected, virtual]
CreateSupervisorSession()MessageTransceiverThread [protected, virtual]
GetDefaultDistributionPath() constMessageTransceiverThread [inline]
GetInternalSocketSet(uint32 socketSet)Thread [inline, protected]
GetInternalSocketSet(uint32 socketSet) constThread [protected]
GetInternalThreadWakeupSocket()Thread [protected]
GetNextEventFromInternalThread(uint32 &retEventCode, MessageRef *optRetMsgRef=NULL, String *optFromSession=NULL, uint32 *optFromFactoryID=NULL)MessageTransceiverThread
GetNextReplyFromInternalThread(MessageRef &ref, uint64 wakeupTime=0)Thread [virtual]
GetOwnerSocketSet(uint32 socketSet)Thread [inline]
GetOwnerSocketSet(uint32 socketSet) constThread
GetOwnerWakeupSocket()Thread
InternalThreadEntry()MessageTransceiverThread [protected, virtual]
IsCallerInternalThread() constThread
IsInternalThreadRunning() constThread [inline]
LockAndReturnMessageQueue()Thread
LockAndReturnReplyQueue()Thread
LockSignalling()Thread [inline, protected]
MessageReceivedFromOwner(const MessageRef &msgRef, uint32 numLeft)Thread [protected, virtual]
MessageTransceiverThread()MessageTransceiverThread
NUM_SOCKET_SETS enum valueThread
PutAcceptFactory(uint16 port, const ThreadWorkerSessionFactoryRef &optFactoryRef, const ip_address &optInterfaceIP=invalidIP)MessageTransceiverThread [virtual]
PutAcceptFactory(uint16 port)MessageTransceiverThread [inline]
RemoveAcceptFactory(uint16 port, const ip_address &optInterfaceIP=invalidIP)MessageTransceiverThread [virtual]
RemoveSessions(const char *optDistPath=NULL)MessageTransceiverThread
RequestOutputQueuesDrainedNotification(const MessageRef &notificationMsg, const char *optDistPath=NULL, DrainTag *optDrainTag=NULL)MessageTransceiverThread
Reset()MessageTransceiverThread [virtual]
SendMessageToInternalThread(const MessageRef &msg)Thread [virtual]
SendMessageToOwner(const MessageRef &replyRef)Thread [protected]
SendMessageToSessions(const MessageRef &msgRef, const char *optDistPath=NULL)MessageTransceiverThread [virtual]
SetDefaultDistributionPath(const String &distPath)MessageTransceiverThread
SetNewInputPolicy(const PolicyRef &pref, const char *optDistPath=NULL)MessageTransceiverThread
SetNewOutputPolicy(const PolicyRef &pref, const char *optDistPath=NULL)MessageTransceiverThread
SetOutgoingMessageEncoding(int32 encoding, const char *optDistPath=NULL)MessageTransceiverThread
ShutdownInternalThread(bool waitForThread=true)Thread [virtual]
SignalInternalThread()Thread [protected, virtual]
SignalOwner()Thread [protected, virtual]
SOCKET_SET_EXCEPTION enum valueThread
SOCKET_SET_READ enum valueThread
SOCKET_SET_WRITE enum valueThread
StartInternalThread()MessageTransceiverThread [virtual]
Thread()Thread
ThreadSupervisorSession classMessageTransceiverThread [friend]
UnlockMessageQueue()Thread
UnlockReplyQueue()Thread
UnlockSignalling()Thread [inline, protected]
WaitForInternalThreadToExit()Thread
WaitForNextMessageFromOwner(MessageRef &ref, uint64 wakeupTime=MUSCLE_TIME_NEVER)Thread [protected, virtual]
~MessageTransceiverThread()MessageTransceiverThread [virtual]
~Thread()Thread [virtual]


Generated on Thu Jun 5 17:48:13 2008 for MUSCLE by  doxygen 1.5.1