• Files
• Commits
• Log
• Graph
• Stats

/*******************************************************************************
 *	PuServer.cc	PuServer process
 *			T.Barnaby,	BEAM Ltd,	2007-02-07
 *******************************************************************************
 */
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <Debug.h>
#include <PuServer.h>
#include <Control.h>
#include <main.h>

#define GETDATA_LOG	0		// Log all getdata() calls

const int	numConnections = 4;

PuServer::PuServer(Control& control, UInt32 number, int physNumber) : ocontrol(control){
	onumber = number;
	ophysNumber = physNumber;
#ifdef ZAP
	for(int n = 0; n < numConnections; n++){
		oconns.append(new PuServerConnection);
	}
#endif
}

PuServer::~PuServer(){
}

BError PuServer::init(){
	BError		err;
	BString		url;
	BIter		i;

	disconnect();
	
	if(ocontrol.boapnsHost() != ""){
		url = BString("//") + ocontrol.boapnsHost() + "/";
	}
	
	if(err = opuControl.connectService(url + "puControl-" + ophysNumber))
		return err;
	if(err = opuProcess.connectService(url + "puProcess-" + ophysNumber))
		return err;

	if(err = opuControl1.connectService(url + "puControl-" + ophysNumber))
		return err;
	if(err = opuProcess1.connectService(url + "puProcess-" + ophysNumber))
		return err;

	// Set high priority on these connections
	opuControl1.setConnectionPriority(BoapPriorityHigh);
	opuControl1.setProcessPriority(PriorityHigh);
	
	// Set timeouts
	opuControl.setTimeout(10000000);
	opuProcess.setTimeout(10000000);
	opuControl1.setTimeout(10000000);
	opuProcess1.setTimeout(10000000);
	
	err = opuProcess1.addEventServer(url + "tmsEvent" + ocontrol.ring());

#ifdef ZAP
	for(oconns.start(i); !oconns.isEnd(i); oconns.next(i)){
		oconns[i]->opuControl.connectService(url + "puControl-" + ophysNumber);
		oconns[i]->opuProcess.connectService(url + "puProcess-" + ophysNumber);
	}
#endif
	
	return err;
}

BError PuServer::disconnect(){
	BError		err;
	BIter		i;

	opuControl.disconnectService();
	opuProcess.disconnectService();

	opuControl1.disconnectService();
	opuProcess1.disconnectService();

#ifdef ZAP
	for(oconns.start(i); !oconns.isEnd(i); oconns.next(i)){
		oconns[i]->opuControl.disconnectService();
		oconns[i]->opuProcess.disconnectService();
	}
#endif
	
	return err;
}

UInt32 PuServer::getNumber(){
	return onumber;
}

BError PuServer::handleError(BError err, int e){
	BError	errRet;

	dprintf(DBG_MISC, "PuServer::handleError: %d\n", err.getErrorNo());
	if((err.getErrorNo() == -EPIPE) && (e < 2)){
		// Try a reconnect
		disconnect();
		init();
	}
	else if(err.getErrorNo() == -ECONNREFUSED){
		errRet.set(err.getErrorNo(), BString("PuConnection Module: ") + onumber + ": Error: " + err.getString());
	}
	else {
		errRet.set(err.getErrorNo(), BString("Module: ") + onumber + ": Error: " + err.getString());
	}
	
	return errRet;
}

BError PuServer::initCmd(){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.init()){
		if(err = handleError(err, n++))
			break;
	}
	
	return err;
}

BError	PuServer::configure(BUInt ring, ConfigInfo configInfo){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.configure(ring, configInfo)){
		if(err = handleError(err, n++))
			break;
	}
	
	return err;
}

BError	PuServer::test(BList<BError>& errors){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.test(errors)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::getStatus(BList<NameValue>& statusList){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.getStatus(statusList)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::getStatistics(BList<NameValue>& statsList){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.getStatistics(statsList)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::getMasterPuChannel(PuChannel& puChannel){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.getMasterPuChannel(puChannel)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}


// Test functions
BError	PuServer::setTestMode(PuChannel puChannel, UInt32 testOutput, UInt32 timingDisableMask){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.setTestMode(puChannel, testOutput, timingDisableMask)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::setTimingSignals(PuChannel puChannel, UInt32 timingSignals){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.setTimingSignals(puChannel, timingSignals)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::captureDiagnostics(PuChannel puChannel, TestCaptureInfo captureInfo, BArray<UInt64>& data){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.captureDiagnostics(puChannel, captureInfo, data)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::setTestData(PuChannel puChannel, Int32 on, BArray<UInt32> data){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.setTestData(puChannel, on, data)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError PuServer::setPupeConfig(PuChannel puPhysChannel, PupeConfig pupeConfig){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.setPupeConfig(puPhysChannel, pupeConfig)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError PuServer::getPupeConfig(PuChannel puPhysChannel, PupeConfig& pupeConfig){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.getPupeConfig(puPhysChannel, pupeConfig)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}



BError	PuServer::setControlInfo(CycleParam params){
	BError	err;
	int	n = 0;
	
	while(err = opuControl.setControlInfo(params)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::setNextCycle(UInt32 cycleNumber, BString cycleType){
	BError	err;
	int	n = 0;
	
	while(err = opuControl1.setNextCycle(cycleNumber, cycleType)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::getStatus(PuChannel puChannel, PuStatus& puStatus){
	BError	err;
	int	n = 0;
	
	while(err = opuProcess.getStatus(puChannel, puStatus)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError PuServer::getCycleInformation(UInt32 cycleNumber, CycleInformation& cycleInformation){
	BError	err;
	int	n = 0;

	while(err = opuProcess.getCycleInformation(cycleNumber, cycleInformation)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}

BError	PuServer::getData(PuChannel puChannel, DataInfo dataInfo, Data& data, UInt32& orbitNumber){
	BError	err;
	int	n = 0;

#if GETDATA_LOG	
	dfprintf("PuServer::getData: Chan: %d Period: %d StartTime: %d Orbit: %d Bunch: %d Function: %d NumValues: %d Beyond: %d\n",
		dataInfo.channel,
		dataInfo.cyclePeriod, dataInfo.startTime, dataInfo.orbitNumber, dataInfo.bunchNumber,
		dataInfo.function, dataInfo.numValues, dataInfo.beyondPeriod);
#endif
	while(err = opuProcess.getData(puChannel, dataInfo, data, orbitNumber)){
		if(err = handleError(err, n++))
			break;
	}
#if GETDATA_LOG	
	dfprintf("PuServer::getData: End: NumValues: %d\n", dataInfo.numValues);
#endif
	return err;
}

BError	PuServer::requestData(PuChannel puChannel, DataInfo dataInfo){
	BError	err;
	int	n = 0;
	
	while(err = opuProcess.requestData(puChannel, dataInfo)){
		if(err = handleError(err, n++))
			break;
	}

	return err;
}