Discussion :

[sofiane80]

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.

[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...

[Invité(e)]

Bonjour,

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

Code :

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

1
2
3
if(0 != pthread_create(...)) {
    perror("Impossible de créer un nouveau thread :");
}

[sofiane80]

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

cannot allocate memory
sincerement je ne la comprends pas !!??

[wiztricks]

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?

[Emmanuel Delahaye]

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 ?

[sofiane80]

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 :

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

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)

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

Code :

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

1
2
3
4
 
 
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);

et créer mes threads comme suit:

Code :

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

1
2
3
 
 
pthread_create (&getmetadata, &attr, getmetadata_process, (void *)download)

ceci m'a permet d'avancer un petit peu . Mais je me suis retrouvé avec le même problème après avoir 303 threads qui tourne au même temps.

ps: je travaille sous linux

[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

[Emmanuel Delahaye]

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 :

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
 
   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 ?

[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:

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
 
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 :

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

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

[wiztricks]

Montrer un malloc dans une boucle while sans expliquer que le thread fera le free à tous les coups me semble à priori "suspect".
- W

[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)

[Emmanuel Delahaye]

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 :

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
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;
}