les erreurs de pthread_create

Version imprimable

10/09/2008, 12h31
sofiane80

les erreurs de pthread_create

Bonjour tout le monde,

J’ai écris une application qui crée plusieurs thread et à un moment donnée la fonction pthrerad_create commence à échouer et elle me retourne une valeur égale à 12.

Pourriez-vous m'expliquer que signifie cette erreur.

merci d'avance.
10/09/2008, 12h53
BainE

Bonjour,

peut etre un bout de reponse ici, en regardant les differentes maccros de retour d erreurs EINVAL, EPERM....

sinon peut etre qu en nous montrant un bout de code on pourra plus t aider...
10/09/2008, 13h22
Invité(e)
Bonjour,

Le fonction perror peut aussi donner une bonne idée de la cause de l'erreur :
Code:

1 2 3 if(0 != pthread_create(...)) { perror("Impossible de créer un nouveau thread :"); }
10/09/2008, 13h32
sofiane80

effectivement avec perror j'ai eu l'interpretation de l'erreur:

cannot allocate memory
sincerement je ne la comprends pas !!??
10/09/2008, 13h40
wiztricks

elles font quoi ces threads?

La mémoire est une ressource partagée par les différents threads (crées).
Il serait peut être bon de s'inquiéter de ce qu'elles allouent directement (via malloc ou pile) ou indirectement si elles utilisent des bibliothèques.
- W
PS: sur quel type d'environnement (Windows, Linux, autres) cela se passe?
11/09/2008, 01h45
Emmanuel Delahaye

Citation:

Envoyé par sofiane80

J’ai écris une application qui crée plusieurs thread et à un moment donnée la fonction pthrerad_create commence à échouer et elle me retourne une valeur égale à 12.

Pourriez-vous m'expliquer que signifie cette erreur.

Si ça signifie 'erreur d'allocation mémoire', c'est qu'il n'y a plus de mémoire disponible. Est-ce que tu libères bien tout ce qui a été alloué dans un thread ?

presque résolu

en fait je développe un serveur qui crée un thread pour chaque connection, la plus part de mes thread on une courte durée de vie il s'achève dès que la connexion est fermée.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 while((newsockfd = accept(sockfd,(struct sockaddr *) &cli_addr,&clilen))>0){ if ((thread_err=pthread_create (&getmetadata, NULL, getmetadata_process, (void *)download)) != 0){ error ("Impossible de créer le thread connection\n",0); close(newsockfd); free(download->hashm); ree(download); } else printf("passif_process:une nouvelle connexion a été crée \n"); }
avec ce code, et bien que je libere tous ce qui est alloué au viveau de chaque thread, j'avais assez tôt l'erreur "cannot allocate memory" ( pas plus de 10 thread qui tourne simultanement) :scarymov:

quelqu'un m'avait proposé je rajouter les lignes de codes suivantes:
Code:

1 2 3 4 pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);
et créer mes threads comme suit:
Code:

1 2 3 pthread_create (&getmetadata, &attr, getmetadata_process, (void *)download)
ceci m'a permet d'avancer un petit peu :D. Mais je me suis retrouvé avec le même problème après avoir 303 threads qui tourne au même temps.8O

ps: je travaille sous linux

12/09/2008, 16h38
wiztricks

Certes PTHREAD_DETACH permet de libérer la mémoire sans attendre un pthread_join... Cela conforte l'oubli de désallouer de la mémoire à chaque fois qu'une thread se termine.

Note: les structures de données éventuellement crée autour de l'accept et du pthread_create n'ont pas une taille nulle ;-(

Serait-il possible de connaitre le nombre total de threads crées (en comptant celles qui se sont déjà terminée) plutôt que le nombre de threads active simultanées: cela nous donnerait peut être une meilleure idée de la quantité de mémoire perdue / thread ?
- W

Citation:

Envoyé par sofiane80

avec ce code, et bien que je libere tous ce qui est alloué au viveau de chaque thread, j'avais assez tôt l'erreur "cannot allocate memory" ( pas plus de 10 thread qui tourne simultanement)

J'ai essayé de le rendre lisible :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 while ((newsockfd = accept (sockfd, (struct sockaddr *) &cli_addr, &clilen)) > 0) { thread_err = pthread_create (&getmetadata, NULL, getmetadata_process, (void *) download); if (thread_err != 0) { error ("Impossible de créer le thread connection\n", 0); close (newsockfd); free (download->hashm); free (download); } else { printf ("passif_process:une nouvelle connexion a été crée \n"); } }
ce code est faux ou incomplet. On ne sait pas d'où vient 'download'. En tout cas, il ne peut pas être modifié par la tâche. On voit qu'il pointe sur un bloc alloué (puisque libéré en cas d'erreurs), mais on ne sait pas comment ni par qui.

De plus, l'information capitale 'newsockfd ' n'est pas transmise à la tache (attention, 'getmetadata_process' est mal nommée, c'est un thread ou tache ou task, mais certainement pas un proces[sus]).

Peux tu montrer une version compilable et testable qui montre le défaut ?

désolé j'ai fait une erreur lors que j'ai copie/collé le code. je voulais juste poster la partie qui me blaque. voici une nouvelle version:

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
 
while ((newsockfd =
           accept (sockfd, (struct sockaddr *) &cli_addr, &clilen)) > 0)
   {
      download=(download_t *)malloc(sizeof (download_t));
      download->sockfd=newsockfd;
      download->hashm=(char *)malloc(T_HASH+1);
      memcpy(download->hashm,(char *)(bcm+2),(T_HASH+1));
      thread_err =
         pthread_create (&getmetadata, NULL, getmetadata_process,
                         (void *) download);
 
      if (thread_err != 0)
      {
         error ("Impossible de créer le thread connection\n", 0);
         close (newsockfd);
         free (download->hashm);
         free (download);
      }
      else
      {
         printf ("passif_process:une nouvelle connexion a été crée \n");
      }
   }

download est de type download_t

Code:

1
2
3
4
5
 
typedef struct DOWNLOAD{
	int sockfd;
	char * hashm;
	} download_t;

12/09/2008, 17h09
wiztricks

Montrer un malloc dans une boucle while sans expliquer que le thread fera le free à tous les coups me semble à priori "suspect".
- W
12/09/2008, 17h18
sofiane80

Citation:

Envoyé par sofiane80

avec ce code, et bien que je libere tous ce qui est alloué au viveau de chaque thread, j'avais assez tôt l'erreur "cannot allocate memory" ( pas plus de 10 thread qui tourne simultanement) :scarymov:

Citation:

Envoyé par sofiane80

désolé j'ai fait une erreur lors que j'ai copie/collé le code. je voulais juste poster la partie qui me blaque. voici une nouvelle version:

Il manque encore plein de choses Si tu ne postes pas du code compilable, on ne va deviner ce que tu as fait de travers...

J'en suis là, mais j'ai déjà fait des hypothèses...

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
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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
 
/* 01.c */
 
#ifdef __cplusplus
#error Be sure you are using a C compiler...
#endif
 
#if defined (WIN32) || defined (_WIN32)
 
#include <winsock2.h>
 
#elif defined (linux) || defined (_POSIX_VERSION) || defined (_POSIX2_C_VERSION)\
 || defined (_XOPEN_VERSION)
 
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>             /* close */
 
#define INVALID_SOCKET -1
#define SOCKET_ERROR -1
 
#define closesocket(s) close (s)
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
 
#else
#error not defined for this platform
#endif
 
#include <stdio.h>
#include <stdlib.h>
 
#include <pthread.h>
 
/* macros ============================================================== */
#define T_HASH 128
/* constants =========================================================== */
/* types =============================================================== */
/* structures ========================================================== */
typedef struct
{
   int sockfd;
   char *hashm;
}
download_t;
 
/* private data ======================================================== */
/* private functions =================================================== */
 
static void error (char const *msg, int a)
{
   printf ("ERR : %d : %s\n", a, msg);
}
 
static void *getmetadata_process (void)
{
   return 0;
}
 
static int server (void)
{
   SOCKET sockfd = 0;
   SOCKET newsockfd;
   SOCKADDR_IN cli_addr = { 0 };
   int clilen = sizeof cli_addr;
 
   char bcm[256] = "";
 
   while ((newsockfd =
           accept (sockfd, (struct sockaddr *) &cli_addr, &clilen)) > 0)
   {
      pthread_t getmetadata;
 
      download_t *download = (download_t *) malloc (sizeof (download_t));
      download->sockfd = newsockfd;
      download->hashm = (char *) malloc (T_HASH + 1);
      memcpy (download->hashm, (char *) (bcm + 2), (T_HASH + 1));
      {
         int thread_err =
            pthread_create (&getmetadata, NULL, getmetadata_process,
                            (void *) download);
 
         if (thread_err != 0)
         {
            error ("Impossible de créer le thread connection\n", 0);
            closesocket (newsockfd);
            free (download->hashm);
            free (download);
         }
         else
         {
            printf ("passif_process:une nouvelle connexion a été crée \n");
         }
      }
   }
 
   return 0;
}
 
/* entry point ========================================================= */
 
/* ---------------------------------------------------------------------
   --------------------------------------------------------------------- */
int main (void)
{
   int ret;
 
#if defined (WIN32) || defined (_WIN32)
   WSADATA wsa_data;
   int err = WSAStartup (MAKEWORD (2, 2), &wsa_data);
 
   if (!err)
   {
      puts ("WIN: winsock2: OK");
#else
   int err;
#endif
 
   server ();
 
#if defined (WIN32) || defined (_WIN32)
   WSACleanup ();
}
#endif
 
if (err)
{
   ret = EXIT_FAILURE;
}
else
{
   ret = EXIT_SUCCESS;
}
 
return ret;
}