Discussion :

[luffydu22]

Bonjour lzq ami(e)s, voila j'ai un petit problème avec mon programme Qt, je passe par un thread qui gère le socket de mon programme.
le soucis st le suivant, via mon thread, je déclare et connecte mon socket dans la fonction run(), tout se passe nikel sauf que celui-ci ne reçois rien.
hors quand je passe par le thread principal, tout marche a merveille, c'est la que je comprend pas trop >_<.

j'ai bien essayer la méthode moveToThread(); mais sans résultat aussi.

voici l bout de code qui se connecte a mon socket

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
 
_socket->connectToHost("192.168.1.12", 9870);
 
 
		QByteArray _data;
		QDataStream packet(& _data, QIODevice::WriteOnly);
 
		packet << (quint16)CMSG_NEW_GUID_NEEDED;
		packet << (quint16)0;
		packet << (quint16)0;
 
		_socket->sendPacket(_data);

et voici ma classe qui gère les socket =) :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
#include "socket.h"
#include "Thread.h"
 
using namespace std;
 
socket::socket(QString host, uint port, MainThread* t)
{
	thread = t;
 
	//_socket = new QTcpSocket(this);
	//_socket->moveToThread(thread);
	connectToHost(host, port);
 
	connect(this , SIGNAL(readyRead()), this ,  SLOT(receive()));
	connect(this , SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(erreurSocket(QAbstractSocket::SocketError)));
 
}
 
socket::socket()
{
 
}
 
void socket::erreurSocket(QAbstractSocket::SocketError erreur)
{
 
    mLoger error_log;
    std::string str;
 
    switch(erreur) // On affiche un message différent selon l'erreur qu'on nous indique
    {
        case QAbstractSocket::HostNotFoundError:
           str =  "ERREUR : le serveur n'a pas pu être trouvé. Vérifiez l'IP et le port.</em>";
            break;
        case QAbstractSocket::ConnectionRefusedError:
           str = "ERREUR : le serveur a refusé la connexion. Vérifiez si le programme \"serveur\" a bien été lancé. Vérifiez aussi l'IP et le port.";
            break;
        case QAbstractSocket::RemoteHostClosedError:
           str = "ERREUR : le serveur a coupé la connexion.";
            break;
        default:            
           str = "ERREUR : " + errorString().toStdString();
 
	error_log << QString::fromStdString(str);
	error_log.write();
    }
}
 
void socket::receive()
 
{
	QDataStream in(this);
 
	quint16 opcode;
 
	in >> opcode;
 
	if(opcode >= TOTAL_NUM_MSG)
	{
		cout << "opcode inconnus : " << getOpcodeName(opcode) << endl;
		return;
	}
 
	_opcodeHandle const& opcodeHandle = opcodeTable[opcode];
 
	WorldSession* session = new WorldSession(thread);
 
	(session->*opcodeHandle.handler)(*&in);
 
}
 
void socket::sendPacket(QByteArray data)
{
 
 
		mLoger error_log;
 
		error_log << "Erreur " << errorString();
		error_log.write();
		write(data);
}

merci d'avance de votre aide

[luffydu22]

enfait, j'ai compris le soucis mais je sais pas comment le résoudre,
quand je me connecte avec mon socket a partir du thread principal via un fonction que j'ai dans ma classe de thread mon serveur reçois mes packet, hors quand le thread se connecte et essaie d'envoyer un packet, ya rien a faire, le serveur ne reçois rien.

quelqu'un aurais une solution ^^ ?

[sysedit]

Concernant les threads:
- assure toi que ton instance de la classe socket est créé dans son thread, et non pas dans le thread graphique (ou alors il faut effectivement faire un moveToThread).

- assure toi que le thread de communication est bien démarré (start() est bien appelé ?)

Après, concernant les sockets:
- connectToHost() n'est pas bloquant. Donc faire un connectToHost() suvi d'une opération d'écriture a de grande chance d'échouer si la connexion n'a pas eu le temps de se faire.
Ajoute un waitForConnected(), ou mieux, utilise le signal connected() pour savoir quand la connexion est faite.