Return to fusible.c CVS log

Up to [local] / rpl / src

Quelques patches pour OS/2.

    1: /*
    2: ================================================================================
    3:   RPL/2 (R) version 4.0.18
    4:   Copyright (C) 1989-2010 Dr. BERTRAND Joël
    5: 
    6:   This file is part of RPL/2.
    7: 
    8:   RPL/2 is free software; you can redistribute it and/or modify it
    9:   under the terms of the CeCILL V2 License as published by the french
   10:   CEA, CNRS and INRIA.
   11:  
   12:   RPL/2 is distributed in the hope that it will be useful, but WITHOUT
   13:   ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
   14:   FITNESS FOR A PARTICULAR PURPOSE.  See the CeCILL V2 License
   15:   for more details.
   16:  
   17:   You should have received a copy of the CeCILL License
   18:   along with RPL/2. If not, write to info@cecill.info.
   19: ================================================================================
   20: */
   21: 
   22: 
   23: #include "rpl-conv.h"
   24: 
   25: 
   26: /*
   27: ================================================================================
   28:   Fonction fusible.
   29:   Elle déclanche un signal d'arrêt (SIGFSTOP) lorsque le timeout est
   30:   dépassé.
   31: ================================================================================
   32:   Entrées : pointeur sur une structure
   33: --------------------------------------------------------------------------------
   34:   Sorties :
   35: --------------------------------------------------------------------------------
   36:   Effets de bord : néant
   37: ================================================================================
   38: */
   39: 
   40: void *
   41: fusible(void *argument)
   42: {
   43: #   ifndef OS2
   44: 
   45:     real8                   temps_cpu_precedent;
   46:     real8                   temps_cpu_courant;
   47: 
   48:     sigset_t                masque;
   49: 
   50:     struct_processus        *s_etat_processus;
   51: 
   52:     struct rusage           s_rusage;
   53: 
   54:     struct timespec         temporisation;
   55: 
   56:     s_etat_processus = argument;
   57: 
   58:     sigemptyset(&masque);
   59:     sigaddset(&masque, SIGINJECT);
   60:     sigaddset(&masque, SIGFSTOP);
   61:     sigaddset(&masque, SIGFABORT);
   62:     sigaddset(&masque, SIGURG);
   63:     sigaddset(&masque, SIGALRM);
   64:     sigaddset(&masque, SIGCONT);
   65:     sigaddset(&masque, SIGINT);
   66:     pthread_sigmask(SIG_BLOCK, &masque, NULL);
   67: 
   68:     if ((*s_etat_processus).debug == d_vrai)
   69:         if (((*s_etat_processus).type_debug &
   70:                 d_debug_fusible) != 0)
   71:     {
   72:         if ((*s_etat_processus).langue == 'F')
   73:         {
   74:             printf("[%d] Lancement du thread fusible du"
   75:                     " processus\n", (int) getpid());
   76:         }
   77:         else
   78:         {
   79:             printf("[%d] Start fuse process\n", (int) getpid());
   80:         }
   81: 
   82:         fflush(stdout);
   83:     }
   84: 
   85:     s_etat_processus = argument;
   86: 
   87:     temporisation.tv_sec = 0;
   88:     temporisation.tv_nsec = 100000000; // un dixième de seconde
   89: 
   90:     pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
   91: 
   92:     getrusage(RUSAGE_SELF, &s_rusage);
   93:     temps_cpu_courant = s_rusage.ru_utime.tv_sec +
   94:             (((real8) s_rusage.ru_utime.tv_usec) / ((real8) 1E6));
   95: 
   96:     do
   97:     {
   98:         pthread_testcancel();
   99:         nanosleep(&temporisation, NULL);
  100:         getrusage(RUSAGE_SELF, &s_rusage);
  101: 
  102:         temps_cpu_precedent = temps_cpu_courant;
  103:         temps_cpu_courant = s_rusage.ru_utime.tv_sec +
  104:                 (((real8) s_rusage.ru_utime.tv_usec) / ((real8) 1E6));
  105: 
  106:         (*s_etat_processus).temps_maximal_cpu -= temps_cpu_courant -
  107:                 temps_cpu_precedent;
  108: 
  109:         if ((*s_etat_processus).temps_maximal_cpu <= 0)
  110:         {
  111:             (*s_etat_processus).temps_maximal_cpu = 0;
  112: 
  113:             pthread_kill((*s_etat_processus).thread_surveille_par_fusible,
  114:                     SIGFSTOP);
  115:             break;
  116:         }
  117:     } while((*s_etat_processus).var_volatile_requete_arret == 0);
  118: 
  119:     if ((*s_etat_processus).debug == d_vrai)
  120:         if (((*s_etat_processus).type_debug &
  121:                 d_debug_fusible) != 0)
  122:     {
  123:         if ((*s_etat_processus).langue == 'F')
  124:         {
  125:             printf("[%d] Arrêt du thread fusible du"
  126:                     " processus\n", (int) getpid());
  127:         }
  128:         else
  129:         {
  130:             printf("[%d] Stop fuse process\n", (int) getpid());
  131:         }
  132: 
  133:         fflush(stdout);
  134:     }
  135: 
  136: #   else
  137: 
  138:     struct_processus        *s_etat_processus;
  139: 
  140:     s_etat_processus = argument;
  141: 
  142:     if ((*s_etat_processus).langue == 'F')
  143:     {
  144:         printf("+++Attention : Support indisponible sous OS/2\n");
  145:     }
  146:     else
  147:     {
  148:         printf("+++Attention : Function unavailable\n");
  149:     }
  150: #   endif
  151: 
  152:     pthread_exit(NULL);
  153: }
  154: 
  155: // vim: ts=4