Annotation of rpl/src/instructions_d5.c, revision 1.151
1.1 bertrand 1: /*
2: ================================================================================
1.138 bertrand 3: RPL/2 (R) version 4.1.25
4: Copyright (C) 1989-2016 Dr. BERTRAND Joël
1.1 bertrand 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:
1.33 bertrand 23: #include "rpl-conv.h"
1.1 bertrand 24:
25:
26: /*
27: ================================================================================
28: Fonction 'DFT'
29: ================================================================================
30: Entrées : structure processus
31: --------------------------------------------------------------------------------
32: Sorties :
33: --------------------------------------------------------------------------------
34: Effets de bord : néant
35: ================================================================================
36: */
37:
38: void
39: instruction_dft(struct_processus *s_etat_processus)
40: {
41: integer4 erreur;
42: integer4 inverse;
1.103 bertrand 43: integer4 longueur_dft;
1.1 bertrand 44: integer4 nombre_colonnes;
45: integer4 nombre_lignes;
46:
47: logical1 presence_longueur_dft;
48:
1.104 bertrand 49: integer8 longueur_dft_signee;
1.1 bertrand 50:
51: struct_complexe16 *matrice_f77;
52:
53: struct_objet *s_objet_argument;
54: struct_objet *s_objet_longueur_dft;
55: struct_objet *s_objet_resultat;
56:
1.103 bertrand 57: integer8 i;
58: integer8 j;
59: integer8 k;
1.1 bertrand 60:
61: (*s_etat_processus).erreur_execution = d_ex;
62:
63: if ((*s_etat_processus).affichage_arguments == 'Y')
64: {
65: printf("\n DFT ");
66:
67: if ((*s_etat_processus).langue == 'F')
68: {
69: printf("(transformée de Fourier discrète)\n\n");
70: }
71: else
72: {
73: printf("(discrete Fourier transform)\n\n");
74: }
75:
76: printf(" 1: %s, %s, %s\n", d_VIN, d_VRL, d_VCX);
77: printf("-> 1: %s\n\n", d_VCX);
78:
79: printf(" 2: %s, %s, %s\n", d_VIN, d_VRL, d_VCX);
80: printf(" 1: %s\n", d_INT);
81: printf("-> 1: %s\n\n", d_VCX);
82:
83: printf(" 1: %s, %s, %s\n", d_MIN, d_MRL, d_MCX);
84: printf("-> 1: %s\n\n", d_VCX);
85:
86: printf(" 2: %s, %s, %s\n", d_MIN, d_MRL, d_MCX);
87: printf(" 1: %s\n", d_INT);
88: printf("-> 1: %s\n", d_MCX);
89:
90: return;
91: }
92: else if ((*s_etat_processus).test_instruction == 'Y')
93: {
94: (*s_etat_processus).nombre_arguments = -1;
95: return;
96: }
97:
98: /*
99: * Il est possible d'imposer une longueur de DFT au premier niveau
100: * de la pile.
101: */
102:
103: if ((*s_etat_processus).l_base_pile == NULL)
104: {
105: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
106: return;
107: }
108:
109: if ((*(*(*s_etat_processus).l_base_pile).donnee).type == INT)
110: {
111: presence_longueur_dft = d_vrai;
112:
113: if (test_cfsf(s_etat_processus, 31) == d_vrai)
114: {
115: if (empilement_pile_last(s_etat_processus, 2) == d_erreur)
116: {
117: return;
118: }
119: }
120:
121: if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
122: &s_objet_longueur_dft) == d_erreur)
123: {
124: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
125: return;
126: }
127:
128: longueur_dft_signee = (*((integer8 *) (*s_objet_longueur_dft).objet));
129:
130: liberation(s_etat_processus, s_objet_longueur_dft);
131:
132: if (longueur_dft_signee <= 0)
133: {
134: (*s_etat_processus).erreur_execution = d_ex_longueur_dft;
135: return;
136: }
137:
1.103 bertrand 138: longueur_dft = (integer4) longueur_dft_signee;
1.1 bertrand 139: }
140: else
141: {
142: presence_longueur_dft = d_faux;
143: longueur_dft = 0;
144:
145: if (test_cfsf(s_etat_processus, 31) == d_vrai)
146: {
147: if (empilement_pile_last(s_etat_processus, 1) == d_erreur)
148: {
149: return;
150: }
151: }
152: }
153:
154: if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
155: &s_objet_argument) == d_erreur)
156: {
157: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
158: return;
159: }
160:
161: /*
162: --------------------------------------------------------------------------------
163: Vecteur
164: --------------------------------------------------------------------------------
165: */
166:
167: if (((*s_objet_argument).type == VIN) ||
168: ((*s_objet_argument).type == VRL) ||
169: ((*s_objet_argument).type == VCX))
170: {
171: if (presence_longueur_dft == d_faux)
172: {
1.103 bertrand 173: longueur_dft = (integer4) (*((struct_vecteur *)
1.1 bertrand 174: (*s_objet_argument).objet)).taille;
175: }
176:
1.103 bertrand 177: if ((matrice_f77 = malloc(((size_t) longueur_dft) *
1.1 bertrand 178: sizeof(struct_complexe16))) == NULL)
179: {
180: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
181: return;
182: }
183:
184: if ((*s_objet_argument).type == VIN)
185: {
186: for(i = 0; i < (*((struct_vecteur *) (*s_objet_argument).objet))
187: .taille; i++)
188: {
189: matrice_f77[i].partie_reelle = (real8) ((integer8 *)
190: (*((struct_vecteur *) (*s_objet_argument).objet))
191: .tableau)[i];
192: matrice_f77[i].partie_imaginaire = (real8) 0;
193: }
194: }
195: else if ((*s_objet_argument).type == VRL)
196: {
197: for(i = 0; i < (*((struct_vecteur *) (*s_objet_argument).objet))
198: .taille; i++)
199: {
200: matrice_f77[i].partie_reelle = ((real8 *)
201: (*((struct_vecteur *) (*s_objet_argument).objet))
202: .tableau)[i];
203: matrice_f77[i].partie_imaginaire = (real8) 0;
204: }
205: }
206: else
207: {
208: for(i = 0; i < (*((struct_vecteur *) (*s_objet_argument).objet))
209: .taille; i++)
210: {
211: matrice_f77[i].partie_reelle = ((struct_complexe16 *)
212: (*((struct_vecteur *) (*s_objet_argument).objet))
213: .tableau)[i].partie_reelle;
214: matrice_f77[i].partie_imaginaire = ((struct_complexe16 *)
215: (*((struct_vecteur *) (*s_objet_argument).objet))
216: .tableau)[i].partie_imaginaire;
217: }
218: }
219:
220: for(; i < longueur_dft; i++)
221: {
222: matrice_f77[i].partie_reelle = (real8) 0;
223: matrice_f77[i].partie_imaginaire = (real8) 0;
224: }
225:
226: nombre_lignes = 1;
227: nombre_colonnes = longueur_dft;
228: inverse = 0;
229:
230: dft(matrice_f77, &nombre_lignes, &nombre_colonnes, &inverse, &erreur);
231:
232: if (erreur != 0)
233: {
234: liberation(s_etat_processus, s_objet_argument);
235: free(matrice_f77);
236:
237: (*s_etat_processus).erreur_execution = d_ex_longueur_dft;
238: return;
239: }
240:
241: if ((s_objet_resultat = allocation(s_etat_processus, VCX)) == NULL)
242: {
243: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
244: return;
245: }
246:
247: (*((struct_vecteur *) (*s_objet_resultat).objet)).taille = longueur_dft;
248: (*((struct_vecteur *) (*s_objet_resultat).objet)).tableau = matrice_f77;
249: }
250:
251: /*
252: --------------------------------------------------------------------------------
253: Matrice
254: --------------------------------------------------------------------------------
255: */
256:
257: else if (((*s_objet_argument).type == MIN) ||
258: ((*s_objet_argument).type == MRL) ||
259: ((*s_objet_argument).type == MCX))
260: {
261: if (presence_longueur_dft == d_faux)
262: {
1.103 bertrand 263: longueur_dft = (integer4) (*((struct_matrice *)
1.1 bertrand 264: (*s_objet_argument).objet)).nombre_colonnes;
265: }
266:
1.103 bertrand 267: if ((matrice_f77 = malloc(((size_t) longueur_dft) * ((size_t)
1.1 bertrand 268: (*((struct_matrice *) (*s_objet_argument).objet))
1.103 bertrand 269: .nombre_lignes) * sizeof(struct_complexe16))) == NULL)
1.1 bertrand 270: {
271: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
272: return;
273: }
274:
275: if ((*s_objet_argument).type == MIN)
276: {
277: for(k = 0, j = 0; j < (*((struct_matrice *) (*s_objet_argument)
278: .objet)).nombre_lignes; j++)
279: {
280: for(i = 0; i < (*((struct_matrice *) (*s_objet_argument)
281: .objet)).nombre_colonnes; i++)
282: {
283: matrice_f77[k].partie_reelle = (real8) ((integer8 **)
284: (*((struct_matrice *) (*s_objet_argument).objet))
285: .tableau)[j][i];
286: matrice_f77[k++].partie_imaginaire = (real8) 0;
287: }
288: }
289:
290: for(; k < longueur_dft * (*((struct_matrice *) (*s_objet_argument)
291: .objet)).nombre_lignes; k++)
292: {
293: matrice_f77[k].partie_reelle = (real8) 0;
294: matrice_f77[k].partie_imaginaire = (real8) 0;
295: }
296: }
297: else if ((*s_objet_argument).type == MRL)
298: {
299: for(k = 0, j = 0; j < (*((struct_matrice *) (*s_objet_argument)
300: .objet)).nombre_lignes; j++)
301: {
302: for(i = 0; i < (*((struct_matrice *) (*s_objet_argument)
303: .objet)).nombre_colonnes; i++)
304: {
305: matrice_f77[k].partie_reelle = ((real8 **)
306: (*((struct_matrice *) (*s_objet_argument).objet))
307: .tableau)[j][i];
308: matrice_f77[k++].partie_imaginaire = (real8) 0;
309: }
310: }
311:
312: for(; k < longueur_dft * (*((struct_matrice *) (*s_objet_argument)
313: .objet)).nombre_lignes; k++)
314: {
315: matrice_f77[k].partie_reelle = (real8) 0;
316: matrice_f77[k].partie_imaginaire = (real8) 0;
317: }
318: }
319: else
320: {
321: for(k = 0, j = 0; j < (*((struct_matrice *) (*s_objet_argument)
322: .objet)).nombre_lignes; j++)
323: {
324: for(i = 0; i < (*((struct_matrice *) (*s_objet_argument)
325: .objet)).nombre_colonnes; i++)
326: {
327: matrice_f77[k].partie_reelle = ((struct_complexe16 **)
328: (*((struct_matrice *) (*s_objet_argument).objet))
329: .tableau)[j][i].partie_reelle;
330: matrice_f77[k++].partie_imaginaire =
331: ((struct_complexe16 **) (*((struct_matrice *)
332: (*s_objet_argument).objet)).tableau)[j][i]
333: .partie_imaginaire;
334: }
335: }
336:
337: for(; k < longueur_dft * (*((struct_matrice *) (*s_objet_argument)
338: .objet)).nombre_lignes; k++)
339: {
340: matrice_f77[k].partie_reelle = (real8) 0;
341: matrice_f77[k].partie_imaginaire = (real8) 0;
342: }
343: }
344:
1.103 bertrand 345: nombre_lignes = (integer4) (*((struct_matrice *) (*s_objet_argument)
346: .objet)).nombre_lignes;
1.1 bertrand 347: nombre_colonnes = longueur_dft;
348: inverse = 0;
349:
350: dft(matrice_f77, &nombre_lignes, &nombre_colonnes, &inverse, &erreur);
351:
352: if (erreur != 0)
353: {
354: liberation(s_etat_processus, s_objet_argument);
355: free(matrice_f77);
356:
357: (*s_etat_processus).erreur_execution = d_ex_longueur_dft;
358: return;
359: }
360:
361: if ((s_objet_resultat = allocation(s_etat_processus, MCX)) == NULL)
362: {
363: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
364: return;
365: }
366:
367: (*((struct_matrice *) (*s_objet_resultat).objet)).nombre_lignes =
368: (*((struct_matrice *) (*s_objet_argument).objet))
369: .nombre_lignes;
370: (*((struct_matrice *) (*s_objet_resultat).objet)).nombre_colonnes =
371: longueur_dft;
372:
373: if (((*((struct_matrice *) (*s_objet_resultat).objet)).tableau =
1.103 bertrand 374: malloc(((size_t) (*((struct_matrice *) (*s_objet_resultat)
375: .objet)).nombre_lignes) * sizeof(struct_complexe16 *))) == NULL)
1.1 bertrand 376: {
377: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
378: return;
379: }
380:
381: for(i = 0; i < (*((struct_matrice *) (*s_objet_resultat).objet))
382: .nombre_lignes; i++)
383: {
384: if ((((struct_complexe16 **) (*((struct_matrice *)
385: (*s_objet_resultat).objet)).tableau)[i] =
1.103 bertrand 386: malloc(((size_t) (*((struct_matrice *)
387: (*s_objet_resultat).objet)).nombre_colonnes) *
1.1 bertrand 388: sizeof(struct_complexe16))) == NULL)
389: {
390: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
391: return;
392: }
393: }
394:
395: for(k = 0, j = 0; j < (*((struct_matrice *) (*s_objet_resultat).objet))
396: .nombre_lignes; j++)
397: {
398: for(i = 0; i < (*((struct_matrice *) (*s_objet_resultat).objet))
399: .nombre_colonnes; i++)
400: {
401: ((struct_complexe16 **) (*((struct_matrice *)
402: (*s_objet_resultat).objet)).tableau)[j][i]
403: .partie_reelle = matrice_f77[k].partie_reelle;
404: ((struct_complexe16 **) (*((struct_matrice *)
405: (*s_objet_resultat).objet)).tableau)[j][i]
406: .partie_imaginaire = matrice_f77[k++].partie_imaginaire;
407: }
408: }
409:
410: free(matrice_f77);
411: }
412:
413: /*
414: --------------------------------------------------------------------------------
415: Calcul de DFT impossible
416: --------------------------------------------------------------------------------
417: */
418:
419: else
420: {
421: liberation(s_etat_processus, s_objet_argument);
422:
423: (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument;
424: return;
425: }
426:
427: liberation(s_etat_processus, s_objet_argument);
428:
429: if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
430: s_objet_resultat) == d_erreur)
431: {
432: return;
433: }
434:
435: return;
436: }
437:
438:
439: /*
440: ================================================================================
441: Fonction 'DER'
442: ================================================================================
443: Entrées : structure processus
444: --------------------------------------------------------------------------------
445: Sorties :
446: --------------------------------------------------------------------------------
447: Effets de bord : néant
448: ================================================================================
449: */
450:
451: void
452: instruction_der(struct_processus *s_etat_processus)
453: {
454: logical1 expression_rpn;
455: logical1 last_valide;
456:
457: struct_liste_chainee *l_element_courant;
458: struct_liste_chainee *l_element_precedent;
459:
460: struct_objet *s_copie_argument_2;
461: struct_objet *s_objet_argument_1;
462: struct_objet *s_objet_argument_2;
463: struct_objet *s_objet_resultat;
464: struct_objet *s_objet_simplifie;
465:
466: (*s_etat_processus).erreur_execution = d_ex;
467:
468: if ((*s_etat_processus).affichage_arguments == 'Y')
469: {
470: printf("\n DER ");
471:
472: if ((*s_etat_processus).langue == 'F')
473: {
474: printf("(dérivation)\n\n");
475: }
476: else
477: {
478: printf("(derivation)\n\n");
479: }
480:
481: printf(" 2: %s, %s, %s, %s\n", d_INT, d_REL, d_CPL, d_NOM);
482: printf(" 1: %s\n", d_NOM);
483: printf("-> 1: %s\n\n", d_INT);
484:
485: printf(" 2: %s, %s\n", d_RPN, d_ALG);
486: printf(" 1: %s\n", d_NOM);
487: printf("-> 1: %s, %s\n", d_RPN, d_ALG);
488:
489: return;
490: }
491: else if ((*s_etat_processus).test_instruction == 'Y')
492: {
493: (*s_etat_processus).nombre_arguments = 2;
494: return;
495: }
496:
497: if ((last_valide = test_cfsf(s_etat_processus, 31)) == d_vrai)
498: {
499: if (empilement_pile_last(s_etat_processus, 2) == d_erreur)
500: {
501: return;
502: }
503: }
504:
505: if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
506: &s_objet_argument_1) == d_erreur)
507: {
508: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
509: return;
510: }
511:
512: if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
513: &s_objet_argument_2) == d_erreur)
514: {
515: liberation(s_etat_processus, s_objet_argument_1);
516:
517: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
518: return;
519: }
520:
521: expression_rpn = d_faux;
522:
523: /*
524: * Dérivation d'une expression
525: */
526:
527: if (((*s_objet_argument_1).type == NOM) &&
528: (((*s_objet_argument_2).type == RPN) ||
529: ((*s_objet_argument_2).type == ALG)))
530: {
531: if ((s_copie_argument_2 = copie_objet(s_etat_processus,
532: s_objet_argument_2, 'N')) == NULL)
533: {
534: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
535: return;
536: }
537:
538: if ((*s_copie_argument_2).type == RPN)
539: {
540: expression_rpn = d_vrai;
541: }
542:
543: l_element_courant = (struct_liste_chainee *)
544: (*s_copie_argument_2).objet;
545: l_element_precedent = l_element_courant;
546:
547: while((*l_element_courant).suivant != NULL)
548: {
549: l_element_precedent = l_element_courant;
550: l_element_courant = (*l_element_courant).suivant;
551: }
552:
553: if (((*l_element_precedent).suivant =
554: allocation_maillon(s_etat_processus)) == NULL)
555: {
556: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
557: return;
558: }
559:
560: (*(*l_element_precedent).suivant).donnee = s_objet_argument_1;
561: l_element_precedent = (*l_element_precedent).suivant;
562:
563: if (((*l_element_precedent).suivant =
564: allocation_maillon(s_etat_processus)) == NULL)
565: {
566: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
567: return;
568: }
569:
570: if (((*(*l_element_precedent).suivant).donnee =
571: allocation(s_etat_processus, FCT)) == NULL)
572: {
573: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
574: return;
575: }
576:
577: (*((struct_fonction *) (*(*(*l_element_precedent).suivant)
578: .donnee).objet)).nombre_arguments = 2;
579: (*((struct_fonction *) (*(*(*l_element_precedent).suivant)
580: .donnee).objet)).fonction = instruction_der;
581:
582: if (((*((struct_fonction *) (*(*(*l_element_precedent)
583: .suivant).donnee).objet)).nom_fonction =
584: malloc(4 * sizeof(unsigned char))) == NULL)
585: {
586: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
587: return;
588: }
589:
590: strcpy((*((struct_fonction *) (*(*(*l_element_precedent)
591: .suivant).donnee).objet)).nom_fonction, "DER");
592:
593: (*(*l_element_precedent).suivant).suivant = l_element_courant;
594:
595: s_objet_resultat = s_copie_argument_2;
596: s_objet_argument_1 = NULL;
597: }
598:
599: /*
600: * Dérivation d'un nom ou d'une constante
601: */
602:
603: else if (((*s_objet_argument_1).type == NOM) &&
604: (((*s_objet_argument_2).type == NOM) ||
605: ((*s_objet_argument_2).type == INT) ||
606: ((*s_objet_argument_2).type == REL) ||
607: ((*s_objet_argument_2).type == CPL)))
608: {
609: if ((s_objet_resultat = allocation(s_etat_processus, ALG)) == NULL)
610: {
611: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
612: return;
613: }
614:
615: if (((*s_objet_resultat).objet =
616: allocation_maillon(s_etat_processus)) == NULL)
617: {
618: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
619: return;
620: }
621:
622: l_element_courant = (*s_objet_resultat).objet;
623:
624: if (((*l_element_courant).donnee = allocation(s_etat_processus, FCT))
625: == NULL)
626: {
627: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
628: return;
629: }
630:
631: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
632: .nombre_arguments = 0;
633: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
634: .fonction = instruction_vers_niveau_superieur;
635:
636: if (((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
637: .nom_fonction = malloc(3 * sizeof(unsigned char))) == NULL)
638: {
639: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
640: return;
641: }
642:
643: strcpy((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
644: .nom_fonction, "<<");
645:
646: if (((*l_element_courant).suivant =
647: allocation_maillon(s_etat_processus)) == NULL)
648: {
649: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
650: return;
651: }
652:
653: l_element_courant = (*l_element_courant).suivant;
654: (*l_element_courant).donnee = s_objet_argument_2;
655:
656: if (((*l_element_courant).suivant =
657: allocation_maillon(s_etat_processus)) == NULL)
658: {
659: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
660: return;
661: }
662:
663: l_element_courant = (*l_element_courant).suivant;
664: (*l_element_courant).donnee = s_objet_argument_1;
665:
666: if (((*l_element_courant).suivant =
667: allocation_maillon(s_etat_processus)) == NULL)
668: {
669: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
670: return;
671: }
672:
673: l_element_courant = (*l_element_courant).suivant;
674:
675: if (((*l_element_courant).donnee = allocation(s_etat_processus, FCT))
676: == NULL)
677: {
678: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
679: return;
680: }
681:
682: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
683: .nombre_arguments = 2;
684: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
685: .fonction = instruction_der;
686:
687: if (((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
688: .nom_fonction = malloc(4 * sizeof(unsigned char))) == NULL)
689: {
690: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
691: return;
692: }
693:
694: strcpy((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
695: .nom_fonction, "DER");
696:
697: if (((*l_element_courant).suivant =
698: allocation_maillon(s_etat_processus)) == NULL)
699: {
700: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
701: return;
702: }
703:
704: l_element_courant = (*l_element_courant).suivant;
705:
706: if (((*l_element_courant).donnee = allocation(s_etat_processus, FCT))
707: == NULL)
708: {
709: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
710: return;
711: }
712:
713: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
714: .nombre_arguments = 0;
715: (*((struct_fonction *) (*(*l_element_courant).donnee).objet))
716: .fonction = instruction_vers_niveau_inferieur;
717:
718: if (((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
719: .nom_fonction = malloc(3 * sizeof(unsigned char))) == NULL)
720: {
721: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
722: return;
723: }
724:
725: strcpy((*((struct_fonction *) (*(*l_element_courant).donnee).objet))
726: .nom_fonction, ">>");
727:
728: (*l_element_courant).suivant = NULL;
729:
730: s_objet_argument_1 = NULL;
731: s_objet_argument_2 = NULL;
732: }
733:
734: /*
735: * Dérivation impossible
736: */
737:
738: else
739: {
740: liberation(s_etat_processus, s_objet_argument_1);
741: liberation(s_etat_processus, s_objet_argument_2);
742:
743: (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument;
744: return;
745: }
746:
747: liberation(s_etat_processus, s_objet_argument_1);
748: liberation(s_etat_processus, s_objet_argument_2);
749:
750: if (expression_rpn == d_faux)
751: {
752: if (last_valide == d_vrai)
753: {
754: cf(s_etat_processus, 31);
755: }
756:
757: derivation(s_etat_processus, &s_objet_resultat);
758:
759: if (last_valide == d_vrai)
760: {
761: sf(s_etat_processus, 31);
762: }
763:
764: if (((*s_etat_processus).var_volatile_requete_arret == 0) &&
765: (s_objet_resultat != NULL))
766: {
767: if ((s_objet_simplifie = simplification(s_etat_processus,
768: s_objet_resultat)) == NULL)
769: {
1.119 bertrand 770: liberation(s_etat_processus, s_objet_resultat);
1.1 bertrand 771: return;
772: }
773:
774: liberation(s_etat_processus, s_objet_resultat);
775:
776: if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
777: s_objet_simplifie) == d_erreur)
778: {
779: return;
780: }
781: }
782: else
783: {
784: if (s_objet_resultat != NULL)
785: {
786: liberation(s_etat_processus, s_objet_resultat);
787: }
788: }
789: }
790: else
791: {
792: if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
793: s_objet_resultat) == d_erreur)
794: {
795: return;
796: }
797: }
798:
799: return;
800: }
801:
802:
803: /*
804: ================================================================================
805: Fonction 'DETACH'
806: ================================================================================
807: Entrées : structure processus
808: --------------------------------------------------------------------------------
809: Sorties :
810: --------------------------------------------------------------------------------
811: Effets de bord : néant
812: ================================================================================
813: */
814:
815: void
816: instruction_detach(struct_processus *s_etat_processus)
817: {
1.95 bertrand 818: int pipe_initialisation_segment_signaux[2];
1.69 bertrand 819:
1.95 bertrand 820: logical1 drapeau;
1.1 bertrand 821:
1.95 bertrand 822: pid_t ppid;
1.1 bertrand 823:
1.95 bertrand 824: pthread_attr_t attributs;
1.1 bertrand 825:
1.95 bertrand 826: pthread_mutexattr_t attributs_mutex;
1.1 bertrand 827:
1.95 bertrand 828: pthread_t thread_surveillance;
1.1 bertrand 829:
1.95 bertrand 830: sig_atomic_t registre_stop;
1.1 bertrand 831:
1.95 bertrand 832: ssize_t longueur_ecriture;
1.1 bertrand 833:
1.95 bertrand 834: struct_descripteur_thread *s_argument_thread;
835: struct_descripteur_thread *s_argument_thread2;
1.1 bertrand 836:
1.95 bertrand 837: struct_liste_chainee *l_element_courant;
838: struct_liste_chainee *l_element_precedent;
839: struct_liste_chainee *l_element_suivant;
1.1 bertrand 840:
1.98 bertrand 841: struct_liste_variables_partagees *l_element_partage_courant;
842: struct_liste_variables_partagees *l_element_partage_suivant;
843:
1.95 bertrand 844: struct_liste_variables_statiques *l_element_statique_courant;
845: struct_liste_variables_statiques *l_element_statique_suivant;
1.1 bertrand 846:
1.95 bertrand 847: struct_objet *s_copie;
848: struct_objet *s_objet;
849: struct_objet *s_objet_systeme;
850: struct_objet *s_objet_temporaire;
1.1 bertrand 851:
1.95 bertrand 852: struct sigaction action;
853: struct sigaction registre;
1.1 bertrand 854:
1.95 bertrand 855: struct timespec attente;
1.1 bertrand 856:
1.95 bertrand 857: unsigned char caractere;
858: unsigned char *message;
1.1 bertrand 859:
1.95 bertrand 860: unsigned int erreur;
1.1 bertrand 861:
1.103 bertrand 862: integer8 i;
1.95 bertrand 863:
864: volatile logical1 variable_partagee;
1.77 bertrand 865:
1.1 bertrand 866: (*s_etat_processus).erreur_execution = d_ex;
867:
868: attente.tv_sec = 0;
869: attente.tv_nsec = GRANULARITE_us * 1000;
870: s_copie = NULL;
871:
872: if ((*s_etat_processus).affichage_arguments == 'Y')
873: {
874: printf("\n DETACH ");
875:
876: if ((*s_etat_processus).langue == 'F')
877: {
878: printf("(détachement d'un processus)\n\n");
879: }
880: else
881: {
882: printf("(fork)\n\n");
883: }
884:
885: printf(" 1: %s, %s\n", d_NOM, d_RPN);
886: printf("-> 1: %s\n", d_PRC);
887:
888: return;
889: }
890: else if ((*s_etat_processus).test_instruction == 'Y')
891: {
892: (*s_etat_processus).nombre_arguments = -1;
893: return;
894: }
895:
896: if (test_cfsf(s_etat_processus, 31) == d_vrai)
897: {
898: if (empilement_pile_last(s_etat_processus, 1) == d_erreur)
899: {
900: return;
901: }
902: }
903:
904: if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
905: &s_objet) == d_erreur)
906: {
907: (*s_etat_processus).erreur_execution = d_ex_manque_argument;
908: return;
909: }
910:
911: /*
912: * Une routine fille doit pouvoir renvoyer des objets au processus
913: * père au travers de la fonction SEND. Il ne peut donc s'agir que
914: * d'une fonction ou d'une expression RPN.
915: */
916:
917: if (((*s_objet).type != NOM) && ((*s_objet).type != RPN))
918: {
919: liberation(s_etat_processus, s_objet);
920:
921: (*s_etat_processus).erreur_execution = d_ex_erreur_type_argument;
922: return;
923: }
924:
925: /*
926: * Si l'argument est de type NOM, il faut que la variable correspondante
927: * soit une variable de type RPN.
928: */
929:
930: variable_partagee = d_faux;
931:
932: if ((*s_objet).type == NOM)
933: {
934: if (recherche_variable(s_etat_processus, (*((struct_nom *)
935: (*s_objet).objet)).nom) == d_vrai)
936: {
1.52 bertrand 937: if ((*(*s_etat_processus).pointeur_variable_courante).objet
1.1 bertrand 938: == NULL)
939: {
940: if (recherche_variable_partagee(s_etat_processus,
1.52 bertrand 941: (*(*s_etat_processus).pointeur_variable_courante).nom,
942: (*(*s_etat_processus).pointeur_variable_courante)
943: .variable_partagee, (*(*s_etat_processus)
1.98 bertrand 944: .pointeur_variable_courante).origine) == NULL)
1.1 bertrand 945: {
946: liberation(s_etat_processus, s_objet);
947:
948: (*s_etat_processus).erreur_systeme = d_es;
949: (*s_etat_processus).erreur_execution =
950: d_ex_argument_invalide;
951: return;
952: }
953:
1.97 bertrand 954: if (((*(*(*s_etat_processus)
955: .pointeur_variable_partagee_courante).objet).type
956: == RPN) && ((*(*(*s_etat_processus)
957: .pointeur_variable_partagee_courante).objet).type
958: == ADR))
1.1 bertrand 959: {
960: if (pthread_mutex_unlock(&((*(*s_etat_processus)
1.97 bertrand 961: .pointeur_variable_partagee_courante).mutex)) != 0)
1.1 bertrand 962: {
963: (*s_etat_processus).erreur_systeme = d_es_processus;
964: return;
965: }
966:
967: liberation(s_etat_processus, s_objet);
968:
969: (*s_etat_processus).erreur_execution =
970: d_ex_argument_invalide;
971: return;
972: }
973:
974: if ((s_copie = copie_objet(s_etat_processus,
1.97 bertrand 975: (*(*s_etat_processus)
976: .pointeur_variable_partagee_courante).objet, 'P'))
977: == NULL)
1.1 bertrand 978: {
979: if (pthread_mutex_unlock(&((*(*s_etat_processus)
1.97 bertrand 980: .pointeur_variable_partagee_courante).mutex)) != 0)
1.1 bertrand 981: {
982: (*s_etat_processus).erreur_systeme = d_es_processus;
983: return;
984: }
985:
986: (*s_etat_processus).erreur_systeme =
987: d_es_allocation_memoire;
988:
989: return;
990: }
991:
992: variable_partagee = d_vrai;
993:
994: if (pthread_mutex_unlock(&((*(*s_etat_processus)
1.97 bertrand 995: .pointeur_variable_partagee_courante).mutex)) != 0)
1.1 bertrand 996: {
997: (*s_etat_processus).erreur_systeme = d_es_processus;
998: return;
999: }
1000: }
1001: else
1002: {
1.52 bertrand 1003: if (((*(*(*s_etat_processus).pointeur_variable_courante).objet)
1004: .type != RPN) && ((*(*(*s_etat_processus)
1005: .pointeur_variable_courante).objet).type != ADR))
1.1 bertrand 1006: {
1007: liberation(s_etat_processus, s_objet);
1008:
1009: (*s_etat_processus).erreur_execution =
1010: d_ex_argument_invalide;
1011: return;
1012: }
1013: }
1014: }
1015: else // Variable inexistante
1016: {
1017: liberation(s_etat_processus, s_objet);
1018:
1019: (*s_etat_processus).erreur_systeme = d_es;
1020: (*s_etat_processus).erreur_execution = d_ex_argument_invalide;
1021: return;
1022: }
1023: }
1024:
1025: if ((s_argument_thread = malloc(sizeof(struct_descripteur_thread))) == NULL)
1026: {
1027: (*s_etat_processus).erreur_systeme = d_es_processus;
1028: return;
1029: }
1030:
1031: if (pipe((*s_argument_thread).pipe_erreurs) != 0)
1032: {
1033: (*s_etat_processus).erreur_systeme = d_es_processus;
1034: return;
1035: }
1036:
1037: if (pipe((*s_argument_thread).pipe_interruptions) != 0)
1038: {
1039: (*s_etat_processus).erreur_systeme = d_es_processus;
1040: return;
1041: }
1042:
1.108 bertrand 1043: if (pipe((*s_argument_thread).pipe_nombre_elements_attente) != 0)
1.1 bertrand 1044: {
1045: (*s_etat_processus).erreur_systeme = d_es_processus;
1046: return;
1047: }
1048:
1049: if (pipe((*s_argument_thread).pipe_objets) != 0)
1050: {
1051: (*s_etat_processus).erreur_systeme = d_es_processus;
1052: return;
1053: }
1054:
1055: if (pipe((*s_argument_thread).pipe_acquittement) != 0)
1056: {
1057: (*s_etat_processus).erreur_systeme = d_es_processus;
1058: return;
1059: }
1060:
1061: if (pipe((*s_argument_thread).pipe_injections) != 0)
1062: {
1063: (*s_etat_processus).erreur_systeme = d_es_processus;
1064: return;
1065: }
1066:
1067: if (pipe((*s_argument_thread).pipe_nombre_injections) != 0)
1068: {
1069: (*s_etat_processus).erreur_systeme = d_es_processus;
1070: return;
1071: }
1072:
1.69 bertrand 1073: if (pipe(pipe_initialisation_segment_signaux) != 0)
1074: {
1075: (*s_etat_processus).erreur_systeme = d_es_processus;
1076: return;
1077: }
1078:
1.1 bertrand 1079: ppid = getpid();
1080:
1081: /*
1082: * Le mutex suivant permet de copier un contexte propre.
1083: */
1084:
1.112 bertrand 1085: if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus)) != 0)
1.1 bertrand 1086: {
1087: (*s_etat_processus).erreur_systeme = d_es_processus;
1088: return;
1089: }
1090:
1.134 bertrand 1091: if (pthread_mutex_lock(&mutex_liste_variables_partagees) != 0)
1.125 bertrand 1092: {
1093: (*s_etat_processus).erreur_systeme = d_es_processus;
1094: return;
1095: }
1096:
1.140 bertrand 1097: verrouillage_threads_concurrents(s_etat_processus);
1098:
1.134 bertrand 1099: if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation_buffer)) != 0)
1.132 bertrand 1100: {
1101: (*s_etat_processus).erreur_systeme = d_es_processus;
1102: return;
1103: }
1104:
1.1 bertrand 1105: fflush(NULL);
1106:
1107: /*
1108: * On bloque tous les threads concurents pour qu'il n'y ait ni allocation
1109: * de mémoire, ni libération, ni copie d'objet concurrent au fork().
1110: */
1111:
1112: (*s_argument_thread).pid = fork();
1.139 bertrand 1113:
1.125 bertrand 1114: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation_buffer))
1115: != 0)
1116: {
1117: (*s_etat_processus).erreur_systeme = d_es_processus;
1118: return;
1119: }
1120:
1.140 bertrand 1121: if ((*s_argument_thread).pid > 0)
1122: {
1123: // On ne déverrouille les threads concurrents que dans le processus
1124: // père. Dans le fils, les valeurs sont non initialisées.
1125: deverrouillage_threads_concurrents(s_etat_processus);
1126: }
1127:
1.1 bertrand 1128: (*s_argument_thread).thread_pere = pthread_self();
1129: (*s_argument_thread).processus_detache = d_vrai;
1130:
1131: pthread_mutexattr_init(&attributs_mutex);
1132: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
1133: pthread_mutex_init(&((*s_argument_thread).mutex), &attributs_mutex);
1134: pthread_mutexattr_destroy(&attributs_mutex);
1135:
1.42 bertrand 1136: pthread_mutexattr_init(&attributs_mutex);
1137: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
1138: pthread_mutex_init(&((*s_argument_thread).mutex_nombre_references),
1139: &attributs_mutex);
1140: pthread_mutexattr_destroy(&attributs_mutex);
1141:
1.1 bertrand 1142: if ((*s_argument_thread).pid > 0)
1143: {
1144: /*
1145: * Processus père
1146: */
1147:
1.132 bertrand 1148: if (pthread_mutex_unlock(&mutex_liste_variables_partagees) != 0)
1149: {
1150: (*s_etat_processus).erreur_systeme = d_es_processus;
1151: return;
1152: }
1153:
1.1 bertrand 1154: if (variable_partagee == d_vrai)
1155: {
1156: liberation(s_etat_processus, s_copie);
1157: }
1158:
1.26 bertrand 1159: liberation(s_etat_processus, s_objet);
1160:
1161: if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
1162: {
1163: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
1164: return;
1165: }
1166:
1167: (*((struct_processus_fils *) (*s_objet).objet)).thread =
1168: s_argument_thread;
1169: (*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1170: .nombre_objets_dans_pipe = 0;
1171: (*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1172: .nombre_interruptions_dans_pipe = 0;
1173: (*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1174: .nombre_references = 1;
1175:
1176: /*
1177: * On copie l'objet plutôt que le pointeur car cet objet peut être
1178: * accédé depuis deux threads distincts et aboutir à un blocage lors
1179: * d'une copie.
1180: */
1181:
1182: if ((s_objet_systeme = copie_objet(s_etat_processus, s_objet, 'O'))
1183: == NULL)
1.1 bertrand 1184: {
1.26 bertrand 1185: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
1.1 bertrand 1186: return;
1187: }
1188:
1189: if (close((*s_argument_thread).pipe_erreurs[1]) != 0)
1190: {
1191: (*s_etat_processus).erreur_systeme = d_es_processus;
1192: return;
1193: }
1194:
1195: if (close((*s_argument_thread).pipe_interruptions[1]) != 0)
1196: {
1197: (*s_etat_processus).erreur_systeme = d_es_processus;
1198: return;
1199: }
1200:
1.108 bertrand 1201: if (close((*s_argument_thread).pipe_nombre_elements_attente[1])
1.1 bertrand 1202: != 0)
1203: {
1204: (*s_etat_processus).erreur_systeme = d_es_processus;
1205: return;
1206: }
1207:
1208: if (close((*s_argument_thread).pipe_objets[1]) != 0)
1209: {
1210: (*s_etat_processus).erreur_systeme = d_es_processus;
1211: return;
1212: }
1213:
1214: if (close((*s_argument_thread).pipe_injections[0]) != 0)
1215: {
1216: (*s_etat_processus).erreur_systeme = d_es_processus;
1217: return;
1218: }
1219:
1220: if (close((*s_argument_thread).pipe_nombre_injections[0]) != 0)
1221: {
1222: (*s_etat_processus).erreur_systeme = d_es_processus;
1223: return;
1224: }
1225:
1226: if (close((*s_argument_thread).pipe_acquittement[0]) != 0)
1227: {
1228: (*s_etat_processus).erreur_systeme = d_es_processus;
1229: return;
1230: }
1231:
1232: if (pthread_attr_init(&attributs) != 0)
1233: {
1234: (*s_etat_processus).erreur_systeme = d_es_processus;
1235: return;
1236: }
1237:
1238: if (pthread_attr_setdetachstate(&attributs,
1239: PTHREAD_CREATE_DETACHED) != 0)
1240: {
1241: (*s_etat_processus).erreur_systeme = d_es_processus;
1242: return;
1243: }
1244:
1.76 bertrand 1245: # ifdef SCHED_OTHER
1.1 bertrand 1246: if (pthread_attr_setschedpolicy(&attributs, SCHED_OTHER) != 0)
1247: {
1248: (*s_etat_processus).erreur_systeme = d_es_processus;
1249: return;
1250: }
1.76 bertrand 1251: # endif
1.1 bertrand 1252:
1.76 bertrand 1253: # ifdef PTHREAD_EXPLICIT_SCHED
1.1 bertrand 1254: if (pthread_attr_setinheritsched(&attributs,
1255: PTHREAD_EXPLICIT_SCHED) != 0)
1256: {
1257: (*s_etat_processus).erreur_systeme = d_es_processus;
1258: return;
1259: }
1.76 bertrand 1260: # endif
1.1 bertrand 1261:
1.76 bertrand 1262: # ifdef PTHREAD_SCOPE_SYSTEM
1.1 bertrand 1263: if (pthread_attr_setscope(&attributs, PTHREAD_SCOPE_SYSTEM) != 0)
1264: {
1265: (*s_etat_processus).erreur_systeme = d_es_processus;
1266: return;
1267: }
1.33 bertrand 1268: # endif
1.1 bertrand 1269:
1270: (*s_argument_thread).s_etat_processus = s_etat_processus;
1271:
1272: if (pthread_create(&thread_surveillance, &attributs,
1273: surveillance_processus, s_argument_thread) != 0)
1274: {
1275: (*s_etat_processus).erreur_systeme = d_es_processus;
1276: return;
1277: }
1278:
1279: if (pthread_attr_destroy(&attributs) != 0)
1280: {
1281: (*s_etat_processus).erreur_systeme = d_es_processus;
1282: return;
1283: }
1284: }
1285: else if ((*s_argument_thread).pid == 0)
1286: {
1287: /*
1288: * Processus fils
1289: */
1290:
1.151 ! bertrand 1291: // EPERM
1.132 bertrand 1292: pthread_mutex_destroy(&mutex_liste_variables_partagees);
1.142 bertrand 1293: pthread_mutex_destroy(&mutex_liste_threads);
1.132 bertrand 1294:
1295: pthread_mutexattr_init(&attributs_mutex);
1296: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
1297: pthread_mutex_init(&mutex_liste_variables_partagees, &attributs_mutex);
1298: pthread_mutexattr_destroy(&attributs_mutex);
1299:
1.136 bertrand 1300: pthread_mutexattr_init(&attributs_mutex);
1301: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
1302: pthread_mutex_init(&mutex_liste_threads, &attributs_mutex);
1303: pthread_mutexattr_destroy(&attributs_mutex);
1304:
1.130 bertrand 1305: liberation_queue_signaux(s_etat_processus);
1306: creation_queue_signaux(s_etat_processus);
1307:
1.74 bertrand 1308: routine_recursive = 0;
1.148 bertrand 1309: nombre_thread_surveillance_processus = 0;
1.37 bertrand 1310:
1.67 bertrand 1311: (*s_etat_processus).pointeur_signal_lecture = 0;
1312: (*s_etat_processus).pointeur_signal_ecriture = 0;
1.66 bertrand 1313:
1.69 bertrand 1314: if (write_atomic(s_etat_processus,
1315: pipe_initialisation_segment_signaux[1],
1316: "-", sizeof(unsigned char)) != sizeof(unsigned char))
1317: {
1318: (*s_etat_processus).erreur_systeme = d_es_processus;
1319: }
1320:
1321: close(pipe_initialisation_segment_signaux[0]);
1322: close(pipe_initialisation_segment_signaux[1]);
1323:
1.25 bertrand 1324: if ((*s_etat_processus).debug == d_vrai)
1325: if (((*s_etat_processus).type_debug &
1326: d_debug_processus) != 0)
1327: {
1328: if ((*s_etat_processus).langue == 'F')
1329: {
1330: printf("[%d] Lancement du processus fils %d de %d\n",
1331: (int) getpid(), (int) getpid(), (int) ppid);
1332: }
1333: else
1334: {
1335: printf("[%d] Start child process %d from %d\n", (int) getpid(),
1336: (int) getpid(), (int) ppid);
1337: }
1338:
1339: fflush(stdout);
1340: }
1341:
1.1 bertrand 1342: if (close((*s_argument_thread).pipe_erreurs[0]) != 0)
1343: {
1344: (*s_etat_processus).erreur_systeme = d_es_processus;
1345: }
1346: else if (close((*s_argument_thread).pipe_interruptions[0]) != 0)
1347: {
1348: (*s_etat_processus).erreur_systeme = d_es_processus;
1349: }
1350: else if (close((*s_argument_thread)
1.108 bertrand 1351: .pipe_nombre_elements_attente[0]) != 0)
1.1 bertrand 1352: {
1353: (*s_etat_processus).erreur_systeme = d_es_processus;
1354: }
1355: else if (close((*s_argument_thread).pipe_objets[0]) != 0)
1356: {
1357: (*s_etat_processus).erreur_systeme = d_es_processus;
1358: }
1359: else if (close((*s_argument_thread).pipe_injections[1]) != 0)
1360: {
1361: (*s_etat_processus).erreur_systeme = d_es_processus;
1362: }
1363: else if (close((*s_argument_thread).pipe_nombre_injections[1]) != 0)
1364: {
1365: (*s_etat_processus).erreur_systeme = d_es_processus;
1366: }
1367: else if (close((*s_argument_thread).pipe_acquittement[1]) != 0)
1368: {
1369: (*s_etat_processus).erreur_systeme = d_es_processus;
1370: }
1371:
1.25 bertrand 1372: if ((*s_etat_processus).debug == d_vrai)
1373: if (((*s_etat_processus).type_debug &
1374: d_debug_processus) != 0)
1375: {
1376: if ((*s_etat_processus).langue == 'F')
1377: {
1378: printf("[%d] Libération des objets du processus père\n",
1379: (int) getpid());
1380: }
1381: else
1382: {
1383: printf("[%d] Freeing parent process memory\n", getpid());
1384: }
1385:
1386: fflush(stdout);
1387: }
1388:
1.1 bertrand 1389: l_element_courant = (*s_etat_processus).liste_mutexes;
1390: while(l_element_courant != NULL)
1391: {
1392: liberation(s_etat_processus, (*l_element_courant).donnee);
1393: l_element_suivant = (*l_element_courant).suivant;
1394: free(l_element_courant);
1395: l_element_courant = l_element_suivant;
1396: }
1397:
1398: (*s_etat_processus).liste_mutexes = NULL;
1399:
1400: liberation_threads(s_etat_processus);
1401: insertion_thread(s_etat_processus, d_vrai);
1402:
1403: // Envoi d'une donnée pour signaler le démarrage du processus au thread
1404: // de surveillance.
1405:
1.108 bertrand 1406: caractere = 0;
1407:
1.1 bertrand 1408: if (write_atomic(s_etat_processus,
1.108 bertrand 1409: (*s_argument_thread).pipe_nombre_elements_attente[1],
1410: &caractere, sizeof(caractere)) != sizeof(caractere))
1.1 bertrand 1411: {
1.112 bertrand 1412: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 1413: (*s_etat_processus).erreur_systeme = d_es_processus;
1414:
1415: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1416: (*s_argument_thread).pipe_nombre_elements_attente[1],
1417: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 1418: {
1419: if (longueur_ecriture == -1)
1420: {
1421: break;
1422: }
1423: }
1424:
1.67 bertrand 1425: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1426: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1.1 bertrand 1427: exit(EXIT_FAILURE);
1428: }
1429:
1.91 bertrand 1430: if (pthread_mutex_destroy(&mutex_sections_critiques) != 0)
1431: {
1432: (*s_etat_processus).erreur_systeme = d_es_processus;
1433:
1434: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1435: (*s_argument_thread).pipe_nombre_elements_attente[1],
1436: &caractere, sizeof(caractere))) != sizeof(caractere))
1.91 bertrand 1437: {
1438: if (longueur_ecriture == -1)
1439: {
1440: break;
1441: }
1442: }
1443:
1444: destruction_queue_signaux(s_etat_processus);
1445: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1446: exit(EXIT_FAILURE);
1447: }
1448:
1449: pthread_mutexattr_init(&attributs_mutex);
1450: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
1451: pthread_mutex_init(&mutex_sections_critiques, &attributs_mutex);
1452: pthread_mutexattr_destroy(&attributs_mutex);
1453:
1.112 bertrand 1454: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
1455: != 0)
1.1 bertrand 1456: {
1457: (*s_etat_processus).erreur_systeme = d_es_processus;
1458:
1.108 bertrand 1459: caractere = 0;
1.1 bertrand 1460:
1461: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1462: (*s_argument_thread).pipe_nombre_elements_attente[1],
1463: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 1464: {
1465: if (longueur_ecriture == -1)
1466: {
1467: break;
1468: }
1469: }
1470:
1.67 bertrand 1471: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1472: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1.1 bertrand 1473: exit(EXIT_FAILURE);
1474: }
1475:
1.27 bertrand 1476: pthread_mutex_trylock(&((*s_etat_processus).protection_liste_mutexes));
1477:
1.1 bertrand 1478: if (pthread_mutex_unlock(&((*s_etat_processus)
1479: .protection_liste_mutexes)) != 0)
1480: {
1481: (*s_etat_processus).erreur_systeme = d_es_processus;
1482:
1.108 bertrand 1483: caractere = 0;
1.1 bertrand 1484:
1485: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1486: (*s_argument_thread).pipe_nombre_elements_attente[1],
1487: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 1488: {
1489: if (longueur_ecriture == -1)
1490: {
1491: break;
1492: }
1493: }
1494:
1.67 bertrand 1495: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1496: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1.1 bertrand 1497: exit(EXIT_FAILURE);
1498: }
1499:
1.111 bertrand 1500: pthread_mutex_trylock(&((*s_etat_processus).mutex_interruptions));
1501:
1502: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions))
1503: != 0)
1504: {
1505: (*s_etat_processus).erreur_systeme = d_es_processus;
1506:
1507: caractere = 0;
1508:
1509: while((longueur_ecriture = write_atomic(s_etat_processus,
1510: (*s_argument_thread).pipe_nombre_elements_attente[1],
1511: &caractere, sizeof(caractere))) != sizeof(caractere))
1512: {
1513: if (longueur_ecriture == -1)
1514: {
1515: break;
1516: }
1517: }
1518:
1519: destruction_queue_signaux(s_etat_processus);
1520: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1521: exit(EXIT_FAILURE);
1522: }
1523:
1.112 bertrand 1524: pthread_mutex_trylock(&((*s_etat_processus).mutex_signaux));
1525:
1526: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_signaux))
1527: != 0)
1528: {
1529: (*s_etat_processus).erreur_systeme = d_es_processus;
1530:
1531: caractere = 0;
1532:
1533: while((longueur_ecriture = write_atomic(s_etat_processus,
1534: (*s_argument_thread).pipe_nombre_elements_attente[1],
1535: &caractere, sizeof(caractere))) != sizeof(caractere))
1536: {
1537: if (longueur_ecriture == -1)
1538: {
1539: break;
1540: }
1541: }
1542:
1543: destruction_queue_signaux(s_etat_processus);
1544: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1545: exit(EXIT_FAILURE);
1546: }
1547:
1.1 bertrand 1548: if ((*s_etat_processus).evaluation_expression_compilee == 'N')
1549: {
1.127 bertrand 1550: free((*s_etat_processus).instruction_courante);
1.1 bertrand 1551: (*s_etat_processus).instruction_courante = NULL;
1552: }
1553:
1554: (*s_etat_processus).var_volatile_processus_pere = 0;
1.41 bertrand 1555: (*s_etat_processus).var_volatile_processus_racine = 0;
1.1 bertrand 1556:
1557: // On réinitialise toutes les interruptions.
1558:
1559: (*s_etat_processus).traitement_interruption = 'N';
1560: (*s_etat_processus).traitement_interruptible = 'Y';
1561: (*s_etat_processus).nombre_interruptions_en_queue = 0;
1562: (*s_etat_processus).nombre_interruptions_non_affectees = 0;
1563: (*s_etat_processus).processus_detache = d_vrai;
1564:
1.13 bertrand 1565: liberation(s_etat_processus, (*s_etat_processus).at_exit);
1566: (*s_etat_processus).at_exit = NULL;
1.32 bertrand 1567: liberation(s_etat_processus, (*s_etat_processus).at_poke);
1568: (*s_etat_processus).at_poke = NULL;
1569: (*s_etat_processus).traitement_at_poke = 'N';
1.12 bertrand 1570:
1.1 bertrand 1571: for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
1572: {
1573: liberation(s_etat_processus,
1574: (*s_etat_processus).corps_interruptions[i]);
1575:
1576: (*s_etat_processus).corps_interruptions[i] = NULL;
1577: (*s_etat_processus).masque_interruptions[i] = 'N';
1578: (*s_etat_processus).queue_interruptions[i] = 0;
1579:
1580: l_element_courant = (*s_etat_processus)
1581: .pile_origine_interruptions[i];
1582:
1583: while(l_element_courant != NULL)
1584: {
1585: l_element_suivant = (*l_element_courant).suivant;
1586: liberation(s_etat_processus, (*l_element_courant).donnee);
1587: free(l_element_courant);
1588: l_element_courant = l_element_suivant;
1589: }
1590:
1591: (*s_etat_processus).pile_origine_interruptions[i] = NULL;
1592: }
1593:
1594: /*
1595: * On bloque l'exécution du processus fils jusqu'à ce que
1596: * le père ait renseigné correctement la pile des processus.
1597: * Dans le cas contraire, on pourrait essayer de traiter
1598: * un RECV sur un système chargé avant que cette pile soit
1599: * renseignée.
1600: */
1601:
1.67 bertrand 1602: // Attente de la réception du signal rpl_sigstart.
1603:
1604: for((*s_etat_processus).demarrage_fils = d_faux;;)
1.1 bertrand 1605: {
1.67 bertrand 1606: scrutation_interruptions(s_etat_processus);
1607:
1608: if ((*s_etat_processus).demarrage_fils == d_vrai)
1.1 bertrand 1609: {
1.67 bertrand 1610: break;
1611: }
1.1 bertrand 1612:
1.67 bertrand 1613: nanosleep(&attente, NULL);
1.1 bertrand 1614: }
1615:
1616: (*s_etat_processus).niveau_initial = (*s_etat_processus).niveau_courant;
1617: (*s_etat_processus).presence_pipes = d_vrai;
1618: (*s_etat_processus).debug_programme = d_faux;
1619: (*s_etat_processus).pipe_donnees = (*s_argument_thread).pipe_objets[1];
1.108 bertrand 1620: (*s_etat_processus).pipe_nombre_elements_attente = (*s_argument_thread)
1621: .pipe_nombre_elements_attente[1];
1.1 bertrand 1622: (*s_etat_processus).pipe_interruptions = (*s_argument_thread)
1623: .pipe_interruptions[1];
1624: (*s_etat_processus).pipe_injections =
1625: (*s_argument_thread).pipe_injections[0];
1626: (*s_etat_processus).pipe_nombre_injections =
1627: (*s_argument_thread).pipe_nombre_injections[0];
1628: (*s_etat_processus).pipe_acquittement =
1629: (*s_argument_thread).pipe_acquittement[0];
1630: (*s_etat_processus).nombre_objets_injectes = 0;
1631: (*s_etat_processus).nombre_objets_envoyes_non_lus = 0;
1632: (*s_etat_processus).temps_maximal_cpu = 0;
1633: (*s_etat_processus).presence_fusible = d_faux;
1634: (*s_etat_processus).thread_fusible = 0;
1635: (*s_etat_processus).pid_erreur_processus_fils = getpid();
1.91 bertrand 1636: (*s_etat_processus).sections_critiques = 0;
1.109 bertrand 1637: (*s_etat_processus).initialisation_scheduler = d_faux;
1.1 bertrand 1638:
1639: if ((*s_etat_processus).profilage == d_vrai)
1640: {
1641: liberation_profil(s_etat_processus);
1642: }
1643:
1644: (*s_etat_processus).pile_profilage = NULL;
1645:
1646: if ((*s_etat_processus).generateur_aleatoire != NULL)
1647: {
1648: liberation_generateur_aleatoire(s_etat_processus);
1649: }
1650:
1651: (*s_etat_processus).generateur_aleatoire = NULL;
1652:
1653: if ((*s_etat_processus).instruction_derniere_erreur != NULL)
1654: {
1655: free((*s_etat_processus).instruction_derniere_erreur);
1656: (*s_etat_processus).instruction_derniere_erreur = NULL;
1657: }
1658:
1659: /*
1.25 bertrand 1660: * Initialisation de la pile des processus. Cette pile est effacée
1661: * par liberation_threads().
1.1 bertrand 1662: */
1663:
1.112 bertrand 1664: if (pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus))
1665: != 0)
1.25 bertrand 1666: {
1667: (*s_etat_processus).erreur_systeme = d_es;
1668:
1.108 bertrand 1669: caractere = 0;
1.25 bertrand 1670:
1671: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1672: (*s_argument_thread).pipe_nombre_elements_attente[1],
1673: &caractere, sizeof(caractere))) != sizeof(caractere))
1.25 bertrand 1674: {
1675: if (longueur_ecriture == -1)
1676: {
1677: break;
1678: }
1679: }
1680:
1.67 bertrand 1681: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1682: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1683: exit(EXIT_FAILURE);
1684: }
1685:
1.24 bertrand 1686: l_element_courant = (struct_liste_chainee *)
1687: (*s_etat_processus).l_base_pile_processus;
1.26 bertrand 1688:
1.24 bertrand 1689: while(l_element_courant != NULL)
1690: {
1.25 bertrand 1691: s_argument_thread2 = (struct_descripteur_thread *)
1.26 bertrand 1692: (*((struct_processus_fils *) (*(*l_element_courant).donnee)
1693: .objet)).thread;
1.25 bertrand 1694:
1695: (*s_argument_thread2).nombre_references--;
1696:
1697: BUG((*s_argument_thread2).nombre_references < 0,
1.67 bertrand 1698: destruction_queue_signaux(s_etat_processus),
1.26 bertrand 1699: printf("(*s_argument_thread2).nombre_references = %d\n",
1.25 bertrand 1700: (int) (*s_argument_thread2).nombre_references));
1.24 bertrand 1701:
1.25 bertrand 1702: if ((*s_argument_thread2).nombre_references == 0)
1.24 bertrand 1703: {
1.25 bertrand 1704: close((*s_argument_thread2).pipe_objets[0]);
1705: close((*s_argument_thread2).pipe_acquittement[1]);
1706: close((*s_argument_thread2).pipe_injections[1]);
1707: close((*s_argument_thread2).pipe_nombre_injections[1]);
1.108 bertrand 1708: close((*s_argument_thread2).pipe_nombre_elements_attente[0]);
1.25 bertrand 1709: close((*s_argument_thread2).pipe_interruptions[0]);
1710:
1711: pthread_mutex_destroy(&((*s_argument_thread2).mutex));
1712:
1713: if ((*s_argument_thread2).processus_detache == d_faux)
1714: {
1715: if ((*s_argument_thread2).destruction_objet == d_vrai)
1716: {
1717: liberation(s_etat_processus,
1718: (*s_argument_thread2).argument);
1719: }
1720: }
1721:
1722: free(s_argument_thread2);
1.28 bertrand 1723: free((*(*l_element_courant).donnee).objet);
1724: free((*l_element_courant).donnee);
1.24 bertrand 1725: }
1726:
1.25 bertrand 1727: l_element_suivant = (*l_element_courant).suivant;
1728: free((struct_liste_chainee *) l_element_courant);
1.24 bertrand 1729: l_element_courant = l_element_suivant;
1730: }
1731:
1.1 bertrand 1732: (*s_etat_processus).l_base_pile_processus = NULL;
1733:
1.112 bertrand 1734: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus))
1735: != 0)
1.25 bertrand 1736: {
1737: (*s_etat_processus).erreur_systeme = d_es;
1738:
1.108 bertrand 1739: caractere = 0;
1.25 bertrand 1740:
1741: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1742: (*s_argument_thread).pipe_nombre_elements_attente[1],
1743: &caractere, sizeof(caractere))) != sizeof(caractere))
1.25 bertrand 1744: {
1745: if (longueur_ecriture == -1)
1746: {
1747: break;
1748: }
1749: }
1750:
1.67 bertrand 1751: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1752: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1753: exit(EXIT_FAILURE);
1754: }
1755:
1.1 bertrand 1756: /*
1757: * Initialisation de la pile système
1758: */
1759:
1760: l_element_courant = (struct_liste_chainee *)
1761: (*s_etat_processus).l_base_pile_systeme;
1762: while(l_element_courant != NULL)
1763: {
1764: l_element_suivant = (struct_liste_chainee *)
1765: (*((struct_liste_pile_systeme *)
1766: l_element_courant)).suivant;
1767:
1768: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
1769: l_element_courant)).indice_boucle);
1770: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
1771: l_element_courant)).limite_indice_boucle);
1772: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
1773: l_element_courant)).objet_de_test);
1774:
1775: if ((*((struct_liste_pile_systeme *) l_element_courant))
1776: .nom_variable != NULL)
1777: {
1778: free((*((struct_liste_pile_systeme *)
1779: l_element_courant)).nom_variable);
1780: }
1781:
1782: free((struct_liste_pile_systeme *) l_element_courant);
1783:
1784: l_element_courant = l_element_suivant;
1785: }
1786:
1787: (*s_etat_processus).l_base_pile_systeme = NULL;
1788: (*s_etat_processus).hauteur_pile_systeme = 0;
1789:
1790: empilement_pile_systeme(s_etat_processus);
1791:
1792: if ((*s_etat_processus).erreur_systeme != d_es)
1793: {
1.108 bertrand 1794: caractere = 0;
1.1 bertrand 1795:
1796: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1797: (*s_argument_thread).pipe_nombre_elements_attente[1],
1798: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 1799: {
1800: if (longueur_ecriture == -1)
1801: {
1802: break;
1803: }
1804: }
1805:
1.67 bertrand 1806: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1807: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1.1 bertrand 1808: exit(EXIT_FAILURE);
1809: }
1810:
1811: (*(*s_etat_processus).l_base_pile_systeme).retour_definition = 'Y';
1812:
1813: l_element_courant = (struct_liste_chainee *)
1814: (*s_etat_processus).s_marques;
1815:
1816: while(l_element_courant != NULL)
1817: {
1818: free((*((struct_marque *) l_element_courant)).label);
1819: free((*((struct_marque *) l_element_courant)).position);
1820: l_element_suivant = (struct_liste_chainee *)
1821: (*((struct_marque *) l_element_courant)).suivant;
1822: free((struct_marque *) l_element_courant);
1823: l_element_courant = l_element_suivant;
1824: }
1825:
1826: (*s_etat_processus).s_marques = NULL;
1827:
1828: /*
1829: * On empile deux valeurs retour_definition pour pouvoir récupérer
1830: * les variables dans le cas d'un programme compilé.
1831: */
1832:
1833: empilement_pile_systeme(s_etat_processus);
1834:
1835: if ((*s_etat_processus).erreur_systeme != d_es)
1836: {
1.108 bertrand 1837: caractere = 0;
1.1 bertrand 1838:
1839: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 1840: (*s_argument_thread).pipe_nombre_elements_attente[1],
1841: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 1842: {
1843: if (longueur_ecriture == -1)
1844: {
1845: break;
1846: }
1847: }
1848:
1.67 bertrand 1849: destruction_queue_signaux(s_etat_processus);
1.25 bertrand 1850: BUG(1, uprintf("Process management error line %d\n", __LINE__));
1.1 bertrand 1851: exit(EXIT_FAILURE);
1852: }
1853:
1854: (*(*s_etat_processus).l_base_pile_systeme).retour_definition = 'Y';
1855:
1856: /*
1857: * Destruction des sorties graphiques et PostScript
1858: */
1859:
1860: while((*s_etat_processus).fichiers_graphiques != NULL)
1861: {
1862: free((*(*s_etat_processus).fichiers_graphiques).nom);
1863:
1864: if ((*(*s_etat_processus).fichiers_graphiques).legende != NULL)
1865: {
1866: free((*(*s_etat_processus).fichiers_graphiques).legende);
1867: }
1868:
1869: l_element_precedent = (void *) (*s_etat_processus)
1870: .fichiers_graphiques;
1871: (*s_etat_processus).fichiers_graphiques =
1872: (*(*s_etat_processus).fichiers_graphiques).suivant;
1873: free(l_element_precedent);
1874: }
1875:
1876: if ((*s_etat_processus).entree_standard != NULL)
1877: {
1878: pclose((*s_etat_processus).entree_standard);
1879: (*s_etat_processus).entree_standard = NULL;
1880: }
1881:
1882: (*s_etat_processus).requete_nouveau_plan = d_vrai;
1883: (*s_etat_processus).mise_a_jour_trace_requise = d_faux;
1884:
1885: if ((*s_etat_processus).nom_fichier_impression != NULL)
1886: {
1887: free((*s_etat_processus).nom_fichier_impression);
1888: (*s_etat_processus).nom_fichier_impression = NULL;
1889: }
1890:
1891: /*
1892: * Destruction des piles de fichiers
1893: */
1894:
1895: l_element_courant = (*s_etat_processus).s_fichiers;
1896:
1897: while(l_element_courant != NULL)
1898: {
1899: l_element_suivant = (*l_element_courant).suivant;
1900:
1901: fclose((*((struct_descripteur_fichier *)
1.7 bertrand 1902: (*l_element_courant).donnee)).descripteur_c);
1903:
1904: if ((*((struct_descripteur_fichier *)
1905: (*l_element_courant).donnee)).type != 'C')
1906: {
1907: sqlite3_close((*((struct_descripteur_fichier *)
1908: (*l_element_courant).donnee)).descripteur_sqlite);
1909: }
1.1 bertrand 1910:
1911: free((*((struct_descripteur_fichier *) (*l_element_courant)
1912: .donnee)).nom);
1913: free((struct_descripteur_fichier *) (*l_element_courant).donnee);
1914: free(l_element_courant);
1915:
1916: l_element_courant = l_element_suivant;
1917: }
1918:
1919: /*
1920: * Destruction des piles de connecteurs SQL
1921: */
1922:
1.18 bertrand 1923: /*
1924: ================================================================================
1925: À noter : on ne ferme pas la connexion car la conséquence immédiate est
1926: une destruction de l'objet pour le processus père.
1927: ================================================================================
1.24 bertrand 1928: */
1.18 bertrand 1929:
1.1 bertrand 1930: l_element_courant = (*s_etat_processus).s_connecteurs_sql;
1931:
1932: while(l_element_courant != NULL)
1933: {
1934: l_element_suivant = (*l_element_courant).suivant;
1935:
1.24 bertrand 1936: // sqlclose((*l_element_courant).donnee);
1.1 bertrand 1937: liberation(s_etat_processus, (*l_element_courant).donnee);
1938: l_element_courant = l_element_suivant;
1939: }
1.18 bertrand 1940:
1941: (*s_etat_processus).s_connecteurs_sql = NULL;
1.1 bertrand 1942:
1943: /*
1944: * On ne détruit pas les sockets car il faut utiliser DETACH
1945: * pour traiter plusieurs connexions simultanées sur les sockets
1946: */
1947:
1948: (*s_etat_processus).s_fichiers = NULL;
1949:
1.25 bertrand 1950: if ((*s_etat_processus).debug == d_vrai)
1951: {
1952: if (((*s_etat_processus).type_debug & d_debug_processus)
1953: != 0)
1954: {
1955: if ((*s_etat_processus).langue == 'F')
1956: {
1957: printf("[%d] Évaluation de l'objet détaché\n", getpid());
1958: }
1959: else
1960: {
1961: printf("[%d] Évaluation of detached object\n", getpid());
1962: }
1963: }
1964: }
1965:
1.1 bertrand 1966: if ((*s_etat_processus).erreur_systeme == d_es)
1967: {
1.80 bertrand 1968: // Évite le warning variable s_copie might be clobbered by
1969: // longjmp or vfork
1970: struct_objet **s;
1971:
1972: if ((s = malloc(sizeof(struct_objet *))) == NULL)
1973: {
1.82 bertrand 1974: (*s_etat_processus).erreur_execution = d_es_allocation_memoire;
1.80 bertrand 1975: return;
1976: }
1977:
1978: (*s) = s_copie;
1979:
1.65 bertrand 1980: if (setjmp(contexte_processus) == 0)
1.1 bertrand 1981: {
1.65 bertrand 1982: if (variable_partagee == d_faux)
1.1 bertrand 1983: {
1.65 bertrand 1984: if (evaluation(s_etat_processus, s_objet, 'E') == d_erreur)
1.1 bertrand 1985: {
1.65 bertrand 1986: if (((*s_etat_processus).erreur_execution == d_ex) &&
1987: ((*s_etat_processus).erreur_systeme == d_es))
1.15 bertrand 1988: {
1989: (*s_etat_processus).erreur_execution =
1990: d_ex_erreur_evaluation;
1991: }
1992: }
1.65 bertrand 1993: else
1.1 bertrand 1994: {
1.105 bertrand 1995: if (((*s_etat_processus).arret_depuis_abort == 0)
1.65 bertrand 1996: && ((*s_etat_processus).at_exit != NULL))
1997: {
1998: (*s_etat_processus).var_volatile_requete_arret = 0;
1.105 bertrand 1999: (*s_etat_processus).var_volatile_alarme = 0;
1.106 bertrand 2000: (*s_etat_processus).var_volatile_traitement_sigint
2001: = 0;
2002:
2003: if ((*s_etat_processus).profilage == d_vrai)
2004: {
2005: profilage(s_etat_processus, "ATEXIT");
2006: }
1.65 bertrand 2007:
2008: if (evaluation(s_etat_processus,
2009: (*s_etat_processus).at_exit, 'E') ==
2010: d_erreur)
2011: {
2012: (*s_etat_processus).erreur_execution =
2013: d_ex_erreur_evaluation;
2014: }
1.106 bertrand 2015:
2016: if ((*s_etat_processus).profilage == d_vrai)
2017: {
2018: profilage(s_etat_processus, NULL);
2019: }
1.65 bertrand 2020: }
1.1 bertrand 2021: }
2022: }
1.12 bertrand 2023: else
2024: {
1.80 bertrand 2025: if (evaluation(s_etat_processus, (*s), 'E') == d_erreur)
1.12 bertrand 2026: {
1.65 bertrand 2027: if (((*s_etat_processus).erreur_execution == d_ex) &&
2028: ((*s_etat_processus).erreur_systeme == d_es))
1.14 bertrand 2029: {
2030: (*s_etat_processus).erreur_execution =
2031: d_ex_erreur_evaluation;
2032: }
1.12 bertrand 2033: }
1.65 bertrand 2034: else
2035: {
1.105 bertrand 2036: if (((*s_etat_processus).arret_depuis_abort == 0)
1.79 bertrand 2037: && ((*s_etat_processus).at_exit != NULL))
1.65 bertrand 2038: {
2039: (*s_etat_processus).var_volatile_requete_arret = 0;
1.105 bertrand 2040: (*s_etat_processus).var_volatile_alarme = 0;
1.106 bertrand 2041: (*s_etat_processus).var_volatile_traitement_sigint
2042: = 0;
2043:
2044: if ((*s_etat_processus).profilage == d_vrai)
2045: {
2046: profilage(s_etat_processus, "ATEXIT");
2047: }
1.65 bertrand 2048:
2049: if (evaluation(s_etat_processus,
2050: (*s_etat_processus).at_exit, 'E') ==
2051: d_erreur)
2052: {
2053: (*s_etat_processus).erreur_execution =
2054: d_ex_erreur_evaluation;
2055: }
1.106 bertrand 2056:
2057: if ((*s_etat_processus).profilage == d_vrai)
2058: {
2059: profilage(s_etat_processus, NULL);
2060: }
1.65 bertrand 2061: }
2062: }
2063:
1.80 bertrand 2064: liberation(s_etat_processus, (*s));
1.12 bertrand 2065: }
1.1 bertrand 2066: }
1.80 bertrand 2067:
2068: free(s);
1.1 bertrand 2069: }
2070:
1.91 bertrand 2071: for(i = 0; i < (*s_etat_processus).sections_critiques; i++)
2072: {
2073: pthread_mutex_unlock(&mutex_sections_critiques);
2074: }
2075:
1.15 bertrand 2076: liberation(s_etat_processus, (*s_etat_processus).at_exit);
1.32 bertrand 2077: liberation(s_etat_processus, (*s_etat_processus).at_poke);
1.15 bertrand 2078:
1.1 bertrand 2079: l_element_courant = (*s_etat_processus).liste_mutexes;
2080: while(l_element_courant != NULL)
2081: {
2082: liberation(s_etat_processus, (*l_element_courant).donnee);
2083: l_element_suivant = (*l_element_courant).suivant;
2084: free(l_element_courant);
2085: l_element_courant = l_element_suivant;
2086: }
2087:
2088: if ((*s_etat_processus).presence_fusible == d_vrai)
2089: {
2090: pthread_cancel((*s_etat_processus).thread_fusible);
2091: }
2092:
1.108 bertrand 2093: caractere = 0;
1.1 bertrand 2094:
2095: while((longueur_ecriture = write_atomic(s_etat_processus,
1.108 bertrand 2096: (*s_argument_thread).pipe_nombre_elements_attente[1],
2097: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 2098: {
2099: if (longueur_ecriture == -1)
2100: {
2101: break;
2102: }
2103: }
2104:
2105: if ((*s_etat_processus).var_volatile_processus_pere != 0)
2106: {
2107: // Racine des processus atteinte
2108:
2109: erreur = d_ex;
2110:
2111: while((longueur_ecriture = write_atomic(s_etat_processus,
2112: (*s_argument_thread).pipe_erreurs[1], &erreur,
2113: sizeof((*s_etat_processus).erreur_execution))) !=
2114: sizeof((*s_etat_processus).erreur_execution))
2115: {
2116: if (longueur_ecriture == -1)
2117: {
2118: break;
2119: }
2120: }
2121: }
2122: else
2123: {
2124: while((longueur_ecriture = write_atomic(s_etat_processus,
2125: (*s_argument_thread).pipe_erreurs[1],
1.108 bertrand 2126: (int *) &((*s_etat_processus).erreur_execution),
1.1 bertrand 2127: sizeof((*s_etat_processus).erreur_execution))) !=
2128: sizeof((*s_etat_processus).erreur_execution))
2129: {
2130: if (longueur_ecriture == -1)
2131: {
2132: break;
2133: }
2134: }
2135: }
2136:
2137: if ((*s_etat_processus).var_volatile_processus_pere != 0)
2138: {
2139: // Racine des processus atteinte
2140:
2141: erreur = d_es;
2142:
2143: while((longueur_ecriture = write_atomic(s_etat_processus,
2144: (*s_argument_thread).pipe_erreurs[1], &erreur,
2145: sizeof((*s_etat_processus).erreur_systeme))) !=
2146: sizeof((*s_etat_processus).erreur_systeme))
2147: {
2148: if (longueur_ecriture == -1)
2149: {
2150: break;
2151: }
2152: }
2153: }
2154: else
2155: {
2156: while((longueur_ecriture = write_atomic(s_etat_processus,
2157: (*s_argument_thread).pipe_erreurs[1],
1.108 bertrand 2158: (int *) &((*s_etat_processus).erreur_systeme),
1.1 bertrand 2159: sizeof((*s_etat_processus).erreur_systeme))) !=
2160: sizeof((*s_etat_processus).erreur_systeme))
2161: {
2162: if (longueur_ecriture == -1)
2163: {
2164: break;
2165: }
2166: }
2167: }
2168:
2169: if ((*s_etat_processus).pid_erreur_processus_fils == 0)
2170: {
2171: while((longueur_ecriture = write_atomic(s_etat_processus,
2172: (*s_argument_thread).pipe_erreurs[1],
2173: &ppid, sizeof(ppid))) != sizeof(ppid))
2174: {
2175: if (longueur_ecriture == -1)
2176: {
2177: break;
2178: }
2179: }
2180: }
2181: else
2182: {
2183: while((longueur_ecriture = write_atomic(s_etat_processus,
2184: (*s_argument_thread).pipe_erreurs[1],
2185: &((*s_etat_processus).pid_erreur_processus_fils),
2186: sizeof((*s_etat_processus).pid_erreur_processus_fils))) !=
2187: sizeof((*s_etat_processus).pid_erreur_processus_fils))
2188: {
2189: if (longueur_ecriture == -1)
2190: {
2191: break;
2192: }
2193: }
2194: }
2195:
2196: l_element_courant = (*s_etat_processus).s_fichiers;
2197:
2198: while(l_element_courant != NULL)
2199: {
2200: l_element_suivant = (*l_element_courant).suivant;
2201:
2202: fclose((*((struct_descripteur_fichier *)
1.7 bertrand 2203: (*l_element_courant).donnee)).descripteur_c);
2204:
2205: if ((*((struct_descripteur_fichier *)
2206: (*l_element_courant).donnee)).type != 'C')
2207: {
2208: sqlite3_close((*((struct_descripteur_fichier *)
2209: (*l_element_courant).donnee)).descripteur_sqlite);
2210: }
1.1 bertrand 2211:
2212: if (((*((struct_descripteur_fichier *) (*l_element_courant)
2213: .donnee)).pid == getpid()) &&
2214: (pthread_equal((*((struct_descripteur_fichier *)
2215: (*l_element_courant).donnee)).tid, pthread_self()) != 0))
2216: {
2217: if ((*((struct_descripteur_fichier *) (*l_element_courant)
2218: .donnee)).effacement == 'Y')
2219: {
2220: unlink((*((struct_descripteur_fichier *)
2221: (*l_element_courant).donnee)).nom);
2222: }
2223: }
2224:
2225: free((*((struct_descripteur_fichier *) (*l_element_courant)
2226: .donnee)).nom);
2227: free((struct_descripteur_fichier *) (*l_element_courant).donnee);
2228: free(l_element_courant);
2229:
2230: l_element_courant = l_element_suivant;
2231: }
2232:
1.112 bertrand 2233: pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2234:
2235: l_element_courant = (struct_liste_chainee *)
2236: (*s_etat_processus).l_base_pile_processus;
2237:
2238: while(l_element_courant != NULL)
2239: {
2240: if ((*(*((struct_processus_fils *) (*(*((struct_liste_chainee *)
2241: l_element_courant)).donnee).objet)).thread)
2242: .processus_detache == d_vrai)
2243: {
2244: if ((*s_etat_processus).debug == d_vrai)
2245: {
2246: if (((*s_etat_processus).type_debug & d_debug_processus)
2247: != 0)
2248: {
2249: if ((*s_etat_processus).langue == 'F')
2250: {
2251: printf("[%d] Signalement pour arrêt du "
2252: "processus %d\n",
2253: (int) getpid(),
2254: (int) (*(*((struct_processus_fils *)
2255: (*(*((struct_liste_chainee *)
2256: l_element_courant)).donnee).objet))
2257: .thread).pid);
2258: }
2259: else
2260: {
2261: printf("[%d] Send stop signal to process %d\n",
2262: (int) getpid(),
2263: (int) (*(*((struct_processus_fils *)
2264: (*(*((struct_liste_chainee *)
2265: l_element_courant)).donnee).objet))
2266: .thread).pid);
2267: }
2268: }
2269: }
2270:
2271: if ((*s_etat_processus).var_volatile_alarme != 0)
2272: {
1.67 bertrand 2273: envoi_signal_processus((*(*((struct_processus_fils *)
1.1 bertrand 2274: (*(*l_element_courant).donnee).objet)).thread).pid,
1.144 bertrand 2275: rpl_sigurg, d_faux);
1.1 bertrand 2276: }
2277: else
2278: {
1.16 bertrand 2279: if ((*s_etat_processus).arret_depuis_abort == -1)
2280: {
1.67 bertrand 2281: envoi_signal_processus((*(*((struct_processus_fils *)
1.16 bertrand 2282: (*(*l_element_courant).donnee).objet)).thread)
1.144 bertrand 2283: .pid, rpl_sigabort, d_faux);
1.16 bertrand 2284: }
2285: else
2286: {
1.67 bertrand 2287: envoi_signal_processus((*(*((struct_processus_fils *)
1.16 bertrand 2288: (*(*l_element_courant).donnee).objet)).thread)
1.144 bertrand 2289: .pid, rpl_sigstop, d_faux);
1.16 bertrand 2290: }
1.1 bertrand 2291: }
2292: }
2293: else
2294: {
2295: if ((*s_etat_processus).debug == d_vrai)
2296: {
2297: if (((*s_etat_processus).type_debug & d_debug_processus)
2298: != 0)
2299: {
2300: if ((*s_etat_processus).langue == 'F')
2301: {
2302: printf("[%d] Signalement pour arrêt du "
2303: "thread %llu\n",
2304: (int) getpid(), (unsigned long long)
2305: (*(*((struct_processus_fils *)
2306: (*(*((struct_liste_chainee *)
2307: l_element_courant)).donnee).objet)).thread)
2308: .tid);
2309: }
2310: else
2311: {
2312: printf("[%d] Send stop signal to thread %llu\n",
2313: (int) getpid(), (unsigned long long)
2314: (*(*((struct_processus_fils *)
2315: (*(*((struct_liste_chainee *)
2316: l_element_courant)).donnee).objet)).thread)
2317: .tid);
2318: }
2319: }
2320: }
2321:
2322: pthread_mutex_lock(&((*(*((struct_processus_fils *)
2323: (*(*l_element_courant).donnee).objet)).thread).mutex));
2324:
2325: if ((*(*((struct_processus_fils *)
2326: (*(*l_element_courant).donnee).objet)).thread)
2327: .thread_actif == d_vrai)
2328: {
2329: if ((*s_etat_processus).var_volatile_alarme != 0)
2330: {
1.67 bertrand 2331: envoi_signal_thread((*(*((struct_processus_fils *)
1.1 bertrand 2332: (*(*l_element_courant).donnee).objet)).thread)
1.67 bertrand 2333: .tid, rpl_sigurg);
1.1 bertrand 2334: }
2335: else
2336: {
1.16 bertrand 2337: if ((*s_etat_processus).arret_depuis_abort == -1)
2338: {
1.67 bertrand 2339: envoi_signal_thread((*(*((struct_processus_fils *)
1.16 bertrand 2340: (*(*l_element_courant).donnee).objet))
1.67 bertrand 2341: .thread).tid, rpl_sigabort);
1.16 bertrand 2342: }
2343: else
2344: {
1.67 bertrand 2345: envoi_signal_thread((*(*((struct_processus_fils *)
1.16 bertrand 2346: (*(*l_element_courant).donnee).objet))
1.67 bertrand 2347: .thread).tid, rpl_sigstop);
1.16 bertrand 2348: }
1.1 bertrand 2349: }
2350: }
2351:
2352: pthread_mutex_unlock(&((*(*((struct_processus_fils *)
2353: (*(*l_element_courant).donnee).objet)).thread).mutex));
2354: }
2355:
2356: l_element_courant = (*l_element_courant).suivant;
2357: }
2358:
2359: /*
2360: * Attente de la fin de tous les processus fils
2361: */
2362:
2363: for(i = 0; i < d_NOMBRE_INTERRUPTIONS;
2364: (*s_etat_processus).masque_interruptions[i++] = 'I');
2365:
2366: attente.tv_sec = 0;
2367: attente.tv_nsec = GRANULARITE_us * 1000;
2368:
2369: while((*s_etat_processus).l_base_pile_processus != NULL)
2370: {
2371: l_element_courant = (struct_liste_chainee *)
2372: (*s_etat_processus).l_base_pile_processus;
2373:
2374: registre_stop = (*s_etat_processus)
2375: .var_volatile_traitement_retarde_stop;
2376: (*s_etat_processus).var_volatile_traitement_retarde_stop = 1;
2377:
1.103 bertrand 2378: for(i = 0; i < (*(*((struct_processus_fils *)
1.1 bertrand 2379: (*(*l_element_courant)
2380: .donnee).objet)).thread).nombre_objets_dans_pipe; i++)
2381: {
2382: if ((s_objet_temporaire = lecture_pipe(s_etat_processus,
2383: (*(*((struct_processus_fils *) (*(*l_element_courant)
2384: .donnee).objet)).thread).pipe_objets[0])) != NULL)
2385: {
2386: liberation(s_etat_processus, s_objet_temporaire);
2387:
2388: (*(*((struct_processus_fils *) (*(*l_element_courant)
2389: .donnee).objet)).thread).nombre_objets_dans_pipe--;
2390:
2391: action.sa_handler = SIG_IGN;
2392: action.sa_flags = SA_ONSTACK;
2393:
2394: if (sigaction(SIGPIPE, &action, ®istre) != 0)
2395: {
1.112 bertrand 2396: pthread_mutex_unlock(&((*s_etat_processus)
2397: .mutex_pile_processus));
1.1 bertrand 2398:
2399: if (registre_stop == 0)
2400: {
2401: if ((*s_etat_processus)
2402: .var_volatile_traitement_retarde_stop
2403: == -1)
2404: {
2405: (*s_etat_processus)
2406: .var_volatile_requete_arret = -1;
2407: }
2408:
2409: (*s_etat_processus)
2410: .var_volatile_traitement_retarde_stop =
2411: registre_stop;
2412: }
2413:
1.67 bertrand 2414: destruction_queue_signaux(s_etat_processus);
1.1 bertrand 2415: (*s_etat_processus).erreur_systeme = d_es_signal;
2416: exit(EXIT_FAILURE);
2417: }
2418:
2419: while((longueur_ecriture = write_atomic(
2420: s_etat_processus, (*(*((struct_processus_fils *)
2421: (*(*l_element_courant).donnee).objet))
2422: .thread).pipe_nombre_injections[1], "+",
2423: sizeof(unsigned char))) !=
2424: sizeof(unsigned char))
2425: {
2426: if (longueur_ecriture == -1)
2427: {
2428: // Le processus n'existe plus.
2429: break;
2430: }
2431: }
2432:
2433: if (registre_stop == 0)
2434: {
2435: if ((*s_etat_processus)
2436: .var_volatile_traitement_retarde_stop == -1)
2437: {
2438: (*s_etat_processus).var_volatile_requete_arret
2439: = -1;
2440: }
2441:
2442: (*s_etat_processus)
2443: .var_volatile_traitement_retarde_stop =
2444: registre_stop;
2445: }
2446:
2447: if (sigaction(SIGPIPE, ®istre, NULL) != 0)
2448: {
1.67 bertrand 2449: destruction_queue_signaux(s_etat_processus);
1.37 bertrand 2450:
1.112 bertrand 2451: pthread_mutex_unlock(&((*s_etat_processus)
2452: .mutex_pile_processus));
1.1 bertrand 2453: (*s_etat_processus).erreur_systeme = d_es_signal;
2454: exit(EXIT_FAILURE);
2455: }
2456: }
2457: }
2458:
1.111 bertrand 2459: if (pthread_mutex_lock(&((*s_etat_processus).mutex_interruptions))
2460: != 0)
2461: {
2462: destruction_queue_signaux(s_etat_processus);
2463:
1.112 bertrand 2464: pthread_mutex_unlock(&((*s_etat_processus)
2465: .mutex_pile_processus));
1.111 bertrand 2466: (*s_etat_processus).erreur_systeme = d_es_processus;
2467: exit(EXIT_FAILURE);
2468: }
2469:
1.17 bertrand 2470: if ((*s_etat_processus).nombre_interruptions_non_affectees != 0)
2471: {
2472: affectation_interruptions_logicielles(s_etat_processus);
2473: }
2474:
1.111 bertrand 2475: if (pthread_mutex_unlock(&((*s_etat_processus)
2476: .mutex_interruptions)) != 0)
2477: {
2478: destruction_queue_signaux(s_etat_processus);
2479:
1.112 bertrand 2480: pthread_mutex_unlock(&((*s_etat_processus)
2481: .mutex_pile_processus));
1.111 bertrand 2482: (*s_etat_processus).erreur_systeme = d_es_processus;
2483: exit(EXIT_FAILURE);
2484: }
2485:
1.112 bertrand 2486: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2487: nanosleep(&attente, NULL);
1.112 bertrand 2488: pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
1.69 bertrand 2489:
2490: scrutation_interruptions(s_etat_processus);
1.1 bertrand 2491: }
2492:
1.112 bertrand 2493: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2494:
2495: l_element_courant = (*s_etat_processus).s_sockets;
2496:
2497: while(l_element_courant != NULL)
2498: {
2499: l_element_suivant = (*l_element_courant).suivant;
2500:
2501: if ((*((struct_socket *) (*(*l_element_courant).donnee)
2502: .objet)).socket_connectee == d_vrai)
2503: {
2504: shutdown((*((struct_socket *) (*(*l_element_courant).donnee)
2505: .objet)).socket, SHUT_RDWR);
2506: }
2507:
2508: close((*((struct_socket *) (*(*l_element_courant).donnee)
2509: .objet)).socket);
2510:
2511: if (((*((struct_socket *) (*(*l_element_courant).donnee).objet))
2512: .pid == getpid()) && (pthread_equal((*((struct_socket *)
2513: (*(*l_element_courant).donnee).objet)).tid, pthread_self())
2514: != 0))
2515: {
2516: if ((*((struct_socket *) (*(*l_element_courant).donnee).objet))
2517: .effacement == 'Y')
2518: {
2519: unlink((*((struct_socket *) (*(*l_element_courant).donnee)
2520: .objet)).adresse);
2521: }
2522: }
2523:
2524: liberation(s_etat_processus,
2525: (*((struct_liste_chainee *) l_element_courant)).donnee);
2526: free(l_element_courant);
2527:
2528: l_element_courant = l_element_suivant;
2529: }
2530:
2531: l_element_courant = (*s_etat_processus).s_connecteurs_sql;
2532:
2533: while(l_element_courant != NULL)
2534: {
2535: l_element_suivant = (*l_element_courant).suivant;
2536:
2537: sqlclose((*l_element_courant).donnee);
2538:
2539: liberation(s_etat_processus,
2540: (*((struct_liste_chainee *) l_element_courant)).donnee);
2541: free(l_element_courant);
2542:
2543: l_element_courant = l_element_suivant;
2544: }
2545:
2546: if ((((*s_etat_processus).erreur_execution != d_ex) ||
2547: ((*s_etat_processus).exception != d_ep) ||
2548: ((*s_etat_processus).erreur_systeme != d_es)) &&
2549: ((*s_etat_processus).var_volatile_traitement_sigint == 0))
2550: {
2551: printf("%s [%d]\n", message =
2552: messages(s_etat_processus), (int) getpid());
2553: free(message);
2554:
2555: if ((*s_etat_processus).core == d_vrai)
2556: {
2557: printf("\n");
2558:
2559: if ((*s_etat_processus).langue == 'F')
2560: {
2561: printf("+++Information : Génération du fichier rpl-core "
2562: "[%d]\n", (int) getpid());
2563: }
2564: else
2565: {
2566: printf("+++Information : Writing rpl-core file [%d]\n",
2567: (int) getpid());
2568: }
2569:
2570: rplcore(s_etat_processus);
2571:
2572: if ((*s_etat_processus).langue == 'F')
2573: {
2574: printf("+++Information : Processus tracé [%d]\n",
2575: (int) getpid());
2576: }
2577: else
2578: {
2579: printf("+++Information : Done [%d]\n", (int) getpid());
2580: }
2581:
2582: printf("\n");
2583: fflush(stdout);
2584: }
2585: }
2586:
2587: liberation_arbre_instructions(s_etat_processus,
2588: (*s_etat_processus).arbre_instructions);
2589: free((*s_etat_processus).pointeurs_caracteres);
2590:
1.95 bertrand 2591: l_element_statique_courant = (*s_etat_processus)
2592: .l_liste_variables_statiques;
2593:
2594: while(l_element_statique_courant != NULL)
2595: {
2596: l_element_statique_suivant = (*l_element_statique_courant).suivant;
2597: free(l_element_statique_courant);
2598: l_element_statique_courant = l_element_statique_suivant;
2599: }
2600:
1.98 bertrand 2601: l_element_partage_courant = (*(*s_etat_processus)
2602: .l_liste_variables_partagees);
2603:
2604: while(l_element_partage_courant != NULL)
2605: {
2606: l_element_partage_suivant = (*l_element_partage_courant).suivant;
2607: free(l_element_partage_courant);
2608: l_element_partage_courant = l_element_partage_suivant;
2609: }
2610:
1.1 bertrand 2611: if ((*s_etat_processus).entree_standard != NULL)
2612: {
2613: pclose((*s_etat_processus).entree_standard);
2614: (*s_etat_processus).entree_standard = NULL;
2615: }
2616:
2617: liberation(s_etat_processus, (*s_etat_processus).indep);
2618: liberation(s_etat_processus, (*s_etat_processus).depend);
2619:
2620: free((*s_etat_processus).label_x);
2621: free((*s_etat_processus).label_y);
2622: free((*s_etat_processus).label_z);
2623: free((*s_etat_processus).titre);
2624: free((*s_etat_processus).legende);
2625:
2626: liberation(s_etat_processus,
2627: (*s_etat_processus).parametres_courbes_de_niveau);
2628:
2629: if ((*s_etat_processus).instruction_derniere_erreur != NULL)
2630: {
2631: free((*s_etat_processus).instruction_derniere_erreur);
2632: (*s_etat_processus).instruction_derniere_erreur = NULL;
2633: }
2634:
1.97 bertrand 2635: liberation_arbre_variables_partagees(s_etat_processus,
1.98 bertrand 2636: (*(*s_etat_processus).s_arbre_variables_partagees));
1.52 bertrand 2637: liberation_arbre_variables(s_etat_processus,
2638: (*s_etat_processus).s_arbre_variables, d_vrai);
2639: free((*s_etat_processus).pointeurs_caracteres_variables);
1.1 bertrand 2640:
2641: l_element_courant = (*s_etat_processus).l_base_pile;
2642: while(l_element_courant != NULL)
2643: {
2644: l_element_suivant = (*l_element_courant).suivant;
2645:
2646: liberation(s_etat_processus, (*l_element_courant).donnee);
2647: free(l_element_courant);
2648:
2649: l_element_courant = l_element_suivant;
2650: }
2651:
2652: l_element_courant = (*s_etat_processus).l_base_pile_last;
2653: while(l_element_courant != NULL)
2654: {
2655: l_element_suivant = (*l_element_courant).suivant;
2656:
2657: liberation(s_etat_processus, (*l_element_courant).donnee);
2658: free(l_element_courant);
2659:
2660: l_element_courant = l_element_suivant;
2661: }
2662:
2663: l_element_courant = (*s_etat_processus).l_base_pile_contextes;
2664: while(l_element_courant != NULL)
2665: {
2666: l_element_suivant = (*l_element_courant).suivant;
2667:
2668: liberation(s_etat_processus, (*l_element_courant).donnee);
2669: free(l_element_courant);
2670:
2671: l_element_courant = l_element_suivant;
2672: }
2673:
2674: l_element_courant = (*s_etat_processus).l_base_pile_taille_contextes;
2675: while(l_element_courant != NULL)
2676: {
2677: l_element_suivant = (*l_element_courant).suivant;
2678:
2679: liberation(s_etat_processus, (*l_element_courant).donnee);
2680: free(l_element_courant);
2681:
2682: l_element_courant = l_element_suivant;
2683: }
2684:
2685: l_element_courant = (struct_liste_chainee *)
2686: (*s_etat_processus).l_base_pile_systeme;
2687: while(l_element_courant != NULL)
2688: {
2689: l_element_suivant = (struct_liste_chainee *)
2690: (*((struct_liste_pile_systeme *)
2691: l_element_courant)).suivant;
2692:
2693: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
2694: l_element_courant)).indice_boucle);
2695: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
2696: l_element_courant)).limite_indice_boucle);
2697: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
2698: l_element_courant)).objet_de_test);
2699:
2700: if ((*((struct_liste_pile_systeme *)
2701: l_element_courant)).nom_variable != NULL)
2702: {
2703: free((*((struct_liste_pile_systeme *)
2704: l_element_courant)).nom_variable);
2705: }
2706:
2707: free((struct_liste_pile_systeme *) l_element_courant);
2708:
2709: l_element_courant = l_element_suivant;
2710: }
2711:
2712: /*
2713: * Destruction des bibliothèques
2714: */
2715:
2716: l_element_courant = (*s_etat_processus).s_bibliotheques;
2717:
2718: while(l_element_courant != NULL)
2719: {
2720: l_element_suivant = (*l_element_courant).suivant;
2721:
2722: free((*((struct_bibliotheque *) (*l_element_courant).donnee)).nom);
2723:
2724: dlclose((*((struct_bibliotheque *) (*l_element_courant).donnee))
2725: .descripteur);
2726:
2727: free((*l_element_courant).donnee);
2728: free(l_element_courant);
2729:
2730: l_element_courant = l_element_suivant;
2731: }
2732:
2733: for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
2734: {
2735: free((*s_etat_processus).s_instructions_externes[i].nom);
2736: free((*s_etat_processus).s_instructions_externes[i]
2737: .nom_bibliotheque);
2738: }
2739:
2740: if ((*s_etat_processus).nombre_instructions_externes != 0)
2741: {
2742: free((*s_etat_processus).s_instructions_externes);
2743: }
2744:
2745: l_element_courant = (struct_liste_chainee *)
2746: (*s_etat_processus).s_marques;
2747:
2748: while(l_element_courant != NULL)
2749: {
2750: free((*((struct_marque *) l_element_courant)).label);
2751: free((*((struct_marque *) l_element_courant)).position);
2752: l_element_suivant = (struct_liste_chainee *)
2753: (*((struct_marque *) l_element_courant)).suivant;
2754: free((struct_marque *) l_element_courant);
2755: l_element_courant = l_element_suivant;
2756: }
2757:
2758: if ((*s_etat_processus).debug == d_vrai)
2759: if (((*s_etat_processus).type_debug &
2760: d_debug_processus) != 0)
2761: {
2762: if ((*s_etat_processus).langue == 'F')
2763: {
2764: printf("[%d] Arrêt du processus\n", (int) getpid());
2765: }
2766: else
2767: {
2768: printf("[%d] Stop process\n", (int) getpid());
2769: }
2770:
2771: fflush(stdout);
2772: }
2773:
2774: liberation(s_etat_processus, s_objet);
2775:
2776: free((*s_etat_processus).definitions_chainees);
2777: free((*s_etat_processus).nom_fichier_historique);
2778:
2779: for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
2780: {
2781: liberation(s_etat_processus,
2782: (*s_etat_processus).corps_interruptions[i]);
2783:
2784: l_element_courant = (*s_etat_processus)
2785: .pile_origine_interruptions[i];
2786:
2787: while(l_element_courant != NULL)
2788: {
2789: l_element_suivant = (*l_element_courant).suivant;
2790:
2791: liberation(s_etat_processus, (*l_element_courant).donnee);
2792: free(l_element_courant);
2793:
2794: l_element_courant = l_element_suivant;
2795: }
2796: }
2797:
2798: if ((*s_etat_processus).generateur_aleatoire != NULL)
2799: {
2800: liberation_generateur_aleatoire(s_etat_processus);
2801: }
2802:
2803: if ((*s_etat_processus).profilage == d_vrai)
2804: {
2805: ecriture_profil(s_etat_processus);
2806: liberation_profil(s_etat_processus);
2807: }
2808:
1.151 ! bertrand 2809: attente.tv_sec = 0;
! 2810: attente.tv_nsec = GRANULARITE_us * 1000;
! 2811:
! 2812: while(nombre_thread_surveillance_processus != 0)
! 2813: {
! 2814: nanosleep(&attente, NULL);
! 2815: INCR_GRANULARITE(attente.tv_nsec);
! 2816: }
! 2817:
1.1 bertrand 2818: closelog();
2819:
2820: retrait_thread(s_etat_processus);
1.151 ! bertrand 2821: liberation_contexte_cas(s_etat_processus);
! 2822: destruction_queue_signaux(s_etat_processus);
1.1 bertrand 2823:
1.72 bertrand 2824: # ifndef SEMAPHORES_NOMMES
1.71 bertrand 2825: sem_post(&((*s_etat_processus).semaphore_fork));
2826: sem_destroy(&((*s_etat_processus).semaphore_fork));
1.72 bertrand 2827: # else
2828: sem_post((*s_etat_processus).semaphore_fork);
2829: sem_destroy3((*s_etat_processus).semaphore_fork, getpid(),
1.73 bertrand 2830: pthread_self(), SEM_FORK);
1.72 bertrand 2831: # endif
1.1 bertrand 2832:
2833: clear_history();
1.4 bertrand 2834:
1.151 ! bertrand 2835: close((*s_argument_thread).pipe_erreurs[1]);
! 2836: close((*s_argument_thread).pipe_interruptions[1]);
! 2837: close((*s_argument_thread).pipe_nombre_elements_attente[1]);
! 2838: close((*s_argument_thread).pipe_objets[1]);
! 2839: close((*s_argument_thread).pipe_injections[0]);
! 2840: close((*s_argument_thread).pipe_nombre_injections[0]);
! 2841: close((*s_argument_thread).pipe_acquittement[0]);
1.142 bertrand 2842:
2843: free((*s_etat_processus).localisation);
2844: free((*s_etat_processus).chemin_fichiers_temporaires);
2845: free(s_argument_thread);
1.143 bertrand 2846:
1.145 bertrand 2847: liberation_allocateur(s_etat_processus);
2848: liberation_allocateur_buffer(s_etat_processus);
2849:
1.143 bertrand 2850: pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
2851: pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
2852: pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
2853: pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
2854: pthread_mutex_destroy(&((*s_etat_processus).protection_liste_mutexes));
2855: pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));
2856: pthread_mutex_destroy(&mutex_sections_critiques);
1.151 ! bertrand 2857: pthread_mutex_destroy(&mutex_liste_variables_partagees);
! 2858: pthread_mutex_destroy(&mutex_liste_threads);
1.143 bertrand 2859:
1.123 bertrand 2860: sys_free(s_etat_processus);
1.20 bertrand 2861:
1.4 bertrand 2862: # ifdef DEBUG_MEMOIRE
1.20 bertrand 2863: debug_memoire_verification();
2864: analyse_post_mortem();
1.4 bertrand 2865: # endif
2866:
1.1 bertrand 2867: exit(EXIT_SUCCESS);
2868: }
2869: else
2870: {
2871: (*s_etat_processus).erreur_systeme = d_es_processus;
2872: return;
2873: }
2874:
2875: // Si le pid existe déjà dans la pile des processus, il s'agit forcement
2876: // d'un processus moribond. On attend donc qu'il soit effectivement
2877: // libéré.
2878:
2879: do
2880: {
2881: l_element_courant = (struct_liste_chainee *)
2882: (*s_etat_processus).l_base_pile_processus;
2883: drapeau = d_faux;
2884:
2885: attente.tv_sec = 0;
2886: attente.tv_nsec = GRANULARITE_us * 1000;
2887:
2888: while(l_element_courant != NULL)
2889: {
2890: if ((*(*((struct_processus_fils *)
2891: (*(*l_element_courant).donnee).objet)).thread)
2892: .processus_detache == d_vrai)
2893: {
2894: if ((*(*((struct_processus_fils *)
2895: (*(*l_element_courant).donnee).objet)).thread).pid ==
2896: (*s_argument_thread).pid)
2897: {
1.112 bertrand 2898: if (pthread_mutex_unlock(&((*s_etat_processus)
2899: .mutex_pile_processus)) != 0)
1.1 bertrand 2900: {
2901: (*s_etat_processus).erreur_systeme = d_es_processus;
2902: return;
2903: }
2904:
2905: nanosleep(&attente, NULL);
2906: INCR_GRANULARITE(attente.tv_nsec);
2907:
1.112 bertrand 2908: if (pthread_mutex_lock(&((*s_etat_processus)
2909: .mutex_pile_processus)) != 0)
1.1 bertrand 2910: {
2911: (*s_etat_processus).erreur_systeme = d_es_processus;
2912: return;
2913: }
2914:
2915: drapeau = d_vrai;
2916: break;
2917: }
2918: }
2919:
1.69 bertrand 2920: scrutation_interruptions(s_etat_processus);
1.1 bertrand 2921: l_element_courant = (*l_element_courant).suivant;
2922: }
2923: } while(drapeau == d_vrai);
2924:
2925: if (empilement(s_etat_processus,
2926: (struct_liste_chainee **) &((*s_etat_processus)
2927: .l_base_pile_processus), s_objet_systeme) == d_erreur)
2928: {
1.112 bertrand 2929: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2930: return;
2931: }
2932:
2933: if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
2934: s_objet) == d_erreur)
2935: {
1.112 bertrand 2936: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2937: return;
2938: }
2939:
1.69 bertrand 2940: // On attend une donnée fictive pour être sûr que le segment de mémoire
2941: // partagée destiné à la gestion des signaux est bien initialisé.
2942:
2943: attente.tv_sec = 0;
2944: attente.tv_nsec = GRANULARITE_us * 1000;
2945:
2946: while(read_atomic(s_etat_processus,
2947: pipe_initialisation_segment_signaux[0],
2948: &caractere, sizeof(caractere)) == 0)
2949: {
2950: scrutation_interruptions(s_etat_processus);
2951: nanosleep(&attente, NULL);
2952: INCR_GRANULARITE(attente.tv_nsec);
2953: }
2954:
2955: close(pipe_initialisation_segment_signaux[0]);
2956: close(pipe_initialisation_segment_signaux[1]);
2957:
1.1 bertrand 2958: // Le fils peut être présent sans être en attente du signal de départ.
2959:
1.144 bertrand 2960: if (envoi_signal_processus((*s_argument_thread).pid, rpl_sigstart,
2961: d_vrai) != 0)
1.1 bertrand 2962: {
2963: (*s_etat_processus).erreur_systeme = d_es_processus;
1.112 bertrand 2964: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 2965: return;
2966: }
2967:
1.112 bertrand 2968: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus)) != 0)
1.1 bertrand 2969: {
2970: (*s_etat_processus).erreur_systeme = d_es_processus;
2971: return;
2972: }
2973:
2974: return;
2975: }
2976:
2977: // vim: ts=4
CVSweb interface <joel.bertrand@systella.fr>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to instructions_d5.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [local] / rpl / src