abbplugin/src/AbbBoard.cxx (r4864/r4162)

Go to the documentation of this file.

#include "roc/AbbBoard.h"

#include "dabc/Manager.h"
#include "dabc/logging.h"

#include "roc/Commands.h"
#include "roc/ReadoutModule.h"
#include "roc/AbbDevice.h"


roc::AbbBoard::AbbBoard(AbbDevice* dev, uint32_t path, base::ClientRole role) :
   roc::OpticBoard(),
   fDev(dev),
   fReadout(0),
   fOpticPath(path)
{
   if (role==base::roleNone) role = base::roleDAQ;
   setRole(role);

   // dabc::lgr()->SetLogLimit(1000000000);

   DOUT3(("Use path code 0x%x to ROC", path));
}

roc::AbbBoard::~AbbBoard()
{
//   module will be cleanup together with pool on the top
//   if (fReadout!=0) dabc::mgr()->DeleteModule(fReadout->GetName());

   fReadout = 0;
}

bool roc::AbbBoard::initAbbBoard()
{
   uint32_t roc_hw_ver = initBoard("ROC", 0x2000000);

   uint32_t optic_hw_ver(0);
   get(ROC_OPTICS_HWV, optic_hw_ver);

   DOUT0(("ROC%u Opt HW version: %s; Path 0x%x", boardNumber(), versionToString(optic_hw_ver), fOpticPath));

   if ((optic_hw_ver & 0xFFFF0000) != (roc_hw_ver & 0xFFFF0000))
      EOUT(("Mismatch of major number of hardware versions"));
   
   return (roc_hw_ver!=0) && (optic_hw_ver!=0);
}


int roc::AbbBoard::operGen(base::OperList& lst, double tmout)
{
   int res = kHostError;

   if (tmout <= 0.) tmout = getDefaultTimeout();

   CmdNOper cmd(&lst, tmout);
   cmd.SetUInt(roc::OpticPathPar, fOpticPath);

   if (fDev->Execute(cmd, tmout + .1))
      res = cmd.GetInt(ErrNoPar, kHostError);

   traceOper(lst, res);

   return res;
}

uint32_t roc::AbbBoard::getRocBackendVersion()
{
   uint32_t val = 0;
   get(ROC_OPTICS_HWV, val);
   return val;
}


int roc::AbbBoard::invokeDLM(unsigned num, double tmout)
{
   int res = kHostError;

   if (tmout <= 0.) tmout = getDefaultTimeout();

   CmdDLM cmd(num, tmout);

   if (fDev->Execute(cmd, tmout + .1))
      res = cmd.GetInt(ErrNoPar, kHostError);

   return res;
}


bool roc::AbbBoard::startDaq()
{
   DOUT2(("Starting DAQ !!!!"));

   if (fReadout==0) return false;

   fReadout->Start();
   
   return true;
}

bool roc::AbbBoard::suspendDaq()
{
   DOUT2(("Suspend DAQ !!!!"));

   // we only send stop daq command, do not do anything else

   dabc::Command cmd("SuspendBoardDaq");
   cmd.SetUInt(roc::OpticPathPar, fOpticPath);
   return fDev->Execute(cmd, 5);
}

bool roc::AbbBoard::stopDaq()
{
   if (fReadout==0) return false;

   DOUT2(("Stop DAQ !!!!"));

   fReadout->Stop();
   
   return true;
}

bool roc::AbbBoard::getNextBuffer(void* &buf, unsigned& len, double tmout)
{
   return fReadout ? fReadout->getNextBuffer(buf, len, tmout) : false;
}

void roc::AbbBoard::setFlushTimeout(double tmout)
{
   dabc::Command cmd("SetFlushTimeout");
   cmd.SetDouble("Timeout", tmout);
   fDev->Execute(cmd);
}