BulkDataDistributerCb Class Reference

#include <bulkDataDistributerCb.h>

Collaboration diagram for BulkDataDistributerCb:

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 ()
ACE_HANDLE	getHandle ()
CORBA::Boolean	isFepAlive ()
virtual void	setCbTimeout (ACE_Time_Value cbTimeout)
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
CORBA::Boolean	isFepAlive_m

---

Member Enumeration Documentation

enum BulkDataDistributerCb::Cb_State

Enumerator:

CB_UNS
CB_SEND_PARAM
CB_SEND_DATA

enum BulkDataDistributerCb::Cb_SubState

Enumerator:

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]

ACE_HANDLE BulkDataDistributerCb::getHandle

(

)

virtual int BulkDataDistributerCb::handle_destroy

(

void

)

[virtual]

virtual int BulkDataDistributerCb::handle_start

(

void

)

[virtual]

virtual int BulkDataDistributerCb::handle_stop

(

void

)

[virtual]

CORBA::Boolean BulkDataDistributerCb::isFepAlive

(

)

[inline]

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::setCbTimeout

(

ACE_Time_Value

cbTimeout

)

[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::Boolean BulkDataDistributerCb::isFepAlive_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