[MFC] Threads et Notifications (OnReceive, etc)

Version imprimable

Bonjour, c'est encore moi ^^"

Décidement chaque fois que je règle un problème, j'en ai un autre ;_;

J'utilise des sockets dans des threads, pour pouvoir utiliser les notifications d'événements comme le OnReceive, il faut faire un detach du handle du socket avant de rentrer dans la thread, et faire un attach(handle) à l'initialisation de la thread.

Jusque là tout va bien, mais je n'ai aucune notification qui se déclenche, je ne comprends pas vraiment pourquoi ça ne fonctionne pas.

Je mets la code de mon appel de thread :

Code:

pThreadReceive = (MyThreadRS*)AfxBeginThread( RUNTIME_CLASS( MyThreadRS ), THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED);

Mon code de detach et de resume thread (dans ma thread principale) :
Code:

1 2 hConnected = incomingSock->Detach(); pThreadReceive->ResumeThread();
Et le code de ma thread :
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 BOOL MyThreadRS::InitInstance() { Connection *m_connect = new Connection; m_sConnected.Attach(hConnected); TRACE("MyThreadRS::InitInstance\n"); if (!AfxSocketInit()) { return FALSE; } InitFile(); while(true) { SingleStep(); Sleep(2000); } m_sConnected.Detach(); return TRUE; } void MyThreadRS::SingleStep() { ARGUMENTS MyArguments; if(!m_pArOut->IsBufferEmpty()) { m_pArOut->Write(&MyArguments, sizeof(ARGUMENTS)); m_pArOut->Flush(); TRACE("MyThreadRS::SingleStep : m_pArOut Flush\n"); } TRACE("MyThreadRS::SingleStep\n"); } void MyThreadRS::InitFile() { m_pFile = new CSocketFile(&m_sConnected); m_pArIn = new CArchive(m_pFile,CArchive::load); m_pArOut = new CArchive(m_pFile,CArchive::store); TRACE("MyThreadRS::InitFile\n"); }
Le Sleep n'est là que pour ne pas avoir trop de trace en éxécution.

En plus, au début de l'enclenchement de ma thread, je fais un flush d'une structure vide mais ça passe en éxécution.

Je devrais avoir des notifications d'événement normalement mais je n'en ai pas...
Peut etre que j'ai mal compris ce qu'il est mis dans MSDN... (je mets les liens au cas où)

http://support.microsoft.com/default.aspx?scid=kb;EN-US;175668
http://msdn.microsoft.com/library/default.asp?url=/library/en-us/dv_wcemfc4/html/aflrfcsocketcolcolattach.asp

Si quelqu'un connait le problème, ce serait gentil de m'aider, je désespère là ;_;

13/04/2005, 13h01
farscape
une precision :
sur la ligne hConnected = incomingSock->Detach();
le hConnected tel qu'il est ecrit ne fait pas partie du thread généré .
moi j'aurais vu plutot:
Code:

1 2 pThreadReceive->hConnected = incomingSock->Detach();
non ?
:D
13/04/2005, 13h09
Kaori

Erf oui, je vais voir tout de suite ^^"

Mais alors je déclare le handle dans le thread?

Je viens d'essayer, ça ne fonctionne pas non plus comme ça.

J'ai déclaré le handle comme ça :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
class MyThreadRS : public CWinThread
{
	DECLARE_DYNCREATE(MyThreadRS)
 
public:
	SOCKET hConnected;
	Connection *m_connect;
	CSocket m_sConnected;
	CSocketFile *m_pFile;
	CArchive *m_pArIn;
	CArchive *m_pArOut;
	~MyThreadRS                 ();
	void SingleStep             ();
	void InitFile               ();
	virtual BOOL InitInstance   ();
};

13/04/2005, 13h35
farscape
heu pourquoi tu detaches la socket dans initinstance du thread ?
Code:

1 2 m_sConnected.Detach();
13/04/2005, 13h39
Kaori

Bah euh c'est pour le détacher quand j'en ai plus besoin, actuellement j'ai une boucle infinie mais plus tard j'aurai une boucle qui aura une autre condition et je pensais qu'il fallait redétacher le handle quand on avait fini la thread :/

Je vais voir si ça passe là quand meme ^^"

EDIT : Je viens de vérifier, il ne passe jamais par cette instruction actuellement, donc je ne pense pas que ce soit ça le problème
13/04/2005, 13h50
farscape

Note:
je pas sur que ça soit tres bon de limiter le traitement dans une boucle infinie dans initinstance c'est pas fait pour ....
de plus la pompe a message du thread risque de ne pas etre actif...

:D
13/04/2005, 13h54
Kaori

C'est parce que je ne sais pas du tout comment s'utilisent ces thread, j'ai fait ça un peu à pouf je dirais, je ne sais pas du tout comment entrer dans une méthode d'un tel thread, j'ai juste compris que le initinstance est appellé automatiquement :/
13/04/2005, 14h42
farscape

et bien le traitement de reception se fait par la fonction OnReceive
de la socket cliente créer.
si le thread doit envoyer des données tu envois un message privé au thread et celui çi devra traiter l'envoi.
la difference avec un workerthread c'est que ton thread dispose d'une pompe a message.
:D
13/04/2005, 14h45
Kaori

Oui mais justement, ma fonction OnReceive n'est jamais appellée :/
13/04/2005, 14h58
farscape

tu as bien fait le accept de la socket cliente a partir de la socket principale d'attente ?

Voui, normalement ça c'est ok, je fais comme ça :

Code:

1
2
3
4
5
6
7
8
9
void Server::OnAccept(int nErrorCode)
{
	/* Le serveur accepte automatiquement les connexions des clients
	   grâce à la fonction surchargée OnAccept de la classe CAsyncSocket
	*/
	CSocket::OnAccept(nErrorCode);
	TRACE("On Accept Server\n");
	m_connect->AcceptProcess();
}

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
int Connection::AcceptProcess()
{
	TRACE("AcceptProcess de Connection\n");	
	if (serverSock->Accept(*incomingSock))
	{
		TRACE("Connexion acceptee\n");
		InitArchive(incomingSock);
		TRACE("(incomingSock = %.8x)\n", incomingSock);
		pThreadReceive->hConnected = incomingSock->Detach();
		pThreadReceive->ResumeThread();
	}
	else
	{
		delete incomingSock;
		incomingSock = NULL;
	}
	return 0;
}

13/04/2005, 15h07
farscape

pourquoi je ne vois pas la creation de l'objet incomingSock dans ton code ?
:D

Parce qu'il est dans le constructeur de ma classe :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 Connection::Connection() { // Création des différents sockets nécéssaires pour les transferts TRACE("Connection : Constructeur\n"); serverSock = new Server(this); clientSock = new Client(this); incomingSock = new Client(this); m_pFile = NULL; m_pArOut = NULL; m_pArIn = NULL; InitFIFO(); InitThread(); }
Je dois certainement encore faire une erreur tout bête quelque part, mais je n'arrive pas à trouver où ;_;

autre point la creation du thread devrais se faire dans cette portion de code non ?:

Code:

1
2
3
4
5
6
7
8
9
 
if (serverSock->Accept(*incomingSock))
   {
      TRACE("Connexion acceptee\n");
      InitArchive(incomingSock);
      TRACE("(incomingSock = %.8x)\n", incomingSock);
      pThreadReceive->hConnected = incomingSock->Detach();
      pThreadReceive->ResumeThread();
   }

13/04/2005, 15h29
Kaori

En fait je devrai avoir 4 thread en tout, et ils devront etre créés qu'on soit coté serveur ou coté client, donc je les crée à l'inialisation pour ne pas avoir deux fois la meme portion de code dans deux méthodes différentes.

Ca peut poser des problèmes de faire comme ça?
13/04/2005, 15h37
farscape

hum c'est pas clair pour moi,
le thread client coté serveur devrait etre créé sur l'accept de la connexion cliente.
13/04/2005, 15h43
Kaori

Et la façon de le créer peut rester le meme? Si je dois faire une manip spéciale, je ne sais pas laquelle il faudrait que je fasse ^^"

Je vais tenter ça
13/04/2005, 15h46
Kaori

J'ai juste changé l'endroit de création de thread par couper-coller, mais ça ne change rien, je n'ai tjrs pas de notification :/