---

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

Go to the documentation of this file.

#include "cmwfwSubscribtionManager.h"
#include "cmwfwList.h"



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






cmwfwSubscribtionManager::cmwfwSubscribtionManager(){
  char* myname = "cmwfwSubscribtionManager::cmwfwSubscribtionManager";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  iopoints = new subman_list_type(true);
  if(!iopoints)heaperr(33);
  attach_iop_func = 0;
  detach_iop_func = 0;

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




cmwfwSubscribtionManager::~cmwfwSubscribtionManager(){
  char* myname = "cmwfwSubscribtionManager::~cmwfwSubscribtionManager";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  bool stat;
  int sz;
  cmwfwIOPoint* tmp_iop = 0;

  iopoints->Size(&sz,false);  //Do not use mutex - something is wrong since the
                                                          // subscribtionmanager is being brought down.
  if(sz > 0){
        iopoints->resetCurrent();
        stat = iopoints->getFirst(&tmp_iop,false);
        while(stat){
          delete tmp_iop;
          stat = iopoints->getNext(&tmp_iop,false);
        };
  };
    delete iopoints;

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



bool cmwfwSubscribtionManager::find(const cmwfwIOPoint& iop,
                                                                    cmwfwIOPoint*& dst){
  char* myname = "cmwfwSubscribtionManager::find";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  bool stat               = false;
  cmwfwIOPoint* iop_tmp   = 0;

  if( (attach_iop_func) || (detach_iop_func) ){
        dst = 0;
        return true;
  };


  iopoints->lock();
  iopoints->resetCurrent(false);
  stat = iopoints->getFirst(&iop_tmp,false);
  while( (stat) && (!(*iop_tmp == iop)) )
    stat = iopoints->getNext(&iop_tmp,false);

  if(stat){
    dst = iop_tmp;
    iopoints->unlock();
    T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
    return true;
  };
  dst = 0;
  iopoints->unlock();

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





bool cmwfwSubscribtionManager::attach(const cmwfwIOPoint& iop){
  char* myname = "cmwfwSubscribtionManager::attach";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  char*            cs         = iop.getCycleSelector();
  bool             stat       = false;
  cmwfwIOPoint*    res        = 0;
  cmwfwIOPoint*    iop_local  = 0;

  if(cs)T(CMWFW_TRACE_CLIENTS,"IOPoint ",iop.getDeviceName(),":",cs);
  else T(CMWFW_TRACE_CLIENTS,
                 "IOPoint ",iop.getDeviceName()," no cycleselector","");

  if( (attach_iop_func) ){
    T(CMWFW_TRACE_CALLS,"Returning user routine value - all ok","","","");
    return (*attach_iop_func)(this,iop);
  };

  if(!find(iop,res)){
        iop_local = new cmwfwIOPoint("","","","");
        if(!iop_local)heaperr(138);
        *iop_local = iop;
    stat = iopoints->insert(iop_local);
    T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
    return (stat);
  };
  T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
  return false;
};


bool cmwfwSubscribtionManager::detach(const cmwfwIOPoint& iop){
  char*              myname        = "cmwfwSubscribtionManager::detach";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  char*              cs            = iop.getCycleSelector();
  bool               stat          = false;
  cmwfwIOPoint*      res           = 0;


  if(cs)T(CMWFW_TRACE_CLIENTS,"IOPoint ",iop.getDeviceName(),":",cs);
  else T(CMWFW_TRACE_CLIENTS,
                 "IOPoint ",iop.getDeviceName()," no cycleselector","");

  if( (detach_iop_func) ){
    T(CMWFW_TRACE_CALLS,"Returning user routine value - all ok","","","");
    return (*detach_iop_func)(this,iop);
  };

  if(find(iop,res)){
    iopoints->remove(res);
        delete res;
    T(CMWFW_TRACE_CALLS,"Returning - all ok","","","");
    return true;
  };

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




void cmwfwSubscribtionManager::passOnIOPoints(
                                                           bool(*att_func)(cmwfwSubscribtionManager*,
                                                                                           const cmwfwIOPoint& iop),
                                                           bool(*det_func)(cmwfwSubscribtionManager*,
                                                                                           const cmwfwIOPoint& iop)){
  char* myname = "cmwfwSubscribtionManager::passOnIOPoints";
  T(CMWFW_TRACE_CALLS,"Entering","","","");

  attach_iop_func = att_func;
  detach_iop_func = det_func;

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




char* cmwfwSubscribtionManager::generateIOPString(const cmwfwIOPoint& iop){
  char* myname = "cmwfwSubscribtionManager::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 cmwfwSubscribtionManager::heaperr(int line){
  char* myname = "cmwfwSubscribtionManager";
  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);
};

---