AcsBulkdata::BulkDataFlowConsumer

AcsBulkdata::BulkDataFlowConsumer −

#include <bulkDataFlowConsumer.h>

Public Member Functions

BulkDataFlowConsumer (const char *flowname, AVStreams::protocolSpec prot, const char *format)

virtual ~BulkDataFlowConsumer ()

virtual int get_callback (const char *flowname, TAO_AV_Callback *&callback)

virtual int set_protocol_object (const char *flowname, TAO_AV_Protocol_Object *object)

virtual TAO_AV_Protocol_Object * getProtocolObject ()

virtual TReceiverCallback * getBulkDataCallback ()

virtual void set_flow_handler (const char *flowname, TAO_AV_Flow_Handler *handler)

virtual TAO_AV_Flow_Handler * getFlowHandler ()

virtual void setCbTimeout (ACE_Time_Value cbTimeout)

Private Attributes

TReceiverCallback * cb_p

ACE_CString flowname_m

TAO_AV_Protocol_Object * protObj_p

TAO_AV_Flow_Handler * handler_p

ACE_Time_Value cbTimeout_m

template<class TReceiverCallback> class AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >

template<class TReceiverCallback > AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::BulkDataFlowConsumer (const char * flowname, AVStreams::protocolSpec prot, const char * format) Constructor

Parameters:

flowname
AVStreams::protocolSpec
format

template<class TReceiverCallback > virtual AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::~BulkDataFlowConsumer () [virtual] Destructor

template<class TReceiverCallback > virtual int AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::get_callback (const char * flowname, TAO_AV_Callback *& callback) [virtual] Creates the application callback and return its handle to AVStreams for further application callbacks. This callback will be used to store data e.g. in the Archive.

Parameters:

flowname
TAO_AV_Callback

Returns:

int

template<class TReceiverCallback > virtual TReceiverCallback* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getBulkDataCallback () [virtual]

template<class TReceiverCallback > virtual TAO_AV_Flow_Handler* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getFlowHandler () [virtual]

template<class TReceiverCallback > virtual TAO_AV_Protocol_Object* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::getProtocolObject () [virtual] Get the protocol object

Returns:

TAO_AV_Protocol_Object *

template<class TReceiverCallback > virtual void AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::set_flow_handler (const char * flowname, TAO_AV_Flow_Handler * handler) [virtual]

template<class TReceiverCallback > virtual int AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::set_protocol_object (const char * flowname, TAO_AV_Protocol_Object * object) [virtual] Set the protocol object

Parameters:

flowname
TAO_AV_Protocol_Object

Returns:

int

template<class TReceiverCallback > virtual void AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::setCbTimeout (ACE_Time_Value cbTimeout) [inline, virtual]

References AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::cbTimeout_m.

template<class TReceiverCallback > TReceiverCallback* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::cb_p [private]

template<class TReceiverCallback > ACE_Time_Value AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::cbTimeout_m [private]

Referenced by AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::setCbTimeout().

template<class TReceiverCallback > ACE_CString AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::flowname_m [private]

template<class TReceiverCallback > TAO_AV_Flow_Handler* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::handler_p [private]

template<class TReceiverCallback > TAO_AV_Protocol_Object* AcsBulkdata::BulkDataFlowConsumer< TReceiverCallback >::protObj_p [private]

Generated automatically by Doxygen for ACS-2016.6 C++ API from the source code.