qscan345server.cpp

Go to the documentation of this file.

#include <QTcpSocket>
#include <QTextStream>
#include "qscan345server.h"
#include "qscan345mainwindow.h"

QScan345Server::QScan345Server(QScan345MainWindow* win, QObject *parent)
  : inherited(parent),
    m_MainWindow(win),
    m_Socket(NULL)
{
  connect(this, SIGNAL(newConnection()),
          this, SLOT(openNewConnection()));

  connect (this, SIGNAL(print_message(QString)), 
           m_MainWindow, SLOT(display_message(QString)));
}

void 
QScan345Server::startServer(QHostAddress a, int p)
{
  setMaxPendingConnections(1);

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

  if (!listen(a, p)) {
    qWarning("Failed to bind to address %s port %d",
             qPrintable(a.toString()), p);
  }
}

void
QScan345Server::openNewConnection()
{
  m_Socket = nextPendingConnection();

  connect(m_Socket, SIGNAL(disconnected()),
          m_Socket, SLOT(deleteLater()));

  connect(m_Socket, SIGNAL(readyRead()),
          this,     SLOT(clientRead()));

  emit print_message(QString("New connection from %1")
                     .arg(m_Socket->peerAddress().toString()) );

  connect(m_Socket, SIGNAL(disconnected()),
          this,     SLOT(connectionClosed()));
}

void
QScan345Server::connectionClosed()
{
  emit print_message("Client closed connection");
}

void
QScan345Server::clientRead()
{
  QTextStream ts( m_Socket );

  while ( m_Socket->canReadLine() ) {
    QString str = ts.readLine();

    emit print_message(tr("Command: %1 received\n").arg(str));
    
    emit execute_command(str);
  }
}

void
QScan345Server::scan_finished()
{
  if (m_Socket && (m_Socket->isWritable())) {
    m_Socket -> write("scan finished\n");
  }
}

void
QScan345Server::erase_finished()
{
  if (m_Socket && (m_Socket->isWritable())) {
    m_Socket -> write("erase finished\n");
  }
}