|
My Project
|
Classes | |
| struct | Board |
Public Types | |
| enum | Command { TYPE_NONE, TYPE_GETBOARDS, TYPE_GETSQUIDS, TYPE_GETSEQID, TYPE_GETREGS } |
| enum | SquidId { SQUID_NONE = 0x0, SQUID_A = 0x1, SQUID_B = 0x2 } |
Public Member Functions | |
| ReceiverConfigConsumer (gcp::mediator::Scanner *scanner, std::string host="localhost", unsigned short port=5207, bool send_connect_request=true) | |
| virtual | ~ReceiverConfigConsumer () |
| bool | getData () |
| bool | requestBoards () |
| bool | ReceiverConfigConsumer::requestSquids () |
| bool | ReceiverConfigConsumer::requestHardwareStatus () |
| bool | ReceiverConfigConsumer::requestHardwareConfiguration () |
| bool | sendCommand (MuxReadout::HardwareManagerClient::Cmd *cmd, Command type) |
| bool | ReceiverConfigConsumer::readResponse () |
| MuxReadout::HardwareManagerClient::Cmd * | getLastSentCommand () |
| bool | readBoardInfo (MuxReadout::HardwareManagerClient::Cmd *cmd) |
| bool | readSquidInfo (MuxReadout::HardwareManagerClient::Cmd *cmd) |
| bool | readHardwareStatus (MuxReadout::HardwareManagerClient::Cmd *cmd) |
| bool | readHardwareConfiguration (MuxReadout::HardwareManagerClient::Cmd *cmd) |
| void | reportError () |
| void | reportSuccess () |
| void | serviceMsgQ () |
Public Member Functions inherited from gcp::receiver::XMLConsumer | |
| XMLConsumer (gcp::receiver::XMLDataFrameManager *dataFrame, gcp::mediator::Scanner *scanner, std::string regMapName, std::string host="localhost", unsigned short port=5207, bool send_connect_request=true) | |
| virtual | ~XMLConsumer () |
| void | sendDispatchDataFrameMsg () |
Public Member Functions inherited from gcp::util::GenericTask< gcp::mediator::ScannerMsg > | |
| void | sendRestartMsg () |
| void | sendStopMsg () |
| void | sendHeartBeatMsg () |
| virtual void | fwdTaskMsg (gcp::mediator::ScannerMsg *msg) |
Additional Inherited Members | |
Static Public Attributes inherited from gcp::receiver::XMLConsumer | |
| static const unsigned | nConnAttemptBeforeReport_ = 30 |
Protected Member Functions inherited from gcp::receiver::XMLConsumer | |
| virtual void | processMsg (gcp::mediator::ScannerMsg *msg) |
| virtual bool | checkClient () |
| void | registerError () |
Protected Member Functions inherited from gcp::util::GenericTask< gcp::mediator::ScannerMsg > | |
| GenericTask () | |
| GenericTask (Thread *thread) | |
| virtual | ~GenericTask () |
| void | sendTaskMsg (gcp::mediator::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 | restart (void) |
| virtual void | run (void) |
| virtual void | processTaskMsg (bool *stop) |
| virtual void | respondToHeartBeat () |
| virtual void | installTimer (gcp::mediator::ScannerMsg *msg) |
| virtual void | installSignal (gcp::mediator::ScannerMsg *msg) |
| virtual void | enableTimer (gcp::mediator::ScannerMsg *msg) |
| virtual void | addHandler (gcp::mediator::ScannerMsg *msg) |
| void | stepCommands () |
Protected Attributes inherited from gcp::receiver::XMLConsumer | |
| bool | commandPending_ |
| unsigned | nConnAttempt_ |
| gcp::mediator::Scanner * | parent_ |
| std::string | regMapName_ |
| std::string | host_ |
| unsigned short | port_ |
| bool | send_connect_request_ |
| bool | connected_ |
| int | clientFd_ |
| gcp::receiver::XMLDataFrameManager * | dataFrame_ |
| MuxReadout::HardwareManagerClient * | client_ |
Protected Attributes inherited from gcp::util::GenericTask< gcp::mediator::ScannerMsg > | |
| Thread * | thread_ |
| std::vector< Thread * > | threads_ |
| PipeQ< gcp::mediator::ScannerMsg > | msgq_ |
| gcp::util::FdSet | fdSet_ |
| std::vector< Command * > | commands_ |
| struct timeval * | timeOut_ |
| TimeVal | commandTimeOut_ |
| ReceiverConfigConsumer::ReceiverConfigConsumer | ( | gcp::mediator::Scanner * | scanner, |
| std::string | host = "localhost", |
||
| unsigned short | port = 5207, |
||
| bool | send_connect_request = true |
||
| ) |
Constructor.
....................................................................... Constructor.
|
virtual |
....................................................................... Destructor.
|
virtual |
....................................................................... Get the next set of data from the server
Reimplemented from gcp::receiver::XMLConsumer.
| MuxReadout::HardwareManagerClient::Cmd * ReceiverConfigConsumer::getLastSentCommand | ( | ) |
....................................................................... Return the last command we sent
|
virtual |
....................................................................... Report an error
Reimplemented from gcp::receiver::XMLConsumer.
|
virtual |
....................................................................... Report a successfull connection
Reimplemented from gcp::receiver::XMLConsumer.
| bool ReceiverConfigConsumer::requestBoards | ( | ) |
....................................................................... Request the list of boards
| bool ReceiverConfigConsumer::sendCommand | ( | MuxReadout::HardwareManagerClient::Cmd * | cmd, |
| Command | type | ||
| ) |
....................................................................... Generic method to send a command to the HWM
|
virtual |
....................................................................... Service our message queue.
Reimplemented from gcp::util::GenericTask< gcp::mediator::ScannerMsg >.