|
BulkDataDistributerCb − |
|
#include <bulkDataDistributerCb.h> |
|
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 |
|
enum BulkDataDistributerCb::Cb_State |
|
Enumerator: |
|
CB_UNS |
|
CB_SEND_PARAM |
|
CB_SEND_DATA |
|
enum BulkDataDistributerCb::Cb_SubState |
|
Enumerator: |
|
CB_SUB_UNS |
|
CB_SUB_INIT |
|
BulkDataDistributerCb::BulkDataDistributerCb () |
|
BulkDataDistributerCb::BulkDataDistributerCb (TAO_StreamCtrl * stream_p) |
|
BulkDataDistributerCb::~BulkDataDistributerCb () |
|
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] |
|
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] |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |