[BACK]Return to rpl.h CVS log [TXT] [DIR] Up to [local] / rpl / src

Diff for /rpl/src/rpl.h between versions 1.123 and 1.131

version 1.123, 2011/09/15 19:23:54 version 1.131, 2011/09/20 15:45:53
Line 122 Line 122
                 ULONG   *nopened;                  ULONG   *nopened;
                 ULONG   allocated;                  ULONG   allocated;
             } sem_t;              } sem_t;
 #       else  #       else // IPCS_SYSV
             typedef struct              typedef struct
             {              {
                 int             sem;                  int             sem;
                   int             alloue;
                 unsigned char   *path;                  unsigned char   *path;
                 pid_t           pid;                  pid_t           pid;
                   pthread_t       tid;
             } sem_t;              } sem_t;
 #       endif  #       endif
   
 #       define SEM_FAILED   NULL  #       ifndef SEM_FAILED
   #           define SEM_FAILED   NULL
   #       endif
   
         sem_t *sem_open_SysV(const char *nom, int oflag, ...);          sem_t *sem_open_SysV(const char *nom, int oflag, ...);
         int sem_init_SysV(sem_t *sem, int shared, unsigned int value);          int sem_init_SysV(sem_t *sem, int shared, unsigned int value);
Line 239  enum signaux_rpl Line 243  enum signaux_rpl
   
 typedef struct queue_signaux  typedef struct queue_signaux
 {  {
     sem_t  #   ifndef IPCS_SYSV
 #   ifdef SEMAPHORES_NOMMES  #       ifndef SEMAPHORES_NOMMES
         *              sem_t               semaphore;
   #       endif
   #   else
           sem_t                   semaphore;
 #   endif  #   endif
                                 semaphore;  
   
     volatile int                pointeur_lecture;      volatile int                pointeur_lecture;
     volatile int                pointeur_ecriture;      volatile int                pointeur_ecriture;
Line 259  typedef struct queue_signaux Line 265  typedef struct queue_signaux
 #   ifndef MAIN_RPL  #   ifndef MAIN_RPL
         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
               extern sem_t                    *semaphore_queue_signaux;
   #       endif
 #   else  #   else
         struct_queue_signaux                *s_queue_signaux;          struct_queue_signaux                *s_queue_signaux;
         int                                 f_queue_signaux;          int                                 f_queue_signaux;
   #       ifdef SEMAPHORES_NOMMES
               sem_t                           *semaphore_queue_signaux;
   #       endif
 #   endif  #   endif
 #endif  #endif
   
Line 428  typedef unsigned char   t_8_bits; Line 440  typedef unsigned char   t_8_bits;
   
         pthread_mutex_t             mutex_liste_threads =          pthread_mutex_t             mutex_liste_threads =
                                             PTHREAD_MUTEX_INITIALIZER;                                              PTHREAD_MUTEX_INITIALIZER;
         pthread_mutex_t             mutex_gestiionnaires_signaux =          pthread_mutex_t             mutex_gestionnaires_signaux =
                                             PTHREAD_MUTEX_INITIALIZER;                                              PTHREAD_MUTEX_INITIALIZER;
         pthread_mutex_t             mutex_gestionnaires_signaux_atomique =          pthread_mutex_t             mutex_gestionnaires_signaux_atomique =
                                             PTHREAD_MUTEX_INITIALIZER;                                              PTHREAD_MUTEX_INITIALIZER;
Line 441  typedef unsigned char   t_8_bits; Line 453  typedef unsigned char   t_8_bits;
 #endif  #endif
   
 #ifdef SEMAPHORES_NOMMES  #ifdef SEMAPHORES_NOMMES
 enum t_semaphore    { sem_liste_threads = 0,  #define SEM_FORK            0
         sem_gestionnaires_signaux = 1,  #define SEM_QUEUE           1
         sem_gestionnaires_signaux_atomique = 2,  #define SEM_SIGNAUX         2
         sem_fork = 3 };  sem_t *sem_init2(unsigned int valeur, pid_t pid, int ordre);
   sem_t *sem_init3(unsigned int valeur, pid_t pid, pthread_t tid, int ordre);
 sem_t *sem_init2(unsigned int valeur, enum t_semaphore semaphore);  int sem_destroy2(sem_t *semaphore_p, pid_t pid, int ordre);
 int sem_destroy2(sem_t *semaphore_p, enum t_semaphore semaphore);  int sem_destroy3(sem_t *semaphore_p, pid_t pid, pthread_t tid, int ordre);
 int sem_getvalue2(sem_t *semaphore, int *valeur);  int sem_getvalue2(sem_t *semaphore, int *valeur);
   sem_t *sem_open2(pid_t pid, int ordre);
   
   // Le mutex est là uniquement pour pouvoir émuler le comportement
   // de sem_getvalue() sur un système comme MacOS X qui ne possède pas
   // cette fonction.
   
 #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) \
Line 480  int sem_getvalue2(sem_t *semaphore, int Line 497  int sem_getvalue2(sem_t *semaphore, int
 #define ufprintf(flux, ...) transliterated_fprintf(NULL, \  #define ufprintf(flux, ...) transliterated_fprintf(NULL, \
             flux, __VA_ARGS__)              flux, __VA_ARGS__)
   
 // Tous les messages pour DISP, INPUT et les E/S par readline sont sur stderr.  
 // Cela évite aux messages envoyés par les gestionnaires de signaux d'être  
 // indéfiniment bloqués.  
   
 #ifdef SunOS  #ifdef SunOS
 #   define fopen(...) ({ FILE *desc; \  #   define fopen(...) ({ FILE *desc; \
             while((desc = fopen(__VA_ARGS__)) == NULL) \              while((desc = fopen(__VA_ARGS__)) == NULL) \
Line 732  pid_t debug_fork(); Line 745  pid_t debug_fork();
 --------------------------------------------------------------------------------  --------------------------------------------------------------------------------
 */  */
   
 #define DEBUG_ERREURS  
 #ifdef DEBUG_ERREURS  #ifdef DEBUG_ERREURS
 #   ifdef MESSAGES  #   ifdef MESSAGES
 #       define __erreur(i)  i  #       define __erreur(i)  i
Line 2170  typedef struct processus Line 2182  typedef struct processus
     pthread_mutex_t             mutex_allocation;      pthread_mutex_t             mutex_allocation;
   
     // Mutex autorisant les fork()      // Mutex autorisant les fork()
     pthread_mutex_t             mutex_fork;      sem_t
   #   ifdef SEMAPHORES_NOMMES
           *
   #   endif
                                   semaphore_fork;
   
 /* Mutexes                                          */  /* Mutexes                                          */
   
Removed from v.1.123  
changed lines
  Added in v.1.131

CVSweb interface <joel.bertrand@systella.fr>