My Project
|
Public Member Functions | |
AntennaConsumerNotification (Scanner *parent, std::string notifyChannel) | |
virtual | ~AntennaConsumerNotification () |
void | run () |
![]() | |
AntennaConsumer (Scanner *parent) | |
virtual | ~AntennaConsumer () |
![]() | |
void | sendRestartMsg () |
void | sendStopMsg () |
void | sendHeartBeatMsg () |
virtual void | fwdTaskMsg (ScannerMsg *msg) |
Additional Inherited Members | |
![]() | |
GenericTask () | |
GenericTask (Thread *thread) | |
virtual | ~GenericTask () |
void | sendTaskMsg (ScannerMsg *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 | serviceMsgQ (void) |
virtual void | restart (void) |
virtual void | processTaskMsg (bool *stop) |
virtual void | processMsg (ScannerMsg *msg) |
virtual void | respondToHeartBeat () |
virtual void | installTimer (ScannerMsg *msg) |
virtual void | installSignal (ScannerMsg *msg) |
virtual void | enableTimer (ScannerMsg *msg) |
virtual void | addHandler (ScannerMsg *msg) |
void | stepCommands () |
![]() | |
Scanner * | parent_ |
![]() | |
Thread * | thread_ |
std::vector< Thread * > | threads_ |
PipeQ< ScannerMsg > | msgq_ |
gcp::util::FdSet | fdSet_ |
std::vector< Command * > | commands_ |
struct timeval * | timeOut_ |
TimeVal | commandTimeOut_ |
AntennaConsumerNotification::AntennaConsumerNotification | ( | Scanner * | parent, |
std::string | notifyChannel | ||
) |
Constructor attaches to the specified notification channel.
....................................................................... Constructor.
|
virtual |
Destructor.
....................................................................... Destructor.
|
virtual |
Override the base-class run methods
....................................................................... Run method blocks in NotificationObserver::run()
Reimplemented from gcp::util::GenericTask< ScannerMsg >.