BulkDataCallback Class Reference

#include <bulkDataCallback.h>

Inheritance diagram for BulkDataCallback:

[legend]List of all members.

Public Types
enum	Cb_State { CB_UNS, CB_SEND_PARAM, CB_SEND_DATA }
enum	Cb_SubState { CB_SUB_UNS, CB_SUB_INIT }
Public Member Functions
	BulkDataCallback ()
virtual	~BulkDataCallback ()
virtual int	handle_start (void)
virtual int	handle_stop (void)
virtual int	handle_destroy (void)
virtual int	receive_frame (ACE_Message_Block *frame, TAO_AV_frame_info *frame_info, const ACE_Addr &)
virtual void	setFlowname (const char *)
virtual void	setReceiverName (ACE_CString recvName)
virtual void	setSleepTime (ACE_Time_Value locWaitPeriod)
virtual void	setSafeTimeout (CORBA::ULong locLoop)
virtual CORBA::Boolean	isTimeout ()
virtual CORBA::Boolean	isWorking ()
virtual CORBA::Boolean	isError ()
virtual CompletionImpl *	getErrorCompletion ()
virtual void	setFlowTimeout (CORBA::ULong timeout)
virtual void	closePeer ()
template<class TCallback> void	setReceiver (AcsBulkdata::BulkDataReceiver< TCallback > *recv)
virtual int	cbStart (ACE_Message_Block *userParam_p=0)=0
virtual int	cbReceive (ACE_Message_Block *frame_p)=0
virtual int	cbStop ()=0
Protected Attributes
ACE_CString	flowname_m
CORBA::ULong	flowNumber_m
ACE_CString	recvName_m
Private Member Functions
void	cleanRecvBuffer ()
void	checkFlowTimeout ()
Private Attributes
ACE_Time_Value	waitPeriod_m
CORBA::ULong	loop_m
Cb_State	state_m
Cb_SubState	substate_m
CORBA::Long	dim_m
CORBA::Long	count_m
CORBA::Long	frameCount_m
ACE_Message_Block *	bufParam_p
CORBA::Boolean	timeout_m
CORBA::Boolean	working_m
CORBA::Boolean	error_m
ACSBulkDataStatus::AVCbErrorCompletion *	errComp_p
CORBA::ULong	flowTimeout_m
ACE_Time_Value	startTime_m

---

Member Enumeration Documentation

enum BulkDataCallback::Cb_State

Enumeration values: CB_UNS  CB_SEND_PARAM  CB_SEND_DATA

enum BulkDataCallback::Cb_SubState

Enumeration values: CB_SUB_UNS  CB_SUB_INIT

---

Constructor & Destructor Documentation

BulkDataCallback::BulkDataCallback (   )

virtual BulkDataCallback::~BulkDataCallback (   )  [virtual]

---

Member Function Documentation

virtual int BulkDataCallback::cbReceive (  ACE_Message_Block *  frame_p  )  [pure virtual]

Implemented in BulkDataReceiver1CbNotif, BulkDataReceiver1PerfCb, BulkDataReceiverCbDistr1, BulkDataReceiverCbDistr2, BulkDataReceiverCbEx1, BulkDataReceiverCbEx2, BulkDataReceiverCbEx3, BulkDataReceiverCbNotif, BulkDataReceiverCbThread, and BulkDataSendRecvCb.

virtual int BulkDataCallback::cbStart (  ACE_Message_Block *  userParam_p = 0  )  [pure virtual]

Implemented in BulkDataReceiver1CbNotif, BulkDataReceiver1PerfCb, BulkDataReceiverCbDistr1, BulkDataReceiverCbDistr2, BulkDataReceiverCbEx1, BulkDataReceiverCbEx2, BulkDataReceiverCbEx3, BulkDataReceiverCbNotif, BulkDataReceiverCbThread, and BulkDataSendRecvCb.

virtual int BulkDataCallback::cbStop (   )  [pure virtual]

Implemented in BulkDataReceiver1CbNotif, BulkDataReceiver1PerfCb, BulkDataReceiverCbDistr1, BulkDataReceiverCbDistr2, BulkDataReceiverCbEx1, BulkDataReceiverCbEx2, BulkDataReceiverCbEx3, BulkDataReceiverCbNotif, BulkDataReceiverCbThread, and BulkDataSendRecvCb.

void BulkDataCallback::checkFlowTimeout (   )  [private]

void BulkDataCallback::cleanRecvBuffer (   )  [private]

virtual void BulkDataCallback::closePeer (   )  [virtual]

virtual CompletionImpl* BulkDataCallback::getErrorCompletion (   )  [virtual]

virtual int BulkDataCallback::handle_destroy (  void   )  [virtual]

virtual int BulkDataCallback::handle_start (  void   )  [virtual]

virtual int BulkDataCallback::handle_stop (  void   )  [virtual]

virtual CORBA::Boolean BulkDataCallback::isError (   )  [virtual]

virtual CORBA::Boolean BulkDataCallback::isTimeout (   )  [virtual]

virtual CORBA::Boolean BulkDataCallback::isWorking (   )  [virtual]

virtual int BulkDataCallback::receive_frame (  ACE_Message_Block *  frame, TAO_AV_frame_info *  frame_info, const ACE_Addr &  )  [virtual]

virtual void BulkDataCallback::setFlowname (  const char *   )  [virtual]

virtual void BulkDataCallback::setFlowTimeout (  CORBA::ULong  timeout  )  [virtual]

template<class TCallback> void BulkDataCallback::setReceiver (  AcsBulkdata::BulkDataReceiver< TCallback > *  recv  )  [inline]

virtual void BulkDataCallback::setReceiverName (  ACE_CString  recvName  )  [virtual]

virtual void BulkDataCallback::setSafeTimeout (  CORBA::ULong  locLoop  )  [virtual]

virtual void BulkDataCallback::setSleepTime (  ACE_Time_Value  locWaitPeriod  )  [virtual]

---

Member Data Documentation

ACE_Message_Block* BulkDataCallback::bufParam_p [private]

CORBA::Long BulkDataCallback::count_m [private]

CORBA::Long BulkDataCallback::dim_m [private]

ACSBulkDataStatus::AVCbErrorCompletion* BulkDataCallback::errComp_p [private]

CORBA::Boolean BulkDataCallback::error_m [private]

ACE_CString BulkDataCallback::flowname_m [protected]

CORBA::ULong BulkDataCallback::flowNumber_m [protected]

CORBA::ULong BulkDataCallback::flowTimeout_m [private]

CORBA::Long BulkDataCallback::frameCount_m [private]

CORBA::ULong BulkDataCallback::loop_m [private]

ACE_CString BulkDataCallback::recvName_m [protected]

ACE_Time_Value BulkDataCallback::startTime_m [private]

Cb_State BulkDataCallback::state_m [private]

Cb_SubState BulkDataCallback::substate_m [private]

CORBA::Boolean BulkDataCallback::timeout_m [private]

Reimplemented in BulkDataReceiverCbEx3.

ACE_Time_Value BulkDataCallback::waitPeriod_m [private]

CORBA::Boolean BulkDataCallback::working_m [private]

---

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

• bulkDataCallback.h

---