CodaObject.hxx

Go to the documentation of this file.

/*----------------------------------------------------------------------------*
*  Copyright (c) 2005        Southeastern Universities Research Association, *
*                            Thomas Jefferson National Accelerator Facility  *
*                                                                            *
*    This software was developed under a United States Government license    *
*    described in the NOTICE file included as part of this distribution.     *
*                                                                            *
*    E.Wolin, 25-Feb-2005, Jefferson Lab                                     *
*                                                                            *
*    Authors: Elliott Wolin                                                  *
*             wolin@jlab.org                    Jefferson Lab, MS-6B         *
*             Phone: (757) 269-7365             12000 Jefferson Ave.         *
*             Fax:   (757) 269-5519             Newport News, VA 23606       *
*
*----------------------------------------------------------------------------*/

#ifndef _CodaObject_hxx
#define _CodaObject_hxx


#include <cMsg.hxx>
#include <CodaException.hxx>
#include <iostream>
#include <sstream>
#include <iomanip>
#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
#include <algorithm>


#define MIN(a,b) ((a)<(b))?(a):(b)
#define MAX(a,b) ((a)>(b))?(a):(b)


// for daLogMsg
#define DALOG_INFO   1
#define DALOG_WARN   5
#define DALOG_ERROR  9
#define DALOG_SEVERE 13


namespace codaObject {

using namespace std;
using namespace cmsg;


//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------


template <class C, typename R, typename T> class pthreadDispatcher {
public:
  C *c;            
  R (C::*mfp)(T);  
  T mfArg;         
  pthreadDispatcher(C *c, R (C::*mfp)(T), T mfArg) : c(c), mfp(mfp), mfArg(mfArg) {}


  static void *dispatchIt(void *pthreadArg) {
    pthreadDispatcher *pd = static_cast<pthreadDispatcher*>(pthreadArg);
    pthread_exit((void*)(((pd->c)->*(pd->mfp))(pd->mfArg)));
    return(NULL);
  }
};


//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------


class CodaObject {
  
public:
  CodaObject(const string& UDL, const string& name, const string& descr, const string &codaClass = "user", 
             const cMsgSubscriptionConfig *scfg = NULL, int connTimeout = 10) throw(CodaException);
  virtual ~CodaObject(void) throw();


protected:
  virtual void sendResponse(const cMsgMessage *msg, const string& subject, const string& type, 
                            const string& text, int userInt) const throw(CodaException);
  virtual void userMsgHandler(cMsgMessage *msg, void *userArg) throw(CodaException);
  virtual string userStatus(void) const throw();
  

public:
  int daLogMsg(const string& text, int sevid, const string& daLogSubj="") const throw(CodaException);
  virtual void startProcessing(void) throw(CodaException);
  virtual void stopProcessing(void) throw(CodaException);

  string getObjectType(void) const throw();
  string getCodaClass(void) const throw();
  string getHostName(void) const throw();
  string getUserName(void) const throw();
  string getState(void) const throw();
  string getStatus(void) const throw();
  string getConfig(void) const throw();


public:
  void changeState(const string& newState) throw(CodaException);
  void changeStatus(const string& newStatus) throw(CodaException);


private:
  void codaObjectCallback(cMsgMessage *msg, void* userArg) throw(CodaException);
  string checkCodaClass(const string &cClass) const throw();


protected:
  virtual void daLogMsgFill(cMsgMessage &msg) const throw(CodaException);


protected:
  string UDL;          
  string name;         
  string descr;        
  string objectType;   
  string codaClass;    
  string hostName;     
  string userName;     
  string state;        
  string status;       
  string config;       
  const cMsgSubscriptionConfig *myscfg;    
public:
  cMsg *rcConn;           
private:
  cMsgCallback *codaCBD;  
  int connTimeout;        
public:
  string CodaObjectDaLogSubject;    
  static int debug;                 
};


//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------



}  // namespace codaObject

#endif /* _CodaObject_hxx */

---