version 1.238, 2014/01/26 18:21:34
|
version 1.242, 2014/04/29 14:41:43
|
Line 1
|
Line 1
|
/* |
/* |
================================================================================ |
================================================================================ |
RPL/2 (R) version 4.1.17 |
RPL/2 (R) version 4.1.18 |
Copyright (C) 1989-2014 Dr. BERTRAND Joël |
Copyright (C) 1989-2014 Dr. BERTRAND Joël |
|
|
This file is part of RPL/2. |
This file is part of RPL/2. |
Line 146
|
Line 146
|
# define SEM_FAILED NULL |
# define SEM_FAILED NULL |
# endif |
# endif |
|
|
sem_t *sem_open_SysV(const char *nom, int oflag, ...); |
# ifndef __RPLCAS |
int sem_init_SysV(sem_t *sem, int shared, unsigned int value); |
sem_t *sem_open_SysV(const char *nom, int oflag, ...); |
int sem_close_SysV(sem_t *sem); |
int sem_init_SysV(sem_t *sem, int shared, unsigned int value); |
int sem_wait_SysV(sem_t *sem); |
int sem_close_SysV(sem_t *sem); |
int sem_trywait_SysV(sem_t *sem); |
int sem_wait_SysV(sem_t *sem); |
int sem_timedwait_SysV(sem_t *sem, struct timespec *ts); |
int sem_trywait_SysV(sem_t *sem); |
int sem_post_SysV(sem_t *sem); |
int sem_timedwait_SysV(sem_t *sem, struct timespec *ts); |
int sem_getvalue_SysV(sem_t *sem, int *value); |
int sem_post_SysV(sem_t *sem); |
int sem_unlink_SysV(char *nom); |
int sem_getvalue_SysV(sem_t *sem, int *value); |
int sem_destroy_SysV(sem_t *sem); |
int sem_unlink_SysV(char *nom); |
|
int sem_destroy_SysV(sem_t *sem); |
|
# endif |
# endif |
# endif |
|
|
# include <setjmp.h> |
# include <setjmp.h> |
Line 318 enum signaux_rpl
|
Line 320 enum signaux_rpl
|
#ifndef RPLARGS |
#ifndef RPLARGS |
typedef struct queue_signaux |
typedef struct queue_signaux |
{ |
{ |
# ifndef IPCS_SYSV |
|
# ifndef SEMAPHORES_NOMMES |
|
sem_t semaphore; |
|
sem_t signalisation; |
|
sem_t arret_signalisation; |
|
# endif |
|
# else |
|
sem_t semaphore; |
|
sem_t signalisation; |
|
sem_t arret_signalisation; |
|
# endif |
|
|
|
volatile int pointeur_lecture; |
volatile int pointeur_lecture; |
volatile int pointeur_ecriture; |
volatile int pointeur_ecriture; |
pthread_t thread_signaux; |
|
volatile logical1 requete_arret; |
volatile logical1 requete_arret; |
|
|
|
pthread_t thread_signaux; |
|
|
volatile struct |
volatile struct |
{ |
{ |
pid_t pid; |
pid_t pid; |
enum signaux_rpl signal; |
enum signaux_rpl signal; |
} queue[LONGUEUR_QUEUE_SIGNAUX]; |
} queue[LONGUEUR_QUEUE_SIGNAUX]; |
|
|
|
# ifdef OS2 |
|
sem_t semaphore; |
|
sem_t signalisation; |
|
sem_t arret_signalisation; |
|
# endif |
} struct_queue_signaux; |
} struct_queue_signaux; |
|
|
__EXTERN__ struct_queue_signaux *s_queue_signaux; |
__EXTERN__ struct_queue_signaux *s_queue_signaux; |
__EXTERN__ int f_queue_signaux; |
__EXTERN__ int f_queue_signaux; |
|
|
# ifdef SEMAPHORES_NOMMES |
# ifndef OS2 |
__EXTERN__ sem_t *semaphore_queue_signaux; |
__EXTERN__ sem_t *semaphore_queue_signaux; |
__EXTERN__ sem_t *semaphore_signalisation; |
__EXTERN__ sem_t *semaphore_signalisation; |
__EXTERN__ sem_t *semaphore_arret_signalisation; |
__EXTERN__ sem_t *semaphore_arret_signalisation; |
# endif |
# endif |
#endif |
#endif |
|
|
Line 462 union semun
|
Line 459 union semun
|
#ifndef RPLARGS |
#ifndef RPLARGS |
# ifdef SEMAPHORES_NOMMES |
# ifdef SEMAPHORES_NOMMES |
# define LONGUEUR_NOM_SEMAPHORE 64 |
# define LONGUEUR_NOM_SEMAPHORE 64 |
# endif |
|
|
|
# ifdef SEMAPHORES_NOMMES |
|
# define __PTR__ * |
# define __PTR__ * |
# else |
# else |
# define __PTR__ |
# define __PTR__ |
Line 480 union semun
|
Line 474 union semun
|
|
|
__EXTERN__ pid_t pid_processus_pere; |
__EXTERN__ pid_t pid_processus_pere; |
|
|
# ifdef SEMAPHORES_NOMMES |
|
__EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; |
|
# endif |
|
|
|
__EXTERN__ pthread_mutex_t mutex_liste_threads |
__EXTERN__ pthread_mutex_t mutex_liste_threads |
__STATIC_MUTEX_INITIALIZATION__; |
__STATIC_MUTEX_INITIALIZATION__; |
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__EXTERN__ pthread_mutex_t mutex_creation_variable_partagee |
__STATIC_MUTEX_INITIALIZATION__; |
__STATIC_MUTEX_INITIALIZATION__; |
__EXTERN__ pthread_mutex_t mutex_sections_critiques; |
__EXTERN__ pthread_mutex_t mutex_sections_critiques; |
__EXTERN__ pthread_mutex_t mutex_liste_variables_partagees; |
__EXTERN__ pthread_mutex_t mutex_liste_variables_partagees; |
|
__EXTERN__ pthread_mutex_t mutex_sem __STATIC_MUTEX_INITIALIZATION__; |
|
|
__EXTERN__ sem_t __PTR__ semaphore_gestionnaires_signaux; |
__EXTERN__ sem_t __PTR__ semaphore_gestionnaires_signaux; |
|
|
__EXTERN__ volatile int routine_recursive; |
__EXTERN__ volatile int routine_recursive; |
#endif |
#endif |
|
|
#ifdef SEMAPHORES_NOMMES |
|
#define SEM_FORK 0 |
#define SEM_FORK 0 |
#define SEM_QUEUE 1 |
#define SEM_QUEUE 1 |
#define SEM_SIGNAUX 2 |
#define SEM_SIGNAUX 2 |
Line 513 sem_t *sem_open2(pid_t pid, int ordre);
|
Line 503 sem_t *sem_open2(pid_t pid, int ordre);
|
// de sem_getvalue() sur un système comme MacOS X qui ne possède pas |
// de sem_getvalue() sur un système comme MacOS X qui ne possède pas |
// cette fonction. |
// cette fonction. |
|
|
|
#ifdef Darwin |
#define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value) |
#define sem_getvalue(semaphore, value) sem_getvalue2(semaphore, value) |
#define sem_post(semaphore) \ |
#define sem_post(semaphore) \ |
({ int r; pthread_mutex_lock(&mutex_sem); \ |
({ int r; pthread_mutex_lock(&mutex_sem); \ |