// $Id$

/************************************************************
 * 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 "dabc/Device.h"

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


dabc::Device::Device(const std::string& name) :
   Worker(MakePair(name)),
   fDeviceMutex(true)
{
   DOUT3("Device %p %s %s constructor prior:%d", this, GetName(), ItemName().c_str(), WorkerPriority());
}

dabc::Device::~Device()
{
   // by this call we synchronise us with anything else
   // that can happen on the device

   DOUT3("Device %s destr prior:%d", GetName(), WorkerPriority());
}

int dabc::Device::ExecuteCommand(Command cmd)
{
   if (cmd.IsName(CmdCreateTransport::CmdName())) {
      CmdCreateTransport crcmd = cmd;

      PortRef port = dabc::mgr.FindPort(crcmd.PortName());

      if (port.null()) return cmd_false;

      port.SetTransient(false);

      TransportRef tr = CreateTransport(cmd, port);

      if (tr==0) return cmd_false;

      std::string thrdname = port.Cfg(xmlThreadAttr, cmd).AsStdStr();
      if (thrdname.empty()) thrdname = ThreadName();

      if (!tr.MakeThreadForWorker(thrdname)) {
         EOUT("Fail to create thread for transport");
         tr.Destroy();
         return cmd_false;
      }

      tr.ConnectPoolHandles();
      if (port.IsInput())
         dabc::LocalTransport::ConnectPorts(tr.OutputPort(), port);
      if (port.IsOutput())
         dabc::LocalTransport::ConnectPorts(port, tr.InputPort());

      return cmd_true;
   }

   return dabc::Worker::ExecuteCommand(cmd);
}