faspplugin/src/Factory.cxx (r4864/r3636)

Go to the documentation of this file.

/********************************************************************
 * 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 "fasp/Factory.h"

#include "dabc/Command.h"
#include "dabc/logging.h"
#include "dabc/Port.h"
#include "dabc/ModuleSync.h"

#include "base/Url.h"
#include "fasp/FileInput.h"
#include "fasp/Transport.h"

dabc::FactoryPlugin rocfactory(new fasp::Factory("fasp"));

fasp::Factory::Factory(const char* name) :
   dabc::Factory(name)
{
}


dabc::Transport* fasp::Factory::CreateTransport(dabc::Reference ref, const char* typ, dabc::Command cmd)
{
   if (strcmp(typ, "fasp::Transport")==0) {
      dabc::PortRef portref = ref;
      if (portref.null()) {
         EOUT(("Port not specified"));
         return 0;
      }

       // FIXME!
      fasp::Transport* tr = new fasp::Transport(portref, cmd);

      if (!tr->IsRawSocket()) { delete tr; tr = 0; }

      return tr;
   }

   return dabc::Factory::CreateTransport(ref, typ, cmd);
}



dabc::DataInput* fasp::Factory::CreateDataInput(const char* typ)
{
   if ((typ==0) || (strlen(typ)==0)) return 0;

   DOUT3(("Factory::CreateDataInput %s", typ));

   if (strcmp(typ, "fasp::FileInput")==0) {
      return new fasp::FileInput();
   }

   return 0;
}