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 () |
![]() | |
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 () |
![]() | |
void | sendRestartMsg () |
void | sendStopMsg () |
void | sendHeartBeatMsg () |
virtual void | fwdTaskMsg (gcp::mediator::ScannerMsg *msg) |
Additional Inherited Members | |
![]() | |
static const unsigned | nConnAttemptBeforeReport_ = 30 |
![]() | |
virtual void | processMsg (gcp::mediator::ScannerMsg *msg) |
virtual bool | checkClient () |
void | registerError () |
![]() | |
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 () |
![]() | |
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_ |
![]() | |
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 >.