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. |