QPidServer Class Reference

#include <qpidserver.h>

Inheritance diagram for QPidServer:

Public Slots
void	runModeChanged ()
void	serverPortChanged ()
void	openNewConnection ()
void	shutdown ()
void	deleteSession (QPidServerSessionWPtr sess)
void	deleteSessionLater (QPidServerSessionWPtr sess)
void	printMessage (QString msg, QDateTime ts=QDateTime::currentDateTime())
void	criticalMessage (QString msg)

Public Member Functions
	QPidServer (QcepSettingsSaverWPtr saver, QPidControllerWPtr ctrl)
virtual	~QPidServer ()
void	startServer (QHostAddress addr, int port)
void	stopServer ()
virtual void	readSettings (QSettings *settings, QString section)
virtual void	writeSettings (QSettings *settings, QString section)

Public Attributes
QPidObjectNamer	m_ObjectNamer

Properties
int	runPidServer
int	pidServerPort

Private Attributes
QPidControllerWPtr	m_Controller
QList< QPidServerSessionPtr >	m_Sessions

Detailed Description

Definition at line 12 of file qpidserver.h.

Constructor & Destructor Documentation

QPidServer::QPidServer ( QcepSettingsSaverWPtr  saver, QPidControllerWPtr  ctrl  )

explicit

Definition at line 8 of file qpidserver.cpp.

References openNewConnection(), runModeChanged(), and serverPortChanged().

                                                                           :
  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 ( )

virtual

Definition at line 27 of file qpidserver.cpp.

References stopServer().

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

  stopServer();
}

Member Function Documentation

void QPidServer::criticalMessage ( QString  msg )

slot

Definition at line 83 of file qpidserver.cpp.

References m_Controller.

Referenced by startServer().

{
  QPidControllerPtr ctl(m_Controller);

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

void QPidServer::deleteSession ( QPidServerSessionWPtr  sess )

slot

Definition at line 126 of file qpidserver.cpp.

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

void QPidServer::deleteSessionLater ( QPidServerSessionWPtr  sess )

slot

Definition at line 132 of file qpidserver.cpp.

References m_Sessions.

{
  QPidServerSessionPtr p(sess);

  int i = m_Sessions.indexOf(p);

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

void QPidServer::openNewConnection ( )

slot

Definition at line 117 of file qpidserver.cpp.

References m_Controller, and m_Sessions.

Referenced by QPidServer().

{
  QPidServerSessionPtr session = QPidServerSessionPtr(new QPidServerSession(QPidServerPtr(this), m_Controller, QTcpSocketPtr(nextPendingConnection())));

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

void QPidServer::printMessage ( QString  msg, QDateTime  ts = QDateTime::currentDateTime()  )

slot

Definition at line 74 of file qpidserver.cpp.

References m_Controller.

Referenced by startServer().

{
  QPidControllerPtr ctl(m_Controller);

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

void QPidServer::readSettings ( QSettings *  settings, QString  section  )

virtual

Definition at line 36 of file qpidserver.cpp.

References runModeChanged().

{
  QcepProperty::readSettings(this, &staticMetaObject, section, settings);

  runModeChanged();
}

void QPidServer::runModeChanged ( )

slot

Definition at line 48 of file qpidserver.cpp.

References startServer(), and stopServer().

Referenced by QPidServer(), and readSettings().

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

void QPidServer::serverPortChanged ( )

slot

Definition at line 61 of file qpidserver.cpp.

References startServer(), and stopServer().

Referenced by QPidServer().

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

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

void QPidServer::shutdown ( )

slot

Definition at line 143 of file qpidserver.cpp.

{
  close();

  thread()->exit();
}

void QPidServer::startServer	(	QHostAddress	addr,
		int	port
	)

Definition at line 92 of file qpidserver.cpp.

References criticalMessage(), and printMessage().

Referenced by runModeChanged(), and serverPortChanged().

{
  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

(

)

Definition at line 110 of file qpidserver.cpp.

Referenced by runModeChanged(), serverPortChanged(), and ~QPidServer().

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

void QPidServer::writeSettings ( QSettings *  settings, QString  section  )

virtual

Definition at line 43 of file qpidserver.cpp.

{
  QcepProperty::writeSettings(this, &staticMetaObject, section, settings);
}

Member Data Documentation

QPidControllerWPtr QPidServer::m_Controller

private

Definition at line 47 of file qpidserver.h.

Referenced by criticalMessage(), openNewConnection(), and printMessage().

QPidObjectNamer QPidServer::m_ObjectNamer

Definition at line 19 of file qpidserver.h.

QList<QPidServerSessionPtr> QPidServer::m_Sessions

private

Definition at line 48 of file qpidserver.h.

Referenced by deleteSessionLater(), and openNewConnection().

Property Documentation

int QPidServer::pidServerPort

readwrite

Definition at line 24 of file qpidserver.h.

int QPidServer::runPidServer

readwrite

Definition at line 21 of file qpidserver.h.

---

The documentation for this class was generated from the following files:

• qpidserver.h
• qpidserver.cpp