#include <bulkDataCallback.h>
Inheritance diagram for BulkDataCallback:
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 |
Member Enumeration Documentation
Constructor & Destructor Documentation
| BulkDataCallback::BulkDataCallback | ( | ) |
| virtual BulkDataCallback::~BulkDataCallback | ( | ) | [virtual] |
Member Function Documentation
| virtual int BulkDataCallback::cbReceive | ( | ACE_Message_Block * | frame_p | ) | [pure virtual] |
| virtual int BulkDataCallback::cbStart | ( | ACE_Message_Block * | userParam_p = 0 |
) | [pure virtual] |
| virtual int BulkDataCallback::cbStop | ( | ) | [pure virtual] |
| 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] |
Member Data Documentation
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] |
The documentation for this class was generated from the following file:
