[Résolu] problème de lancement de threads par icare14 - page 1

salut,

j'ai fais un serveur et un client qui sont censé discuter.Dans le serveur j'utilise une boucle qui attent la connection d'un client et à chaque connection il est censé lancer un thread mais ... il le fait pas

. En fait il lance le tout premier thread mais aucun des suivants.

Voici le code du serveur :

#include <iostream>
#include <winsock2.h>
#include <windows.h>
#include <string>
#include <vector>
#define NBR_MAX_CLIENT 4
#define TAILLE_MESSAGE 4
using namespace std;
DWORD WINAPI threadsecoute(void* x);
CRITICAL_SECTION Sync;
struct thread_params
{
SOCKET sock;
int num;
char *tableau[NBR_MAX_CLIENT][TAILLE_MESSAGE];
bool *joueurexiste[NBR_MAX_CLIENT];
};
char associer(int nbr);
int main()
{
cout << "demarrage du serveur" <<endl;
WSADATA WSAData;//initialisation du WSAstartup
WSAStartup(MAKEWORD(2,0), &WSAData);
cout << "demarrage de WSAstartup" << endl;
SOCKET sock_ecoute;//creation du socket d ecoute
SOCKADDR_IN sin_ecoute;
sock_ecoute = socket(AF_INET, SOCK_STREAM, 0);
cout << "creation du socket" << endl;
int port;
cout << "reception au port : ";
cin >> port;
cout << endl;
// Configuration de la connexion en serveur
sin_ecoute.sin_addr.s_addr = htonl(INADDR_ANY);
sin_ecoute.sin_family = AF_INET;
sin_ecoute.sin_port = htons(port);
cout << "socket configuree" << endl;
bind(sock_ecoute, (SOCKADDR *)&sin_ecoute, sizeof(sin_ecoute));//association des infos
cout << "association des informations au socket" << endl;
listen(sock_ecoute, 5);//début de l'écoute
cout << "debut de l'attente des clients" << endl << endl;
SOCKET sock_mess;
SOCKADDR_IN sin_mess;//paramétrage
int poid = sizeof(sin_mess);
char tableauposition[NBR_MAX_CLIENT][TAILLE_MESSAGE];
bool joueur[NBR_MAX_CLIENT];
for(int i = 0;i<NBR_MAX_CLIENT; i++)
{
joueur[i] = false;
}
thread_params parametre;
vector<HANDLE> thread;
thread.resize(NBR_MAX_CLIENT);
int compteur = 0;
bool x = true;
InitializeCriticalSection(&Sync);
cout << "initialisation de la section critique" << endl;
while(x)
{
sock_mess = accept(sock_ecoute, (SOCKADDR *) &sin_mess, &poid);
cout << "client accepte" << endl;
cout << "infos client :" << endl << "socket : " << sock_mess <<endl;
cout << "adresse : " << inet_ntoa(sin_mess.sin_addr) << endl;
cout << "port : " << htons(sin_mess.sin_port) << endl << endl;
//creation des threads
parametre.sock = sock_mess;
parametre.num = compteur;
for(int i = 0; i < NBR_MAX_CLIENT; i++)
{
for(int j =0 ; j< TAILLE_MESSAGE; j++)
{
parametre.tableau[i][j] = &tableauposition[i][j];
}
parametre.joueurexiste[i] = &joueur[i];
}
thread[compteur] = (CreateThread(NULL,0,threadsecoute,&parametre,0,0));
Sleep(10);
if(compteur == NBR_MAX_CLIENT)
{
x = false;
}
compteur++;
}
//fin du programme début des libérations
cout << endl;
system("PAUSE");
cout << endl;
cout << endl << "fermeture du serveur" << endl;
closesocket(sock_ecoute);
cout <<"fermeture du socket d ecoute" << endl;
closesocket(sock_mess);
cout <<"fermeture du socket de reception" << endl;
WSACleanup();
cout << "fermeture de WSA" <<endl;
for(int i = 0; i < thread.size(); i++)
{
TerminateThread(thread[i],0);
cout << "thread n" << i + 1 <<" termine" << endl;
}
LeaveCriticalSection(&Sync);
cout << "section critique fermee " <<endl;
DeleteCriticalSection(&Sync);
cout << "section critique detruite" <<endl;
cout << "serveur ferme" <<endl<<endl;
system("PAUSE");
return 0;
}
DWORD WINAPI threadsecoute(void* x)
{
EnterCriticalSection(&Sync);//entré en section critique
bool continuer = true;
thread_params params;//structure contenant les informations pour le threads
if(x!= NULL)
{
struct thread_params *param = reinterpret_cast<struct thread_params *>(x);//convertir void* en struct
params.sock = param->sock;//initialisation de la structure
params.num = param->num;
for(int i = 0; i < NBR_MAX_CLIENT; i++)
{
for(int j = 0; j < TAILLE_MESSAGE; j++)
{
params.tableau[i][j] = param->tableau[i][j];
}
params.joueurexiste[i] = param->joueurexiste[i];
}
for(int i = 0; i < TAILLE_MESSAGE; i++)
{
*params.tableau[params.num][i] = '0';
}
cout << endl << "thread n" << params.num + 1<<" cree avec succes" << endl;
if(params.sock == SOCKET_ERROR)
{
continuer = false;
cout << "la creation du socket dans le threads a eu un probleme" << endl;
}
}
else
{
cout << "une erreur est survenue" << endl;
continuer = false;
}
cout << endl;
LeaveCriticalSection(&Sync);
char message[TAILLE_MESSAGE];//création des deux message
char messageenvoye[TAILLE_MESSAGE];
int y =0;
EnterCriticalSection(&Sync);
*params.joueurexiste[params.num] = true;//ce thread marche donbc il existe
while(continuer)//boucle de reception emission
{
if(recv(params.sock, message, sizeof(message), 0)!= SOCKET_ERROR)//si on reçoit correctement les messages
{
if(message[0] == 's' && message[1] == 'p')//on regarde si c'est pas un message de fin
{
send(params.sock, "sp",sizeof("sp"),0); //si c'est un message de fin on en renvoi un même
continuer = false;
}
EnterCriticalSection(&Sync);
for(int i = 0; i < TAILLE_MESSAGE; i++)
{
*params.tableau[params.num][i] = message[i];//on transmet le messageau programme
}
LeaveCriticalSection(&Sync);
}
else
{
continuer = false;
cout << "une erreur est survenue Erreur n" << WSAGetLastError() << endl;
}
EnterCriticalSection(&Sync);
for(int i = 0 ; i< NBR_MAX_CLIENT; i++)//on regarde combien de thread existe (donc nbr joueur)
{
if(*params.joueurexiste[i] == true && i!= params.num)//BUG
{
y++;//on incrémente le compteur
}
}
LeaveCriticalSection(&Sync);
messageenvoye[0] = associer(y);//on crée un message qui indiquera combien de message vont suivre
send(params.sock, messageenvoye,sizeof(messageenvoye),0);//on envoie le nombre de futur message
EnterCriticalSection(&Sync);
for(int i = 0; i < NBR_MAX_CLIENT; i++)//boucle qui envoie les messages
{
if(i != params.num && *params.joueurexiste[i] == true)
{
send(params.sock, *params.tableau[i], sizeof(*params.tableau[i]), 0);
y--;
}
}
LeaveCriticalSection(&Sync);
if(y > 0)//si le compteur n'est pas vide (donc pas tous les message envoyé
{
for(y; y !=0 ; y--)//on fait une boucle pour complèter
{
send(params.sock, "vide", sizeof("vide"), 0);
}
}
y = 0 ;//compteur revient à 0
Sleep(50);//on dort 50 ms
}//fin de la boucle de reception emission
EnterCriticalSection(&Sync);//on termine la socket
shutdown(params.sock, 2);//on termine la socket
cout << "fin du thread" << endl;
LeaveCriticalSection(&Sync);
}

Je suis désolé le code est un peu long mais je préfère tout mettre comme ça pas d'ambiguité (à noter que j'ai enlever une fonction nommée associer())

merci d'avance à ceux qui auront le courage de me lire et de m'aider

icare

icare14

27 novembre 2007 à 20:17:37

28 novembre 2007 à 20:24:49

je me permets de faire un petit up parce que malgrès mes nombreux essais ça marche toujours pas

alors si quelqu'un pouvait m'aider

29 novembre 2007 à 20:49:21

dernier petit up SVP

MatteX

30 novembre 2007 à 7:25:30

mets des traces... qu'est-ce que tu veux qu'on fasse avec un code aussi long? fait un petit programme avec des thread qui ne font pratiquement rien et essaye ton démarrage de threads

3 décembre 2007 à 22:10:51

est ce que vous pensez que ça peut être du au fait que je ne change pas de socket en chaque threads ? (la socket nommée sock_mess)

problème de lancement de threads

problème de lancement de threads

Supprimer

Modérer

Signaler le message aux modérateurs