version 1.320, 2018/12/21 10:56:23
|
version 1.332, 2019/02/17 16:08:41
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.29 |
RPL/2 (R) version 4.1.31 |
Copyright (C) 1989-2018 Dr. BERTRAND Joël |
Copyright (C) 1989-2019 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
|
|
Line 325 enum signaux_rpl
|
Line 325 enum signaux_rpl
|
rpl_sighup, |
rpl_sighup, |
rpl_sigtstp, |
rpl_sigtstp, |
rpl_sigexcept, |
rpl_sigexcept, |
rpl_sigmax |
rpl_sigmax, |
|
rpl_siguser // Base des signaux à la discrétion de l'utilisateur |
}; |
}; |
|
|
#define LONGUEUR_QUEUE_SIGNAUX 1024 |
#define LONGUEUR_QUEUE_SIGNAUX 1024 |
Line 395 union semun
|
Line 396 union semun
|
#ifdef IPCS_SYSV |
#ifdef IPCS_SYSV |
# ifdef DEBUG_SEMAPHORES |
# ifdef DEBUG_SEMAPHORES |
# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ |
|
if (strstr(#a, "fork") != NULL) \ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
"waiting at %s() " \ |
"waiting at %s() " \ |
"line #%d\n", (int) getpid(), (unsigned long long) i\ |
"line #%d <%d>\n", (int) getpid(), (unsigned long long) i\ |
pthread_self(), \ |
pthread_self(), \ |
#a, a, __FUNCTION__, __LINE__), fflush(stdout); \ |
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value > 1) BUG(1, uprintf("Value %d\n", value)); \ |
|
sem_wait_SysV(a); }) |
sem_wait_SysV(a); }) |
# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_trywait(a) ({ int value; sem_getvalue(a, &value); \ |
|
if (strstr(#a, "fork") != NULL) \ |
|
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
|
"trywaiting at %s() " \ |
|
"line #%d <%d>\n", (int) getpid(), (unsigned long long) i\ |
|
pthread_self(), \ |
|
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
|
sem_trywait_SysV(a); }) |
|
# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ |
|
if (strstr(#a, "fork") != NULL) \ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
"posting at %s() " \ |
"posting at %s() " \ |
"line #%d\n", (int) getpid(), (unsigned long long) \ |
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
pthread_self(), \ |
pthread_self(), \ |
#a, a, __FUNCTION__, __LINE__), fflush(stdout); \ |
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value > 0) BUG(1, uprintf("Value %d\n", value)); \ |
|
sem_post_SysV(a); }) |
sem_post_SysV(a); }) |
# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ |
|
if (strstr(#a, "fork") != NULL) \ |
|
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
|
"destroying at %s() " \ |
|
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
|
pthread_self(), \ |
|
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ |
if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ |
sem_destroy_SysV(a); }) |
sem_destroy_SysV(a); }) |
# else |
# else |
Line 431 union semun
|
Line 446 union semun
|
# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_wait(a) ({ int value; sem_getvalue(a, &value); \ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
"waiting at %s() " \ |
"waiting at %s() " \ |
"line #%d\n", (int) getpid(), (unsigned long long) \ |
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
pthread_self(), \ |
pthread_self(), \ |
#a, a, __FUNCTION__, __LINE__), fflush(stdout); \ |
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value > 1) BUG(1, uprintf("Value %d\n", value)); sem_wait(a); }) |
sem_wait(a); }) |
|
# define sem_trywait(a) ({ int value; sem_getvalue(a, &value); \ |
|
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
|
"trywaiting at %s() " \ |
|
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
|
pthread_self(), \ |
|
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
|
sem_trywait(a); }) |
# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_post(a) ({ int value; sem_getvalue(a, &value); \ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
"posting at %s() " \ |
"posting at %s() " \ |
"line #%d\n", (int) getpid(), (unsigned long long) \ |
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
pthread_self(), \ |
pthread_self(), \ |
#a, a, __FUNCTION__, __LINE__), fflush(stdout); \ |
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value > 0) BUG(1, uprintf("Value %d\n", value)); sem_post(a); }) |
sem_post(a); }) |
# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ |
# define sem_destroy(a) ({ int value; sem_getvalue(a, &value); \ |
|
uprintf("[%d-%llu] Semaphore %s (%p) "\ |
|
"destroying at %s() " \ |
|
"line #%d <%d>\n", (int) getpid(), (unsigned long long) \ |
|
pthread_self(), \ |
|
#a, a, __FUNCTION__, __LINE__, value), fflush(stdout); \ |
if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ |
if (value == 0) BUG(1, uprintf("Value %d\n", value)); \ |
sem_destroy(a); }) |
sem_destroy(a); }) |
# endif |
# endif |
Line 531 union semun
|
Line 558 union semun
|
|
|
__EXTERN__ pid_t pid_processus_pere; |
__EXTERN__ pid_t pid_processus_pere; |
|
|
|
__EXTERN__ pthread_mutex_t mutex_sigaction; |
__EXTERN__ pthread_mutex_t mutex_liste_threads; |
__EXTERN__ pthread_mutex_t mutex_liste_threads; |
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__STATIC_MUTEX_INITIALIZATION__; |
__STATIC_MUTEX_INITIALIZATION__; |
Line 539 union semun
|
Line 567 union semun
|
__EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; |
__EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; |
|
|
__EXTERN__ volatile int routine_recursive; |
__EXTERN__ volatile int routine_recursive; |
__EXTERN__ volatile int nombre_thread_surveillance_processus; |
__EXTERN__ volatile int nombre_threads_surveillance_processus; |
|
|
# define SEM_FORK 0 |
# define SEM_FORK 0 |
# define SEM_QUEUE 1 |
# define SEM_QUEUE 1 |
Line 775 pid_t debug_fork();
|
Line 803 pid_t debug_fork();
|
#define d_SPH "Semaphore $n 'name'" |
#define d_SPH "Semaphore $n 'name'" |
#define d_TAB "<[ table ]>" |
#define d_TAB "<[ table ]>" |
#define d_MTX "Mutex $n" |
#define d_MTX "Mutex $n" |
#define d_REC "|[ <[ 'name_1' ... 'name_n' ]> " \ |
#define d_REC "|[ record ]|" |
"<[ data_1 ... data_n ]> ]|" |
|
|
|
/* |
/* |
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
Line 1585 typedef struct liste_pile_systeme
|
Line 1612 typedef struct liste_pile_systeme
|
logical1 creation_variables_statiques; |
logical1 creation_variables_statiques; |
logical1 creation_variables_partagees; |
logical1 creation_variables_partagees; |
logical1 evaluation_expression; |
logical1 evaluation_expression; |
|
logical1 debug_programme; |
|
|
unsigned char clause; |
unsigned char clause; |
|
|
Line 1775 typedef struct record
|
Line 1803 typedef struct record
|
struct_objet *donnees; |
struct_objet *donnees; |
} struct_record; |
} struct_record; |
|
|
|
|
/* |
/* |
-------------------------------------------------------------------------------- |
-------------------------------------------------------------------------------- |
Structure arbre |
Structure arbre |
Line 3283 int envoi_signal_contexte(struct_process
|
Line 3312 int envoi_signal_contexte(struct_process
|
enum signaux_rpl signal); |
enum signaux_rpl signal); |
int envoi_signal_processus(pid_t pid, enum signaux_rpl signal, |
int envoi_signal_processus(pid_t pid, enum signaux_rpl signal, |
logical1 test_ouverture); |
logical1 test_ouverture); |
int envoi_signal_thread(pthread_t tid, enum signaux_rpl signal); |
int envoi_signal_thread(struct_processus *s_etat_processus, |
|
pthread_t tid, enum signaux_rpl signal); |
#endif |
#endif |
|
|
/* |
/* |