|
My Project
|
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::RegMapDataFrameManager * | grabReadFrame () |
| 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) |
| Thread * | getThread (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::Scanner * | parent_ |
| std::string | dioHost_ |
| unsigned short | dioPort_ |
| std::string | hwHost_ |
| unsigned short | hwPort_ |
| gcp::util::TimeVal | timer_ |
| struct timeval * | timeOut_ |
| DioClient * | dioClient_ |
Protected Attributes inherited from gcp::util::GenericTask< gcp::mediator::DioMsg > | |
| Thread * | thread_ |
| std::vector< Thread * > | threads_ |
| PipeQ< gcp::mediator::DioMsg > | msgq_ |
| gcp::util::FdSet | fdSet_ |
| std::vector< Command * > | commands_ |
| struct timeval * | timeOut_ |
| TimeVal | commandTimeOut_ |
Friends | |
| class | gcp::mediator::Scanner |
|
virtual |
....................................................................... Destructor.
|
protected |
....................................................................... Constructor.
| void DioConsumer::checkForDioData | ( | ) |
....................................................................... Check for from the DIO Client
|
protected |
....................................................................... Set the timeout until the next connection attempt
|
protectedvirtual |
....................................................................... Copy stored values of persistent items into the register frame
|
protected |
....................................................................... Return the currently-readable frame
|
inlinevirtual |
This method should be defined by each inheriting task to process its own task-specific messages.
| Exception | Method to process a message received on the Task message * queue |
Reimplemented from gcp::util::GenericTask< gcp::mediator::DioMsg >.
Reimplemented in gcp::receiver::BolometerConsumer.
|
protected |
....................................................................... Release the read frame
|
protected |
....................................................................... Set the timeout until the next connection attempt
|
virtual |
....................................................................... Service our message queue.
Reimplemented from gcp::util::GenericTask< gcp::mediator::DioMsg >.