|
AcsBulkdata::BulkDataDistributer − |
|
#include <bulkDataDistributer.h> |
|
Public Member Functions |
|
BulkDataDistributer () |
|
virtual ~BulkDataDistributer () |
|
virtual void multiConnect (bulkdata::BulkDataReceiverConfig *recvConfig_p, const char *fepsConfig, const ACE_CString &receiverName) |
|
virtual void multiDisconnect (const ACE_CString &receiverName) |
|
virtual BulkDataReceiver< TReceiverCallback > * getReceiver () |
|
virtual Sender_Map * getSenderMap () |
|
virtual bool isRecvConnected (const ACE_CString &receiverName) |
|
virtual bool isSenderConnected (const ACE_CString &receiverName) |
|
virtual bool isReceiverConnected (const ACE_CString &receiverName) |
|
virtual void distSendStart (ACE_CString &flowName, CORBA::ULong flowNumber) |
|
virtual int distSendDataHsk (ACE_CString &flowName, ACE_Message_Block *frame_p, CORBA::ULong flowNumber) |
|
virtual int distSendData (ACE_CString &flowName, ACE_Message_Block *frame_p, CORBA::ULong flowNumber) |
|
virtual CORBA::Boolean distSendStopTimeout (ACE_CString &flowName, CORBA::ULong flowNumber) |
|
virtual void distSendStop (ACE_CString &flowName, CORBA::ULong flowNumber) |
|
void setTimeout (CORBA::ULong user_timeout) |
|
void setContSvc (maci::ContainerServices *services_p) |
|
void subscribeNotification (ACS::CBvoid_ptr notifCb) |
|
void notifySender (const ACSErr::Completion &comp) |
|
bulkdata::Connection getSenderConnectionState () |
|
Private Types |
|
enum Flow_Status { FLOW_AVAILABLE, FLOW_NOT_AVAILABLE } |
|
typedef std::pair< RecvData, AcsBulkdata::BulkDataSender< TSenderCallback > * > Sender_Map_Pair |
|
typedef ACE_Hash_Map_Manager< ACE_CString, Sender_Map_Pair, ACE_Null_Mutex > Sender_Map |
|
typedef ACE_Hash_Map_Entry< ACE_CString, Sender_Map_Pair > Sender_Map_Entry |
|
typedef ACE_Hash_Map_Iterator< ACE_CString, Sender_Map_Pair,ACE_Null_Mutex > Sender_Map_Iterator |
|
typedef ACE_Hash_Map_Manager< CORBA::ULong, Flow_Status, ACE_Null_Mutex > Flows_Status_Map |
|
typedef ACE_Hash_Map_Entry< CORBA::ULong, Flow_Status > Flows_Status_Map_Entry |
|
typedef ACE_Hash_Map_Iterator< CORBA::ULong, Flow_Status, ACE_Null_Mutex > Flows_Status_Map_Iterator |
|
typedef ACE_Hash_Map_Manager< ACE_CString, CORBA::ULong, ACE_Null_Mutex > Recv_Status_Map |
|
typedef ACE_Hash_Map_Entry< ACE_CString, CORBA::ULong > Recv_Status_Map_Entry |
|
typedef ACE_Hash_Map_Iterator< ACE_CString, CORBA::ULong, ACE_Null_Mutex > Recv_Status_Map_Iterator |
|
Private Member Functions |
|
CORBA::Boolean getFlowReceiverStatus (const ACE_CString &receiverName, CORBA::ULong flowNumber) |
|
CORBA::Boolean isFlowReceiverAvailable (const ACE_CString &receiverName, CORBA::ULong flowNumber) |
|
Private Attributes |
|
BulkDataSender< TSenderCallback > * sender_p |
|
BulkDataReceiver< TReceiverCallback > receiver_m |
|
Sender_Map senderMap_m |
|
Recv_Status_Map recvStatusMap_m |
|
Flows_Status_Map flowsStatusMap_m |
|
CORBA::ULong timeout_m |
|
CORBA::ULong numberOfFlows |
|
CORBA::ULong offset |
|
maci::ContainerServices * contSvc_p |
|
BulkDataDistributerNotifCb< TReceiverCallback, TSenderCallback > * distributerNotifCb_p |
|
ACS::CBvoid_ptr locNotifCb_p |
|
template<class TReceiverCallback, class TSenderCallback> class AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback > |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Manager<CORBA::ULong, Flow_Status, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Entry<CORBA::ULong, Flow_Status> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map_Entry [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Iterator<CORBA::ULong, Flow_Status, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map_Iterator [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Manager<ACE_CString, CORBA::ULong, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Entry<ACE_CString, CORBA::ULong> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map_Entry [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Iterator<ACE_CString, CORBA::ULong, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map_Iterator [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Manager<ACE_CString, Sender_Map_Pair, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Entry<ACE_CString, Sender_Map_Pair > AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Entry [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef ACE_Hash_Map_Iterator<ACE_CString, Sender_Map_Pair ,ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Iterator [private] |
|
template<class TReceiverCallback, class TSenderCallback> typedef std::pair< RecvData , AcsBulkdata::BulkDataSender<TSenderCallback> *> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Pair [private] |
|
template<class TReceiverCallback, class TSenderCallback> enum AcsBulkdata::BulkDataDistributer::Flow_Status [private] |
|
Enumerator: |
|
FLOW_AVAILABLE |
|
FLOW_NOT_AVAILABLE |
|
template<class TReceiverCallback, class TSenderCallback> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::BulkDataDistributer () Constructor |
|
template<class TReceiverCallback, class TSenderCallback> virtual AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::~BulkDataDistributer () [virtual] Destructor |
|
template<class TReceiverCallback, class TSenderCallback> virtual int AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendData (ACE_CString & flowName, ACE_Message_Block * frame_p, CORBA::ULong flowNumber) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual int AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendDataHsk (ACE_CString & flowName, ACE_Message_Block * frame_p, CORBA::ULong flowNumber) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStart (ACE_CString & flowName, CORBA::ULong flowNumber) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStop (ACE_CString & flowName, CORBA::ULong flowNumber) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStopTimeout (ACE_CString & flowName, CORBA::ULong flowNumber) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getFlowReceiverStatus (const ACE_CString & receiverName, CORBA::ULong flowNumber) [private] |
|
template<class TReceiverCallback, class TSenderCallback> virtual BulkDataReceiver<TReceiverCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getReceiver () [inline, virtual] |
|
Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getSenderConnectionState(). |
|
template<class TReceiverCallback, class TSenderCallback> bulkdata::Connection AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getSenderConnectionState () [inline] |
|
template<class TReceiverCallback, class TSenderCallback> virtual Sender_Map* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getSenderMap () [inline, virtual] |
|
template<class TReceiverCallback, class TSenderCallback> CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isFlowReceiverAvailable (const ACE_CString & receiverName, CORBA::ULong flowNumber) [private] |
|
template<class TReceiverCallback, class TSenderCallback> virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isReceiverConnected (const ACE_CString & receiverName) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isRecvConnected (const ACE_CString & receiverName) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isSenderConnected (const ACE_CString & receiverName) [virtual] |
|
template<class TReceiverCallback, class TSenderCallback> virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::multiConnect (bulkdata::BulkDataReceiverConfig * recvConfig_p, const char * fepsConfig, const ACE_CString & receiverName) [virtual] Exceptions: |
|
ACSBulkDataError::AVConnectErrorExImpl |
|
template<class TReceiverCallback, class TSenderCallback> virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::multiDisconnect (const ACE_CString & receiverName) [virtual] Exceptions: |
|
ACSBulkDataError::AVDisconnectErrorExImpl |
|
template<class TReceiverCallback, class TSenderCallback> void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::notifySender (const ACSErr::Completion & comp) Exceptions: |
|
ACSBulkDataError::AVNotificationMechanismErrorExImpl |
|
template<class TReceiverCallback, class TSenderCallback> void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::setContSvc (maci::ContainerServices * services_p) [inline] |
|
template<class TReceiverCallback, class TSenderCallback> void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::setTimeout (CORBA::ULong user_timeout) [inline] |
|
template<class TReceiverCallback, class TSenderCallback> void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::subscribeNotification (ACS::CBvoid_ptr notifCb) Exceptions: |
|
ACSBulkDataError::AVNotificationMechanismErrorExImpl |
|
template<class TReceiverCallback, class TSenderCallback> maci::ContainerServices* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::contSvc_p [private] |
|
Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::setContSvc(). |
|
template<class TReceiverCallback, class TSenderCallback> BulkDataDistributerNotifCb<TReceiverCallback, TSenderCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distributerNotifCb_p [private] |
|
template<class TReceiverCallback, class TSenderCallback> Flows_Status_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::flowsStatusMap_m [private] |
|
template<class TReceiverCallback, class TSenderCallback> ACS::CBvoid_ptr AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::locNotifCb_p [private] |
|
template<class TReceiverCallback, class TSenderCallback> CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::numberOfFlows [private] |
|
template<class TReceiverCallback, class TSenderCallback> CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::offset [private] |
|
template<class TReceiverCallback, class TSenderCallback> BulkDataReceiver<TReceiverCallback> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::receiver_m [private] |
|
Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getReceiver(). |
|
template<class TReceiverCallback, class TSenderCallback> Recv_Status_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::recvStatusMap_m [private] |
|
template<class TReceiverCallback, class TSenderCallback> BulkDataSender<TSenderCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::sender_p [private] |
|
template<class TReceiverCallback, class TSenderCallback> Sender_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::senderMap_m [private] |
|
Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getSenderMap(). |
|
template<class TReceiverCallback, class TSenderCallback> CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::timeout_m [private] |
|
Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::setTimeout(). |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |