added missing files
This commit is contained in:
parent
d96f6d8b91
commit
3f5035c38c
2 changed files with 53 additions and 0 deletions
29
servatrice/src/serversocketthread.cpp
Normal file
29
servatrice/src/serversocketthread.cpp
Normal file
|
@ -0,0 +1,29 @@
|
||||||
|
#include "serversocketthread.h"
|
||||||
|
#include "serversocketinterface.h"
|
||||||
|
#include "server_logger.h"
|
||||||
|
#include "main.h"
|
||||||
|
|
||||||
|
ServerSocketThread::ServerSocketThread(int _socketDescriptor, Servatrice *_server, QObject *parent)
|
||||||
|
: QThread(parent), server(_server), socketDescriptor(_socketDescriptor)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
ServerSocketThread::~ServerSocketThread()
|
||||||
|
{
|
||||||
|
quit();
|
||||||
|
wait();
|
||||||
|
}
|
||||||
|
|
||||||
|
void ServerSocketThread::run()
|
||||||
|
{
|
||||||
|
QTcpSocket *socket = new QTcpSocket;
|
||||||
|
socket->setSocketDescriptor(socketDescriptor);
|
||||||
|
logger->logMessage(QString("incoming connection: %1").arg(socket->peerAddress().toString()));
|
||||||
|
|
||||||
|
ssi = new ServerSocketInterface(server, socket);
|
||||||
|
connect(ssi, SIGNAL(destroyed()), this, SLOT(deleteLater()));
|
||||||
|
|
||||||
|
emit clientAdded(ssi);
|
||||||
|
|
||||||
|
exec();
|
||||||
|
}
|
24
servatrice/src/serversocketthread.h
Normal file
24
servatrice/src/serversocketthread.h
Normal file
|
@ -0,0 +1,24 @@
|
||||||
|
#ifndef SERVERSOCKETTHREAD_H
|
||||||
|
#define SERVERSOCKETTHREAD_H
|
||||||
|
|
||||||
|
#include <QThread>
|
||||||
|
|
||||||
|
class Servatrice;
|
||||||
|
class ServerSocketInterface;
|
||||||
|
|
||||||
|
class ServerSocketThread : public QThread {
|
||||||
|
Q_OBJECT
|
||||||
|
private:
|
||||||
|
Servatrice *server;
|
||||||
|
ServerSocketInterface *ssi;
|
||||||
|
int socketDescriptor;
|
||||||
|
public:
|
||||||
|
ServerSocketThread(int _socketDescriptor, Servatrice *_server, QObject *parent = 0);
|
||||||
|
~ServerSocketThread();
|
||||||
|
protected:
|
||||||
|
void run();
|
||||||
|
signals:
|
||||||
|
void clientAdded(ServerSocketInterface *client);
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif
|
Loading…
Reference in a new issue