qpidserverthread.cpp

Go to the documentation of this file.

#include "qpidserverthread.h"

#include "qpidserver.h"
#include <QMetaObject>
#include <QDateTime>
#include "qpidcontroller.h"
#include "qpiddebug.h"

QPidServerThread::QPidServerThread(QcepSettingsSaverWPtr saver, QPidControllerWPtr ctrl) :
  m_Saver(saver),
  m_Controller(ctrl),
  m_Server(NULL)
{
  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QPidServerThread::QPidServerThread(%p)\n", this);
  }
}

QPidServerThread::~QPidServerThread()
{
  shutdown();

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

QPidServerPtr QPidServerThread::server() const
{
  while (isRunning() && m_Server == NULL) {
    QThread::msleep(50);
  }

  return m_Server;
}

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

  wait();
}

void QPidServerThread::run()
{
  {
    QPidControllerPtr ctl(m_Controller);

    if (ctl && qcepDebug(DEBUG_THREADS)) {
      ctl->printMessage("Starting Server Thread");
    }

    QPidServerPtr server(new QPidServer(m_Saver, m_Controller));

    if (server) {
      m_Server = server;
    }
  }

  int rc = exec();

  {
    QPidControllerPtr ctrl(m_Controller);

    if (ctrl && qcepDebug(DEBUG_THREADS)) {
      ctrl->printMessage(tr("Server Thread Terminated with rc %1").arg(rc));
    }
  }
}

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