---

/ps/src/dsc/co/mw/mwfwk/cmwfwDeviceAdapter.cc

Go to the documentation of this file.

#include "cmwfw_defs.h"
#include "cmwfwTime.h"
#include "cmwfwIOPMapper.h"
#include "cmwfwDeviceServer.h"
#include "cmwfwDeviceAdapter.h"
#include "cmwfwPoller.h"
#include "cmwfwForwarder.h"
#include "cmwfwIOValue.h"
#ifndef CMWFW_WINDOWSNT
#include <tgm/tgm.h>
#include <gm/gm_def.h>
extern"C"{
TgmMachine gm_getmachine();                //To get default machine for this DSC
}
#endif


extern cmwfwIOPMapper framework_iop_mapper;


#define FILE "source file:cmwfwDeviceAdapter.cc"
#define ID "Contact Steen JENSEN, PS/CO"
#define PROGRAM "Middleware server framework"
#define T(a,b,c,d,e) TRACE(a,"%s(%s): %s %s %s %s\n",myname,FILE,b,c,d,e)
#define E(a,b,c,d) ERROR("%s:%s(%s):ERROR: %s %s %s %s - %s\n",PROGRAM,myname,FILE,a,b,c,d,ID)
//T(CMWFW_TRACE_,"","","","");
//E("","","","");



cmwfwDeviceAdapter::cmwfwDeviceAdapter(){

  char* myname = "cmwfwDeviceAdapter::cmwfwDeviceAdapter";
  T(CMWFW_TRACE_CALLS,"Entering","","","");
  T(CMWFW_TRACE_SERVER,"Registering adapter","","","");

  framework_iop_mapper.reg(*this);

  T(CMWFW_TRACE_CALLS,"Returning","","","");
};


cmwfwDeviceAdapter::~cmwfwDeviceAdapter(){
  char* myname = "cmwfwDeviceAdapter::~cmwfwDeviceAdapter";
  T(CMWFW_TRACE_CALLS,"Entering","","","");
  T(CMWFW_TRACE_SERVER,"Unregistering adapter","","","");

  framework_iop_mapper.unreg(*this);

  T(CMWFW_TRACE_CALLS,"Returning","","","");
};


cmwfwData* cmwfwDeviceAdapter::cmwfw_get(const cmwfwIOPoint& iop,
                                                                                 const cmwfwData& ctx){
  char* myname = "cmwfwDeviceAdapter::cmwfw_get";
  T(CMWFW_TRACE_CALLS,"Entering","","","");
  cmwfwData* value = this->get(iop,ctx);
  if(!value){
    T(CMWFW_TRACE_CALLS,"Returning - no value from get","","","");
        return value;
  };

  if(!value->contains(CYCLESTAMP_TAG))
    value->insert(CYCLESTAMP_TAG,cmwfwGetCurrentTime());

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
  return value;
};



void cmwfwDeviceAdapter::cmwfw_poll(const cmwfwIOPoint& iop,
                                                                        cmwfwData& value_to_fill,
                                                                        cmwfwValueQualifier& vq_to_set){
  char* myname = "cmwfwDeviceAdapter::cmwfw_poll";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  this->poll(iop,value_to_fill,vq_to_set);

  if(!value_to_fill.contains(CYCLESTAMP_TAG))
    value_to_fill.insert(CYCLESTAMP_TAG,cmwfwGetCurrentTime());

  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};





char* cmwfwDeviceAdapter::generateIOPString(const cmwfwIOPoint& iop){
  char* myname = "cmwfwDeviceAdapter::generateIOPString";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  char* cn = iop.getClassName();
  char* dn = iop.getDeviceName();
  char* pn = iop.getPropertyName();
  char* cs = iop.getCycleSelector();
  int cnl = strlen(cn);
  int dnl = strlen(dn);
  int pnl = strlen(pn);
  int csl = 0;
  if(cs)
        csl = strlen(cs);

  char* m = new char[cnl+dnl+pnl+csl+2+5];
  if(!m)heaperr(1928);
  m[0] = 0;
  strcat(m,cn);
  strcat(m,":");
  strcat(m,dn);
  strcat(m,":");
  strcat(m,pn);
  if(cs){
    strcat(m,":");
        strcat(m,cs);
  };
  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
  return m;
};






void cmwfwDeviceAdapter::heaperr(int line){
  char* myname = "cmwfwDeviceServer";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  char l[30];
  itoa(line,l);
  E("Out of heap in line ",l,"","");
  throw cmwfwInternalError(FILE,line,"Out of heap memory");

  T(CMWFW_TRACE_CALLS,"Exiting","","","");
  exit(-1);
};

---