Annotation of rpl/src/gestion_threads.c, revision 1.112
1.1 bertrand 1: /*
2: ================================================================================
1.110 bertrand 3: RPL/2 (R) version 4.1.31
1.109 bertrand 4: Copyright (C) 1989-2019 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.26 bertrand 23: #include "rpl-conv.h"
1.1 bertrand 24:
25:
26: /*
27: ================================================================================
28: Fonction de lancement d'un thread
29: ================================================================================
30: Entrées : pointeur sur une structure
31: --------------------------------------------------------------------------------
32: Sorties :
33: --------------------------------------------------------------------------------
34: Effets de bord : néant
35: ================================================================================
36: */
37:
38: void *
39: lancement_thread(void *argument)
40: {
1.69 bertrand 41: int status;
1.1 bertrand 42:
1.69 bertrand 43: pid_t ppid;
1.1 bertrand 44:
1.69 bertrand 45: sig_atomic_t registre_stop;
1.1 bertrand 46:
1.69 bertrand 47: ssize_t longueur_ecriture;
1.1 bertrand 48:
1.69 bertrand 49: struct_descripteur_thread *s_argument_thread;
1.1 bertrand 50:
1.69 bertrand 51: struct_liste_chainee *l_element_courant;
52: struct_liste_chainee *l_element_suivant;
1.1 bertrand 53:
1.69 bertrand 54: struct_liste_variables_statiques *l_element_statique_courant;
55: struct_liste_variables_statiques *l_element_statique_suivant;
1.1 bertrand 56:
1.69 bertrand 57: struct_objet *s_objet_temporaire;
1.1 bertrand 58:
1.69 bertrand 59: struct_processus *s_etat_processus;
1.1 bertrand 60:
1.69 bertrand 61: struct sigaction action;
62: struct sigaction registre;
1.1 bertrand 63:
1.69 bertrand 64: struct timespec attente;
1.1 bertrand 65:
1.79 bertrand 66: unsigned char caractere;
1.69 bertrand 67: unsigned char *message;
1.1 bertrand 68:
1.69 bertrand 69: unsigned int erreur;
70:
1.74 bertrand 71: integer8 i;
1.1 bertrand 72:
73: attente.tv_sec = 0;
74: attente.tv_nsec = GRANULARITE_us * 1000;
75:
76: s_argument_thread = (struct_descripteur_thread *) argument;
1.20 bertrand 77: s_etat_processus = (*s_argument_thread).s_nouvel_etat_processus;
1.55 bertrand 78:
79: # ifndef SEMAPHORES_NOMMES
80: sem_init(&((*s_etat_processus).semaphore_fork), 0, 0);
81: # else
82: if (((*s_etat_processus).semaphore_fork = sem_init3(0, getpid(),
83: pthread_self(), SEM_FORK)) == SEM_FAILED)
84: {
85: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
1.112 ! bertrand 86: pthread_exit(NULL);
1.55 bertrand 87: }
88: # endif
89:
1.1 bertrand 90: (*s_argument_thread).tid = pthread_self();
1.75 bertrand 91: insertion_thread(s_etat_processus, d_faux);
1.80 bertrand 92:
93: if (pthread_mutex_lock(&((*s_argument_thread).mutex)) != 0)
94: {
95: (*s_etat_processus).erreur_systeme = d_es_processus;
1.112 ! bertrand 96: pthread_exit(NULL);
1.80 bertrand 97: }
98:
1.1 bertrand 99: (*s_argument_thread).thread_actif = d_vrai;
100:
1.80 bertrand 101: if (pthread_mutex_unlock(&((*s_argument_thread).mutex)) != 0)
102: {
103: (*s_etat_processus).erreur_systeme = d_es_processus;
1.112 ! bertrand 104: pthread_exit(NULL);
1.80 bertrand 105: }
106:
1.1 bertrand 107: // Envoi d'une donnée pour signaler le démarrage du thread au thread
108: // de surveillance.
109:
1.79 bertrand 110: caractere = 0;
111:
1.1 bertrand 112: if (write_atomic(s_etat_processus,
1.79 bertrand 113: (*s_argument_thread).pipe_nombre_elements_attente[1],
114: &caractere, sizeof(caractere)) != sizeof(caractere))
1.1 bertrand 115: {
116: (*s_etat_processus).erreur_systeme = d_es_processus;
117:
118: pthread_mutex_lock(&((*s_argument_thread).mutex));
119: pthread_mutex_unlock(&((*s_argument_thread).mutex));
120:
121: (*s_argument_thread).thread_actif = d_faux;
122:
123: while((longueur_ecriture = write_atomic(s_etat_processus,
1.79 bertrand 124: (*s_argument_thread).pipe_nombre_elements_attente[1],
125: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 126: {
127: if (longueur_ecriture == -1)
128: {
129: break;
130: }
131: }
132:
133: pthread_exit(NULL);
134: }
135:
136: if ((*s_etat_processus).evaluation_expression_compilee == 'N')
137: {
138: free((*s_etat_processus).instruction_courante);
139: (*s_etat_processus).instruction_courante = NULL;
140: }
141:
1.50 bertrand 142: // Attente de la réception du signal rpl_sigstart.
1.1 bertrand 143:
1.50 bertrand 144: for((*s_etat_processus).demarrage_fils = d_faux;;)
1.1 bertrand 145: {
1.50 bertrand 146: scrutation_interruptions(s_etat_processus);
147:
148: if ((*s_etat_processus).demarrage_fils == d_vrai)
1.1 bertrand 149: {
1.50 bertrand 150: break;
151: }
1.1 bertrand 152:
1.112 ! bertrand 153: if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
! 154: {
! 155: (*s_etat_processus).erreur_systeme = d_es_processus;
! 156: pthread_exit(NULL);
! 157: }
! 158:
1.50 bertrand 159: nanosleep(&attente, NULL);
1.112 ! bertrand 160:
! 161: while(sem_wait(&((*s_etat_processus).semaphore_fork)) != 0)
! 162: {
! 163: if (errno != EINTR)
! 164: {
! 165: (*s_etat_processus).erreur_systeme = d_es_processus;
! 166: pthread_exit(NULL);
! 167: }
! 168: }
1.1 bertrand 169: }
170:
171: if ((*s_etat_processus).debug == d_vrai)
172: if (((*s_etat_processus).type_debug & d_debug_processus) != 0)
173: {
174: if ((*s_etat_processus).langue == 'F')
175: {
176: printf("[%d] Lancement du thread %llu\n", (int) getpid(),
177: (unsigned long long) pthread_self());
178: }
179: else
180: {
181: printf("[%d] Start thread %llu\n", (int) getpid(),
182: (unsigned long long) pthread_self());
183: }
184:
185: fflush(stdout);
186: }
187:
188: (*s_etat_processus).pid_erreur_processus_fils = getpid();
189:
190: // Évaluation de l'objet
191:
192: if ((*s_etat_processus).erreur_systeme == d_es)
193: {
1.49 bertrand 194: if (setjmp(contexte_thread) == 0)
1.1 bertrand 195: {
1.49 bertrand 196: if (evaluation(s_etat_processus, (*s_argument_thread).argument, 'E')
197: == d_erreur)
1.1 bertrand 198: {
1.49 bertrand 199: if (((*s_etat_processus).erreur_execution == d_ex) &&
200: ((*s_etat_processus).erreur_systeme == d_es))
201: {
202: (*s_etat_processus).erreur_execution =
203: d_ex_erreur_evaluation;
204: }
1.1 bertrand 205: }
1.49 bertrand 206: else
1.10 bertrand 207: {
1.76 bertrand 208: if (((*s_etat_processus).arret_depuis_abort == 0)
1.49 bertrand 209: && ((*s_etat_processus).at_exit != NULL))
210: {
211: (*s_etat_processus).var_volatile_requete_arret = 0;
1.76 bertrand 212: (*s_etat_processus).var_volatile_alarme = 0;
1.77 bertrand 213: (*s_etat_processus).var_volatile_traitement_sigint = 0;
214:
215: if ((*s_etat_processus).profilage == d_vrai)
216: {
217: profilage(s_etat_processus, "ATEXIT");
218: }
1.13 bertrand 219:
1.49 bertrand 220: if (evaluation(s_etat_processus,
221: (*s_etat_processus).at_exit, 'E') == d_erreur)
1.12 bertrand 222: {
1.49 bertrand 223: if (((*s_etat_processus).erreur_execution == d_ex) &&
224: ((*s_etat_processus).erreur_systeme == d_es))
225: {
226: (*s_etat_processus).erreur_execution =
227: d_ex_erreur_evaluation;
228: }
1.12 bertrand 229: }
1.77 bertrand 230:
231: if ((*s_etat_processus).profilage == d_vrai)
232: {
233: profilage(s_etat_processus, NULL);
234: }
1.10 bertrand 235: }
236: }
237: }
1.1 bertrand 238:
239: if ((*s_argument_thread).destruction_objet == d_vrai)
240: {
241: liberation(s_etat_processus, (*s_argument_thread).argument);
242: }
243: }
244:
245: if ((*s_etat_processus).presence_fusible == d_vrai)
246: {
247: pthread_cancel((*s_etat_processus).thread_fusible);
248: }
249:
1.79 bertrand 250: caractere = 0;
1.1 bertrand 251:
252: while((longueur_ecriture = write_atomic(s_etat_processus,
1.79 bertrand 253: (*s_argument_thread).pipe_nombre_elements_attente[1],
254: &caractere, sizeof(caractere))) != sizeof(caractere))
1.1 bertrand 255: {
256: if (longueur_ecriture == -1)
257: {
258: break;
259: }
260: }
261:
262: if ((*s_etat_processus).var_volatile_processus_pere != 0)
263: {
264: // Racine des processus atteinte
265:
266: erreur = d_ex;
267:
268: while((longueur_ecriture = write_atomic(s_etat_processus,
269: (*s_argument_thread).pipe_erreurs[1], &erreur,
270: sizeof((*s_etat_processus).erreur_execution))) !=
271: sizeof((*s_etat_processus).erreur_execution))
272: {
273: if (longueur_ecriture == -1)
274: {
275: break;
276: }
277: }
278: }
279: else
280: {
281: while((longueur_ecriture = write_atomic(s_etat_processus,
282: (*s_argument_thread).pipe_erreurs[1],
1.79 bertrand 283: (int *) &((*s_etat_processus).erreur_execution),
1.1 bertrand 284: sizeof((*s_etat_processus).erreur_execution))) !=
285: sizeof((*s_etat_processus).erreur_execution))
286: {
287: if (longueur_ecriture == -1)
288: {
289: break;
290: }
291: }
292: }
293:
294: if ((*s_etat_processus).var_volatile_processus_pere != 0)
295: {
296: // Racine des processus atteinte
297:
298: erreur = d_es;
299:
300: while((longueur_ecriture = write_atomic(s_etat_processus,
301: (*s_argument_thread).pipe_erreurs[1], &erreur,
302: sizeof((*s_etat_processus).erreur_systeme))) !=
303: sizeof((*s_etat_processus).erreur_systeme))
304: {
305: if (longueur_ecriture == -1)
306: {
307: break;
308: }
309: }
310: }
311: else
312: {
313: while((longueur_ecriture = write_atomic(s_etat_processus,
314: (*s_argument_thread).pipe_erreurs[1],
1.79 bertrand 315: (int *) &((*s_etat_processus).erreur_systeme),
1.1 bertrand 316: sizeof((*s_etat_processus).erreur_systeme))) !=
317: sizeof((*s_etat_processus).erreur_systeme))
318: {
319: if (longueur_ecriture == -1)
320: {
321: break;
322: }
323: }
324: }
325:
326: if ((*s_etat_processus).pid_erreur_processus_fils == 0)
327: {
328: ppid = getpid();
329:
330: while((longueur_ecriture = write_atomic(s_etat_processus,
331: (*s_argument_thread).pipe_erreurs[1],
332: &ppid, sizeof(ppid))) != sizeof(ppid))
333: {
334: if (longueur_ecriture == -1)
335: {
336: break;
337: }
338: }
339: }
340: else
341: {
342: while((longueur_ecriture = write_atomic(s_etat_processus,
343: (*s_argument_thread).pipe_erreurs[1],
344: &((*s_etat_processus).pid_erreur_processus_fils),
345: sizeof((*s_etat_processus).pid_erreur_processus_fils))) !=
346: sizeof((*s_etat_processus).pid_erreur_processus_fils))
347: {
348: if (longueur_ecriture == -1)
349: {
350: break;
351: }
352: }
353: }
354:
355: l_element_courant = (*s_etat_processus).s_fichiers;
356:
357: while(l_element_courant != NULL)
358: {
359: l_element_suivant = (*l_element_courant).suivant;
360:
361: if ((*((struct_descripteur_fichier *) (*l_element_courant)
362: .donnee)).pid == getpid())
363: {
364: fclose((*((struct_descripteur_fichier *)
1.5 bertrand 365: (*l_element_courant).donnee)).descripteur_c);
366:
367: if ((*((struct_descripteur_fichier *)
368: (*l_element_courant).donnee)).type != 'C')
369: {
370: sqlite3_close((*((struct_descripteur_fichier *)
371: (*l_element_courant).donnee)).descripteur_sqlite);
372: }
1.1 bertrand 373:
374: if ((*((struct_descripteur_fichier *) (*l_element_courant)
375: .donnee)).effacement == 'Y')
376: {
377: unlink((*((struct_descripteur_fichier *)
378: (*l_element_courant).donnee)).nom);
379: }
380: }
381:
382: free((*((struct_descripteur_fichier *) (*l_element_courant)
383: .donnee)).nom);
384: free((struct_descripteur_fichier *) (*l_element_courant).donnee);
385: free(l_element_courant);
386:
387: l_element_courant = l_element_suivant;
388: }
389:
1.83 bertrand 390: pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 391:
392: l_element_courant = (struct_liste_chainee *)
393: (*s_etat_processus).l_base_pile_processus;
394:
395: while(l_element_courant != NULL)
396: {
397: if ((*(*((struct_processus_fils *) (*(*l_element_courant).donnee)
398: .objet)).thread).processus_detache == d_vrai)
399: {
400: if ((*s_etat_processus).debug == d_vrai)
401: {
402: if (((*s_etat_processus).type_debug & d_debug_processus) != 0)
403: {
404: if ((*s_etat_processus).langue == 'F')
405: {
406: printf("[%d] Signalement pour arrêt du processus %d\n",
407: (int) getpid(),
408: (int) (*(*((struct_processus_fils *)
409: (*(*l_element_courant).donnee).objet)).thread)
410: .pid);
411: }
412: else
413: {
414: printf("[%d] Send stop signal to process %d\n",
415: (int) getpid(),
416: (int) (*(*((struct_processus_fils *)
417: (*(*l_element_courant).donnee).objet)).thread)
418: .pid);
419: }
420: }
421: }
422:
423: if ((*s_etat_processus).var_volatile_alarme != 0)
424: {
1.50 bertrand 425: envoi_signal_processus((*(*((struct_processus_fils *)
426: (*(*l_element_courant)
1.102 bertrand 427: .donnee).objet)).thread).pid, rpl_sigurg, d_faux);
1.1 bertrand 428: }
429: else
430: {
1.14 bertrand 431: if ((*s_etat_processus).arret_depuis_abort == -1)
432: {
1.50 bertrand 433: envoi_signal_processus((*(*((struct_processus_fils *)
434: (*(*l_element_courant)
1.102 bertrand 435: .donnee).objet)).thread).pid, rpl_sigabort, d_faux);
1.14 bertrand 436: }
437: else
438: {
1.50 bertrand 439: envoi_signal_processus((*(*((struct_processus_fils *)
440: (*(*l_element_courant)
1.102 bertrand 441: .donnee).objet)).thread).pid, rpl_sigstop,d_faux);
1.14 bertrand 442: }
1.1 bertrand 443: }
444: }
445: else
446: {
447: if ((*s_etat_processus).debug == d_vrai)
448: {
449: if (((*s_etat_processus).type_debug & d_debug_processus) != 0)
450: {
451: if ((*s_etat_processus).langue == 'F')
452: {
453: printf("[%d] Signalement pour arrêt du thread %llu\n",
454: (int) getpid(), (unsigned long long)
455: (*(*((struct_processus_fils *)
456: (*(*l_element_courant).donnee).objet)).thread)
457: .tid);
458: }
459: else
460: {
461: printf("[%d] Send stop signal to thread %llu\n",
462: (int) getpid(), (unsigned long long)
463: (*(*((struct_processus_fils *)
464: (*(*l_element_courant).donnee).objet)).thread)
465: .tid);
466: }
467: }
468: }
469:
470: if ((*s_etat_processus).var_volatile_alarme != 0)
471: {
472: if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
473: (*(*l_element_courant).donnee).objet)).thread).mutex))
474: != 0)
475: {
1.83 bertrand 476: pthread_mutex_unlock(&((*s_etat_processus)
477: .mutex_pile_processus));
1.1 bertrand 478: (*s_etat_processus).erreur_systeme = d_es_processus;
479:
480: pthread_mutex_lock(&((*s_argument_thread).mutex));
481: pthread_mutex_unlock(&((*s_argument_thread).mutex));
482:
483: (*s_argument_thread).thread_actif = d_faux;
484:
485: pthread_exit(NULL);
486: }
487:
488: if ((*(*((struct_processus_fils *)
489: (*(*l_element_courant).donnee).objet)).thread)
490: .thread_actif == d_vrai)
491: {
1.112 ! bertrand 492: envoi_signal_thread(NULL,
! 493: (*(*((struct_processus_fils *)
1.1 bertrand 494: (*(*l_element_courant).donnee).objet)).thread).tid,
1.50 bertrand 495: rpl_sigurg);
1.1 bertrand 496: }
497:
498: if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
499: (*(*l_element_courant).donnee).objet)).thread)
500: .mutex)) != 0)
501: {
1.83 bertrand 502: pthread_mutex_unlock(&((*s_etat_processus)
503: .mutex_pile_processus));
1.1 bertrand 504: (*s_etat_processus).erreur_systeme = d_es_processus;
505:
506: pthread_mutex_lock(&((*s_argument_thread).mutex));
507: pthread_mutex_unlock(&((*s_argument_thread).mutex));
508:
509: (*s_argument_thread).thread_actif = d_faux;
510:
511: pthread_exit(NULL);
512: }
513: }
514: else
515: {
516: if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
517: (*(*l_element_courant).donnee).objet)).thread).mutex))
518: != 0)
519: {
1.83 bertrand 520: pthread_mutex_unlock(&((*s_etat_processus)
521: .mutex_pile_processus));
1.1 bertrand 522: (*s_etat_processus).erreur_systeme = d_es_processus;
523:
524: pthread_mutex_lock(&((*s_argument_thread).mutex));
525: pthread_mutex_unlock(&((*s_argument_thread).mutex));
526:
527: (*s_argument_thread).thread_actif = d_faux;
528:
529: pthread_exit(NULL);
530: }
531:
532: if ((*(*((struct_processus_fils *)
533: (*(*l_element_courant).donnee).objet)).thread)
534: .thread_actif == d_vrai)
535: {
1.14 bertrand 536: if ((*s_etat_processus).arret_depuis_abort == -1)
537: {
1.112 ! bertrand 538: envoi_signal_thread(NULL,
! 539: (*(*((struct_processus_fils *)
1.14 bertrand 540: (*(*l_element_courant).donnee).objet)).thread)
1.50 bertrand 541: .tid, rpl_sigabort);
1.14 bertrand 542: }
543: else
544: {
1.112 ! bertrand 545: envoi_signal_thread(NULL,
! 546: (*(*((struct_processus_fils *)
1.14 bertrand 547: (*(*l_element_courant).donnee).objet)).thread)
1.50 bertrand 548: .tid, rpl_sigstop);
1.14 bertrand 549: }
1.1 bertrand 550: }
551:
552: if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
553: (*(*l_element_courant).donnee).objet)).thread).mutex))
554: != 0)
555: {
1.83 bertrand 556: pthread_mutex_unlock(&((*s_etat_processus)
557: .mutex_pile_processus));
1.1 bertrand 558: (*s_etat_processus).erreur_systeme = d_es_processus;
559:
560: pthread_mutex_lock(&((*s_argument_thread).mutex));
561: pthread_mutex_unlock(&((*s_argument_thread).mutex));
562:
563: (*s_argument_thread).thread_actif = d_faux;
564:
565: pthread_exit(NULL);
566: }
567: }
568: }
569:
570: l_element_courant = (*l_element_courant).suivant;
571: }
572:
573: /*
574: * Attente de la fin de tous les processus fils
575: */
576:
577: for(i = 0; i < d_NOMBRE_INTERRUPTIONS;
578: (*s_etat_processus).masque_interruptions[i++] = 'I');
579:
580: attente.tv_sec = 0;
581: attente.tv_nsec = GRANULARITE_us * 1000;
582:
583: while((*s_etat_processus).l_base_pile_processus != NULL)
584: {
585: status = 0;
586:
587: l_element_courant = (struct_liste_chainee *)
588: (*s_etat_processus).l_base_pile_processus;
589:
590: registre_stop = (*s_etat_processus)
591: .var_volatile_traitement_retarde_stop;
592: (*s_etat_processus).var_volatile_traitement_retarde_stop = 1;
593:
1.74 bertrand 594: for(i = 0; i < (*(*((struct_processus_fils *)
1.1 bertrand 595: (*(*l_element_courant).donnee).objet)).thread)
596: .nombre_objets_dans_pipe; i++)
597: {
598: if ((s_objet_temporaire = lecture_pipe(s_etat_processus,
599: (*(*((struct_processus_fils *) (*(*l_element_courant)
600: .donnee).objet)).thread).pipe_objets[0])) != NULL)
601: {
602: liberation(s_etat_processus, s_objet_temporaire);
603:
604: (*(*((struct_processus_fils *) (*(*l_element_courant)
605: .donnee).objet)).thread).nombre_objets_dans_pipe--;
606:
607: action.sa_handler = SIG_IGN;
1.112 ! bertrand 608: action.sa_flags = 0;
1.1 bertrand 609:
610: if (sigaction(SIGPIPE, &action, ®istre) != 0)
611: {
1.83 bertrand 612: pthread_mutex_unlock(&((*s_etat_processus)
613: .mutex_pile_processus));
1.1 bertrand 614:
615: if (registre_stop == 0)
616: {
617: if ((*s_etat_processus)
618: .var_volatile_traitement_retarde_stop
619: == -1)
620: {
621: (*s_etat_processus)
622: .var_volatile_requete_arret = -1;
623: }
624:
625: (*s_etat_processus)
626: .var_volatile_traitement_retarde_stop =
627: registre_stop;
628: }
629:
630: (*s_etat_processus).erreur_systeme = d_es_signal;
631: exit(EXIT_FAILURE);
632: }
633:
634: while((longueur_ecriture = write_atomic(
635: s_etat_processus, (*(*((struct_processus_fils *)
636: (*(*l_element_courant).donnee).objet)).thread)
637: .pipe_nombre_injections[1], "+",
638: sizeof(unsigned char))) !=
639: sizeof(unsigned char))
640: {
641: if (longueur_ecriture == -1)
642: {
643: // Le processus n'existe plus.
644: break;
645: }
646: }
647:
648: if (registre_stop == 0)
649: {
650: if ((*s_etat_processus)
651: .var_volatile_traitement_retarde_stop == -1)
652: {
653: (*s_etat_processus).var_volatile_requete_arret
654: = -1;
655: }
656:
657: (*s_etat_processus)
658: .var_volatile_traitement_retarde_stop =
659: registre_stop;
660: }
661:
662: if (sigaction(SIGPIPE, ®istre, NULL) != 0)
663: {
1.83 bertrand 664: pthread_mutex_unlock(&((*s_etat_processus)
665: .mutex_pile_processus));
1.1 bertrand 666:
667: (*s_etat_processus).erreur_systeme = d_es_signal;
668: exit(EXIT_FAILURE);
669: }
670: }
671: }
672:
673: if ((*(*((struct_processus_fils *) (*(*l_element_courant)
674: .donnee).objet)).thread).processus_detache == d_vrai)
675: {
676: if (waitpid((*(*((struct_processus_fils *)
677: (*(*l_element_courant).donnee).objet)).thread).pid,
678: &status, WNOHANG) < 0)
679: {
680: }
681: }
682:
1.82 bertrand 683: if (pthread_mutex_lock(&((*s_etat_processus).mutex_interruptions)) != 0)
684: {
1.83 bertrand 685: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.82 bertrand 686:
687: (*s_etat_processus).erreur_systeme = d_es_processus;
688: exit(EXIT_FAILURE);
689: }
690:
1.15 bertrand 691: if ((*s_etat_processus).nombre_interruptions_non_affectees != 0)
692: {
693: affectation_interruptions_logicielles(s_etat_processus);
694: }
695:
1.82 bertrand 696: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_interruptions))
697: != 0)
698: {
1.83 bertrand 699: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.82 bertrand 700:
701: (*s_etat_processus).erreur_systeme = d_es_processus;
702: exit(EXIT_FAILURE);
703: }
704:
1.83 bertrand 705: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 706: nanosleep(&attente, NULL);
1.83 bertrand 707: pthread_mutex_lock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 708: }
709:
1.83 bertrand 710: pthread_mutex_unlock(&((*s_etat_processus).mutex_pile_processus));
1.1 bertrand 711:
712: l_element_courant = (*s_etat_processus).s_sockets;
713:
714: while(l_element_courant != NULL)
715: {
716: l_element_suivant = (*l_element_courant).suivant;
717:
718: /*
719: * Fermeture des sockets créées dans le processus courant.
720: */
721:
722: if (((*((struct_socket *) (*(*l_element_courant).donnee).objet))
723: .pid == getpid()) && (pthread_equal((*((struct_socket *)
724: (*(*l_element_courant).donnee).objet)).tid, pthread_self())
725: != 0))
726: {
727: if ((*((struct_socket *) (*(*l_element_courant).donnee).objet))
728: .socket_connectee == d_vrai)
729: {
730: shutdown((*((struct_socket *) (*(*l_element_courant).donnee)
731: .objet)).socket, SHUT_RDWR);
732: }
733:
734: close((*((struct_socket *) (*(*l_element_courant).donnee).objet))
735: .socket);
736:
737: if ((*((struct_socket *) (*(*l_element_courant).donnee).objet))
738: .effacement == 'Y')
739: {
740: unlink((*((struct_socket *) (*(*l_element_courant).donnee)
741: .objet)).adresse);
742: }
743: }
744:
745: liberation(s_etat_processus, (*((struct_liste_chainee *)
746: l_element_courant)).donnee);
747: free(l_element_courant);
748:
749: l_element_courant = l_element_suivant;
750: }
751:
752: l_element_courant = (*s_etat_processus).s_connecteurs_sql;
753:
754: while(l_element_courant != NULL)
755: {
756: l_element_suivant = (*l_element_courant).suivant;
757:
758: /*
759: * Fermeture des connecteurs créés dans le processus courant.
760: */
761:
762: if (((*((struct_socket *) (*(*l_element_courant).donnee).objet))
763: .pid == getpid()) && (pthread_equal((*((struct_socket *)
764: (*(*l_element_courant).donnee).objet)).tid, pthread_self())
765: != 0))
766: {
767: sqlclose((*l_element_courant).donnee);
768: }
769:
770: liberation(s_etat_processus, (*((struct_liste_chainee *)
771: l_element_courant)).donnee);
772: free(l_element_courant);
773:
774: l_element_courant = l_element_suivant;
775: }
776:
777: if ((((*s_etat_processus).erreur_execution != d_ex) ||
778: ((*s_etat_processus).exception != d_ep) ||
779: ((*s_etat_processus).erreur_systeme != d_es)) &&
780: ((*s_etat_processus).var_volatile_traitement_sigint == 0))
781: {
782: printf("%s [%d]\n", message =
783: messages(s_etat_processus), (int) getpid());
784: free(message);
785:
786: if ((*s_etat_processus).core == d_vrai)
787: {
788: printf("\n");
789:
790: if ((*s_etat_processus).langue == 'F')
791: {
792: printf("+++Information : Génération du fichier rpl-core "
793: "[%d]\n", (int) getpid());
794: }
795: else
796: {
797: printf("+++Information : Writing rpl-core file [%d]\n",
798: (int) getpid());
799: }
800:
801: rplcore(s_etat_processus);
802:
803: if ((*s_etat_processus).langue == 'F')
804: {
805: printf("+++Information : Processus tracé [%d]\n",
806: (int) getpid());
807: }
808: else
809: {
810: printf("+++Information : Done [%d]\n", (int) getpid());
811: }
812:
813: printf("\n");
814: fflush(stdout);
815: }
816: }
817:
818: if ((*s_etat_processus).entree_standard != NULL)
819: {
820: pclose((*s_etat_processus).entree_standard);
821: (*s_etat_processus).entree_standard = NULL;
822: }
823:
824: if ((*s_etat_processus).fichiers_graphiques != NULL)
825: {
826: instruction_cllcd(s_etat_processus);
827: }
828:
829: liberation(s_etat_processus, (*s_etat_processus).indep);
830: liberation(s_etat_processus, (*s_etat_processus).depend);
831:
832: free((*s_etat_processus).label_x);
833: free((*s_etat_processus).label_y);
834: free((*s_etat_processus).label_z);
835: free((*s_etat_processus).titre);
836: free((*s_etat_processus).legende);
837:
838: liberation(s_etat_processus,
839: (*s_etat_processus).parametres_courbes_de_niveau);
840:
841: if ((*s_etat_processus).instruction_derniere_erreur != NULL)
842: {
843: free((*s_etat_processus).instruction_derniere_erreur);
844: (*s_etat_processus).instruction_derniere_erreur = NULL;
845: }
846:
1.35 bertrand 847: liberation_arbre_variables(s_etat_processus,
848: (*s_etat_processus).s_arbre_variables, d_faux);
1.1 bertrand 849:
1.69 bertrand 850: l_element_statique_courant = (*s_etat_processus)
851: .l_liste_variables_statiques;
852:
853: while(l_element_statique_courant != NULL)
854: {
855: l_element_statique_suivant = (*l_element_statique_courant).suivant;
856: free(l_element_statique_courant);
857: l_element_statique_courant = l_element_statique_suivant;
858: }
859:
1.1 bertrand 860: l_element_courant = (*s_etat_processus).l_base_pile;
861: while(l_element_courant != NULL)
862: {
863: l_element_suivant = (*l_element_courant).suivant;
864:
865: liberation(s_etat_processus, (*l_element_courant).donnee);
866: free(l_element_courant);
867:
868: l_element_courant = l_element_suivant;
869: }
870:
871: l_element_courant = (*s_etat_processus).l_base_pile_last;
872: while(l_element_courant != NULL)
873: {
874: l_element_suivant = (*l_element_courant).suivant;
875:
876: liberation(s_etat_processus, (*l_element_courant).donnee);
877: free(l_element_courant);
878:
879: l_element_courant = l_element_suivant;
880: }
881:
882: l_element_courant = (*s_etat_processus).l_base_pile_contextes;
883: while(l_element_courant != NULL)
884: {
885: l_element_suivant = (*l_element_courant).suivant;
886:
887: liberation(s_etat_processus, (*l_element_courant).donnee);
888: free(l_element_courant);
889:
890: l_element_courant = l_element_suivant;
891: }
892:
893: l_element_courant = (*s_etat_processus).l_base_pile_taille_contextes;
894: while(l_element_courant != NULL)
895: {
896: l_element_suivant = (*l_element_courant).suivant;
897:
898: liberation(s_etat_processus, (*l_element_courant).donnee);
899: free(l_element_courant);
900:
901: l_element_courant = l_element_suivant;
902: }
903:
904: l_element_courant = (struct_liste_chainee *)
905: (*s_etat_processus).l_base_pile_systeme;
906: while(l_element_courant != NULL)
907: {
908: l_element_suivant = (struct_liste_chainee *)
909: (*((struct_liste_pile_systeme *)
910: l_element_courant)).suivant;
911:
912: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
913: l_element_courant)).indice_boucle);
914: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
915: l_element_courant)).limite_indice_boucle);
916: liberation(s_etat_processus, (*((struct_liste_pile_systeme *)
917: l_element_courant)).objet_de_test);
918:
919: if ((*((struct_liste_pile_systeme *)
920: l_element_courant)).nom_variable != NULL)
921: {
922: free((*((struct_liste_pile_systeme *)
923: l_element_courant)).nom_variable);
924: }
925:
926: free((struct_liste_pile_systeme *) l_element_courant);
927:
928: l_element_courant = l_element_suivant;
929: }
930:
931: l_element_courant = (*s_etat_processus).s_bibliotheques;
932:
933: while(l_element_courant != NULL)
934: {
935: l_element_suivant = (*l_element_courant).suivant;
936:
937: free((*((struct_bibliotheque *) (*l_element_courant).donnee)).nom);
938:
939: if (((*((struct_bibliotheque *) (*l_element_courant).donnee)).pid
940: == getpid()) && (pthread_equal((*((struct_bibliotheque *)
941: (*l_element_courant).donnee)).tid, pthread_self()) != 0))
942: {
943: dlclose((*((struct_bibliotheque *) (*l_element_courant).donnee))
944: .descripteur);
945: }
946:
947: free((*l_element_courant).donnee);
948: free(l_element_courant);
949:
950: l_element_courant = l_element_suivant;
951: }
952:
953: for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
954: {
955: free((*s_etat_processus).s_instructions_externes[i].nom);
956: free((*s_etat_processus).s_instructions_externes[i]
957: .nom_bibliotheque);
958: }
959:
960: if ((*s_etat_processus).nombre_instructions_externes != 0)
961: {
962: free((*s_etat_processus).s_instructions_externes);
963: }
964:
965: if ((*s_etat_processus).debug == d_vrai)
966: if (((*s_etat_processus).type_debug & d_debug_processus) != 0)
967: {
968: if ((*s_etat_processus).langue == 'F')
969: {
970: printf("[%d] Fin du thread %llu\n", (int) getpid(),
971: (unsigned long long) pthread_self());
972: }
973: else
974: {
975: printf("[%d] End of thread %llu\n", (int) getpid(),
976: (unsigned long long) pthread_self());
977: }
978:
979: fflush(stdout);
980: }
981:
982: liberation(s_etat_processus, (*s_argument_thread).argument);
1.11 bertrand 983: liberation(s_etat_processus, (*s_etat_processus).at_exit);
1.25 bertrand 984: liberation(s_etat_processus, (*s_etat_processus).at_poke);
1.1 bertrand 985:
986: for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
987: {
988: liberation(s_etat_processus,
989: (*s_etat_processus).corps_interruptions[i]);
990:
991: l_element_courant = (*s_etat_processus)
992: .pile_origine_interruptions[i];
993:
994: while(l_element_courant != NULL)
995: {
996: l_element_suivant = (*l_element_courant).suivant;
997:
998: liberation(s_etat_processus, (*l_element_courant).donnee);
999: free(l_element_courant);
1000:
1001: l_element_courant = l_element_suivant;
1002: }
1003: }
1004:
1005: l_element_courant = (struct_liste_chainee *) (*s_etat_processus).s_marques;
1006:
1007: while(l_element_courant != NULL)
1008: {
1009: free((*((struct_marque *) l_element_courant)).label);
1010: free((*((struct_marque *) l_element_courant)).position);
1011: l_element_suivant = (struct_liste_chainee *)
1012: (*((struct_marque *) l_element_courant)).suivant;
1013: free((struct_marque *) l_element_courant);
1014: l_element_courant = l_element_suivant;
1015: }
1016:
1017: if ((*s_etat_processus).generateur_aleatoire != NULL)
1018: {
1019: liberation_generateur_aleatoire(s_etat_processus);
1020: }
1021:
1022: if ((*s_etat_processus).profilage == d_vrai)
1023: {
1024: ecriture_profil(s_etat_processus);
1025: liberation_profil(s_etat_processus);
1026: }
1027:
1028: retrait_thread(s_etat_processus);
1.83 bertrand 1029: pthread_mutex_destroy(&((*s_etat_processus).mutex_pile_processus));
1.21 bertrand 1030: pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation));
1.82 bertrand 1031: pthread_mutex_destroy(&((*s_etat_processus).mutex_interruptions));
1.83 bertrand 1032: pthread_mutex_destroy(&((*s_etat_processus).mutex_signaux));
1.53 bertrand 1033:
1034: # ifndef SEMAPHORES_NOMMES
1.111 bertrand 1035: sem_post(&((*s_etat_processus).semaphore_fork));
1.53 bertrand 1036: sem_destroy(&((*s_etat_processus).semaphore_fork));
1037: # else
1.111 bertrand 1038: sem_post((*s_etat_processus).semaphore_fork);
1.55 bertrand 1039: sem_destroy3((*s_etat_processus).semaphore_fork, getpid(),
1040: pthread_self(), SEM_FORK);
1.53 bertrand 1041: # endif
1.28 bertrand 1042:
1.101 bertrand 1043: close((*s_argument_thread).pipe_erreurs[1]);
1044: close((*s_argument_thread).pipe_interruptions[1]);
1045: close((*s_argument_thread).pipe_nombre_elements_attente[1]);
1046: close((*s_argument_thread).pipe_objets[1]);
1047: close((*s_argument_thread).pipe_injections[0]);
1048: close((*s_argument_thread).pipe_nombre_injections[0]);
1049: close((*s_argument_thread).pipe_acquittement[0]);
1050:
1.45 bertrand 1051: liberation_contexte_cas(s_etat_processus);
1.95 bertrand 1052: free((*s_etat_processus).localisation);
1053: liberation_allocateur(s_etat_processus);
1.92 bertrand 1054: liberation_allocateur_buffer(s_etat_processus);
1.95 bertrand 1055: pthread_mutex_destroy(&((*s_etat_processus).mutex_allocation_buffer));
1.93 bertrand 1056: sys_free(s_etat_processus);
1.1 bertrand 1057:
1058: pthread_mutex_lock(&((*s_argument_thread).mutex));
1.81 bertrand 1059: (*s_argument_thread).thread_actif = d_faux;
1.1 bertrand 1060: pthread_mutex_unlock(&((*s_argument_thread).mutex));
1061:
1062: pthread_exit(NULL);
1.26 bertrand 1063: return(NULL);
1.1 bertrand 1064: }
1065:
1066: // vim: ts=4
CVSweb interface <joel.bertrand@systella.fr>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to gestion_threads.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [local] / rpl / src