|
AcsBulkdata::BulkDataReceiver − |
|
#include <bulkDataReceiver.h> |
|
Classes |
|
struct FepsCfgB |
|
Public Member Functions |
|
BulkDataReceiver () |
|
virtual ~BulkDataReceiver () |
|
void initialize () |
|
void createSingleFlow () |
|
void createMultipleFlows (const char *fepsConfig) |
|
bulkdata::BulkDataReceiverConfig * getReceiverConfig () |
|
void getFlowCallback (ACE_CString &flowName, TReceiverCallback *&cb_p) |
|
void getFlowCallback (CORBA::ULong flowNumber, TReceiverCallback *&cb_p) |
|
void closeReceiver () |
|
std::vector< std::string > getFlowNames () |
|
void setReceiverName (ACE_CString recvName) |
|
void subscribeNotification (ACS::CBvoid_ptr notifCb) |
|
void fwdData2UserCB (CORBA::Boolean enable) |
|
void notifySender (const ACSErr::Completion &comp) |
|
void addHandle (ACE_CString flowName, ACE_HANDLE handle) |
|
void setCbTimeout (const char *cbTimeout) |
|
bulkdata::Connection checkFlowCallbacks () |
|
bulkdata::Connection getSenderConnectionState () |
|
Private Types |
|
typedef ACE_Hash_Map_Manager< ACE_CString, BulkDataFlowConsumer< TReceiverCallback > *, ACE_Null_Mutex > FepObjects |
|
typedef ACE_Hash_Map_Iterator< ACE_CString, BulkDataFlowConsumer< TReceiverCallback > *, ACE_Null_Mutex > FepObjectsIterator |
|
typedef ACE_Hash_Map_Manager< ACE_CString, ACE_HANDLE, ACE_Null_Mutex > HandleMap |
|
typedef ACE_Hash_Map_Iterator< ACE_CString, ACE_HANDLE, ACE_Null_Mutex > HandleMapIterator |
|
Private Member Functions |
|
void initPartB () |
|
AVStreams::StreamEndPoint_B_ptr createSepB () |
|
AVStreams::FlowConsumer_ptr createFepConsumerB (ACE_CString &flowName, AVStreams::protocolSpec protocols, ACE_CString &format) |
|
void addFepToSep (AVStreams::StreamEndPoint_B_ptr locSepB_p, AVStreams::FlowConsumer_ptr locFepB_p) |
|
AVStreams::StreamEndPoint_B_ptr getStreamEndPointB () |
|
AVStreams::flowSpec * getFepsConfig () |
|
void deleteFepsB () |
|
void deleteSepB () |
|
void deleteAcceptor () |
|
void deleteHandler () |
|
void closeSocket () |
|
const char * createFlowSpec (ACE_CString &flowName, ACE_CString &fepProtocol) |
|
Private Attributes |
|
FepObjects fepMap_m |
|
HandleMap handleMap_m |
|
TAO_AV_Endpoint_Reactive_Strategy_B< TAO_StreamEndPoint_B, TAO_VDev, AV_Null_MediaCtrl > reactiveStrategy_m |
|
AVStreams::StreamEndPoint_B_var sepB_p |
|
AVStreams::flowSpec fepsData |
|
bulkdata::BulkDataReceiverConfig * recvConfig_p |
|
TAO_StreamEndPoint_B * sepRefCount_p |
|
CORBA::Boolean closeReceiverFlag |
|
ACS::CBvoid_ptr locNotifCb_p |
|
ACE_Time_Value cbTimeout_m |
|
template<class TReceiverCallback> class AcsBulkdata::BulkDataReceiver< TReceiverCallback > |
|
template<class TReceiverCallback> typedef ACE_Hash_Map_Manager<ACE_CString, BulkDataFlowConsumer<TReceiverCallback> *, ACE_Null_Mutex> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::FepObjects [private] |
|
template<class TReceiverCallback> typedef ACE_Hash_Map_Iterator<ACE_CString, BulkDataFlowConsumer<TReceiverCallback> *, ACE_Null_Mutex> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::FepObjectsIterator [private] |
|
template<class TReceiverCallback> typedef ACE_Hash_Map_Manager<ACE_CString, ACE_HANDLE, ACE_Null_Mutex> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::HandleMap [private] |
|
template<class TReceiverCallback> typedef ACE_Hash_Map_Iterator<ACE_CString, ACE_HANDLE, ACE_Null_Mutex> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::HandleMapIterator [private] |
|
template<class TReceiverCallback> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::BulkDataReceiver () Constructor |
|
template<class TReceiverCallback> virtual AcsBulkdata::BulkDataReceiver< TReceiverCallback >::~BulkDataReceiver () [virtual] Destructor |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::addFepToSep (AVStreams::StreamEndPoint_B_ptr locSepB_p, AVStreams::FlowConsumer_ptr locFepB_p) [private] Add the Flow End Point to the Stream End Point |
|
Parameters: |
|
AVStreams::StreamEndPoint_B_ptr |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::addHandle (ACE_CString flowName, ACE_HANDLE handle) [inline] |
|
template<class TReceiverCallback> bulkdata::Connection AcsBulkdata::BulkDataReceiver< TReceiverCallback >::checkFlowCallbacks () Exceptions: |
|
ACSBulkDataError::AVFlowEndpointErrorExImpl |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::closeReceiver () Close the Receiver |
|
Exceptions: |
|
ACSBulkDataError::AVCloseReceiverErrorExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::closeSocket () [private] |
|
template<class TReceiverCallback> AVStreams::FlowConsumer_ptr AcsBulkdata::BulkDataReceiver< TReceiverCallback >::createFepConsumerB (ACE_CString & flowName, AVStreams::protocolSpec protocols, ACE_CString & format) [private] Create the Consumer Flow End Point |
|
Parameters: |
|
flowname |
|
Returns: |
|
AVStreams::FlowConsumer_ptr |
|
template<class TReceiverCallback> const char* AcsBulkdata::BulkDataReceiver< TReceiverCallback >::createFlowSpec (ACE_CString & flowName, ACE_CString & fepProtocol) [private] Create the Flow Specifications |
|
Parameters: |
|
flowname |
|
Returns: |
|
const char * |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::createMultipleFlows (const char * fepsConfig) Create multiple flows (user defined) |
|
Parameters: |
|
fepsConfig |
|
Exceptions: |
|
ACSBulkDataError::AVStreamEndpointErrorExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> AVStreams::StreamEndPoint_B_ptr AcsBulkdata::BulkDataReceiver< TReceiverCallback >::createSepB () [private] Create the part B Stream End Point |
|
Returns: |
|
AVStreams::StreamEndPoint_B_ptr |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::createSingleFlow () Create single flow (TCP, A/V default port) |
|
Exceptions: |
|
ACSBulkDataError::AVStreamEndpointErrorExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::deleteAcceptor () [private] |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::deleteFepsB () [private] Delete allocated feps |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::deleteHandler () [private] |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::deleteSepB () [private] Delete allocated sep |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::fwdData2UserCB (CORBA::Boolean enable) Enable or disable that data are sent to the user’s CB. By default this is enable. This operation has to be use with caution!!! |
|
Parameters: |
|
enable true -> data will be sent to the user’s CB, false -> data will *not* be sent to the user’s CB, |
|
Returns: |
|
void |
|
template<class TReceiverCallback> AVStreams::flowSpec* AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getFepsConfig () [private] Accessor for the part B configuration |
|
Returns: |
|
AVStreams::StreamEndPoint_B_ptr |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getFlowCallback (ACE_CString & flowName, TReceiverCallback *& cb_p) Accessor to allocated receiver callback |
|
Parameters: |
|
ACE_CString |
|
Exceptions: |
|
ACSBulkDataError::AVFlowEndpointErrorExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getFlowCallback (CORBA::ULong flowNumber, TReceiverCallback *& cb_p) Accessor to allocated receiver callback |
|
Parameters: |
|
CORBA::ULong |
|
Exceptions: |
|
ACSBulkDataError::AVInvalidFlowNumberExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> std::vector<std::string> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getFlowNames () Get the names of the connected flows |
|
Returns: |
|
vector<string> |
|
template<class TReceiverCallback> bulkdata::BulkDataReceiverConfig* AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getReceiverConfig () Get the receiver flow and sep configuration |
|
Exceptions: |
|
ACSBulkDataError::AVReceiverConfigErrorExImpl |
|
Returns: |
|
bulkdata::BulkDataReceiverConfig * |
|
template<class TReceiverCallback> bulkdata::Connection AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getSenderConnectionState () [inline] |
|
template<class TReceiverCallback> AVStreams::StreamEndPoint_B_ptr AcsBulkdata::BulkDataReceiver< TReceiverCallback >::getStreamEndPointB () [private] Accessor for the part B Stream End Point |
|
Returns: |
|
AVStreams::StreamEndPoint_B_ptr |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::initialize () Initialize the A/V |
|
Exceptions: |
|
ACSBulkDataError::AVInitErrorExImpl |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::initPartB () [private] Initialize the A/V part B |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::notifySender (const ACSErr::Completion & comp) |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::setCbTimeout (const char * cbTimeout) |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::setReceiverName (ACE_CString recvName) Set receiver name in receiver callback |
|
Parameters: |
|
ACE_CString |
|
Returns: |
|
void |
|
template<class TReceiverCallback> void AcsBulkdata::BulkDataReceiver< TReceiverCallback >::subscribeNotification (ACS::CBvoid_ptr notifCb) Subscribe to the Notification Mechanism |
|
Exceptions: |
|
ACSBulkDataError::AVNotificationMechanismErrorExImpl |
|
Parameters: |
|
ACS::CBvoid_ptr |
|
Returns: |
|
void |
|
template<class TReceiverCallback> ACE_Time_Value AcsBulkdata::BulkDataReceiver< TReceiverCallback >::cbTimeout_m [private] |
|
template<class TReceiverCallback> CORBA::Boolean AcsBulkdata::BulkDataReceiver< TReceiverCallback >::closeReceiverFlag [private] |
|
template<class TReceiverCallback> FepObjects AcsBulkdata::BulkDataReceiver< TReceiverCallback >::fepMap_m [private] |
|
template<class TReceiverCallback> AVStreams::flowSpec AcsBulkdata::BulkDataReceiver< TReceiverCallback >::fepsData [private] |
|
template<class TReceiverCallback> HandleMap AcsBulkdata::BulkDataReceiver< TReceiverCallback >::handleMap_m [private] |
|
Referenced by AcsBulkdata::BulkDataReceiver< TCallback >::addHandle(). |
|
template<class TReceiverCallback> ACS::CBvoid_ptr AcsBulkdata::BulkDataReceiver< TReceiverCallback >::locNotifCb_p [private] |
|
template<class TReceiverCallback> TAO_AV_Endpoint_Reactive_Strategy_B<TAO_StreamEndPoint_B,TAO_VDev,AV_Null_MediaCtrl> AcsBulkdata::BulkDataReceiver< TReceiverCallback >::reactiveStrategy_m [private] The endpoint strategy used by the receiver |
|
template<class TReceiverCallback> bulkdata::BulkDataReceiverConfig* AcsBulkdata::BulkDataReceiver< TReceiverCallback >::recvConfig_p [private] |
|
Referenced by AcsBulkdata::BulkDataReceiver< TCallback >::getSenderConnectionState(). |
|
template<class TReceiverCallback> AVStreams::StreamEndPoint_B_var AcsBulkdata::BulkDataReceiver< TReceiverCallback >::sepB_p [private] |
|
template<class TReceiverCallback> TAO_StreamEndPoint_B* AcsBulkdata::BulkDataReceiver< TReceiverCallback >::sepRefCount_p [private] |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |