---

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

Go to the documentation of this file.

#include "cmwfwList.h"
#include "cmwfwPoller.h"
#include "cmwfwIOValue.h"
#include "cmwfwIOPMapper.h"
#include "cmwfwDeviceServer.h"
#include "cmwfwDeviceAdapter.h"


extern cmwfwIOPMapper framework_iop_mapper;
void* pollThrRoutine(void*);



#define FILE "source file:cmwfwPoller.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_CALLS,"","","","");
//E("","","","");





cmwfwPoller::cmwfwPoller(){
  char* myname = "cmwfwPoller::cmwfwPoller";
  T(CMWFW_TRACE_CALLS,"Entering","","","");
  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};



cmwfwPoller::~cmwfwPoller(){
  char* myname = "cmwfwPoller::~cmwfwPoller";
  T(CMWFW_TRACE_CALLS,"Entering","","","");
  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
};


void cmwfwPoller::processIOP(const cmwfwIOPoint& iop){
  char* myname = "cmwfwPoller::processIOP";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  int                  did_update = 0;
  int                  updated_with_error = 0;
  cmwfwIOValue*        iov_ptr1    = 0;
  cmwfwIOValue*        iov_ptr2    = 0;
  cmwfwIOError*        ioe_ptr    = 0;
  cmwfwData            data_being_filled;
  cmwfwValueQualifier  vq_being_set;
  cmwfwDeviceServer*   srv_ptr    = framework_iop_mapper.getServer(iop);
  cmwfwDeviceAdapter*  adp_ptr    = framework_iop_mapper.getAdapter(iop);
  char* dn = iop.getDeviceName();
  char* cn = iop.getClassName();
  char* pn = iop.getPropertyName();
  char* cs = iop.getCycleSelector();
  cmwfwIOPoint iop_no_cs(dn,cn,pn,0);

  if( !srv_ptr ){
        char* dn = iop.getDeviceName();
        char* e = "Unable to update clients for ";
        char* errmess = new char[strlen(dn) + strlen(e) + 5];
        if(!errmess)heaperr(85);
        strcat(errmess,e);
        strcat(errmess,dn);
        throw cmwfwBadParameter(errmess);
    exit(-1);
  };
  if( !adp_ptr ){
        char* dn = iop.getDeviceName();
        char* e = "Unable to retrieve data for ";
        char* errmess = new char[strlen(dn) + strlen(e) + 5];
        if(!errmess)heaperr(94);
        strcat(errmess,e);
        strcat(errmess,dn);
        throw cmwfwBadParameter(errmess);
    exit(-1);
  };

  srv_ptr->iovalues->lock();
  iov_ptr1 = srv_ptr->getIOValue(iop,false);
  if(cs)
    iov_ptr2 = srv_ptr->getIOValue(iop_no_cs,false);

  if( (!iov_ptr1) && (!iov_ptr2) ){
    srv_ptr->iovalues->unlock();
    T(CMWFW_TRACE_CALLS,"Returning - no iovalues","","","");
        return;
  };

  try{
        adp_ptr->cmwfw_poll(iop,data_being_filled,vq_being_set);
  }
  catch(cmwfwIOError err){
        if(iov_ptr1)
          iov_ptr1->update(err);
        if(iov_ptr2)
          iov_ptr1->update(err);
    srv_ptr->iovalues->unlock();
    T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
        return;
  };
  if(iov_ptr1){
        iov_ptr1->update(data_being_filled,vq_being_set);
  };
  if(iov_ptr2){
        iov_ptr2->update(data_being_filled,vq_being_set);
  }
  srv_ptr->iovalues->unlock();
  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
  return;
};




void cmwfwPoller::poll(const cmwfwIOPoint& iop){
  char* myname = "cmwfwPoller::poll(iopoint)";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  cmwfwIOPoint* res  = 0;

  if(find(iop,res)){
        if(!res)          //Someone below took control of the iopoint management
      processIOP(iop);
        else              //iopoint management is at this level
      processIOP(*res);
  };

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




void cmwfwPoller::poll(){
  char* myname = "cmwfwPoller::poll";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  bool                 stat      = false;
  int                  stop      = 0;
  cmwfwIOPoint*        iop_ptr   = 0;

  iopoints->lock();
  iopoints->resetCurrent(false);
  stat = iopoints->getFirst(&iop_ptr,false);
  if(stat){
    processIOP(*iop_ptr);
  };
  while(stat){
    stat = iopoints->getNext(&iop_ptr,false);
        if(stat){
          processIOP(*iop_ptr);
        };
  };
  iopoints->unlock();

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





void cmwfwPoller::poll(cmwfwList<cmwfwIOPoint*>& list){
  char* myname = "cmwfwPoller::poll(iopoint list)";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  cmwfwIOPoint* iop_ptr = 0;

  list.resetCurrent();
  list.getFirst(&iop_ptr);
  while(iop_ptr){
    processIOP(*iop_ptr);
    list.getNext(&iop_ptr);
  };

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


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

  char l[30];
  itoa(line,l);
  E("Out of heap in line ",l,"","");
  T(CMWFW_TRACE_CALLS,"Exiting due to heap allocation error","","","");
  throw cmwfwInternalError(FILE,line,"Out of heap memory");
  exit(-1);
};

---