BulkDataDistributerCb Class Reference

#include <bulkDataDistributerCb.h>

Collaboration diagram for BulkDataDistributerCb:

[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
	BulkDataDistributerCb ()
	BulkDataDistributerCb (TAO_StreamCtrl *stream_p)
	~BulkDataDistributerCb ()
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	setSleepTime (ACE_Time_Value locWaitPeriod)
virtual void	setSafeTimeout (CORBA::ULong locLoop)
virtual int	cbFwdStart (ACE_Message_Block *userParam_p=0)
virtual int	cbFwdReceive (ACE_Message_Block *frame_p)
virtual int	cbFwdStop ()
virtual int	cbFwdUserStop ()
virtual int	cbHandshake (ACE_Message_Block *frame_p)
virtual void	setDistributerImpl (BulkDataDistributerImpl< BulkDataDistributerCb > *distr_p)
virtual CORBA::Boolean	isTimeout ()
virtual CORBA::Boolean	isWorking ()
Protected Attributes
ACE_CString	flowname_m
CORBA::ULong	flowNumber_m
Private Attributes
BulkDataDistributerImpl< BulkDataDistributerCb > *	distr_m
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
CORBA::Boolean	timeout_m
CORBA::Boolean	working_m

---

Member Enumeration Documentation

enum BulkDataDistributerCb::Cb_State

Enumeration values: CB_UNS  CB_SEND_PARAM  CB_SEND_DATA

enum BulkDataDistributerCb::Cb_SubState

Enumeration values: CB_SUB_UNS  CB_SUB_INIT

---

Constructor & Destructor Documentation

BulkDataDistributerCb::BulkDataDistributerCb (   )

BulkDataDistributerCb::BulkDataDistributerCb (  TAO_StreamCtrl *  stream_p  )

BulkDataDistributerCb::~BulkDataDistributerCb (   )

---

Member Function Documentation

virtual int BulkDataDistributerCb::cbFwdReceive (  ACE_Message_Block *  frame_p  )  [virtual]

virtual int BulkDataDistributerCb::cbFwdStart (  ACE_Message_Block *  userParam_p = 0  )  [virtual]

virtual int BulkDataDistributerCb::cbFwdStop (   )  [virtual]

virtual int BulkDataDistributerCb::cbFwdUserStop (   )  [virtual]

virtual int BulkDataDistributerCb::cbHandshake (  ACE_Message_Block *  frame_p  )  [virtual]

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

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

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

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

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

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

virtual void BulkDataDistributerCb::setDistributerImpl (  BulkDataDistributerImpl< BulkDataDistributerCb > *  distr_p  )  [virtual]

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

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

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

---

Member Data Documentation

CORBA::Long BulkDataDistributerCb::count_m [private]

CORBA::Long BulkDataDistributerCb::dim_m [private]

BulkDataDistributerImpl<BulkDataDistributerCb>* BulkDataDistributerCb::distr_m [private]

ACE_CString BulkDataDistributerCb::flowname_m [protected]

CORBA::ULong BulkDataDistributerCb::flowNumber_m [protected]

CORBA::Long BulkDataDistributerCb::frameCount_m [private]

CORBA::ULong BulkDataDistributerCb::loop_m [private]

Cb_State BulkDataDistributerCb::state_m [private]

Cb_SubState BulkDataDistributerCb::substate_m [private]

CORBA::Boolean BulkDataDistributerCb::timeout_m [private]

ACE_Time_Value BulkDataDistributerCb::waitPeriod_m [private]

CORBA::Boolean BulkDataDistributerCb::working_m [private]

---

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

• bulkDataDistributerCb.h

---