/*******************************************************************************
* 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>
PuServer::PuServer(Control& control, UInt32 number, int physNumber) : ocontrol(control){
onumber = number;
ophysNumber = physNumber;
}
PuServer::~PuServer(){
}
BError PuServer::init(){
BError err;
BString url;
if(ocontrol.boapnsHost() != ""){
url = BString("//") + ocontrol.boapnsHost() + "/";
}
opuControl.connectService(url + "puControl-" + ophysNumber);
opuProcess.connectService(url + "puProcess-" + ophysNumber);
err = opuProcess.addEventServer(url + "tmsEvent");
return err;
}
UInt32 PuServer::getNumber(){
return onumber;
}
BError PuServer::handleError(BError err, int e){
BError errRet;
printf("PuServer::handleError: %d\n", err.getErrorNo());
if((err.getErrorNo() == -EPIPE) && (e < 2)){
// Try a reconnect
opuControl.disconnectService();
opuProcess.disconnectService();
init();
}
else if(err.getErrorNo() == -ECONNREFUSED){
errRet.set(err.getErrorNo(), BString("PuConnection Error: ") + err.getString());
}
else {
errRet = err;
}
return errRet;
}
BError PuServer::configure(ConfigInfo configInfo){
BError err;
int n = 0;
while(err = opuControl.configure(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;
}
// 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::captureTestData(PuChannel puChannel, TestCaptureInfo captureInfo, BArray<UInt64>& data){
BError err;
int n = 0;
while(err = opuControl.captureTestData(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::setControlInfo(CycleParam params){
BError err;
int n = 0;
while(err = opuProcess.setControlInfo(params)){
if(err = handleError(err, n++))
break;
}
return err;
}
BError PuServer::setNextCycle(UInt32 cycleNumber, BString cycleType){
BError err;
int n = 0;
while(err = opuProcess.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::getData(PuChannel puChannel, DataInfo dataInfo, Data& data){
BError err;
int n = 0;
while(err = opuProcess.getData(puChannel, dataInfo, data)){
if(err = handleError(err, n++))
break;
}
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;
}
