// $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 "verbs/Worker.h"

#include "dabc/Command.h"
#include "dabc/ConnectionManager.h"

#include "verbs/Device.h"
#include "verbs/QueuePair.h"
#include "verbs/ComplQueue.h"
#include "verbs/MemoryPool.h"
#include "verbs/Thread.h"

ibv_gid VerbsConnThrd_Multi_Gid =  {   {
      0xFF, 0x12, 0xA0, 0x1C,
      0xFE, 0x80, 0x00, 0x00,
      0x00, 0x00, 0x00, 0x00,
      0x33, 0x44, 0x55, 0x66
    } };


verbs::WorkerAddon::WorkerAddon(QueuePair* qp) :
   dabc::WorkerAddon("verbs"),
   fQP(qp)
{
}

verbs::WorkerAddon::~WorkerAddon()
{
   CloseQP();
}

std::string verbs::WorkerAddon::RequiredThrdClass() const
{
   return verbs::typeThread;
}

void verbs::WorkerAddon::SetQP(QueuePair* qp)
{
   CloseQP();
   fQP = qp;
}

void verbs::WorkerAddon::CloseQP()
{
   if (fQP) {
      delete fQP;
      fQP = nullptr;
   }
}

verbs::QueuePair* verbs::WorkerAddon::TakeQP()
{
   QueuePair* qp = fQP;
   fQP = nullptr;
   return qp;
}


void verbs::WorkerAddon::ProcessEvent(const dabc::EventId& evnt)
{
   switch (evnt.GetCode()) {

      case evntVerbsSendCompl:
         VerbsProcessSendCompl(evnt.GetArg());
         break;

      case evntVerbsRecvCompl:
         VerbsProcessRecvCompl(evnt.GetArg());
         break;

      case evntVerbsError:
         VerbsProcessOperError(evnt.GetArg());
         break;

      default:
         dabc::WorkerAddon::ProcessEvent(evnt);
   }
}