probleme thread linux (pthread)

probleme thread linux (pthread) - C - Programmation

Marsh Posté le 17-08-2009 à 15:20:27    

Bonjour,
 
J'ai un problème de threads sous linux ubuntu 9.04.
Je code en C avec la bibliothèque <sys/socket.h>.
 
Avant de poster le code j'explique mon probleme :
Je dois réaliser un module de gestion de message (HTTP/TCP),  
et je me place entre un serveur S et un client C.
 
J'utilise LibCurl pour quelques étapes.
 
L'étape 1 consiste à réceptionner une requete HTTP de C
L'étape 2 consiste à la renvoyer à S.
S nous répond, on réceptionne la requette et on la relance a C.
 
Dans le principe, c'est simple. Mais l'on reçoit une cinquantaine de requete HTTP de C,
donc l'emploi des threads s'impose, et là c'est le drame (corruption de mémoire, etc.)
 
Il faut savoir que si je met les threads en mode JOIN, le programme marche !
Mais le but est bien entendu de lancer les 50 threads d'un coup, pas l'un a la suite de l'autre.
 
Voici la partie principale du code :
 

Code :
  1. if((socket_server = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
  2. {
  3.  printf("Socket creation error !\n" );
  4.  return EXIT_FAILURE;
  5. }
  7. // nous : on écoute sur le port HTTP (80) en local
  8. sockaddr_server.sin_family = AF_INET;
  9. sockaddr_server.sin_port = htons(80);
  10. sockaddr_server.sin_addr.s_addr = inet_addr("127.0.0.1" );
  12. server_len = sizeof(sockaddr_server);
  13. client_len = sizeof(sockaddr_client);
  16. if(setsockopt(socket_server, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {
  17.  printf("setsockopt" );
  18.  return EXIT_FAILURE;
  19. }
  22. if(bind(socket_server, (struct sockaddr*)&sockaddr_server, server_len) < 0)
  23. {
  24.  printf("Socket bind error !\n" );
  25.  return EXIT_FAILURE;
  26. }
  28. if(listen(socket_server, 10) != 0)
  29. {
  30.  printf("Socket listen error !\n" );
  31.  return EXIT_FAILURE;
  32. }
  34. int bEnd = 0;
  35. int iThreadNumber = 1;
  37.  pthread_attr_init(&attr);
  38. pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);
  40. while(bEnd == 0)//boucle infinie pour le moment
  41. {
  42.  printf("[~]Waiting connection... \n" );
  43.  socket_client = accept(socket_server, (struct sockaddr*)&sockaddr_client, (socklen_t *)&client_len);
  45.  if(socket_client > 0)
  46.  {
  47.   printf("Recu une connection... socket %i\n",socket_client);
  48.   printf("IP du client : %s\n",inet_ntoa(sockaddr_client.sin_addr));
  49.   printf("Port du client : %i\n",ntohs(sockaddr_client.sin_port));
  50.   time(&date);
  51.   printf("[!]Established connection at %s\n", ctime(&date));
  54.   // reception du paquet HTTP
  55.   nbOctects = 0;
  56.   memset(requestHTTP,0,MAX_RECEPT);
  57.   if(   (nbOctects = read(socket_client, &requestHTTP, MAX_RECEPT))    < 0)
  58.   {
  59.    printf("Socket recv error !" );
  60.    return EXIT_FAILURE;
  61.   }
  63.   requestHTTP[nbOctects] = '\0';
  65.   printf("\n" );
  66.   printf("ETAPE 1 : Requete HTTP entière : (%d octects)\n", nbOctects);
  67.   //printf("%s\n", requestHTTP);  
  68.   /////////////////////////////////////////////////////////////////////////////////////////////////////////////     
  70.   // Gestion des threads :
  71.   ex = (struct infosThread *)malloc(sizeof(struct infosThread));
  72.   memset(ex,0,sizeof(struct infosThread));
  74.   if(ex!=NULL)
  75.   {
  76.    memcpy(&(ex->iSocketTCPClient),&socket_client, sizeof(socket_client));
  77.    memcpy(&(ex->iSizeRequetteHTTP),&nbOctects, sizeof(nbOctects));
  78.    memcpy(&(ex->iThreadNumber),&iThreadNumber, sizeof(iThreadNumber));
  80.    ex->cRequetteHTTP = (char *)malloc(sizeof(char) * nbOctects);
  81.    memcpy(ex->cRequetteHTTP,requestHTTP, nbOctects);
  82.    ex->cRequetteHTTP[nbOctects]='\0';
  84.   }else{
  85.    printf("probleme structure declaration\n" );
  86.   }
  88.   //lancement de la thread (etape 2 a finale)
  89.   printf("\n" );
  90.   printf(" --------------------------------------------- \n" );
  91.   printf(" LANCEMENT THREAD NUMERO %i sur socket %i\n",iThreadNumber,ex->iSocketTCPClient);
  93.   pthread_t thread;
  94.   usleep(10); // 10 ms
  95.   rc = pthread_create(&thread, &attr, print_message_function, (void *)ex);
  97.   if(rc != 0)
  98.   {
  99.    printf ("pthread_create error for thread\n" );
  100.    exit(0);
  101.   }
  102.   else
  103.   {
  104.    iThreadNumber++;//thread suivante
  105.   }
  107.   if(ex->cRequetteHTTP !=NULL){
  108.    free(ex->cRequetteHTTP);
  109.    ex->cRequetteHTTP= NULL;
  110.   }
  112.   if(ex!=NULL){
  113.    free(ex);
  114.    ex=NULL;
  115.   }
  117.  }
  118. }


 
 
Voici la fonction threadée :
 

Code :
  1. void * print_message_function( void *ptr )
  2. {
  3. char * requestHTTP = NULL;
  4. // récupération des données :
  5. int iSocketTCPClient = 0;
  6. int iSizeRequetteHTTP = 0;
  7. int iThreadNumber = 0;
  9. memcpy(&iSocketTCPClient,&(((struct infosThread *)(ptr))->iSocketTCPClient), sizeof(int));
  10. memcpy(&iSizeRequetteHTTP,&(((struct infosThread *)(ptr))->iSizeRequetteHTTP), sizeof(int));
  11. memcpy(&iThreadNumber,&(((struct infosThread *)(ptr))->iThreadNumber), sizeof(int));
  13. printf("iSocketTCPClient : %i\n",iSocketTCPClient);
  14. printf("iSizeRequetteHTTP : %i\n",iSizeRequetteHTTP);
  15. printf("iThreadNumber : %i\n",iThreadNumber);
  17. // PARFOIS iSocketTCPClient = 0 ! BUG !
  18. if(iSocketTCPClient > 0 && iSizeRequetteHTTP >0 && iThreadNumber >0)
  19. {
  20. requestHTTP = (char *)malloc(iSizeRequetteHTTP);// ici ça change la taille du ptr
  22. memset(requestHTTP,0,iSizeRequetteHTTP);
  23. memcpy(requestHTTP,((struct infosThread *)(ptr))->cRequetteHTTP,iSizeRequetteHTTP);
  25. requestHTTP[iSizeRequetteHTTP] = '\0';
  26. printf("taille  : %i     taille : %i    taille:%i\n",iSizeRequetteHTTP,strlen(requestHTTP),strlen(((struct infosThread *)(ptr))->cRequetteHTTP));
  28. printf("cRequetteHTTP :\n %s ",requestHTTP);
  31. /////////////////////////////////////////////////////////////////////////////////////
  32. //autres variables : (gestion des fichiers temporaires suivant les threads)
  33. char REQUEST_HTTP_THREAD[40]="";
  34. char RESPONSE_THREAD[40]="";
  36. sprintf(REQUEST_HTTP_THREAD,"thread_%i_1_requetteHTTP",iThreadNumber);
  37. sprintf(RESPONSE_THREAD,"thread_%i_2_reponse",iThreadNumber);
  39. /////////////////////
  40. // lancer le processus :
  42. printf("etape2\n" );
  43. /////////////////////////////////////////////////////////////////////////////////////////////////////////////     
  44. // ETAPE 2 : renvoyer la requete vers les serveurs
  45. CURL *curl = NULL;
  46. CURLcode res = 0;
  48. int sockfd = 0;
  49. size_t iolen = 0;
  50. curl = curl_easy_init();
  51. if(curl)
  52. {
  53.  // ici on met l'IP du server
  54.  curl_easy_setopt(curl, CURLOPT_URL, IP_SERVER);
  56.  // Do not do the transfer - only connect to host
  57.  curl_easy_setopt(curl, CURLOPT_CONNECT_ONLY, 1L);
  58.  res = curl_easy_perform(curl);
  60.  if(CURLE_OK != res)
  61.  {
  62.   printf("Error: %s\n", strerror(res));
  63.   //return 1;
  64.  }
  67.  // Extract the socket from the curl handle - we'll need it for waiting
  68.  res = curl_easy_getinfo(curl, CURLINFO_LASTSOCKET, &sockfd);
  69.  //int flags = fcntl (sockfd, F_GETFL);
  70.  //fcntl (sockfd, F_SETFL, flags | O_NONBLOCK);  
  72.  if(res != CURLE_OK)
  73.  {
  74.   printf("Error: %s\n", strerror(res));
  75.   //return 1;
  76.  }
  78.  // wait for the socket to become ready for sending
  79.  if(!wait_on_socket(sockfd, 0, 10000L))
  80.  {
  81.   printf("Error: timeout.\n" );
  82.   //return 1;
  83.  }
  85.  printf("Sending request (thread(%i)) from TV to Server\n",iThreadNumber);
  86.  // sauvegarde de la requete dans un fichier :
  87.  FILE * pRequestHTTP = fopen(REQUEST_HTTP_THREAD, "wb" );
  88.  if(pRequestHTTP)
  89.  {
  90.   fwrite(requestHTTP,1,iSizeRequetteHTTP,pRequestHTTP);
  91.   fclose(pRequestHTTP);
  92.  }//  
  93.  // Send the requestHTTP. Real applications should check the iolen to see if all the request has been sent
  94.  res = curl_easy_send(curl, requestHTTP, strlen(requestHTTP), &iolen);
  96.  if(res != CURLE_OK)
  97.  {
  98.   printf("Error: %s\n", strerror(res));
  99.   exit(1);
  100.   //return 1;
  101.  }
  102.  printf("Reading response (thread(%i)) from Server.\n",iThreadNumber);
  104. printf("etape3\n" );
  105.  ////////////////////////////////////////////////////  
  106.  // ETAPE 3 : récupérer la réponse du serveur
  107.  int iPart = 0;
  108.  FILE * pReponse = fopen (RESPONSE_THREAD,"wb" );
  110.  char buf[MAX_RECEPT]="";
  111.  memset(buf,0,MAX_RECEPT);
  113.  if(pReponse)
  114.  {
  115.   for(;;)
  116.   {
  117.    wait_on_socket(sockfd, 1, 500L);
  118.    res = curl_easy_recv(curl, buf, MAX_RECEPT, &iolen);
  119.    fwrite(buf,1,iolen,pReponse);// en binaire !!!!!
  120.    memset(buf,0,MAX_RECEPT);
  121.    if(res != CURLE_OK){ break; }
  122.    iPart++;
  123.   }
  125.   ////////////////////////////////////////////////////
  127.   fclose (pReponse);
  130.  }
  131.  else{
  132.   printf("impossible d'ouvrir %s\n",RESPONSE_THREAD);
  133.  }
  134.  printf("Reading response (thread(%i)) from Server DONE !.\n",iThreadNumber);
  135.  curl_easy_cleanup(curl);
  136. }
  137. /////////////////////////////////////////////////////////////////////////////////////////////////////////////
  139. printf("etape Finale\n" );
  140. /////////////////////////////////////////////////////////////////////////////////////////////////////////////     
  141. // ETAPE FINALE
  143. char * cBody = NULL;
  144. int nbOctects = 0;
  145. FILE * pBodyfileRead = fopen (RESPONSE_THREAD,"rb" );
  147. // obtain file size:
  148. fseek (pBodyfileRead , 0 , SEEK_END);
  149. long lSize = ftell (pBodyfileRead);
  150. rewind (pBodyfileRead);
  152. // allocate memory to contain the whole file:
  153. cBody= (char*) malloc (sizeof(char)*lSize);
  154. memset(cBody,0,sizeof(char)*lSize);
  155. if (cBody== NULL) {fputs ("Memory error",stderr); exit (2);}
  157. // copy the file into the buffer:
  158. int result = fread (cBody,1,lSize,pBodyfileRead);
  159. cBody[lSize] = '\0';
  160. if (result != lSize) {fputs ("Reading error",stderr); exit (3);}
  161. //pthread_mutex_lock (&my_mutex);
  163. // cBodycontiennent les informations a renvoyer a la box
  164. // on renvoie a la netgem box tv du départ :
  165. //int flags = fcntl (iSocketTCPClient, F_GETFL);
  166. //fcntl (iSocketTCPClient, F_SETFL, flags | O_NONBLOCK);  
  167. if(  (nbOctects = write(iSocketTCPClient, cBody, lSize)) < 0)
  168. {
  169.  printf("Socket send error !" );
  170.  return (void *)EXIT_FAILURE;
  171. }
  172. else
  173. {
  174.  printf("etape finale (thread(%i)): %i envoyés\n", iThreadNumber, nbOctects);
  175. /*  
  176.  struct timeval to;  
  177.  fd_set myset;
  178.  
  179.  to.tv_sec = 0;
  180.  to.tv_usec =0; //microseconde
  181.  
  182.  FD_ZERO(&myset);
  183.  FD_SET(iSocketTCPClient,&myset);
  185.  if(select(iSocketTCPClient+1,&myset,NULL,&myset,&to) == 1){
  186.   printf("EVENEMENT !\n" );
  187.   return (void *)-1;
  188.  }
  189. */
  190. }
  191. fclose(pBodyfileRead);
  192. if(cBody!=NULL){
  193.  free(cBody);
  194.  cBody=NULL;
  195. }
  196. /////////////////////////////////////////
  198. /////////////////////////////////////////////////////////////////////////////////////////////////////////////     
  200. // Nettoyage de sockets et des pointeurs :
  202. remove(REQUEST_HTTP_THREAD);
  203. remove(RESPONSE_THREAD);
  205. }
  206. printf("Close sockets (thread(%i))\n",iThreadNumber);
  207. int iCheckSocketClosedClient = close(iSocketTCPClient);
  208. iSocketTCPClient=-1;
  209. printf("Check state of sockets (0 is OK) : Client : %i\n", iCheckSocketClosedClient);
  211. if(requestHTTP!=NULL){
  212.  free(requestHTTP);
  213.  requestHTTP=NULL;
  214. }
  216. printf(" FIN THREAD NUMERO %i\n",iThreadNumber);
  217. printf(" --------------------------------------------- \n" );
  218. printf("\n" );
  220. pthread_exit ((void *)0);
  221. }

Reply

Marsh Posté le 17-08-2009 à 15:20:27   

Reply

Marsh Posté le 17-08-2009 à 15:23:10    

Quel est le problème?


---------------
deluser --remove-home ptitchep
Reply

Marsh Posté le 17-08-2009 à 15:27:26    

J'ai ce genre d'erreur :
*** glibc detected *** ./main: corrupted double-linked list: 0x09fe3b58 ***
======= Backtrace: =========
/lib/tls/i686/cmov/libc.so.6[0xb7dcb07f]
/lib/tls/i686/cmov/libc.so.6[0xb7dccb8d]
/lib/tls/i686/cmov/libc.so.6(__libc_calloc+0xef)[0xb7dce6ef]
/usr/local/lib/libcurl.so.4(Curl_open+0x36)[0xb7ef8226]
/usr/local/lib/libcurl.so.4(curl_easy_init+0x37)[0xb7f06697]
./main[0x8049aec]
/lib/tls/i686/cmov/libpthread.so.0[0xb7ec44ff]
/lib/tls/i686/cmov/libc.so.6(clone+0x5e)[0xb7e3f49e]
 
etc............
 
Parfois j'ai ça, parfois le programme se bloque (comme s'il ne recevait plus de connection...) dur dur

Reply

Marsh Posté le 17-08-2009 à 15:56:43    

Alors ce n'est sans doute pas la solution, mais je dirais que  

Code :
  1. ex = (struct infosThread *)malloc(sizeof(struct infosThread));
  2. rc = pthread_create(&thread, &attr, print_message_function, (void *)ex);
  3. if(ex->cRequetteHTTP !=NULL){
  4.    free(ex->cRequetteHTTP);
  5.    ex->cRequetteHTTP= NULL;
  6.   }
  7.   if(ex!=NULL){
  8.    free(ex);
  9.    ex=NULL;
  10.   }


c'est moyen parce que rien n'indique que le thread a eu le temps de se servir de ton pointeur avant que tu ne libères la mémoire. Tu devrais libérer dans le thread je pense.


---------------
deluser --remove-home ptitchep
Reply

Marsh Posté le 17-08-2009 à 16:11:49    

je vais essayer cette solution pourquoi pas !
 
je ne savais pas qu'il est possible de libérer dans le thread l"élément passé en paramètre

Reply

Marsh Posté le 17-08-2009 à 16:19:17    

Ton élément n'est qu'un pointeur, pas la zone mémoire en question.
Essaie:

Code :
  1. int *i=malloc (4*sizeof(int));
  2. int *z=i;
  3. free(z);


Tu verras qu'il n'y a pas de problème. z peut aussi être défini dans une autre fonction. Par contre il ne faut pas oublier de libérer la mémoire et de ne pas le faire deux fois.


Message édité par ptitchep le 17-08-2009 à 16:23:57

---------------
deluser --remove-home ptitchep
Reply

Marsh Posté le 17-08-2009 à 16:23:20    

bon ça a l'air de marcher un chouillia mieux (j'ai enlever le usleep aussi)
je traite bien une quinzaine de threads et le glibc error arrive d'un coup

Reply

Marsh Posté le 17-08-2009 à 16:26:31    

j'ai mis :
 
 // libération de la structure :
 if(((struct infosThread *)(ptr))->cRequetteHTTP !=NULL){
  free(((struct infosThread *)(ptr))->cRequetteHTTP);
  ((struct infosThread *)(ptr))->cRequetteHTTP= NULL;
 }
 
 if(ptr!=NULL){
  free(ptr);
  ptr = NULL;
 }
 
a la fin de la fonction threadé

Reply

Marsh Posté le 17-08-2009 à 16:30:57    

je ne pense pas que ce soit ça l'erreur, car si je commente les free(structure) que ce soit dans la fonction thréadé ou dans la boucle, ça plante de la même manière !

Reply

Marsh Posté le 17-08-2009 à 16:33:22    

Utilise un debugger pour trouver la ligne qui plante. Vu d'ici avec juste un bout de code et une erreur ce n'est pas facile. Surtout que honnêtement, je n'ai pas tout lu XD. Je pense que si tu arrives à trouver l'instruction qui fait tout tomber, tu pourrais identifier le problème.

 

Ca ne plantait pas parce que tu avais de la chance et que le thread copiait les infos avant qu'elles ne soient détruites.
Si ptr est NULL, tu auras une segmentation fault sur  if(((struct infosThread *)(ptr))->cRequetteHTTP !=NULL). Vérifie d'abord ptr avant ptr->cRequetteHTTP. Par contre les free sont dans le bon ordre.

 

(Je l'avais dit que ça n'était sûrement pas le problème: tu aurais eu seg fault comme message d'erreur)

 

Au fait la pile d'appels de ton message d'erreur parle de curl. Tu appelles peut-être une fonction de cette bibliothèque en lui donnant une variable avec du caca dedans...


Message édité par ptitchep le 17-08-2009 à 16:41:51

---------------
deluser --remove-home ptitchep
Reply

Marsh Posté le 17-08-2009 à 16:33:22   

Reply

Marsh Posté le 17-08-2009 à 16:47:36    

en utilsant gdb il mécrit la même chose que au dessus

Reply

Marsh Posté le 17-08-2009 à 17:38:33    

Oué, débugguage de programme multi-threadé en C, des heures de plaisir en vue :love:  
 
Le genre d'erreur que tu obtiens, ça pu à plein nez le buffer overflow, erreur assez difficile à corriger.
 
Déjà, dans ce pavé, il y a une ligne qui devrait t'arracher les yeux :

Code :
  1. requestHTTP = (char *)malloc(iSizeRequetteHTTP);// ici ça change la taille du ptr
  2. memset(requestHTTP,0,iSizeRequetteHTTP);
  3. memcpy(requestHTTP,((struct infosThread *)(ptr))->cRequetteHTTP,iSizeRequetteHTTP);
  4. requestHTTP[iSizeRequetteHTTP] = '\0';


 
Ce qui n'est pas gagné, car si tu fais ce genre d'erreur sur des trucs aussi simple, tu vas en chier pour la suite.


Message édité par tpierron le 17-08-2009 à 17:39:03
Reply

Marsh Posté le 17-08-2009 à 17:45:31    

je ne comprend pas, quelle est l"erreur mon ami ? je ne suis sans doute pas un pro comme toi :)

Reply

Marsh Posté le 17-08-2009 à 17:53:18    

Hmm, pas besoin d'être un pro pour comprendre ton erreur. Pour la débusquer au milieu du tas, il faut de l'expérience, certes. Mais maintenant que que je te l'ai montrée, tu dois comprendre ce qui ne vas pas, parce que c'est la base du C. Si tu ne veux pas faire cet effort, j'ai sincèrement peur pour la suite de ton projet.
 
Surtout que j'ai juste survolé ton code, rien ne dit que c'est l'unique erreur qu'il puisse y avoir.

Reply

Marsh Posté le 17-08-2009 à 18:01:45    

tu me serai d'une grande aide si tu pouvais m'aider.
ça fait vraiment un moment que je bloque !
j'ai beau cherché je ne comprend pas mon erreur...

Reply

Marsh Posté le 17-08-2009 à 18:14:48    

j'ai fait :
 
if(iSizeRequetteHTTP == strlen(((struct infosThread *)(ptr))->cRequetteHTTP)){
  strcpy(requestHTTP,((struct infosThread *)(ptr))->cRequetteHTTP);
}else{
  printf("probleme taille !!!!\n" );
}
 
et il arrive quon n'est pas la même taille... tu métonnes que ça narrive pas a bien copié !
mais alors pourquoi en faisant  
iSizeRequetteHTTP = ((struct infosThread *)(ptr))->iSizeRequetteHTTP;
2 lignes après ils sont différents !! ça mépate là

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed