version 1.49, 2013/03/21 12:07:38
|
version 1.53, 2013/06/21 14:15:55
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.13 |
RPL/2 (R) version 4.1.15 |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
Copyright (C) 1989-2013 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 109 instruction_recv(struct_processus *s_eta
|
Line 109 instruction_recv(struct_processus *s_eta
|
* de la structure présente dans la pile opérationnelle. |
* de la structure présente dans la pile opérationnelle. |
*/ |
*/ |
|
|
if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) |
|
!= 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 207 instruction_recv(struct_processus *s_eta
|
Line 208 instruction_recv(struct_processus *s_eta
|
|
|
if (nombre_donnees == -1) |
if (nombre_donnees == -1) |
{ |
{ |
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus) |
|
.mutex_pile_processus)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 223 instruction_recv(struct_processus *s_eta
|
Line 225 instruction_recv(struct_processus *s_eta
|
* On empile une valeur nulle |
* On empile une valeur nulle |
*/ |
*/ |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus) |
|
.mutex_pile_processus)) != 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 309 instruction_recv(struct_processus *s_eta
|
Line 312 instruction_recv(struct_processus *s_eta
|
profilage(s_etat_processus, NULL); |
profilage(s_etat_processus, NULL); |
} |
} |
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
return; |
return; |
} |
} |
|
|
Line 360 instruction_recv(struct_processus *s_eta
|
Line 363 instruction_recv(struct_processus *s_eta
|
= registre_stop; |
= registre_stop; |
} |
} |
|
|
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
if ((*s_etat_processus).profilage == d_vrai) |
if ((*s_etat_processus).profilage == d_vrai) |
{ |
{ |
Line 424 instruction_recv(struct_processus *s_eta
|
Line 427 instruction_recv(struct_processus *s_eta
|
|
|
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
if (sigaction(SIGPIPE, ®istre, NULL) != 0) |
{ |
{ |
pthread_mutex_unlock(&((*s_etat_processus).mutex)); |
pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)); |
|
|
(*s_etat_processus).erreur_systeme = d_es_signal; |
(*s_etat_processus).erreur_systeme = d_es_signal; |
return; |
return; |
} |
} |
|
|
if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0) |
if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) |
|
!= 0) |
{ |
{ |
(*s_etat_processus).erreur_systeme_processus_fils = |
(*s_etat_processus).erreur_systeme_processus_fils = |
d_es_processus; |
d_es_processus; |
Line 793 instruction_rdate(struct_processus *s_et
|
Line 797 instruction_rdate(struct_processus *s_et
|
if ((*s_objet_argument).type == INT) |
if ((*s_objet_argument).type == INT) |
{ |
{ |
gettimeofday(&horodatage, NULL); |
gettimeofday(&horodatage, NULL); |
horodatage.tv_sec += (*((integer8 *) (*s_objet_argument).objet)); |
horodatage.tv_sec += (time_t) (*((integer8 *) |
|
(*s_objet_argument).objet)); |
|
|
if (horodatage.tv_sec < 0) |
if (horodatage.tv_sec < 0) |
{ |
{ |