Discussion :

[Benyou]

Bonjour,

Je suis entrain de créer un serveur multi-client avec des threads...
le problème apparaît lors de l'appel de ma fonction CreateThread
#
hProcessThread = CreateThread(NULL, 0,&server::ClientThread, &p,0,NULL);
#
et exactement dans le 3 éme paramètre parce ma fonction " ClientThread" doit retourner quelque chose ( je sais pas ce qu'elle doit retourner ) .

voilà mon code :

#

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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
server::server(int p)
{
	port = p;
	//running         = false;
}
 
 
int server::init()
{    
	WORD wVersionRequested;
	WSADATA	 Data;
	int error= (WSAStartup(MAKEWORD(2,2), &Data ));
 
	if(error != 0 )
	{
		cerr <<"WSAStartup a échoué "<< endl;
		return 1;
	}
	else
	{
			ServerAddr.sin_family = AF_INET;
			ServerAddr.sin_port = htons( port );   
		//	ServerAddr.sin_addr.s_addr=inet_addr("192.168.241.174");	
			ServerAddr.sin_addr.s_addr=htons(INADDR_ANY) ;	
	}
 
	cout <<"server correctement initialise" << endl;    
	return 0;   
}
 
DWORD WINAPI server::ClientThread(void * p)
{
 
		struct thread_param *Obj = (struct thread_param      *) p ;
	//coversion de p en objet de la structure thread_param 
		server *s = Obj->ser;		 // mettre le contenu de ser dans *s
 
 
		cout << "thread client demarre" << endl;
 
 
	char buffer[100];
			//**** envoi ****
 
				strcpy(buffer, "coucou \n");
				send(Obj->soc, buffer,strlen(buffer), 0);
				cout<<"message envoye"<<endl;
 
		int reponse = 0;	
			do
			{
			//	cout<<"******** reception ...********"<<endl;
				reponse = recv(Obj->soc, buffer, sizeof(buffer), 0);
				cout<<"reponse"<<reponse<<endl;
				buffer[reponse]='\0';
				cout<<"msg recu "<<buffer<<endl;
 
			}while(reponse=0);
 
 
	return 0;
}
 
int server::start ()
{
 
	SOCKADDR_IN  			ClientAddr;
	int          			ClientAddrLen;
	HANDLE       			hProcessThread;
 
 
	struct thread_param		p;
 
		ListeningSocket = socket(AF_INET, SOCK_STREAM, 0);
 
		if(ListeningSocket == INVALID_SOCKET)
		{
			perror("socket()");
			exit(-1);
		}
			cout <<"socket correctement creee" << endl;  
		if( bind( ListeningSocket, (SOCKADDR *)&ServerAddr, sizeof( ServerAddr ) ) == SOCKET_ERROR )
		{
			cerr<<"bind a echoue avec l'erreur "<< WSAGetLastError()<< endl;
			cerr<<"Le port est peut-être deja utilise par un autre processus "<< endl;
 
			return 1;
		} 
			cerr<<"Bind... "<< endl;
		if( listen( ListeningSocket, 5 ) == SOCKET_ERROR )
		{
	        cerr<<"listen a échoué avec l'erreur "<< WSAGetLastError()<< endl;
 
			return 1;
		} 
 
		cout <<"serveur demarre : a l ecoute du port "<<port<< endl; 
			running = true;
			ClientAddrLen = sizeof( ClientAddr );
		while(running)
		{			
	if(Newconnection = accept(ListeningSocket, (struct sockaddr *)&ClientAddr, &ClientAddrLen) == INVALID_SOCKET)
		{
 
	 cout<<"accept a echoue avec l erreur "<< WSAGetLastError() << endl;
 
			return 1;
		}
			p.ser=this;
			p.soc=Newconnection;
			cout<<"client connecte..."<<endl;
	hProcessThread = CreateThread(NULL, 0,&server::ClientThread, &p,0,NULL);
 
		if ( hProcessThread == NULL )
		{                       
	cerr <<"CreateThread a échoué avec l'erreur "<<GetLastError()<< endl;
		}
	}
	closesocket( ListeningSocket );
	WSACleanup();
	return 0;
}

#

Merci d'avance

[Emmanuel Deloget]

Si tu ne sais pas ce que ta fonction doit retourner, alors on ne peut pas vraiment t'aider

C'est toi qui choisi. Si tu n'en a rien à faire de la valeur de retour, renvoie 0. Si tu penses qu'un code de sortie peut être intéressant, alors n'hésite pas à renvoyer une valeur qui représente ton code de sortie. Tu peux ensuite récupérer cette valeur avec GetExitCodeThread()

Sur un autre point, dans ta fonction ClientThread :

Code :

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

1
2
3
4
5
 
	do
	{
		...
	} while(reponse=0);

Ne vas pas boucler très longtemps... (et il ne sert à rien d'initialiser reponse avant d'entrer dans la boucle).

[minnesota]

Salut,

Ben en fait sur le type de retour y'a pas le choix, puisqu’est utilisé l'api Windows CreateThread, il faut "obligatoirement" (hum ça sent le pléonasme) utiliser une fonction callback de "type threadProc" dont le prototype attendu est de la forme DWORD WINAPI ThreadProc(void* pParam), DWORD étant alors le type de retour.

Par ailleurs, pour que le code puisse compiler (par rapport à ce point, j'ai pas regardé le reste), y'a deux solutions, soit placer la fonction callback en dehors de la class, soit l'y inclure comme étant static...

[Benyou]

Bonjour,
j'ai trouvé la solution:

en fait la fonction CreateThread n'est pas une fonction membre de la classe Server, je n'aurai pas du mettre son prototype dans le fichier.h,

Bref Merci pour l'aide
et par rapport à la boucle

Code :

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

1
2
3
4
do
	{
		...
	} while(reponse=0);

cette boucle sert à afficher tant que ya des caractere à afficher, Mais je vois qu'elle ne marche pas et le probleme est dans mon appel de RECV

Code :

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

1
2
3
4
5
6
7
8
9
10
11
    char tabRecep[100];
	do
			{
				cout<<"******** reception ...********"<<endl;
				cout<<"reponse = "<<reponse<<endl;
				reponse=recv(sock, tabRecep, sizeof(tabRecep), 0);
				cout<<"reponse"<<reponse<<endl;
				tabRecep[reponse]='\0';
				cout<<"msg recu "<<tabRecep<<endl;
 
			}while(reponse=0);

le programme s’arrête à " recv(sock, tabRecep, sizeof(tabRecep), 0); "

merci de m'aider à trouver le problème

[jean.charlara]

socket bloquant, donc recv ne retournera que quand des données seront arrivées
bonne chance

[Emmanuel Deloget]

Indépendamment de l'appel bloquant à recv, cette boucle ne va s'exécuter qu'une seule fois. La condition reponse=0 n'est pas écrite correctement. Etant donné que c'est une expression valide, elle n'est pas signalée comme erronée par le compilateur, mais elle signifie :

* met 0 dans réponse
* test réponse != 0

Il faut réécrire la condition : reponse == 0 (et oui).