qpidserver.cpp

Go to the documentation of this file.

#include "qpidserver.h"
#include "qpidcontroller.h"
#include "qpiddebug.h"
#include <QThread>
#include <QTcpSocket>
#include "qpidserversession.h"

QPidServer::QPidServer(QcepSettingsSaverWPtr saver, QPidControllerWPtr ctrl) :
  QTcpServer(NULL),
  m_ObjectNamer(this, "socketServer"),
  m_RunPidServer(saver, this,"runPidServer", 1, "Run Simple Socket Server?"),
  m_PidServerPort(saver, this,"pidServerPort", 1234, "Port for Simple Socket Server"),
  m_Controller(ctrl)
{
  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QPidServer::QPidServer(%p)\n", this);
  }

  qRegisterMetaType<QPidServerSessionWPtr>("QPidServerSessionWPtr");

  connect(prop_RunPidServer(), SIGNAL(valueChanged(int,int)), this, SLOT(runModeChanged()));
  connect(prop_PidServerPort(), SIGNAL(valueChanged(int,int)), this, SLOT(serverPortChanged()));

  connect(this, SIGNAL(newConnection()), this, SLOT(openNewConnection()));
}

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

  stopServer();
}

void QPidServer::readSettings(QSettings *settings, QString section)
{
  QcepProperty::readSettings(this, &staticMetaObject, section, settings);

  runModeChanged();
}

void QPidServer::writeSettings(QSettings *settings, QString section)
{
  QcepProperty::writeSettings(this, &staticMetaObject, section, settings);
}

void QPidServer::runModeChanged()
{
  if (QThread::currentThread() != thread()) {
    QMetaObject::invokeMethod(this, "runModeChanged");
  } else {
    if (get_RunPidServer()) {
      startServer(QHostAddress::Any, get_PidServerPort());
    } else {
      stopServer();
    }
  }
}

void QPidServer::serverPortChanged()
{
  if (QThread::currentThread() != thread()) {
    QMetaObject::invokeMethod(this, "serverPortChanged");
  } else {
    stopServer();

    if (get_RunPidServer()) {
      startServer(QHostAddress::Any, get_PidServerPort());
    }
  }
}

void QPidServer::printMessage(QString msg, QDateTime ts)
{
  QPidControllerPtr ctl(m_Controller);

  if (ctl) {
    ctl->printMessage(msg, ts);
  }
}

void QPidServer::criticalMessage(QString msg)
{
  QPidControllerPtr ctl(m_Controller);

  if (ctl) {
    ctl->criticalMessage(msg);
  }
}

void QPidServer::startServer(QHostAddress addr, int port)
{
  if (qcepDebug(DEBUG_SERVER)) {
    printMessage(tr("Starting simple server on address %1, port %2")
                 .arg(addr.toString()).arg(port));
  }

  setMaxPendingConnections(10);

  if (isListening()) {
    close();
  }

  if (!listen(addr, port)) {
    criticalMessage(tr("Failed to bind to address %1 port %2\nIs there another copy running already?").arg(addr.toString()).arg(port));
  }
}

void QPidServer::stopServer()
{
  if (isListening()) {
    close();
  }
}

void QPidServer::openNewConnection()
{
  QPidServerSessionPtr session = QPidServerSessionPtr(new QPidServerSession(QPidServerPtr(this), m_Controller, QTcpSocketPtr(nextPendingConnection())));

  if (session) {
    m_Sessions.append(session);
  }
}

void QPidServer::deleteSession(QPidServerSessionWPtr sess)
{
  INVOKE_CHECK(
        QMetaObject::invokeMethod(this, "deleteSessionLater", Qt::QueuedConnection, Q_ARG(QPidServerSessionWPtr, sess)));
}

void QPidServer::deleteSessionLater(QPidServerSessionWPtr sess)
{
  QPidServerSessionPtr p(sess);

  int i = m_Sessions.indexOf(p);

  if (i>=0) {
    m_Sessions.removeAt(i);
  }
}

void QPidServer::shutdown()
{
  close();

  thread()->exit();
}