Inheritance diagram for gcp::receiver::XMLConsumer:

Public Member Functions
	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)

Static Public Attributes
static const unsigned	nConnAttemptBeforeReport_ = 30

Protected Member Functions
virtual void	processMsg (gcp::mediator::ScannerMsg *msg)

virtual bool	getData ()

virtual bool	checkClient ()

void	registerError ()

virtual void	reportError ()

virtual void	reportSuccess ()

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	serviceMsgQ (void)

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
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_

Friends
class	gcp::mediator::Scanner

Constructor & Destructor Documentation

XMLConsumer::XMLConsumer	(	gcp::receiver::XMLDataFrameManager *	dataFrame,
		gcp::mediator::Scanner *	parent,
		std::string	regMapName,
		std::string	host = `"localhost"`,
		unsigned short	port = `5207`,
		bool	send_connect_request = `true`
	)

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

XMLConsumer::~XMLConsumer ( )

virtual

Destructor.

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

Member Function Documentation

bool XMLConsumer::checkClient ( )

protectedvirtual

....................................................................... Check that we have a valid client connection

bool XMLConsumer::getData ( )

protectedvirtual

....................................................................... Get the next set of data from the server

Reimplemented in gcp::receiver::ReceiverConfigConsumer.

void XMLConsumer::processMsg ( gcp::mediator::ScannerMsg * msg )

protectedvirtual

....................................................................... Process a message specific to this task.

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

void XMLConsumer::registerError ( )

protected

....................................................................... Register an error communicating with the server

void XMLConsumer::reportError ( )

protectedvirtual

....................................................................... Report an error

Reimplemented in gcp::receiver::ReceiverConfigConsumer.

void XMLConsumer::reportSuccess ( )

protectedvirtual

....................................................................... Report a successfull connection

Reimplemented in gcp::receiver::ReceiverConfigConsumer.

Friends And Related Function Documentation

friend class gcp::mediator::Scanner

friend

We declare Scanner a friend so that it alone can instantiate this class.

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

gcpCbass/receiver/cbass/XMLConsumer.h
gcpCbass/receiver/cbass/XMLConsumer.cc

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Friends

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation