[QTCPSocket] Problème pour la réalisation d'un serveur multithread
Salut à tous,
je suis en train de réaliser un ensemble client serveur pour le boulot et je suis coincé.
Je n'arrive pas à trouver de moyen "propre" pour "passer" la socket au thread qui doit s'en occuper.
j'aimerai connecter la socket au thread pour que lorsque le client se déconnecte le thread se coupe mais j'ai des messages type :
"QSocketNotifier: socket notifiers cannot be enabled from another thread"
Je pense que c'est lié au fait que la socket est passé en argument pour le constructeur et non "construite" dans le run.
mais du coup je ne sais pas comment faire.
voila mon code :
lorsqu'une nouvelle connection est reçu :
(pour le moment je n'ai mis qu'un seul thread pour les tests ensuite je pense gérer ça en pool ou en threadlist)
Code:
1
2
3
4
5
6
7
| void ServerTcp::nouvelleConnexion(void)
{
QTcpSocket *nouveauClient = serveur->nextPendingConnection();
mThread = new MyThread(nouveauClient);
mThread->start();
} |
le constructeur
Code:
1
2
3
4
5
6
| MyThread::MyThread(QTcpSocket * soc)
{
MySocket=soc;
desc = new descripteurViper();
connected=true;
} |
le run....
Code:
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
|
void MyThread::run()
{
connect(MySocket,SIGNAL(disconnected()),this,SLOT(quit()));
ViPerTCPMessage *message = new ViPerTCPMessage();
QByteArray input;
QByteArray tempsize;
qint32 size=0;
int i=0;
send_0x0403();
while(1)
{
MySocket->waitForReadyRead(1000);
while(MySocket->bytesAvailable()>8)
{
tempsize=MySocket->read(4);
for(i=0;i<4;i++)
{
size = size << 8;
size+=tempsize[i];
}
QByteArray code = MySocket->read(4);
message->clear();
input.clear();
input.append(tempsize);
input.append(code);
input.append(MySocket->read(size));
message->SetMessage(input);
select_answer(message);
}
}
} |
merci à tous
