1: /*
2: ================================================================================
3: RPL/2 (R) version 4.1.3
4: Copyright (C) 1989-2011 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: struct_processus *s_etat_processus;
49:
50: struct rusage s_rusage;
51:
52: struct timespec temporisation;
53:
54: s_etat_processus = argument;
55:
56: if ((*s_etat_processus).debug == d_vrai)
57: if (((*s_etat_processus).type_debug &
58: d_debug_fusible) != 0)
59: {
60: if ((*s_etat_processus).langue == 'F')
61: {
62: printf("[%d] Lancement du thread fusible du"
63: " processus\n", (int) getpid());
64: }
65: else
66: {
67: printf("[%d] Start fuse process\n", (int) getpid());
68: }
69:
70: fflush(stdout);
71: }
72:
73: s_etat_processus = argument;
74:
75: temporisation.tv_sec = 0;
76: temporisation.tv_nsec = 100000000; // un dixième de seconde
77:
78: pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
79:
80: getrusage(RUSAGE_SELF, &s_rusage);
81: temps_cpu_courant = s_rusage.ru_utime.tv_sec +
82: (((real8) s_rusage.ru_utime.tv_usec) / ((real8) 1E6));
83:
84: do
85: {
86: pthread_testcancel();
87: nanosleep(&temporisation, NULL);
88: getrusage(RUSAGE_SELF, &s_rusage);
89:
90: temps_cpu_precedent = temps_cpu_courant;
91: temps_cpu_courant = s_rusage.ru_utime.tv_sec +
92: (((real8) s_rusage.ru_utime.tv_usec) / ((real8) 1E6));
93:
94: (*s_etat_processus).temps_maximal_cpu -= temps_cpu_courant -
95: temps_cpu_precedent;
96:
97: if ((*s_etat_processus).temps_maximal_cpu <= 0)
98: {
99: (*s_etat_processus).temps_maximal_cpu = 0;
100:
101: envoi_signal_thread((*s_etat_processus)
102: .thread_surveille_par_fusible, rpl_sigstop);
103: break;
104: }
105: } while((*s_etat_processus).var_volatile_requete_arret == 0);
106:
107: if ((*s_etat_processus).debug == d_vrai)
108: if (((*s_etat_processus).type_debug &
109: d_debug_fusible) != 0)
110: {
111: if ((*s_etat_processus).langue == 'F')
112: {
113: printf("[%d] Arrêt du thread fusible du"
114: " processus\n", (int) getpid());
115: }
116: else
117: {
118: printf("[%d] Stop fuse process\n", (int) getpid());
119: }
120:
121: fflush(stdout);
122: }
123:
124: # else
125:
126: struct_processus *s_etat_processus;
127:
128: s_etat_processus = argument;
129:
130: if ((*s_etat_processus).langue == 'F')
131: {
132: printf("+++Attention : Support indisponible sous OS/2\n");
133: }
134: else
135: {
136: printf("+++Warning : Function unavailable\n");
137: }
138: # endif
139:
140: pthread_exit(NULL);
141: }
142:
143: // vim: ts=4
CVSweb interface <joel.bertrand@systella.fr>