epicsobject.cpp

Go to the documentation of this file.

#include "epicsobject.h"

#include <stdio.h>

QMutex EpicsObject::m_Mutex(QMutex::Recursive);

EpicsObject::EpicsObject(QString pvName, QObject *parent, int debug)
  : QObject(parent),
    m_PVName(pvName),
    m_ChannelID(0),
    m_EventID(0),
    m_HasEventHandler(0),
    m_Debug(debug)
{
//   printf("Epics Object %p Constructed - pvName = %s\n", this, qPrintable(pvName));

  changeConnection(pvName);
}

EpicsObject::~EpicsObject()
{
//   printf ("EpicsObject::~EpicsObject(\"%s\")\n", qPrintable(m_PVName));

  if (m_ChannelID) {
    SEVCHK(ca_clear_channel(m_ChannelID), 0);
    m_ChannelID = 0;
  }
}

QString EpicsObject::pvName()
{
  return m_PVName;
}

QString EpicsObject::toolTip()
{
  return m_PVName;
}

int EpicsObject::count()
{
  return ca_element_count(m_ChannelID);
}

void EpicsObject::connected()
{
  if (!m_HasEventHandler) {
    chtype typ = ca_field_type(m_ChannelID);

    SEVCHK(ca_create_subscription(typ, 0, m_ChannelID, DBE_VALUE|DBE_ALARM, 
                                  get_event_handler(), this, &m_EventID), NULL);

    m_HasEventHandler = 1;

//     printf("Channel %s connected\n", qPrintable(pvName()));
  }
}

void EpicsObject::disconnected()
{
}

chid EpicsObject::channelID()
{
  return m_ChannelID;
}

static void connection_handler(struct connection_handler_args args)
{
//   printf("%s EpicsArray Connection Handler called %ld\n",
//       ca_name(args.chid), args.op);

  EpicsObject* ob = (EpicsObject*) ca_puser(args.chid);

  if (ob) {
    if (args.op == CA_OP_CONN_UP) {
      ob->connected();
    } else {
      ob->disconnected();
    }
  }
}

void EpicsObject::changeConnection(QString pv)
{
//   printf("EpicsObject::changeConnection(this:%p,pvname:\"%s\",chann:%p)\n",
//       this, qPrintable(m_PVName), m_ChannelID);

  if (m_ChannelID) {
    SEVCHK(ca_clear_channel(m_ChannelID), 0);
    m_ChannelID = 0;
  }

  SEVCHK(ca_search(qPrintable(pv), &m_ChannelID), NULL);
  ca_set_puser(m_ChannelID, this); 
  SEVCHK(ca_change_connection_event(m_ChannelID, &connection_handler), NULL);

  m_PVName = pv;

  if (debug()) {
    printf("EpicsObject::changeConnection(this:%p,pvname:\"%s\",chann:%p)\n",
           this, qPrintable(m_PVName), m_ChannelID);
  }
}
  
int EpicsObject::debug()
{
  return m_Debug;
}

void EpicsObject::setDebug(int dbg)
{
  m_Debug = dbg;
}

void EpicsObject::settle(double t)
{
  ::ca_pend_event(t);
}

void EpicsObject::ca_pend_io(double t)
{
  ::ca_pend_io(t);
}