My Project
 All Classes Files Functions Variables Enumerations Enumerator Friends Macros Pages
gcp::receiver::DioConsumer Class Reference
Inheritance diagram for gcp::receiver::DioConsumer:
gcp::util::GenericTask< gcp::mediator::DioMsg > gcp::receiver::BolometerConsumer gcp::receiver::SquidConsumer

Public Member Functions

virtual ~DioConsumer ()
 
virtual void serviceMsgQ ()
 
virtual void processMsg (gcp::mediator::DioMsg *msg)
 
void checkForDioData ()
 
- Public Member Functions inherited from gcp::util::GenericTask< gcp::mediator::DioMsg >
void sendRestartMsg ()
 
void sendStopMsg ()
 
void sendHeartBeatMsg ()
 
virtual void fwdTaskMsg (gcp::mediator::DioMsg *msg)
 

Protected Member Functions

 DioConsumer (gcp::mediator::Scanner *parent, std::string dioHost, unsigned short dioPort, std::string hwHost, unsigned short hwPort)
 
void resetTimeout ()
 
void clearTimeout ()
 
virtual void packFrame ()
 
gcp::util::RegMapDataFrameManagergrabReadFrame ()
 
void releaseReadFrame ()
 
virtual void copyPersistentRegs (gcp::util::ArrayMapDataFrameManager *frame)
 
virtual
gcp::util::BoardDataFrameManager
getFrame ()
 
- Protected Member Functions inherited from gcp::util::GenericTask< gcp::mediator::DioMsg >
 GenericTask ()
 
 GenericTask (Thread *thread)
 
virtual ~GenericTask ()
 
void sendTaskMsg (gcp::mediator::DioMsg *msg)
 
void startThreads (void *arg)
 
void startThread (void *arg, unsigned order)
 
unsigned getMinStartOrder ()
 
bool threadsNeedStarting ()
 
void cancelThreads ()
 
void cancelThread (unsigned order)
 
unsigned getMinCancelOrder ()
 
bool threadsNeedCancelling ()
 
void pingThreads (void *arg)
 
void raise (std::string name, int sigNo)
 
ThreadgetThread (std::string name)
 
bool threadsAreRunning ()
 
void shutdownConnection (int fd)
 
virtual void restart (void)
 
virtual void run (void)
 
virtual void processTaskMsg (bool *stop)
 
virtual void respondToHeartBeat ()
 
virtual void installTimer (gcp::mediator::DioMsg *msg)
 
virtual void installSignal (gcp::mediator::DioMsg *msg)
 
virtual void enableTimer (gcp::mediator::DioMsg *msg)
 
virtual void addHandler (gcp::mediator::DioMsg *msg)
 
void stepCommands ()
 

Protected Attributes

gcp::mediator::Scannerparent_
 
std::string dioHost_
 
unsigned short dioPort_
 
std::string hwHost_
 
unsigned short hwPort_
 
gcp::util::TimeVal timer_
 
struct timeval * timeOut_
 
DioClientdioClient_
 
- Protected Attributes inherited from gcp::util::GenericTask< gcp::mediator::DioMsg >
Threadthread_
 
std::vector< Thread * > threads_
 
PipeQ< gcp::mediator::DioMsgmsgq_
 
gcp::util::FdSet fdSet_
 
std::vector< Command * > commands_
 
struct timeval * timeOut_
 
TimeVal commandTimeOut_
 

Friends

class gcp::mediator::Scanner
 

Constructor & Destructor Documentation

DioConsumer::~DioConsumer ( )
virtual

....................................................................... Destructor.

DioConsumer::DioConsumer ( gcp::mediator::Scanner parent,
std::string  dioHost,
unsigned short  dioPort,
std::string  hwHost,
unsigned short  hwPort 
)
protected

....................................................................... Constructor.

Member Function Documentation

void DioConsumer::checkForDioData ( )

....................................................................... Check for from the DIO Client

void DioConsumer::clearTimeout ( )
protected

....................................................................... Set the timeout until the next connection attempt

void DioConsumer::copyPersistentRegs ( gcp::util::ArrayMapDataFrameManager frame)
protectedvirtual

....................................................................... Copy stored values of persistent items into the register frame

RegMapDataFrameManager * DioConsumer::grabReadFrame ( )
protected

....................................................................... Return the currently-readable frame

virtual void gcp::receiver::DioConsumer::processMsg ( gcp::mediator::DioMsg msg)
inlinevirtual

This method should be defined by each inheriting task to process its own task-specific messages.

Exceptions
ExceptionMethod to process a message received on the Task message * queue

Reimplemented from gcp::util::GenericTask< gcp::mediator::DioMsg >.

Reimplemented in gcp::receiver::BolometerConsumer.

void DioConsumer::releaseReadFrame ( )
protected

....................................................................... Release the read frame

void DioConsumer::resetTimeout ( )
protected

....................................................................... Set the timeout until the next connection attempt

void DioConsumer::serviceMsgQ ( void  )
virtual

....................................................................... Service our message queue.

Reimplemented from gcp::util::GenericTask< gcp::mediator::DioMsg >.


The documentation for this class was generated from the following files: