|
BulkDataCallback − |
|
#include <bulkDataCallback.h> Inherited by BulkDataReceiver1CbNotif, BulkDataReceiver1PerfCb, BulkDataReceiverCbDistr1, BulkDataReceiverCbDistr2, BulkDataReceiverCbEx1, BulkDataReceiverCbEx2, BulkDataReceiverCbEx3, BulkDataReceiverCbNotif, BulkDataReceiverCbThread, and BulkDataSendRecvCb. |
|
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) |
|
ACE_HANDLE getHandle () |
|
CORBA::Boolean isFepAlive () |
|
virtual void setCbTimeout (ACE_Time_Value cbTimeout) |
|
void fwdData2UserCB (CORBA::Boolean enable) |
|
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 |
|
bool fwdData2UserCB_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 |
|
CORBA::Boolean isFepAlive_m |
|
enum BulkDataCallback::Cb_State |
|
Enumerator: |
|
CB_UNS |
|
CB_SEND_PARAM |
|
CB_SEND_DATA |
|
enum BulkDataCallback::Cb_SubState |
|
Enumerator: |
|
CB_SUB_UNS |
|
CB_SUB_INIT |
|
BulkDataCallback::BulkDataCallback () |
|
virtual BulkDataCallback::~BulkDataCallback () [virtual] |
|
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] |
|
void BulkDataCallback::fwdData2UserCB (CORBA::Boolean enable) |
|
virtual CompletionImpl* BulkDataCallback::getErrorCompletion () [virtual] |
|
ACE_HANDLE BulkDataCallback::getHandle () |
|
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] |
|
CORBA::Boolean BulkDataCallback::isFepAlive () [inline] |
|
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::setCbTimeout (ACE_Time_Value cbTimeout) [inline, virtual] |
|
References isFepAlive_m. |
|
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] |
|
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] |
|
bool BulkDataCallback::fwdData2UserCB_m [protected] |
|
CORBA::Boolean BulkDataCallback::isFepAlive_m [private] |
|
Referenced by setCbTimeout(). |
|
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] |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |