bnet/src_clust/RocClusterApplication.cxx (r4864/r1304)

Go to the documentation of this file.

#include "bnet/RocClusterApplication.h"

#include "bnet/RocClusterFactory.h"
#include "roc/Commands.h"
#include "roc/Board.h"

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

bnet::RocClusterApplication::RocClusterApplication() :
   bnet::ClusterApplication(xmlRocClusterClass)
{
   CreateParBool("DLMmaster", false);
   
   fDLMDev = "";
}

int bnet::RocClusterApplication::ExecuteCommand(dabc::Command* cmd)
{

   if (cmd->IsName(roc::CmdCalibration::CmdName())) {

      bool flag = cmd->GetBool(roc::CmdCalibration::FlagName(), true);

      for (int n=0;n<NumWorkers();n++)
         if (IsWorkerActive(n)) {
            dabc::Command* gcmd = new roc::CmdGlobalCalibration(flag);
            dabc::SetCmdReceiver(gcmd, GetWorkerNodeName(n), dabc::xmlAppDfltName);
            dabc::mgr()->Submit(gcmd);
         }

      return dabc::cmd_true;
   }

   return bnet::ClusterApplication::ExecuteCommand(cmd);

}


bool bnet::RocClusterApplication::CreateAppModules()
{
   if (GetParBool("DLMmaster", false)) {
     
      fDLMDev = "AbbDev";
      
      if (dabc::mgr()->FindDevice(fDLMDev.c_str()) == 0) {
     
         dabc::Command* cmd = new dabc::CmdCreateDevice(roc::typeAbbDevice, fDLMDev.c_str(), "AbbDevThrd");
         cmd->SetBool(roc::xmlUseDLM, true);

         if (!dabc::mgr()->Execute(cmd)) {
            EOUT(("Cannot create DLM device"));
            return false;
         }
      }
   }
  
   return bnet::ClusterApplication::CreateAppModules();
}

bool bnet::RocClusterApplication::BeforeAppModulesStarted()
{
   if (fDLMDev.length() > 0) {
      dabc::Command* cmd = new roc::CmdDLM(8);
      dabc::SetCmdReceiver(cmd, FORMAT(("%s/%s", dabc::Manager::DevicesFolderName(), fDLMDev.c_str())));
      dabc::mgr()->Submit(cmd);
   }
   
   return bnet::ClusterApplication::BeforeAppModulesStarted();
}

bool bnet::RocClusterApplication::AfterAppModulesStopped()
{
   if (fDLMDev.length() > 0) {
      dabc::Command* cmd = new roc::CmdDLM(9);
      dabc::SetCmdReceiver(cmd, FORMAT(("%s/%s", dabc::Manager::DevicesFolderName(), fDLMDev.c_str())));
      dabc::mgr()->Submit(cmd);
   }
   return bnet::ClusterApplication::AfterAppModulesStopped();
}

bool bnet::RocClusterApplication::BeforeAppModulesDestroyed()
{
   if (fDLMDev.length() > 0) {
      // DABC concept foresees that all devices remain after application is destroyed
      // In DABC version 2.0 this should be changed
      DOUT0(("One should here destroy DLM device"));
   }
   
   fDLMDev = "";
   return bnet::ClusterApplication::BeforeAppModulesDestroyed();
}