qxrdserverthread.cpp

Go to the documentation of this file.

#include "qxrddebug.h"
#include "qxrdserverthread.h"

#include "qxrdserver.h"
#include <QMetaObject>
#include <QDateTime>
#include "qxrdapplication.h"
#include "qxrdexperiment.h"
#include "qcepmutexlocker.h"

QxrdServerThread::QxrdServerThread(QcepSettingsSaverWPtr saver, QxrdExperimentWPtr doc, QString name) :
  m_Saver(saver),
  m_Experiment(doc),
  m_Name(name),
  m_Server(NULL)
{
  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QxrdServerThread::QxrdServerThread(%p)\n", this);
  }

  setObjectName("specserver");
}

QxrdServerThread::~QxrdServerThread()
{
  shutdown();

  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QxrdServerThread::~QxrdServerThread(%p)\n", this);
  }
}

QxrdServerPtr QxrdServerThread::server() const
{
  while (isRunning()) {
    {
      QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

      if (m_Server) return m_Server;
    }

    QThread::msleep(50);
  }

  return QxrdServerPtr();
}

void QxrdServerThread::shutdown()
{
  exit();

  wait();
}

void QxrdServerThread::run()
{
  if (qcepDebug(DEBUG_THREADS)) {
    printf("Spec Server Thread Started\n");
  }

  {
    QxrdServerPtr server(new QxrdServer(m_Saver, m_Experiment, m_Name));


    if (server) {
      m_Mutex.lock();
//      server -> moveToThread(g_Application->thread());
      m_Server = server;
      m_Mutex.unlock();
    }
  }

  int rc = -1;

  if (m_Server) {
    rc = exec();
  }

  {
    QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

    m_Server = QxrdServerPtr();
  }

  if (qcepDebug(DEBUG_THREADS)) {
    printf("Spec Server Thread Terminated with rc %d\n", rc);
  }
}

void QxrdServerThread::executeScript(QString cmd)
{
  emit execute(cmd);
}