CommunicationManagerImpl Class Reference

#include <H:/WOSH/win32_vc2010/src/bundles/CommunicationManager/CommunicationManagerImpl.h>

List of all members.

Public Member Functions
	CommunicationManagerImpl (BundleGeneric &bundle)
	Default constructor. Init vars.
virtual	~CommunicationManagerImpl ()
	Deconstructor. If thread is still running, it will be stopped.
Setters
void	setListener (ICommunicationManagerListener *list)
void	setFlowTimeOut (long seconds)
void	setFlowRetryTime (long seconds)
void	setFlowRetryCount (long times)
Getters
long	getFlowTimeOut () const
long	getFlowRetryTime () const
long	getFlowRetryCount () const
tStrCommunicatorMap &	getCommunicators ()
tStrInterpreterMap &	getInterpreters ()
tLongNotificationFlowMap &	getMessages ()
tLongNotificationFlowMap &	getMessagesArchived ()
Protected Member Functions
Internal methods
bool	processNotification_ (NotificationFlow *notification)
virtual void	runThread ()
Protected Attributes
tStrCommunicatorMap	comms
	communicators
tStrInterpreterMap	transl
	interpreters
tLongNotificationFlowMap	messages
	processing messages cache [flowid, notf*]
tLongNotificationFlowMap	messagesArchived
	archived messages cache [flowid, notf*]
long	messageArchiveSize
	size of archived messages cache
long	flowTimeout
	timeout of notification-flow processing
long	flowRetryTime
	minimum number of seconds between each flow-processing retry [0=disabled]
long	flowRetryCount
	maximum number of retries of flow-processing [0=disabled]
MessageQueue	msgQueue
	messages' queue
ICommunicationManagerListener *	listener
	callbacks

---

Detailed Description

Version:

Id:

CommunicationManagerImpl.h 3775 2011-01-01 16:38:17Z alex

Author:

Alessandro Polo

Definition at line 60 of file CommunicationManagerImpl.h.

---

Constructor & Destructor Documentation

CommunicationManagerImpl::CommunicationManagerImpl

(

BundleGeneric &

bundle )

Default constructor. Init vars.

Parameters:

bundle

[in] the parent bundle, see BundleGenericWorker interface

Definition at line 52 of file CommunicationManagerImpl.cpp.

References flowRetryCount, flowRetryTime, flowTimeout, listener, and messageArchiveSize.

CommunicationManagerImpl::~CommunicationManagerImpl

(

)

[virtual]

Deconstructor. If thread is still running, it will be stopped.

Definition at line 64 of file CommunicationManagerImpl.cpp.

References comms, wosh::BundleGenericWorker::Log, wosh::LOG_VERBOSE, messages, messagesArchived, and transl.

---

Member Function Documentation

bool CommunicationManagerImpl::processNotification_

(

NotificationFlow *

notification )

[protected]

Todo:

reply to sender that it is (èartially) archived

Definition at line 124 of file CommunicationManagerImpl.cpp.

References flowRetryCount, flowRetryTime, flowTimeout, wosh::BundleGenericWorker::Log, wosh::LOG_CRITICAL, wosh::LOG_VERBOSE, and wosh::LOG_WARNING.

Referenced by runThread().

void CommunicationManagerImpl::runThread

(

)

[protected, virtual]

See also:

running

Definition at line 92 of file CommunicationManagerImpl.cpp.

References wosh::BundleGenericWorker::Log, wosh::LOG_VERBOSE, messages, and processNotification_().

---

Member Data Documentation

tStrCommunicatorMap CommunicationManagerImpl::comms [protected]

communicators

Definition at line 146 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().

long CommunicationManagerImpl::flowRetryCount [protected]

maximum number of retries of flow-processing [0=disabled]

Definition at line 155 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

long CommunicationManagerImpl::flowRetryTime [protected]

minimum number of seconds between each flow-processing retry [0=disabled]

Definition at line 154 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

long CommunicationManagerImpl::flowTimeout [protected]

timeout of notification-flow processing

Definition at line 153 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl(), and processNotification_().

ICommunicationManagerListener* CommunicationManagerImpl::listener [protected]

callbacks

Definition at line 159 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl().

long CommunicationManagerImpl::messageArchiveSize [protected]

size of archived messages cache

Definition at line 151 of file CommunicationManagerImpl.h.

Referenced by CommunicationManagerImpl().

tLongNotificationFlowMap CommunicationManagerImpl::messages [protected]

processing messages cache [flowid, notf*]

Definition at line 149 of file CommunicationManagerImpl.h.

Referenced by runThread(), and ~CommunicationManagerImpl().

tLongNotificationFlowMap CommunicationManagerImpl::messagesArchived [protected]

archived messages cache [flowid, notf*]

Definition at line 150 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().

MessageQueue CommunicationManagerImpl::msgQueue [protected]

messages' queue

Definition at line 157 of file CommunicationManagerImpl.h.

tStrInterpreterMap CommunicationManagerImpl::transl [protected]

interpreters

Definition at line 147 of file CommunicationManagerImpl.h.

Referenced by ~CommunicationManagerImpl().

---

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

• CommunicationManagerImpl.h
• CommunicationManagerImpl.cpp
• CommunicationManagerSelector.cpp
• CommunicationManagerSelectorAIga.cpp