VP1TcpServer Class Reference

#include <VP1TcpServer.h>

Inheritance diagram for VP1TcpServer:

Collaboration diagram for VP1TcpServer:

Classes
class	Imp

Public Slots
void	close ()

Signals
void	receivedExternalRequest (VP1ExternalRequest)
void	listenStateChanged (bool)

Public Member Functions
	VP1TcpServer ()
virtual	~VP1TcpServer ()
bool	listen (QString &err, const quint16 &port=4747)
quint16	port () const
bool	isListening ()

Private Slots
void	acceptConnection ()
void	readData ()
void	handleError (QAbstractSocket::SocketError)
void	socketDestroyed (QObject *)
void	listenStateMightHaveChanged ()

Private Attributes
Imp *	m_d

Detailed Description

Definition at line 22 of file VP1TcpServer.h.

Constructor & Destructor Documentation

VP1TcpServer()

VP1TcpServer::VP1TcpServer

(

)

Definition at line 35 of file VP1TcpServer.cxx.

  : QObject(), m_d(new Imp)
{
  m_d->lastemit_listen=-1;
  m_d->tcpserv=this;
  m_d->port=0;
  connect(&m_d->tcpserver, SIGNAL(newConnection()),this, SLOT(acceptConnection()));
 
  //
  QTimer * timer = new QTimer(this);
  timer->start(2000);
  connect(timer, SIGNAL(timeout()),this, SLOT(listenStateMightHaveChanged()));
}

~VP1TcpServer()

VP1TcpServer::~VP1TcpServer ( )

virtual

Definition at line 50 of file VP1TcpServer.cxx.

{
  close();
  delete m_d; m_d=0;
}

Member Function Documentation

acceptConnection

void VP1TcpServer::acceptConnection ( )

privateslot

Definition at line 107 of file VP1TcpServer.cxx.

{
  if (!m_d->tcpserver.hasPendingConnections())
    return;
  QTcpSocket * socket = m_d->tcpserver.nextPendingConnection();
  if (m_d->sockets2blocksize.contains(socket)) {
    //we are already dealing with this one, but look back here in a
    //short while to se if anything else is queued.
    QTimer::singleShot(100, this, SLOT(acceptConnection()));
    return;
  }
  assert(!m_d->sockets2blocksize.contains(socket));
  m_d->sockets2blocksize.insert(socket,0);
  connect(socket, SIGNAL(readyRead()),this, SLOT(readData()));
  connect(socket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(handleError(QAbstractSocket::SocketError)));
  connect(socket, SIGNAL(disconnected()),socket, SLOT(deleteLater()));
  connect(socket, SIGNAL(destroyed(QObject*)),this,SLOT(socketDestroyed (QObject*)));
  listenStateMightHaveChanged();
}

close

void VP1TcpServer::close ( )

slot

Definition at line 87 of file VP1TcpServer.cxx.

{
  if (!isListening())
    return;
  disconnect(&m_d->tcpserver, SIGNAL(newConnection()),this, SLOT(acceptConnection()));
 
  QMapIterator<QTcpSocket *,quint16> it(m_d->sockets2blocksize);
  while (it.hasNext()) {
    it.next();
    QTcpSocket * socket = it.key();
    delete socket;
  }
  m_d->sockets2blocksize.clear();
 
  m_d->tcpserver.close();
  m_d->port=0;
  listenStateMightHaveChanged();
}

handleError

void VP1TcpServer::handleError ( QAbstractSocket::SocketError  se )

privateslot

Definition at line 128 of file VP1TcpServer.cxx.

{
  if (se == QTcpSocket::RemoteHostClosedError)
    return;
  QTcpSocket * socket = m_d->recognisedSocket(sender());
  if (!socket)
    return;
  if (socket->state()!=QAbstractSocket::UnconnectedState) {
    socket->disconnectFromHost();
  }
  //   std::cout << "VP1TcpServer::Error during connection:"<<m_d->tcpserver.errorString().toStdString()<<std::endl;
  listenStateMightHaveChanged();
}

isListening()

bool VP1TcpServer::isListening

(

)

Definition at line 81 of file VP1TcpServer.cxx.

{
  return m_d->tcpserver.isListening();
}

listen()

bool VP1TcpServer::listen	(	QString &	err,
		const quint16 &	port = 4747
	)

Definition at line 57 of file VP1TcpServer.cxx.

                                                           {
  if (isListening())
    close();
  bool success = m_d->tcpserver.listen(QHostAddress::LocalHost,port);
  if (!success) {
    err = m_d->tcpserver.errorString();
    m_d->port=0;
    listenStateMightHaveChanged();
    return false;
  }
  m_d->port=port;
  err.clear();
 
  listenStateMightHaveChanged();
  return true;
}

listenStateChanged

void VP1TcpServer::listenStateChanged ( bool  )

signal

listenStateMightHaveChanged

void VP1TcpServer::listenStateMightHaveChanged ( )

privateslot

Definition at line 206 of file VP1TcpServer.cxx.

{
  bool l = isListening();
  bool last = m_d->lastemit_listen == 1 ? true : false;
  if (m_d->lastemit_listen==-1||(l!=last)) {
    listenStateChanged(l);
  }
  m_d->lastemit_listen = l ? 1 : 0;
}

port()

quint16 VP1TcpServer::port

(

)

const

Definition at line 75 of file VP1TcpServer.cxx.

{
  return m_d->port;
}

readData

void VP1TcpServer::readData ( )

privateslot

Definition at line 143 of file VP1TcpServer.cxx.

{
  QTcpSocket * socket = m_d->recognisedSocket(sender());
  if (!socket)
    return;
  if (socket->state()!=QAbstractSocket::ConnectedState) {
    //     assert(0&&"This should never happen...");
    return;
  }
 
  QDataStream in(socket);
  in.setVersion(QDataStream::Qt_4_2);
 
  //Make sure that we can read enough to determine the data length:
  if (m_d->sockets2blocksize[socket] == 0) {
    if (socket->bytesAvailable() < (int)sizeof(quint16))
      return;
    in >> m_d->sockets2blocksize[socket];
  }
 
  //Make sure that we can read all of the data:
  if (socket->bytesAvailable() < m_d->sockets2blocksize[socket])
    return;
 
  QString data;
  in >> data;
  //   qDebug(QString("Got: "+data).toStdString().c_str());
 
  if (m_d->sockets2blocksize.contains(socket)) {
    socket->disconnectFromHost();
  }
 
  //Notice that we dont fire any signals unless we positively see something that we know how to handle!
  if (data.startsWith("VP1ExternalRequest")) {
    VP1ExternalRequest request(data);
    if (request.isValid()) {
      //qDebug("Got valid VP1ExternalRequest!");
      receivedExternalRequest(request);
    }
  }
  listenStateMightHaveChanged();
}

receivedExternalRequest

void VP1TcpServer::receivedExternalRequest ( VP1ExternalRequest  )

signal

socketDestroyed

void VP1TcpServer::socketDestroyed ( QObject *  obj )

privateslot

Definition at line 196 of file VP1TcpServer.cxx.

{
  QTcpSocket * socket = static_cast<QTcpSocket *>(obj);
  if (!socket)
    return;
  if (m_d->sockets2blocksize.contains(socket))
    m_d->sockets2blocksize.remove(socket);
  listenStateMightHaveChanged();
}

Member Data Documentation

m_d

Imp* VP1TcpServer::m_d

private

Definition at line 51 of file VP1TcpServer.h.

---

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

• VP1TcpServer.h
• VP1TcpServer.cxx