Skip to content
Extraits de code Groupes Projets
Valider c85c43ec rédigé par Raphaël Ngenyi-Ngondo's avatar Raphaël Ngenyi-Ngondo
Parcourir les fichiers

final

parent c6d5c94c
Aucune branche associée trouvée
Aucune étiquette associée trouvée
Aucune requête de fusion associée trouvée
Pipeline #10288 en échec
...@@ -132,7 +132,7 @@ void enqueue(queue_t* q, uint_64 val){ ...@@ -132,7 +132,7 @@ void enqueue(queue_t* q, uint_64 val){
struct node *ptr; struct node *ptr;
ptr = malloc(sizeof(node_t)); ptr = malloc(sizeof(node_t));
if (ptr == NULL){ if (ptr == NULL){
//free(ptr);
return;} return;}
ptr->value = val; ptr->value = val;
...@@ -149,9 +149,8 @@ void enqueue(queue_t* q, uint_64 val){ ...@@ -149,9 +149,8 @@ void enqueue(queue_t* q, uint_64 val){
} }
/* /*Fait une liste de diviseur premier
fait une liste de diviseur premier en vérifiant si number est premier*/
*/
queue_t* prime_divs(uint_64 number){ queue_t* prime_divs(uint_64 number){
queue_t *ptr; queue_t *ptr;
...@@ -173,9 +172,7 @@ queue_t* prime_divs(uint_64 number){ ...@@ -173,9 +172,7 @@ queue_t* prime_divs(uint_64 number){
} }
/* /*Ecriture dans le finchier output*/
Ecriture dans le finchier output
*/
void *writing(void *param){ void *writing(void *param){
struct buffer_cw *param1 = (struct buffer_cw *) param; struct buffer_cw *param1 = (struct buffer_cw *) param;
...@@ -192,7 +189,7 @@ void *writing(void *param){ ...@@ -192,7 +189,7 @@ void *writing(void *param){
if (pr_divs->final == 1) if (pr_divs->final == 1)
{ {
if (stop == N-1){ if (stop == N-1){ \\arrêt des threads
free(pr_divs); free(pr_divs);
free(param1->tab); free(param1->tab);
return NULL; return NULL;
...@@ -229,7 +226,9 @@ void *writing(void *param){ ...@@ -229,7 +226,9 @@ void *writing(void *param){
} }
/*Récupère les élément du buffer 1,
effectue les calculs et
replace les nombres dans le buffers 2*/
void *calculating(void *param){ void *calculating(void *param){
struct buffer_rccw *param1 = (struct buffer_rccw *) param; struct buffer_rccw *param1 = (struct buffer_rccw *) param;
...@@ -245,7 +244,7 @@ void *calculating(void *param){ ...@@ -245,7 +244,7 @@ void *calculating(void *param){
pthread_mutex_unlock(&mutex1); pthread_mutex_unlock(&mutex1);
sem_post(&empty1); sem_post(&empty1);
if (strcmp("stop",chaine) == 0) if (strcmp("stop",chaine) == 0) // arrêt des threads
{ {
struct queue *final; struct queue *final;
final = malloc(sizeof(queue_t)); final = malloc(sizeof(queue_t));
...@@ -263,7 +262,7 @@ void *calculating(void *param){ ...@@ -263,7 +262,7 @@ void *calculating(void *param){
return NULL; return NULL;
} }
uint_64 number; uint_64 number;
number = strtoll(chaine,NULL,0); number = strtoll(chaine,NULL,0); //conversion en long long
if (number != 0 || strcmp("0\n",chaine) == 0) if (number != 0 || strcmp("0\n",chaine) == 0)
{ {
struct queue *pr_divs; struct queue *pr_divs;
...@@ -282,9 +281,7 @@ void *calculating(void *param){ ...@@ -282,9 +281,7 @@ void *calculating(void *param){
return NULL; return NULL;
} }
/* /*Fonction qui lit un finchier d'entrée*/
Fonction qui lit un finchier d'entrée
*/
void *reading (void *param){ void *reading (void *param){
......
0% Chargement en cours ou .
You are about to add 0 people to the discussion. Proceed with caution.
Terminez d'abord l'édition de ce message.
Veuillez vous inscrire ou vous pour commenter