forked from DragonPang/QtMultiThreadTcpServer
-
Notifications
You must be signed in to change notification settings - Fork 0
/
serverthread.cpp
51 lines (40 loc) · 1.16 KB
/
serverthread.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
#include "serverthread.h"
serverThread::serverThread(int sockDesc, QObject *parent) :
QThread(parent),
m_sockDesc(sockDesc)
{
}
serverThread::~serverThread()
{
m_socket->close();
}
void serverThread::run(void)
{
m_socket = new MySocket(m_sockDesc);
if (!m_socket->setSocketDescriptor(m_sockDesc)) {
return ;
}
connect(m_socket, &MySocket::disconnected, this, &serverThread::disconnectToHost);
connect(m_socket, SIGNAL(dataReady(const QString&, const QByteArray&)),
this, SLOT(recvDataSlot(const QString&, const QByteArray&)));
connect(this, SIGNAL(sendData(int, const QByteArray&)),
m_socket, SLOT(sendData(int, const QByteArray&)));
this->exec();
}
void serverThread::sendDataSlot(int sockDesc, const QByteArray &data)
{
if (data.isEmpty()) {
return ;
}
emit sendData(sockDesc, data);
}
void serverThread::recvDataSlot(const QString &ip, const QByteArray &data)
{
emit dataReady(ip, data);
}
void serverThread::disconnectToHost(void)
{
emit disconnectTCP(m_sockDesc);
m_socket->disconnectFromHost();
this->quit();
}