Factory.cxx

Go to the documentation of this file.

// $Id: Factory.cxx 3862 2018-05-11 10:06:18Z linev $
 
/************************************************************
 * The Data Acquisition Backbone Core (DABC)                *
 ************************************************************
 * Copyright (C) 2009 -                                     *
 * GSI Helmholtzzentrum fuer Schwerionenforschung GmbH      *
 * Planckstr. 1, 64291 Darmstadt, Germany                   *
 * Contact:  http://dabc.gsi.de                             *
 ************************************************************
 * This software can be used under the GPL license          *
 * agreements as stated in LICENSE.txt file                 *
 * which is part of the distribution.                       *
 ************************************************************/
 
#include "stream/Factory.h"
 
#include "dabc/Url.h"
#include "dabc/Port.h"
#include "dabc/Manager.h"
 
#include "stream/RunModule.h"
#include "stream/TdcCalibrationModule.h"
#include "stream/RecalibrateModule.h"
 
dabc::FactoryPlugin streamfactory(new stream::Factory("stream"));
 
dabc::Module* stream::Factory::CreateModule(const std::string &classname, const std::string &modulename, dabc::Command cmd)
{
   if (classname == "stream::RunModule")
      return new stream::RunModule(modulename, cmd);
 
   if (classname == "stream::TdcCalibrationModule")
      return new stream::TdcCalibrationModule(modulename, cmd);
 
   if (classname == "stream::RecalibrateModule")
      return new stream::RecalibrateModule(modulename, cmd);
 
   return dabc::Factory::CreateModule(classname, modulename, cmd);
}
 
 
dabc::Module* stream::Factory::CreateTransport(const dabc::Reference& port, const std::string &typ, dabc::Command cmd)
{
   dabc::Url url(typ);
 
   dabc::PortRef portref = port;
 
   if (!portref.IsOutput() || (url.GetProtocol()!="stream"))
      return dabc::Factory::CreateTransport(port, typ, cmd);
 
   cmd.SetBool("use_autotdc", true);
   cmd.SetStr("fileurl", typ);
 
   dabc::mgr.app().AddObject("module", "StreamMonitor");
 
   return new stream::RunModule("StreamMonitor", cmd);
}