Annotation of rpl/src/gestion_objets.c, revision 1.83
1.1 bertrand 1: /*
2: ================================================================================
1.83 ! bertrand 3: RPL/2 (R) version 4.1.10
1.77 bertrand 4: Copyright (C) 1989-2012 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: ================================================================================
1.6 bertrand 28: Routines de gestion du nombre d'occurrences comme grandeur atomique
1.1 bertrand 29: ================================================================================
30: entrées : structure sur l'état du processus et objet à afficher
31: --------------------------------------------------------------------------------
32: sorties : chaine de caractères
33: --------------------------------------------------------------------------------
34: effets de bord : néant
35: ================================================================================
36: */
37:
38: static inline void
39: incrementation_atomique(struct_objet *s_objet)
40: {
41: // Le mutex est sur l'objet.
42:
43: (*s_objet).nombre_occurrences++;
44:
45: BUG((*s_objet).nombre_occurrences <= 0,
46: uprintf("Capacity exceeded %ld\n", (*s_objet).nombre_occurrences));
47:
48: return;
49: }
50:
51: static inline long
52: decrementation_atomique(struct_objet *s_objet)
53: {
54: // Le mutex est sur l'objet.
55:
56: (*s_objet).nombre_occurrences--;
57: return((*s_objet).nombre_occurrences);
58: }
59:
1.43 bertrand 60: void
1.1 bertrand 61: initialisation_objet(struct_objet *s_objet)
62: {
63: pthread_mutexattr_t attributs_mutex;
64:
65: pthread_mutexattr_init(&attributs_mutex);
66: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
67: pthread_mutex_init(&((*s_objet).mutex), &attributs_mutex);
68: pthread_mutexattr_destroy(&attributs_mutex);
69:
70: (*s_objet).nombre_occurrences = 1;
71:
72: return;
73: }
74:
75:
76: /*
77: ================================================================================
78: Routines d'initialisation et de purge de l'allocateur
79: ================================================================================
80: Entrées : structure sur l'état du processus et objet à afficher
81: --------------------------------------------------------------------------------
82: Sorties : chaine de caractères
83: --------------------------------------------------------------------------------
84: Effets de bord : néant
85: ================================================================================
86: */
87:
88: void
89: initialisation_allocateur(struct_processus *s_etat_processus)
90: {
91: (*s_etat_processus).estimation_taille_pile_tampon = 0;
92: (*s_etat_processus).taille_pile_tampon = 0;
93: (*s_etat_processus).pile_tampon = NULL;
94:
95: (*s_etat_processus).estimation_taille_pile_systeme_tampon = 0;
96: (*s_etat_processus).taille_pile_systeme_tampon = 0;
97: (*s_etat_processus).pile_systeme_tampon = NULL;
98:
99: (*s_etat_processus).taille_pile_objets = 0;
100: (*s_etat_processus).pile_objets = NULL;
101:
102: (*s_etat_processus).pointeur_adr = 0;
103: (*s_etat_processus).pointeur_bin = 0;
104: (*s_etat_processus).pointeur_cpl = 0;
105: (*s_etat_processus).pointeur_fct = 0;
106: (*s_etat_processus).pointeur_int = 0;
107: (*s_etat_processus).pointeur_mat = 0;
108: (*s_etat_processus).pointeur_nom = 0;
109: (*s_etat_processus).pointeur_rel = 0;
110: (*s_etat_processus).pointeur_tab = 0;
111: (*s_etat_processus).pointeur_vec = 0;
112: (*s_etat_processus).pointeur_maillons = 0;
113:
1.53 bertrand 114: (*s_etat_processus).pointeur_variables_noeud = 0;
115: (*s_etat_processus).pointeur_variables_feuille = 0;
116: (*s_etat_processus).pointeur_variables_variable = 0;
117: (*s_etat_processus).pointeur_variables_tableau_noeuds = 0;
118:
1.1 bertrand 119: return;
120: }
121:
122:
123: void
124: liberation_allocateur(struct_processus *s_etat_processus)
125: {
126: int i;
127:
128: for(i = 0; i < (*s_etat_processus).pointeur_adr;
129: free((*s_etat_processus).objets_adr[i++]));
130: for(i = 0; i < (*s_etat_processus).pointeur_bin;
131: free((*s_etat_processus).objets_bin[i++]));
132: for(i = 0; i < (*s_etat_processus).pointeur_cpl;
133: free((*s_etat_processus).objets_cpl[i++]));
134: for(i = 0; i < (*s_etat_processus).pointeur_fct;
135: free((*s_etat_processus).objets_fct[i++]));
136: for(i = 0; i < (*s_etat_processus).pointeur_int;
137: free((*s_etat_processus).objets_int[i++]));
138: for(i = 0; i < (*s_etat_processus).pointeur_mat;
139: free((*s_etat_processus).objets_mat[i++]));
140: for(i = 0; i < (*s_etat_processus).pointeur_nom;
141: free((*s_etat_processus).objets_nom[i++]));
142: for(i = 0; i < (*s_etat_processus).pointeur_rel;
143: free((*s_etat_processus).objets_rel[i++]));
144: for(i = 0; i < (*s_etat_processus).pointeur_tab;
145: free((*s_etat_processus).objets_tab[i++]));
146: for(i = 0; i < (*s_etat_processus).pointeur_vec;
147: free((*s_etat_processus).objets_vec[i++]));
148: for(i = 0; i < (*s_etat_processus).pointeur_maillons;
149: free((*s_etat_processus).maillons[i++]));
150:
1.53 bertrand 151: for(i = 0; i < (*s_etat_processus).pointeur_variables_noeud;
152: free((*s_etat_processus).variables_noeud[i++]));
153: for(i = 0; i < (*s_etat_processus).pointeur_variables_feuille;
154: free((*s_etat_processus).variables_feuille[i++]));
155: for(i = 0; i < (*s_etat_processus).pointeur_variables_variable;
156: free((*s_etat_processus).variables_variable[i++]));
157: for(i = 0; i < (*s_etat_processus).pointeur_variables_tableau_noeuds;
158: free((*s_etat_processus).variables_tableau_noeuds[i++]));
159:
1.1 bertrand 160: {
161: struct_liste_chainee *l_element_courant;
162: struct_liste_chainee *l_element_suivant;
163:
164: l_element_courant = (*s_etat_processus).pile_tampon;
165:
166: while(l_element_courant != NULL)
167: {
168: l_element_suivant = (*l_element_courant).suivant;
169: liberation(s_etat_processus, (*l_element_courant).donnee);
170: free(l_element_courant);
171: l_element_courant = l_element_suivant;
172: }
173: }
174:
175: {
176: struct_liste_pile_systeme *l_element_courant;
177: struct_liste_pile_systeme *l_element_suivant;
178:
179: l_element_courant = (*s_etat_processus).pile_systeme_tampon;
180:
181: while(l_element_courant != NULL)
182: {
183: l_element_suivant = (*l_element_courant).suivant;
184: free(l_element_courant);
185: l_element_courant = l_element_suivant;
186: }
187: }
188:
189: {
190: struct_objet *l_element_courant;
191: struct_objet *l_element_suivant;
192:
193: l_element_courant = (*s_etat_processus).pile_objets;
194:
195: while(l_element_courant != NULL)
196: {
197: l_element_suivant = (*l_element_courant).objet;
198:
199: if (pthread_mutex_destroy(&((*l_element_courant).mutex)) != 0)
200: {
201: (*s_etat_processus).erreur_systeme = d_es_processus;
202: BUG(1, printf("Mutex error\n"));
203: return;
204: }
205:
206: free(l_element_courant);
207: l_element_courant = l_element_suivant;
208: }
209: }
210:
211: return;
212: }
213:
214:
215: /*
216: ================================================================================
217: Routine d'allocation d'un maillon d'un objet (liste, expression...)
218: ================================================================================
219: Entrées : structure sur l'état du processus et objet à afficher
220: --------------------------------------------------------------------------------
221: Sorties : chaine de caractères
222: --------------------------------------------------------------------------------
223: Effets de bord : néant
224: ================================================================================
225: */
226:
227: void *
228: allocation_maillon(struct_processus *s_etat_processus)
229: {
230: struct_liste_chainee *s_maillon;
231:
232: if ((*s_etat_processus).pointeur_maillons > 0)
233: {
234: s_maillon = (*s_etat_processus).maillons
235: [--(*s_etat_processus).pointeur_maillons];
236: }
237: else
238: {
239: if ((s_maillon = malloc(sizeof(struct_liste_chainee))) == NULL)
240: {
241: return(NULL);
242: }
243: }
244:
245: return(s_maillon);
246: }
247:
248:
249: /*
250: ================================================================================
1.53 bertrand 251: Routine de libération d'un maillon d'un objet (liste, expression...)
1.1 bertrand 252: ================================================================================
253: Entrées : structure sur l'état du processus et objet à afficher
254: --------------------------------------------------------------------------------
255: Sorties : chaine de caractères
256: --------------------------------------------------------------------------------
257: Effets de bord : néant
258: ================================================================================
259: */
260:
261: void
262: liberation_maillon(struct_processus *s_etat_processus,
263: struct_liste_chainee *maillon)
264: {
265: if ((*s_etat_processus).pointeur_maillons < TAILLE_CACHE)
266: {
267: (*s_etat_processus).maillons
268: [(*s_etat_processus).pointeur_maillons++] = maillon;
269: }
270: else
271: {
272: free(maillon);
273: }
274:
275: return;
276: }
277:
278:
279: /*
280: ================================================================================
281: Routine d'allocation d'une structure *s_objet
282: ================================================================================
1.28 bertrand 283: Entrées : structure sur l'état du processus et objet à allouer
1.1 bertrand 284: --------------------------------------------------------------------------------
285: Sorties : chaine de caractères
286: --------------------------------------------------------------------------------
287: Effets de bord : néant
288: ================================================================================
289: */
290:
1.55 bertrand 291: struct_objet *
1.1 bertrand 292: allocation(struct_processus *s_etat_processus, enum t_type type)
293: {
294: struct_objet *s_objet;
295:
1.28 bertrand 296: if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation)) != 0)
297: {
298: (*s_etat_processus).erreur_systeme = d_es_processus;
299: return(NULL);
300: }
301:
1.1 bertrand 302: if ((*s_etat_processus).pile_objets == NULL)
303: {
1.28 bertrand 304: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
305: {
306: (*s_etat_processus).erreur_systeme = d_es_processus;
307: return(NULL);
308: }
309:
1.1 bertrand 310: // Il n'existe aucune structure struct_objet disponible dans le cache.
311:
312: if ((s_objet = malloc(sizeof(struct_objet))) == NULL)
313: {
314: return(NULL);
315: }
316:
317: initialisation_objet(s_objet);
318: }
319: else
320: {
321: // Récupération d'une structure dans le cache.
322:
323: s_objet = (*s_etat_processus).pile_objets;
324: (*s_etat_processus).pile_objets = (*s_objet).objet;
325: (*s_etat_processus).taille_pile_objets--;
326:
327: (*s_objet).nombre_occurrences = 1;
1.28 bertrand 328:
329: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
330: {
331: (*s_etat_processus).erreur_systeme = d_es_processus;
332: return(NULL);
333: }
1.1 bertrand 334: }
335:
336: (*s_objet).type = type;
337:
338: switch(type)
339: {
340: case ADR :
341: {
342: if ((*s_etat_processus).pointeur_adr > 0)
343: {
344: (*s_objet).objet = (*s_etat_processus).objets_adr
345: [--(*s_etat_processus).pointeur_adr];
346: }
347: else
348: {
349: if (((*s_objet).objet = malloc(sizeof(unsigned long))) == NULL)
350: {
351: free(s_objet);
352: return(NULL);
353: }
354: }
355:
356: break;
357: }
358:
359: case ALG :
360: {
361: (*s_objet).objet = NULL;
362: break;
363: }
364:
365: case BIN :
366: {
367: if ((*s_etat_processus).pointeur_bin > 0)
368: {
369: (*s_objet).objet = (*s_etat_processus).objets_bin
370: [--(*s_etat_processus).pointeur_bin];
371: }
372: else
373: {
374: if (((*s_objet).objet = malloc(sizeof(logical8))) == NULL)
375: {
376: free(s_objet);
377: return(NULL);
378: }
379: }
380:
381: break;
382: }
383:
384: case CHN :
385: {
386: (*s_objet).objet = NULL;
387: break;
388: }
389:
390: case CPL :
391: {
392: if ((*s_etat_processus).pointeur_cpl > 0)
393: {
394: (*s_objet).objet = (*s_etat_processus).objets_cpl
395: [--(*s_etat_processus).pointeur_cpl];
396: }
397: else
398: {
399: if (((*s_objet).objet = malloc(sizeof(struct_complexe16)))
400: == NULL)
401: {
402: free(s_objet);
403: return(NULL);
404: }
405: }
406:
407: break;
408: }
409:
410: case FCH :
411: {
412: if (((*s_objet).objet = malloc(sizeof(struct_fichier))) == NULL)
413: {
414: free(s_objet);
415: return(NULL);
416: }
417:
418: break;
419: }
420:
421: case FCT :
422: {
423: if ((*s_etat_processus).pointeur_fct > 0)
424: {
425: (*s_objet).objet = (*s_etat_processus).objets_fct
426: [--(*s_etat_processus).pointeur_fct];
427: }
428: else
429: {
430: if (((*s_objet).objet = malloc(sizeof(struct_fonction)))
431: == NULL)
432: {
433: free(s_objet);
434: return(NULL);
435: }
436: }
437:
1.5 bertrand 438: (*((struct_fonction *) (*s_objet).objet)).fonction = NULL;
1.1 bertrand 439: (*((struct_fonction *) (*s_objet).objet)).prediction_saut = NULL;
1.5 bertrand 440: (*((struct_fonction *) (*s_objet).objet)).prediction_execution
441: = d_faux;
1.1 bertrand 442: break;
443: }
444:
445: case INT :
446: {
447: if ((*s_etat_processus).pointeur_int > 0)
448: {
449: (*s_objet).objet = (*s_etat_processus).objets_int
450: [--(*s_etat_processus).pointeur_int];
451: }
452: else
453: {
454: if (((*s_objet).objet = malloc(sizeof(integer8))) == NULL)
455: {
456: free(s_objet);
457: return(NULL);
458: }
459: }
460:
461: break;
462: }
463:
464: case LST :
465: {
466: (*s_objet).objet = NULL;
467: break;
468: }
469:
470: case MCX :
471: {
472: if ((*s_etat_processus).pointeur_mat > 0)
473: {
474: (*s_objet).objet = (*s_etat_processus).objets_mat
475: [--(*s_etat_processus).pointeur_mat];
476: }
477: else
478: {
479: if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
480: {
481: free(s_objet);
482: return(NULL);
483: }
484: }
485:
486: (*((struct_matrice *) (*s_objet).objet)).type = 'C';
487: (*((struct_matrice *) (*s_objet).objet)).nombre_lignes = 0;
488: (*((struct_matrice *) (*s_objet).objet)).nombre_colonnes = 0;
489: (*((struct_matrice *) (*s_objet).objet)).tableau = NULL;
490: break;
491: }
492:
493: case MIN :
494: {
495: if ((*s_etat_processus).pointeur_mat > 0)
496: {
497: (*s_objet).objet = (*s_etat_processus).objets_mat
498: [--(*s_etat_processus).pointeur_mat];
499: }
500: else
501: {
502: if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
503: {
504: free(s_objet);
505: return(NULL);
506: }
507: }
508:
509: (*((struct_matrice *) (*s_objet).objet)).type = 'I';
510: (*((struct_matrice *) (*s_objet).objet)).nombre_lignes = 0;
511: (*((struct_matrice *) (*s_objet).objet)).nombre_colonnes = 0;
512: (*((struct_matrice *) (*s_objet).objet)).tableau = NULL;
513: break;
514: }
515:
516: case MRL :
517: {
518: if ((*s_etat_processus).pointeur_mat > 0)
519: {
520: (*s_objet).objet = (*s_etat_processus).objets_mat
521: [--(*s_etat_processus).pointeur_mat];
522: }
523: else
524: {
525: if (((*s_objet).objet = malloc(sizeof(struct_matrice))) == NULL)
526: {
527: free(s_objet);
528: return(NULL);
529: }
530: }
531:
532: (*((struct_matrice *) (*s_objet).objet)).type = 'R';
533: (*((struct_matrice *) (*s_objet).objet)).nombre_lignes = 0;
534: (*((struct_matrice *) (*s_objet).objet)).nombre_colonnes = 0;
535: (*((struct_matrice *) (*s_objet).objet)).tableau = NULL;
536: break;
537: }
538:
539: case MTX :
540: {
541: if (((*s_objet).objet = malloc(sizeof(struct_mutex))) == NULL)
542: {
543: free(s_objet);
544: return(NULL);
545: }
546:
1.76 bertrand 547: (*((struct_mutex *) (*s_objet).objet)).tid = pthread_self();
1.1 bertrand 548: break;
549: }
550:
551: case NOM :
552: {
553: if ((*s_etat_processus).pointeur_nom > 0)
554: {
555: (*s_objet).objet = (*s_etat_processus).objets_nom
556: [--(*s_etat_processus).pointeur_nom];
557: }
558: else
559: {
560: if (((*s_objet).objet = malloc(sizeof(struct_nom))) == NULL)
561: {
562: free(s_objet);
563: return(NULL);
564: }
565: }
566:
567: break;
568: }
569:
570: case NON :
571: {
572: (*s_objet).objet = NULL;
573: break;
574: }
575:
576: case PRC :
577: {
578: if (((*s_objet).objet = malloc(sizeof(struct_processus_fils)))
579: == NULL)
580: {
581: free(s_objet);
582: return(NULL);
583: }
584:
585: break;
586: }
587:
588: case REL :
589: {
590: if ((*s_etat_processus).pointeur_rel > 0)
591: {
592: (*s_objet).objet = (*s_etat_processus).objets_rel
593: [--(*s_etat_processus).pointeur_rel];
594: }
595: else
596: {
597: if (((*s_objet).objet = malloc(sizeof(real8))) == NULL)
598: {
599: free(s_objet);
600: return(NULL);
601: }
602: }
603:
604: break;
605: }
606:
607: case RPN :
608: {
609: (*s_objet).objet = NULL;
610: break;
611: }
612:
613: case SCK :
614: {
615: if (((*s_objet).objet = malloc(sizeof(struct_socket))) == NULL)
616: {
617: free(s_objet);
618: return(NULL);
619: }
620:
621: break;
622: }
623:
624: case SLB :
625: {
626: if (((*s_objet).objet = malloc(sizeof(struct_bibliotheque)))
627: == NULL)
628: {
629: free(s_objet);
630: return(NULL);
631: }
632:
633: break;
634: }
635:
636: case SPH :
637: {
638: if (((*s_objet).objet = malloc(sizeof(struct_semaphore))) == NULL)
639: {
640: free(s_objet);
641: return(NULL);
642: }
643:
644: break;
645: }
646:
647: case SQL :
648: {
649: if (((*s_objet).objet = malloc(sizeof(struct_connecteur_sql)))
650: == NULL)
651: {
652: free(s_objet);
653: return(NULL);
654: }
655:
656: break;
657: }
658:
659: case TBL :
660: {
661: if ((*s_etat_processus).pointeur_tab > 0)
662: {
663: (*s_objet).objet = (*s_etat_processus).objets_tab
664: [--(*s_etat_processus).pointeur_tab];
665: }
666: else
667: {
668: if (((*s_objet).objet = malloc(sizeof(struct_tableau))) == NULL)
669: {
670: free(s_objet);
671: return(NULL);
672: }
673: }
674:
675: (*((struct_tableau *) (*s_objet).objet)).nombre_elements = 0;
676: (*((struct_tableau *) (*s_objet).objet)).elements = NULL;
677: break;
678: }
679:
680: case VCX :
681: {
682: if ((*s_etat_processus).pointeur_vec > 0)
683: {
684: (*s_objet).objet = (*s_etat_processus).objets_vec
685: [--(*s_etat_processus).pointeur_vec];
686: }
687: else
688: {
689: if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
690: {
691: free(s_objet);
692: return(NULL);
693: }
694: }
695:
696: (*((struct_vecteur *) (*s_objet).objet)).type = 'C';
697: (*((struct_vecteur *) (*s_objet).objet)).taille = 0;
698: (*((struct_vecteur *) (*s_objet).objet)).tableau = NULL;
699: break;
700: }
701:
702: case VIN :
703: {
704: if ((*s_etat_processus).pointeur_vec > 0)
705: {
706: (*s_objet).objet = (*s_etat_processus).objets_vec
707: [--(*s_etat_processus).pointeur_vec];
708: }
709: else
710: {
711: if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
712: {
713: free(s_objet);
714: return(NULL);
715: }
716: }
717:
718: (*((struct_vecteur *) (*s_objet).objet)).type = 'I';
719: (*((struct_vecteur *) (*s_objet).objet)).taille = 0;
720: (*((struct_vecteur *) (*s_objet).objet)).tableau = NULL;
721: break;
722: }
723:
724: case VRL :
725: {
726: if ((*s_etat_processus).pointeur_vec > 0)
727: {
728: (*s_objet).objet = (*s_etat_processus).objets_vec
729: [--(*s_etat_processus).pointeur_vec];
730: }
731: else
732: {
733: if (((*s_objet).objet = malloc(sizeof(struct_vecteur))) == NULL)
734: {
735: free(s_objet);
736: return(NULL);
737: }
738: }
739:
740: (*((struct_vecteur *) (*s_objet).objet)).type = 'R';
741: (*((struct_vecteur *) (*s_objet).objet)).taille = 0;
742: (*((struct_vecteur *) (*s_objet).objet)).tableau = NULL;
743: break;
744: }
745:
746: default :
747: {
748: free(s_objet);
749: BUG(1, printf("Allocation failure (type %d)\n", type));
750:
751: return(NULL);
752: }
753: }
754:
755: return(s_objet);
756: }
757:
758:
759: /*
760: ================================================================================
761: Routine de libération d'une structure *s_objet
762: ================================================================================
763: Entrées : structure sur l'état du processus et objet à afficher
764: --------------------------------------------------------------------------------
765: Sorties : chaine de caractères
766: --------------------------------------------------------------------------------
767: Effets de bord : néant
768: ================================================================================
769: */
770:
771: void
772: liberation(struct_processus *s_etat_processus, struct_objet *s_objet)
773: {
774: logical1 drapeau;
775:
776: struct_liste_chainee *l_element_courant;
777: struct_liste_chainee *l_element_suivant;
778:
779: unsigned long i;
780:
781: if (s_objet == NULL)
782: {
783: return;
784: }
785:
786: if (pthread_mutex_lock(&((*s_objet).mutex)) != 0)
787: {
788: (*s_etat_processus).erreur_systeme = d_es_processus;
789: return;
790: }
791:
792: #define return \
793: if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0) \
794: { (*s_etat_processus).erreur_systeme = d_es_processus; return; } \
795: return
796:
797: BUG((*s_objet).nombre_occurrences <= 0,
798: pthread_mutex_unlock(&((*s_objet).mutex)),
799: printf("(*s_objet).nombre_occurrences=%ld\n",
800: (*s_objet).nombre_occurrences));
801:
802: switch((*s_objet).type)
803: {
804: case ADR :
805: {
806: if (decrementation_atomique(s_objet) > 0)
807: {
808: return;
809: }
810:
811: if ((*s_etat_processus).pointeur_adr < TAILLE_CACHE)
812: {
813: (*s_etat_processus).objets_adr
814: [(*s_etat_processus).pointeur_adr++] = (*s_objet).objet;
815: }
816: else
817: {
818: free((unsigned long *) ((*s_objet).objet));
819: }
820:
821: break;
822: }
823:
824: case ALG :
825: {
826: l_element_courant = (struct_liste_chainee *) ((*s_objet).objet);
827:
828: if (decrementation_atomique(s_objet) > 0)
829: { // Il reste un pointeur sur l'objet.
830: while(l_element_courant != NULL)
831: {
832: BUG((*(*l_element_courant).donnee).nombre_occurrences <= 1,
833: pthread_mutex_unlock(&((*s_objet).mutex)),
834: printf("(*(*l_element_courant).donnee)"
835: ".nombre_occurrences=%ld\n",
836: (*(*l_element_courant).donnee).nombre_occurrences));
837:
838: liberation(s_etat_processus, (*l_element_courant).donnee);
839: l_element_courant = (*l_element_courant).suivant;
840: }
841:
842: return;
843: }
844: else
845: { // Il ne reste plus aucun pointeur sur l'objet.
846: while(l_element_courant != NULL)
847: {
848: l_element_suivant = (*l_element_courant).suivant;
849: liberation(s_etat_processus, (*l_element_courant).donnee);
850: liberation_maillon(s_etat_processus, l_element_courant);
851: l_element_courant = l_element_suivant;
852: }
853: }
854:
855: break;
856: }
857:
858: case BIN :
859: {
860: if (decrementation_atomique(s_objet) > 0)
861: {
862: return;
863: }
864:
865: if ((*s_etat_processus).pointeur_bin < TAILLE_CACHE)
866: {
867: (*s_etat_processus).objets_bin
868: [(*s_etat_processus).pointeur_bin++] = (*s_objet).objet;
869: }
870: else
871: {
872: free((logical8 *) ((*s_objet).objet));
873: }
874:
875: break;
876: }
877:
878: case CHN :
879: {
880: if (decrementation_atomique(s_objet) > 0)
881: {
882: return;
883: }
884:
885: free((unsigned char *) ((*s_objet).objet));
886: break;
887: }
888:
889: case CPL :
890: {
891: if (decrementation_atomique(s_objet) > 0)
892: {
893: return;
894: }
895:
896: if ((*s_etat_processus).pointeur_cpl < TAILLE_CACHE)
897: {
898: (*s_etat_processus).objets_cpl
899: [(*s_etat_processus).pointeur_cpl++] = (*s_objet).objet;
900: }
901: else
902: {
903: free((struct_complexe16 *) ((*s_objet).objet));
904: }
905:
906: break;
907: }
908:
909: case FCH :
910: {
911: if (decrementation_atomique(s_objet) > 0)
912: {
1.18 bertrand 913: BUG((*(*((struct_fichier *) (*s_objet).objet)).format)
914: .nombre_occurrences <= 1,
915: pthread_mutex_unlock(&((*s_objet).mutex)),
916: printf("(*(*((struct_fichier *) (*s_objet).objet))"
917: ".format).nombre_occurrences=%ld\n",
918: (*(*((struct_fichier *) (*s_objet).objet)).format)
919: .nombre_occurrences));
920:
921: liberation(s_etat_processus,
922: (*((struct_fichier *) (*s_objet).objet)).format);
1.1 bertrand 923: return;
924: }
925:
926: liberation(s_etat_processus,
927: (*((struct_fichier *) (*s_objet).objet)).format);
928: free((unsigned char *) (*((struct_fichier *)
929: (*s_objet).objet)).nom);
930: free((struct_fichier *) ((*s_objet).objet));
931: break;
932: }
933:
934: case FCT :
935: {
936: if (decrementation_atomique(s_objet) > 0)
937: {
938: return;
939: }
940:
941: free((unsigned char *) (*((struct_fonction *)
942: (*s_objet).objet)).nom_fonction);
943:
944: if ((*s_etat_processus).pointeur_fct < TAILLE_CACHE)
945: {
946: (*s_etat_processus).objets_fct
947: [(*s_etat_processus).pointeur_fct++] = (*s_objet).objet;
948: }
949: else
950: {
951: free((struct_fonction *) (*s_objet).objet);
952: }
953:
954: break;
955: }
956:
957: case INT :
958: {
959: if (decrementation_atomique(s_objet) > 0)
960: {
961: return;
962: }
963:
964: if ((*s_etat_processus).pointeur_int < TAILLE_CACHE)
965: {
966: (*s_etat_processus).objets_int
967: [(*s_etat_processus).pointeur_int++] = (*s_objet).objet;
968: }
969: else
970: {
971: free((integer8 *) ((*s_objet).objet));
972: }
973:
974: break;
975: }
976:
977: case LST :
978: {
979: l_element_courant = (struct_liste_chainee *) ((*s_objet).objet);
980:
981: if (decrementation_atomique(s_objet) > 0)
982: { // Il reste un pointeur sur l'objet.
983: while(l_element_courant != NULL)
984: {
985: BUG((*(*l_element_courant).donnee).nombre_occurrences <= 1,
986: pthread_mutex_unlock(&((*s_objet).mutex)),
987: printf("(*(*l_element_courant).donnee)"
988: ".nombre_occurrences=%ld\n",
989: (*(*l_element_courant).donnee).nombre_occurrences));
990:
991: liberation(s_etat_processus, (*l_element_courant).donnee);
992: l_element_courant = (*l_element_courant).suivant;
993: }
994:
995: return;
996: }
997: else
998: { // Il ne reste plus aucun pointeur sur l'objet.
999: while(l_element_courant != NULL)
1000: {
1001: l_element_suivant = (*l_element_courant).suivant;
1002: liberation(s_etat_processus, (*l_element_courant).donnee);
1003: liberation_maillon(s_etat_processus, l_element_courant);
1004: l_element_courant = l_element_suivant;
1005: }
1006: }
1007:
1008: break;
1009: }
1010:
1011: case MIN :
1012: {
1013: if (decrementation_atomique(s_objet) > 0)
1014: {
1015: return;
1016: }
1017:
1018: for(i = 0; i < (*((struct_matrice *)
1019: ((*s_objet).objet))).nombre_lignes; i++)
1020: {
1021: free(((integer8 **) (*((struct_matrice *)
1022: (*s_objet).objet)).tableau)[i]);
1023: }
1024:
1025: free((integer8 **) (*((struct_matrice *)
1026: (*s_objet).objet)).tableau);
1027:
1028: if ((*s_etat_processus).pointeur_mat < TAILLE_CACHE)
1029: {
1030: (*s_etat_processus).objets_mat
1031: [(*s_etat_processus).pointeur_mat++] = (*s_objet).objet;
1032: }
1033: else
1034: {
1035: free((struct_matrice *) (*s_objet).objet);
1036: }
1037:
1038: break;
1039: }
1040:
1041: case MCX :
1042: {
1043: if (decrementation_atomique(s_objet) > 0)
1044: {
1045: return;
1046: }
1047:
1048: for(i = 0; i < (*((struct_matrice *)
1049: ((*s_objet).objet))).nombre_lignes; i++)
1050: {
1051: free(((struct_complexe16 **) (*((struct_matrice *)
1052: (*s_objet).objet)).tableau)[i]);
1053: }
1054:
1055: free((struct_complexe16 **) (*((struct_matrice *)
1056: (*s_objet).objet)).tableau);
1057:
1058: if ((*s_etat_processus).pointeur_mat < TAILLE_CACHE)
1059: {
1060: (*s_etat_processus).objets_mat
1061: [(*s_etat_processus).pointeur_mat++] = (*s_objet).objet;
1062: }
1063: else
1064: {
1065: free((struct_matrice *) (*s_objet).objet);
1066: }
1067:
1068: break;
1069: }
1070:
1071: case MRL :
1072: {
1073: if (decrementation_atomique(s_objet) > 0)
1074: {
1075: return;
1076: }
1077:
1078: for(i = 0; i < (*((struct_matrice *)
1079: ((*s_objet).objet))).nombre_lignes; i++)
1080: {
1081: free(((real8 **) (*((struct_matrice *)
1082: (*s_objet).objet)).tableau)[i]);
1083: }
1084:
1085: free((real8 **) (*((struct_matrice *) (*s_objet).objet)).tableau);
1086:
1087: if ((*s_etat_processus).pointeur_mat < TAILLE_CACHE)
1088: {
1089: (*s_etat_processus).objets_mat
1090: [(*s_etat_processus).pointeur_mat++] = (*s_objet).objet;
1091: }
1092: else
1093: {
1094: free((struct_matrice *) (*s_objet).objet);
1095: }
1096:
1097: break;
1098: }
1099:
1100: case MTX :
1101: {
1102: if (decrementation_atomique(s_objet) > 0)
1103: {
1104: return;
1105: }
1106:
1.76 bertrand 1107: if (pthread_mutex_trylock(&((*((struct_mutex *)
1108: (*s_objet).objet)).mutex)) == 0)
1109: {
1110: // On a pu verrouiller le mutex. Il faut donc spécifier le tid.
1111: (*((struct_mutex *) (*s_objet).objet)).tid = pthread_self();
1112: }
1113:
1114: if (pthread_equal(pthread_self(),
1115: (*((struct_mutex *) (*s_objet).objet)).tid) != 0)
1116: {
1117: pthread_mutex_unlock(&((*((struct_mutex *)
1118: (*s_objet).objet)).mutex));
1119: }
1120: else
1121: {
1122: (*s_etat_processus).erreur_systeme =
1123: d_es_mutex_acquis_autre_thread;
1124: return;
1125: }
1126:
1127: pthread_mutex_destroy(&((*((struct_mutex *)
1128: (*s_objet).objet)).mutex));
1.1 bertrand 1129: free((struct_mutex *) (*s_objet).objet);
1130: break;
1131: }
1132:
1133: case NOM :
1134: {
1135: if (decrementation_atomique(s_objet) > 0)
1136: {
1137: return;
1138: }
1139:
1140: free((*((struct_nom *) (*s_objet).objet)).nom);
1141:
1142: if ((*s_etat_processus).pointeur_nom < TAILLE_CACHE)
1143: {
1144: (*s_etat_processus).objets_nom
1145: [(*s_etat_processus).pointeur_nom++] = (*s_objet).objet;
1146: }
1147: else
1148: {
1149: free((struct_nom *) (*s_objet).objet);
1150: }
1151:
1152: break;
1153: }
1154:
1155: case NON :
1156: {
1157: if (decrementation_atomique(s_objet) > 0)
1158: {
1159: return;
1160: }
1161:
1162: break;
1163: }
1164:
1165: case PRC :
1166: {
1167: if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
1.40 bertrand 1168: (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
1.1 bertrand 1169: {
1170: (*s_etat_processus).erreur_systeme = d_es_processus;
1171: return;
1172: }
1173:
1174: (*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1175: .nombre_references--;
1176:
1177: BUG((*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1.24 bertrand 1178: .nombre_references < 0, uprintf(
1179: "(*(*((struct_processus_fils"
1.1 bertrand 1180: " *) (*s_objet).objet)).thread).nombre_references = %d\n",
1181: (int) (*(*((struct_processus_fils *) (*s_objet).objet))
1182: .thread).nombre_references));
1183:
1184: if ((*(*((struct_processus_fils *) (*s_objet).objet)).thread)
1185: .nombre_references == 0)
1186: {
1187: drapeau = d_vrai;
1188: }
1189: else
1190: {
1191: drapeau = d_faux;
1192: }
1193:
1194: if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
1.40 bertrand 1195: (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
1.1 bertrand 1196: {
1197: (*s_etat_processus).erreur_systeme = d_es_processus;
1198: return;
1199: }
1200:
1201: if (drapeau == d_vrai)
1202: {
1203: pthread_mutex_destroy(&((*(*((struct_processus_fils *)
1204: (*s_objet).objet)).thread).mutex));
1.40 bertrand 1205: pthread_mutex_destroy(&((*(*((struct_processus_fils *)
1206: (*s_objet).objet)).thread).mutex_nombre_references));
1.1 bertrand 1207: free((*((struct_processus_fils *) (*s_objet).objet)).thread);
1208: }
1209:
1210: if (decrementation_atomique(s_objet) > 0)
1211: {
1.28 bertrand 1212: BUG(drapeau == d_vrai, uprintf("(*(*((struct_processus_fils"
1213: " *) (*s_objet).objet)).thread).nombre_references "
1214: "= 0 with nombre_occurrences > 0\n"));
1.1 bertrand 1215: return;
1216: }
1217:
1218: free((struct_processus_fils *) ((*s_objet).objet));
1219: break;
1220: }
1221:
1222: case REL :
1223: {
1224: if (decrementation_atomique(s_objet) > 0)
1225: {
1226: return;
1227: }
1228:
1229: if ((*s_etat_processus).pointeur_rel < TAILLE_CACHE)
1230: {
1231: (*s_etat_processus).objets_rel
1232: [(*s_etat_processus).pointeur_rel++] = (*s_objet).objet;
1233: }
1234: else
1235: {
1236: free((real8 *) ((*s_objet).objet));
1237: }
1238:
1239: break;
1240: }
1241:
1242: case RPN :
1243: {
1244: l_element_courant = (struct_liste_chainee *) ((*s_objet).objet);
1245:
1246: if (decrementation_atomique(s_objet) > 0)
1247: { // Il reste un pointeur sur l'objet.
1248: while(l_element_courant != NULL)
1249: {
1250: BUG((*(*l_element_courant).donnee).nombre_occurrences <= 1,
1251: pthread_mutex_unlock(&((*s_objet).mutex)),
1252: printf("(*(*l_element_courant).donnee)"
1253: ".nombre_occurrences=%ld\n",
1254: (*(*l_element_courant).donnee).nombre_occurrences));
1255:
1256: liberation(s_etat_processus, (*l_element_courant).donnee);
1257: l_element_courant = (*l_element_courant).suivant;
1258: }
1259:
1260: return;
1261: }
1262: else
1263: { // Il ne reste plus aucun pointeur sur l'objet.
1264: while(l_element_courant != NULL)
1265: {
1266: l_element_suivant = (*l_element_courant).suivant;
1267: liberation(s_etat_processus, (*l_element_courant).donnee);
1268: liberation_maillon(s_etat_processus, l_element_courant);
1269: l_element_courant = l_element_suivant;
1270: }
1271: }
1272:
1273: break;
1274: }
1275:
1276: case SCK :
1277: {
1278: if (decrementation_atomique(s_objet) > 0)
1279: {
1.18 bertrand 1280: BUG((*(*((struct_socket *) (*s_objet).objet)).format)
1281: .nombre_occurrences <= 1,
1282: pthread_mutex_unlock(&((*s_objet).mutex)),
1283: printf("(*(*((struct_socket *) (*s_objet).objet))"
1284: ".format).nombre_occurrences=%ld\n",
1285: (*(*((struct_socket *) (*s_objet).objet)).format)
1286: .nombre_occurrences));
1287:
1.17 bertrand 1288: liberation(s_etat_processus, (*((struct_socket *)
1289: (*s_objet).objet)).format);
1.1 bertrand 1290: return;
1291: }
1292:
1293: liberation(s_etat_processus, (*((struct_socket *)
1294: (*s_objet).objet)).format);
1.18 bertrand 1295:
1.1 bertrand 1296: free((unsigned char *) (*((struct_socket *) (*s_objet).objet))
1297: .adresse);
1298: free((unsigned char *) (*((struct_socket *) (*s_objet).objet))
1299: .adresse_distante);
1300: free((struct_socket *) ((*s_objet).objet));
1301: break;
1302: }
1303:
1304: case SLB :
1305: {
1306: if (decrementation_atomique(s_objet) > 0)
1307: {
1308: return;
1309: }
1310:
1311: free((*((struct_bibliotheque *) (*s_objet).objet)).nom);
1312: free((struct_bibliotheque *) (*s_objet).objet);
1313: break;
1314: }
1315:
1316: case SPH :
1317: {
1318: if (decrementation_atomique(s_objet) > 0)
1319: {
1320: return;
1321: }
1322:
1323: free((*((struct_semaphore *) (*s_objet).objet)).nom);
1324: free((struct_bibliotheque *) (*s_objet).objet);
1325: break;
1326: }
1327:
1328: case SQL :
1329: {
1330: if (decrementation_atomique(s_objet) > 0)
1331: {
1332: return;
1333: }
1334:
1335: free((*((struct_connecteur_sql *) (*s_objet).objet)).type);
1336: free((*((struct_connecteur_sql *) (*s_objet).objet)).locale);
1337: free((struct_connecteur_sql *) (*s_objet).objet);
1338: break;
1339: }
1340:
1341: case TBL :
1342: {
1343: if (decrementation_atomique(s_objet) > 0)
1344: {
1345: for(i = 0; i < (*((struct_tableau *) (*s_objet).objet))
1346: .nombre_elements; i++)
1347: {
1348: BUG((*((*((struct_tableau *)
1349: (*s_objet).objet)).elements[i]))
1350: .nombre_occurrences <= 1,
1351: pthread_mutex_unlock(&((*s_objet).mutex)),
1352: printf("(*((*((struct_tableau *) (*s_objet).objet))"
1353: ".element[%lu])).nombre_occurrences=%ld\n", i,
1354: (*((*((struct_tableau *) (*s_objet).objet))
1355: .elements[i])).nombre_occurrences));
1356: liberation(s_etat_processus, (*((struct_tableau *)
1357: (*s_objet).objet)).elements[i]);
1358: }
1359:
1360: return;
1361: }
1362:
1363: for(i = 0; i < (*((struct_tableau *) (*s_objet).objet))
1364: .nombre_elements; i++)
1365: {
1366: liberation(s_etat_processus, (*((struct_tableau *)
1367: (*s_objet).objet)).elements[i]);
1368: }
1369:
1370: free((*((struct_tableau *) (*s_objet).objet)).elements);
1371:
1372: if ((*s_etat_processus).pointeur_tab < TAILLE_CACHE)
1373: {
1374: (*s_etat_processus).objets_tab
1375: [(*s_etat_processus).pointeur_tab++] = (*s_objet).objet;
1376: }
1377: else
1378: {
1379: free((struct_tableau *) (*s_objet).objet);
1380: }
1381:
1382: break;
1383: }
1384:
1385: case VIN :
1386: {
1387: if (decrementation_atomique(s_objet) > 0)
1388: {
1389: return;
1390: }
1391:
1392: free((integer8 *) (*((struct_vecteur *) (*s_objet).objet)).tableau);
1393:
1394: if ((*s_etat_processus).pointeur_vec < TAILLE_CACHE)
1395: {
1396: (*s_etat_processus).objets_vec
1397: [(*s_etat_processus).pointeur_vec++] = (*s_objet).objet;
1398: }
1399: else
1400: {
1401: free((struct_vecteur *) (*s_objet).objet);
1402: }
1403:
1404: break;
1405: }
1406:
1407: case VCX :
1408: {
1409: if (decrementation_atomique(s_objet) > 0)
1410: {
1411: return;
1412: }
1413:
1414: free((struct_complexe16 *) (*((struct_vecteur *)
1415: (*s_objet).objet)).tableau);
1416:
1417: if ((*s_etat_processus).pointeur_vec < TAILLE_CACHE)
1418: {
1419: (*s_etat_processus).objets_vec
1420: [(*s_etat_processus).pointeur_vec++] = (*s_objet).objet;
1421: }
1422: else
1423: {
1424: free((struct_vecteur *) (*s_objet).objet);
1425: }
1426:
1427: break;
1428: }
1429:
1430: case VRL :
1431: {
1432: if (decrementation_atomique(s_objet) > 0)
1433: {
1434: return;
1435: }
1436:
1437: free((real8 *) (*((struct_vecteur *) (*s_objet).objet)).tableau);
1438:
1439: if ((*s_etat_processus).pointeur_vec < TAILLE_CACHE)
1440: {
1441: (*s_etat_processus).objets_vec
1442: [(*s_etat_processus).pointeur_vec++] = (*s_objet).objet;
1443: }
1444: else
1445: {
1446: free((struct_vecteur *) (*s_objet).objet);
1447: }
1448:
1449: break;
1450: }
1451:
1452: default :
1453: {
1454: if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)
1455: {
1456: (*s_etat_processus).erreur_systeme = d_es_processus;
1457: return;
1458: }
1459:
1460: if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)
1461: {
1462: (*s_etat_processus).erreur_systeme = d_es_processus;
1463: return;
1464: }
1465:
1466: BUG(1, printf("Free failure (type %d)\n", (*s_objet).type));
1467: return;
1468: }
1469: }
1470:
1471: #undef return
1472:
1473: if (pthread_mutex_unlock(&((*s_objet).mutex)) != 0)
1474: {
1475: (*s_etat_processus).erreur_systeme = d_es_processus;
1476: return;
1477: }
1478:
1.28 bertrand 1479: if (pthread_mutex_lock(&((*s_etat_processus).mutex_allocation)) != 0)
1.1 bertrand 1480: {
1.28 bertrand 1481: (*s_etat_processus).erreur_systeme = d_es_processus;
1482: return;
1483: }
1484:
1485: if ((*s_etat_processus).taille_pile_objets < TAILLE_CACHE)
1486: {
1487: (*s_objet).objet = (*s_etat_processus).pile_objets;
1488: (*s_etat_processus).pile_objets = s_objet;
1489: (*s_etat_processus).taille_pile_objets++;
1490: }
1491: else
1492: {
1493: if (pthread_mutex_destroy(&((*s_objet).mutex)) != 0)
1.1 bertrand 1494: {
1.28 bertrand 1495: pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation));
1496: (*s_etat_processus).erreur_systeme = d_es_processus;
1497: return;
1.1 bertrand 1498: }
1499:
1.28 bertrand 1500: free(s_objet);
1.1 bertrand 1501: }
1.28 bertrand 1502:
1503: if (pthread_mutex_unlock(&((*s_etat_processus).mutex_allocation)) != 0)
1.1 bertrand 1504: {
1.28 bertrand 1505: (*s_etat_processus).erreur_systeme = d_es_processus;
1506: return;
1.1 bertrand 1507: }
1508:
1509: return;
1510: }
1511:
1512:
1513: /*
1514: ================================================================================
1515: Routine de copie d'une structure *s_objet
1516: ================================================================================
1517: Entrées : structure *s_objet à copier
1518: type :
1519: 'P' : renvoie le même objet en incrémentant le nombre
1520: d'occurrence de chaque objet élémentaire ;
1521: 'O' : crée un nouvel objet en copiant chaque objet élémentaire ;
1522: 'N' : crée un nouvel objet mais les objets élémentaires
1523: sont réutilisés (voir 'P'). Dans le cas d'un objet
1524: élémentaire, 'N' et 'P' sont identiques.
1525: 'Q' : 'P' si nombre_occurrences vaut 1, 'O' sinon.
1526: 'R' : 'P' si nombre_occurrences vaut 1, 'N' sinon.
1527: --------------------------------------------------------------------------------
1528: Sorties : structure identique (tous les objets sont copiés)
1529: --------------------------------------------------------------------------------
1530: Effets de bord : néant
1531: ================================================================================
1532: */
1533:
1534: struct_objet *
1535: copie_objet(struct_processus *s_etat_processus,
1536: struct_objet *s_objet, unsigned char type)
1537: {
1538: struct_liste_chainee *l_element_base;
1539: struct_liste_chainee *l_element_courant;
1540: struct_liste_chainee *l_element_courant_ecriture;
1541: struct_liste_chainee *l_element_courant_lecture;
1542: struct_liste_chainee *l_element_suivant_ecriture;
1543: struct_liste_chainee *l_element_suivant_lecture;
1544:
1545: struct_objet *s_nouvel_objet;
1546: struct_objet *s_objet_tampon;
1547:
1548: unsigned long i;
1549: unsigned long j;
1550:
1551: if (pthread_mutex_lock(&((*s_objet).mutex)) != 0)
1552: {
1553: (*s_etat_processus).erreur_systeme = d_es_processus;
1554: return(NULL);
1555: }
1556:
1557: if (type == 'Q')
1558: {
1559: if ((*s_objet).nombre_occurrences == 1)
1560: {
1561: type = 'P';
1562: }
1563: else
1564: {
1565: type = 'O';
1566: }
1567: }
1568: else if (type == 'R')
1569: {
1570: if ((*s_objet).nombre_occurrences == 1)
1571: {
1572: type = 'P';
1573: }
1574: else
1575: {
1576: type = 'N';
1577: }
1578: }
1579:
1580: #define return(pointeur) \
1581: if (pthread_mutex_unlock(&((*s_objet).mutex))) \
1582: { (*s_etat_processus).erreur_systeme = d_es_processus; return(NULL); } \
1583: return(pointeur)
1584:
1585: switch((*s_objet).type)
1586: {
1587: case ADR :
1588: {
1589: if (type != 'O')
1590: {
1591: incrementation_atomique(s_objet);
1592: return(s_objet);
1593: }
1594:
1595: if ((s_nouvel_objet = allocation(s_etat_processus, ADR)) == NULL)
1596: {
1597: return(NULL);
1598: }
1599:
1600: (*((unsigned long *) ((*s_nouvel_objet).objet))) =
1601: (*((unsigned long *) ((*s_objet).objet)));
1602: break;
1603: }
1604:
1605: case ALG :
1606: {
1607: if (type != 'P')
1608: {
1609: if ((s_nouvel_objet = allocation(s_etat_processus, ALG))
1610: == NULL)
1611: {
1612: return(NULL);
1613: }
1614:
1615: l_element_courant_lecture = (struct_liste_chainee *)
1616: ((*s_objet).objet);
1617:
1618: l_element_base = NULL;
1619: l_element_courant_ecriture = l_element_base;
1620:
1621: while(l_element_courant_lecture != NULL)
1622: {
1623: s_objet_tampon = copie_objet(s_etat_processus,
1624: (*l_element_courant_lecture).donnee, type);
1625: l_element_suivant_ecriture = (struct_liste_chainee *)
1626: malloc(sizeof(struct_liste_chainee));
1627:
1628: if ((s_objet_tampon == NULL) ||
1629: (l_element_suivant_ecriture == NULL))
1630: {
1631: l_element_courant_lecture = (struct_liste_chainee *)
1632: ((*s_nouvel_objet).objet);
1633:
1634: while(l_element_courant_lecture != NULL)
1635: {
1636: l_element_suivant_lecture =
1637: (*l_element_courant_lecture).suivant;
1638: liberation(s_etat_processus,
1639: (*l_element_courant_lecture).donnee);
1640: free(l_element_courant_lecture);
1641: l_element_courant_lecture =
1642: l_element_suivant_lecture;
1643: }
1644:
1645: return(NULL);
1646: }
1647:
1648: if (l_element_courant_ecriture == NULL)
1649: {
1650: l_element_base = l_element_suivant_ecriture;
1651: }
1652: else
1653: {
1654: (*l_element_courant_ecriture).suivant =
1655: l_element_suivant_ecriture;
1656: }
1657:
1658: l_element_courant_ecriture = l_element_suivant_ecriture;
1659:
1660: (*l_element_courant_ecriture).donnee = s_objet_tampon;
1661: (*l_element_courant_ecriture).suivant = NULL;
1662: l_element_courant_lecture =
1663: (*l_element_courant_lecture).suivant;
1664: }
1665:
1666: (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)
1667: l_element_base);
1668: }
1669: else // type == 'P'
1670: {
1671: incrementation_atomique(s_objet);
1672: l_element_courant = (*s_objet).objet;
1673:
1674: while(l_element_courant != NULL)
1675: {
1676: (*l_element_courant).donnee = copie_objet(s_etat_processus,
1677: (*l_element_courant).donnee, 'P');
1678: l_element_courant = (*l_element_courant).suivant;
1679: }
1680:
1681: return(s_objet);
1682: }
1683:
1684: break;
1685: }
1686:
1687: case BIN :
1688: {
1689: if (type != 'O')
1690: {
1691: incrementation_atomique(s_objet);
1692: return(s_objet);
1693: }
1694:
1695: if ((s_nouvel_objet = allocation(s_etat_processus, BIN)) == NULL)
1696: {
1697: return(NULL);
1698: }
1699:
1700: (*((logical8 *) ((*s_nouvel_objet).objet))) =
1701: (*((logical8 *) ((*s_objet).objet)));
1702: break;
1703: }
1704:
1705: case CHN :
1706: {
1707: if (type != 'O')
1708: {
1709: incrementation_atomique(s_objet);
1710: return(s_objet);
1711: }
1712:
1713: if ((s_nouvel_objet = allocation(s_etat_processus, CHN)) == NULL)
1714: {
1715: return(NULL);
1716: }
1717:
1718: (*s_nouvel_objet).objet = (void *) ((unsigned char *)
1719: malloc((strlen((unsigned char *) ((*s_objet).objet)) + 1)
1720: * sizeof(unsigned char)));
1721:
1722: if ((*s_nouvel_objet).objet == NULL)
1723: {
1724: free(s_nouvel_objet);
1725: return(NULL);
1726: }
1727:
1728: strcpy((unsigned char *) ((*s_nouvel_objet).objet),
1729: (unsigned char *) ((*s_objet).objet));
1730: break;
1731: }
1732:
1733: case CPL :
1734: {
1735: if (type != 'O')
1736: {
1737: incrementation_atomique(s_objet);
1738: return(s_objet);
1739: }
1740:
1741: if ((s_nouvel_objet = allocation(s_etat_processus, CPL)) == NULL)
1742: {
1743: return(NULL);
1744: }
1745:
1746: (*((struct_complexe16 *) ((*s_nouvel_objet).objet))) =
1747: (*((struct_complexe16 *) ((*s_objet).objet)));
1748: break;
1749: }
1750:
1751: case RPN :
1752: {
1753: if (type != 'P')
1754: {
1755: if ((s_nouvel_objet = allocation(s_etat_processus, RPN))
1756: == NULL)
1757: {
1758: return(NULL);
1759: }
1760:
1761: l_element_courant_lecture = (struct_liste_chainee *)
1762: ((*s_objet).objet);
1763:
1764: l_element_base = NULL;
1765: l_element_courant_ecriture = l_element_base;
1766:
1767: while(l_element_courant_lecture != NULL)
1768: {
1769: s_objet_tampon = copie_objet(s_etat_processus,
1770: (*l_element_courant_lecture).donnee, type);
1771: l_element_suivant_ecriture = (struct_liste_chainee *)
1772: malloc(sizeof(struct_liste_chainee));
1773:
1774: if ((s_objet_tampon == NULL) ||
1775: (l_element_suivant_ecriture == NULL))
1776: {
1777: l_element_courant_lecture = (struct_liste_chainee *)
1778: ((*s_nouvel_objet).objet);
1779:
1780: while(l_element_courant_lecture != NULL)
1781: {
1782: l_element_suivant_lecture =
1783: (*l_element_courant_lecture).suivant;
1784: liberation(s_etat_processus,
1785: (*l_element_courant_lecture).donnee);
1786: free(l_element_courant_lecture);
1787: l_element_courant_lecture =
1788: l_element_suivant_lecture;
1789: }
1790:
1791: return(NULL);
1792: }
1793:
1794: if (l_element_courant_ecriture == NULL)
1795: {
1796: l_element_base = l_element_suivant_ecriture;
1797: }
1798: else
1799: {
1800: (*l_element_courant_ecriture).suivant =
1801: l_element_suivant_ecriture;
1802: }
1803:
1804: l_element_courant_ecriture = l_element_suivant_ecriture;
1805:
1806: (*l_element_courant_ecriture).donnee = s_objet_tampon;
1807: (*l_element_courant_ecriture).suivant = NULL;
1808: l_element_courant_lecture =
1809: (*l_element_courant_lecture).suivant;
1810: }
1811:
1812: (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)
1813: l_element_base);
1814: }
1815: else // type == 'P'
1816: {
1817: incrementation_atomique(s_objet);
1818: l_element_courant = (*s_objet).objet;
1819:
1820: while(l_element_courant != NULL)
1821: {
1822: (*l_element_courant).donnee = copie_objet(s_etat_processus,
1823: (*l_element_courant).donnee, 'P');
1824: l_element_courant = (*l_element_courant).suivant;
1825: }
1826:
1827: return(s_objet);
1828: }
1829:
1830: break;
1831: }
1832:
1833: case FCH :
1834: {
1835: if (type == 'P')
1836: {
1837: incrementation_atomique(s_objet);
1.17 bertrand 1838:
1839: if (((*((struct_fichier *) ((*s_objet).objet))).format =
1840: copie_objet(s_etat_processus, (*((struct_fichier *)
1841: ((*s_objet).objet))).format, 'P')) == NULL)
1842: {
1843: return(NULL);
1844: }
1845:
1.1 bertrand 1846: return(s_objet);
1847: }
1848:
1849: if ((s_nouvel_objet = allocation(s_etat_processus, FCH)) == NULL)
1850: {
1851: return(NULL);
1852: }
1853:
1854: (*((struct_fichier *) ((*s_nouvel_objet).objet))).descripteur =
1855: (*((struct_fichier *) ((*s_objet).objet))).descripteur;
1856: (*((struct_fichier *) ((*s_nouvel_objet).objet))).acces =
1857: (*((struct_fichier *) ((*s_objet).objet))).acces;
1858: (*((struct_fichier *) ((*s_nouvel_objet).objet))).binaire =
1859: (*((struct_fichier *) ((*s_objet).objet))).binaire;
1860: (*((struct_fichier *) ((*s_nouvel_objet).objet))).ouverture =
1861: (*((struct_fichier *) ((*s_objet).objet))).ouverture;
1862: (*((struct_fichier *) ((*s_nouvel_objet).objet))).protection =
1863: (*((struct_fichier *) ((*s_objet).objet))).protection;
1864: (*((struct_fichier *) ((*s_nouvel_objet).objet)))
1865: .position_clef = (*((struct_fichier *)
1866: ((*s_objet).objet))).position_clef;
1867: (*((struct_fichier *) ((*s_nouvel_objet).objet))).pid =
1868: (*((struct_fichier *) ((*s_objet).objet))).pid;
1869: (*((struct_fichier *) ((*s_nouvel_objet).objet))).tid =
1870: (*((struct_fichier *) ((*s_objet).objet))).tid;
1871:
1872: if (((*((struct_fichier *) ((*s_nouvel_objet).objet))).format =
1873: copie_objet(s_etat_processus, (*((struct_fichier *)
1874: ((*s_objet).objet))).format, type)) == NULL)
1875: {
1876: free((*s_nouvel_objet).objet);
1877: free(s_nouvel_objet);
1878: return(NULL);
1879: }
1880:
1881: if (((*((struct_fichier *) ((*s_nouvel_objet).objet))).nom =
1882: (unsigned char *) malloc((strlen((*((struct_fichier *)
1883: ((*s_objet).objet))).nom) + 1) * sizeof(unsigned char)))
1884: == NULL)
1885: {
1886: liberation(s_etat_processus, (*((struct_fichier *)
1887: (*s_nouvel_objet).objet)).format);
1888: free((*s_nouvel_objet).objet);
1889: free(s_nouvel_objet);
1890: return(NULL);
1891: }
1892:
1893: strcpy((*((struct_fichier *) ((*s_nouvel_objet).objet))).nom,
1894: (*((struct_fichier *) ((*s_objet).objet))).nom);
1895: break;
1896: }
1897:
1898: case FCT :
1899: {
1900: if (type != 'O')
1901: {
1902: /*
1903: * Remise à zéro de la prédiction pour respecter la cohérence
1904: * du saut dans les cas EXSUB et OBSUB.
1905: */
1906:
1907: (*((struct_fonction *) ((*s_objet).objet)))
1908: .prediction_saut = NULL;
1909: incrementation_atomique(s_objet);
1910: return(s_objet);
1911: }
1912:
1913: if ((s_nouvel_objet = allocation(s_etat_processus, FCT)) == NULL)
1914: {
1915: return(NULL);
1916: }
1917:
1918: if (((*((struct_fonction *) ((*s_nouvel_objet).objet)))
1919: .nom_fonction = (unsigned char *)
1920: malloc((strlen((*((struct_fonction *)
1921: ((*s_objet).objet))).nom_fonction) + 1) *
1922: sizeof(unsigned char))) == NULL)
1923: {
1924: free(s_nouvel_objet);
1925: return(NULL);
1926: }
1927:
1928: strcpy((unsigned char *) (*((struct_fonction *)
1929: ((*s_nouvel_objet).objet))).nom_fonction,
1930: (unsigned char *) (*((struct_fonction *)
1931: ((*s_objet).objet))).nom_fonction);
1932: (*((struct_fonction *) ((*s_nouvel_objet).objet)))
1933: .nombre_arguments = (*((struct_fonction *)
1934: ((*s_objet).objet))).nombre_arguments;
1935: (*((struct_fonction *) ((*s_nouvel_objet).objet))).fonction =
1936: (*((struct_fonction *) ((*s_objet).objet))).fonction;
1937: break;
1938: }
1939:
1940: case INT :
1941: {
1942: if (type != 'O')
1943: {
1944: incrementation_atomique(s_objet);
1945: return(s_objet);
1946: }
1947:
1948: if ((s_nouvel_objet = allocation(s_etat_processus, INT)) == NULL)
1949: {
1950: return(NULL);
1951: }
1952:
1953: (*((integer8 *) ((*s_nouvel_objet).objet))) =
1954: (*((integer8 *) ((*s_objet).objet)));
1955: break;
1956: }
1957:
1958: case LST :
1959: {
1960: if (type != 'P')
1961: {
1962: if ((s_nouvel_objet = allocation(s_etat_processus, LST))
1963: == NULL)
1964: {
1965: return(NULL);
1966: }
1967:
1968: l_element_courant_lecture = (struct_liste_chainee *)
1969: ((*s_objet).objet);
1970:
1971: l_element_base = NULL;
1972: l_element_courant_ecriture = l_element_base;
1973:
1974: while(l_element_courant_lecture != NULL)
1975: {
1976: s_objet_tampon = copie_objet(s_etat_processus,
1977: (*l_element_courant_lecture).donnee, type);
1978: l_element_suivant_ecriture = (struct_liste_chainee *)
1979: malloc(sizeof(struct_liste_chainee));
1980:
1981: if ((s_objet_tampon == NULL) ||
1982: (l_element_suivant_ecriture == NULL))
1983: {
1984: l_element_courant_lecture = (struct_liste_chainee *)
1985: ((*s_nouvel_objet).objet);
1986:
1987: while(l_element_courant_lecture != NULL)
1988: {
1989: l_element_suivant_lecture =
1990: (*l_element_courant_lecture).suivant;
1991: liberation(s_etat_processus,
1992: (*l_element_courant_lecture).donnee);
1993: free(l_element_courant_lecture);
1994: l_element_courant_lecture =
1995: l_element_suivant_lecture;
1996: }
1997:
1998: return(NULL);
1999: }
2000:
2001: if (l_element_courant_ecriture == NULL)
2002: {
2003: l_element_base = l_element_suivant_ecriture;
2004: }
2005: else
2006: {
2007: (*l_element_courant_ecriture).suivant =
2008: l_element_suivant_ecriture;
2009: }
2010:
2011: l_element_courant_ecriture = l_element_suivant_ecriture;
2012:
2013: (*l_element_courant_ecriture).donnee = s_objet_tampon;
2014: (*l_element_courant_ecriture).suivant = NULL;
2015: l_element_courant_lecture =
2016: (*l_element_courant_lecture).suivant;
2017: }
2018:
2019: (*s_nouvel_objet).objet = (void *) ((struct_liste_chainee *)
2020: l_element_base);
2021: }
2022: else
2023: {
2024: incrementation_atomique(s_objet);
2025: l_element_courant = (*s_objet).objet;
2026:
2027: while(l_element_courant != NULL)
2028: {
2029: (*l_element_courant).donnee = copie_objet(s_etat_processus,
2030: (*l_element_courant).donnee, 'P');
2031: l_element_courant = (*l_element_courant).suivant;
2032: }
2033:
2034: return(s_objet);
2035: }
2036:
2037: break;
2038: }
2039:
2040: case MIN :
2041: {
2042: if (type != 'O')
2043: {
2044: incrementation_atomique(s_objet);
2045: return(s_objet);
2046: }
2047:
2048: if ((s_nouvel_objet = allocation(s_etat_processus, MIN)) == NULL)
2049: {
2050: return(NULL);
2051: }
2052:
2053: (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =
2054: (void **) ((integer8 **) malloc(
2055: ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)
2056: * sizeof(integer8 *)));
2057:
2058: if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
2059: == NULL)
2060: {
2061: free((*s_nouvel_objet).objet);
2062: free(s_nouvel_objet);
2063: return(NULL);
2064: }
2065:
2066: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_colonnes =
2067: (*((struct_matrice *) ((*s_objet).objet))).nombre_colonnes;
2068: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_lignes =
2069: (*((struct_matrice *) ((*s_objet).objet))).nombre_lignes;
2070: (*((struct_matrice *) ((*s_nouvel_objet).objet))).type =
2071: (*((struct_matrice *) ((*s_objet).objet))).type;
2072:
2073: for(i = 0; i < (*((struct_matrice *)
2074: ((*s_objet).objet))).nombre_lignes; i++)
2075: {
2076: if ((((integer8 **) ((*((struct_matrice *)
2077: ((*s_nouvel_objet).objet))).tableau))[i] =
2078: (void *) ((integer8 *) malloc(
2079: ((*((struct_matrice *) ((*s_objet).objet)))
2080: .nombre_colonnes) * sizeof(integer8)))) == NULL)
2081: {
2082: for(j = 0; j < i; j++)
2083: {
2084: free(((integer8 **) ((*((struct_matrice *)
2085: ((*s_nouvel_objet).objet))).tableau))[j]);
2086: }
2087:
2088: free((*s_nouvel_objet).objet);
2089: free(s_nouvel_objet);
2090: return(NULL);
2091: }
2092:
2093: for(j = 0; j < (*((struct_matrice *)
2094: ((*s_objet).objet))).nombre_colonnes; j++)
2095: {
2096: ((integer8 **) ((*((struct_matrice *)
2097: ((*s_nouvel_objet).objet))).tableau))[i][j] =
2098: ((integer8 **) ((*((struct_matrice *)
2099: ((*s_objet).objet))).tableau))[i][j];
2100: }
2101: }
2102:
2103: break;
2104: }
2105:
2106: case MCX :
2107: {
2108: if (type != 'O')
2109: {
2110: incrementation_atomique(s_objet);
2111: return(s_objet);
2112: }
2113:
2114: if ((s_nouvel_objet = allocation(s_etat_processus, MCX))
2115: == NULL)
2116: {
2117: return(NULL);
2118: }
2119:
2120: (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =
2121: (void **) ((struct_complexe16 **) malloc(
2122: ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)
2123: * sizeof(struct_complexe16 *)));
2124:
2125: if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
2126: == NULL)
2127: {
2128: free((*s_nouvel_objet).objet);
2129: free(s_nouvel_objet);
2130: return(NULL);
2131: }
2132:
2133: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_colonnes =
2134: (*((struct_matrice *) ((*s_objet).objet))).nombre_colonnes;
2135: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_lignes =
2136: (*((struct_matrice *) ((*s_objet).objet))).nombre_lignes;
2137: (*((struct_matrice *) ((*s_nouvel_objet).objet))).type =
2138: (*((struct_matrice *) ((*s_objet).objet))).type;
2139:
2140: for(i = 0; i < (*((struct_matrice *)
2141: ((*s_objet).objet))).nombre_lignes; i++)
2142: {
2143: if ((((struct_complexe16 **) ((*((struct_matrice *)
2144: ((*s_nouvel_objet).objet))).tableau))[i] =
2145: (void *) ((struct_complexe16 *) malloc(
2146: ((*((struct_matrice *) ((*s_objet).objet)))
2147: .nombre_colonnes) * sizeof(struct_complexe16))))
2148: == NULL)
2149: {
2150: for(j = 0; j < i; j++)
2151: {
2152: free(((struct_complexe16 **) ((*((struct_matrice *)
2153: ((*s_nouvel_objet).objet))).tableau))[j]);
2154: }
2155:
2156: free((*s_nouvel_objet).objet);
2157: free(s_nouvel_objet);
2158: return(NULL);
2159: }
2160:
2161: for(j = 0; j < (*((struct_matrice *)
2162: ((*s_objet).objet))).nombre_colonnes; j++)
2163: {
2164: ((struct_complexe16 **) ((*((struct_matrice *)
2165: ((*s_nouvel_objet).objet))).tableau))[i][j] =
2166: ((struct_complexe16 **) ((*((struct_matrice *)
2167: ((*s_objet).objet))).tableau))[i][j];
2168: }
2169: }
2170:
2171: break;
2172: }
2173:
2174: case MRL :
2175: {
2176: if (type != 'O')
2177: {
2178: incrementation_atomique(s_objet);
2179: return(s_objet);
2180: }
2181:
2182: if ((s_nouvel_objet = allocation(s_etat_processus, MRL)) == NULL)
2183: {
2184: return(NULL);
2185: }
2186:
2187: (*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau =
2188: (void **) ((real8 **) malloc(
2189: ((*((struct_matrice *) ((*s_objet).objet))).nombre_lignes)
2190: * sizeof(real8 *)));
2191:
2192: if ((*((struct_matrice *) ((*s_nouvel_objet).objet))).tableau
2193: == NULL)
2194: {
2195: free((*s_nouvel_objet).objet);
2196: free(s_nouvel_objet);
2197: return(NULL);
2198: }
2199:
2200: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_colonnes =
2201: (*((struct_matrice *) ((*s_objet).objet))).nombre_colonnes;
2202: (*((struct_matrice *) ((*s_nouvel_objet).objet))).nombre_lignes =
2203: (*((struct_matrice *) ((*s_objet).objet))).nombre_lignes;
2204: (*((struct_matrice *) ((*s_nouvel_objet).objet))).type =
2205: (*((struct_matrice *) ((*s_objet).objet))).type;
2206:
2207: for(i = 0; i < (*((struct_matrice *)
2208: ((*s_objet).objet))).nombre_lignes; i++)
2209: {
2210: if ((((real8 **) ((*((struct_matrice *)
2211: ((*s_nouvel_objet).objet))).tableau))[i] =
2212: (void *) ((real8 *) malloc(
2213: ((*((struct_matrice *) ((*s_objet).objet)))
2214: .nombre_colonnes) * sizeof(real8)))) == NULL)
2215: {
2216: for(j = 0; j < i; j++)
2217: {
2218: free(((real8 **) ((*((struct_matrice *)
2219: ((*s_nouvel_objet).objet))).tableau))[j]);
2220: }
2221:
2222: free((*s_nouvel_objet).objet);
2223: free(s_nouvel_objet);
2224: return(NULL);
2225: }
2226:
2227: for(j = 0; j < (*((struct_matrice *)
2228: ((*s_objet).objet))).nombre_colonnes; j++)
2229: {
2230: ((real8 **) ((*((struct_matrice *)
2231: ((*s_nouvel_objet).objet))).tableau))[i][j] =
2232: ((real8 **) ((*((struct_matrice *)
2233: ((*s_objet).objet))).tableau))[i][j];
2234: }
2235: }
2236:
2237: break;
2238: }
2239:
2240: case MTX :
2241: {
1.75 bertrand 2242: // La duplication d'un mutex renvoie le même objet.
2243: incrementation_atomique(s_objet);
1.76 bertrand 2244: return(s_objet);
1.1 bertrand 2245: }
2246:
2247: case NOM :
2248: {
2249: if (type != 'O')
2250: {
2251: incrementation_atomique(s_objet);
2252: return(s_objet);
2253: }
2254:
2255: if ((s_nouvel_objet = allocation(s_etat_processus, NOM)) == NULL)
2256: {
2257: return(NULL);
2258: }
2259:
2260: (*((struct_nom *) (*s_nouvel_objet).objet)).nom = malloc((
2261: strlen((*((struct_nom *) (*s_objet).objet)).nom) + 1) *
2262: sizeof(unsigned char));
2263:
2264: if ((*((struct_nom *) (*s_nouvel_objet).objet)).nom == NULL)
2265: {
2266: free((*s_nouvel_objet).objet);
2267: free(s_nouvel_objet);
2268: return(NULL);
2269: }
2270:
2271: strcpy((*((struct_nom *) (*s_nouvel_objet).objet)).nom,
2272: (*((struct_nom *) (*s_objet).objet)).nom);
2273: (*((struct_nom *) (*s_nouvel_objet).objet)).symbole =
2274: (*((struct_nom *) (*s_objet).objet)).symbole;
2275: break;
2276: }
2277:
2278: case NON :
2279: {
2280: if (type != 'O')
2281: {
2282: incrementation_atomique(s_objet);
2283: return(s_objet);
2284: }
2285:
2286: if ((s_nouvel_objet = allocation(s_etat_processus, NON)) == NULL)
2287: {
2288: return(NULL);
2289: }
2290:
2291: (*s_nouvel_objet).objet = NULL;
2292: break;
2293: }
2294:
2295: case PRC :
2296: {
2297: if (pthread_mutex_lock(&((*(*((struct_processus_fils *)
1.40 bertrand 2298: (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
1.1 bertrand 2299: {
2300: return(NULL);
2301: }
2302:
2303: (*(*((struct_processus_fils *) (*s_objet).objet)).thread)
2304: .nombre_references++;
2305:
2306: if (pthread_mutex_unlock(&((*(*((struct_processus_fils *)
1.40 bertrand 2307: (*s_objet).objet)).thread).mutex_nombre_references)) != 0)
1.1 bertrand 2308: {
2309: return(NULL);
2310: }
2311:
2312: if (type != 'O')
2313: {
2314: incrementation_atomique(s_objet);
2315: return(s_objet);
2316: }
2317:
2318: if ((s_nouvel_objet = allocation(s_etat_processus, PRC)) == NULL)
2319: {
2320: return(NULL);
2321: }
2322:
2323: (*((struct_processus_fils *) (*s_nouvel_objet).objet)) =
2324: (*((struct_processus_fils *) (*s_objet).objet));
2325: break;
2326: }
2327:
2328: case REL :
2329: {
2330: if (type != 'O')
2331: {
2332: incrementation_atomique(s_objet);
2333: return(s_objet);
2334: }
2335:
2336: if ((s_nouvel_objet = allocation(s_etat_processus, REL)) == NULL)
2337: {
2338: return(NULL);
2339: }
2340:
2341: (*((real8 *) ((*s_nouvel_objet).objet))) =
2342: (*((real8 *) ((*s_objet).objet)));
2343: break;
2344: }
2345:
2346: case SCK :
2347: {
2348: if (type == 'P')
2349: {
2350: incrementation_atomique(s_objet);
1.17 bertrand 2351:
1.18 bertrand 2352: if (((*((struct_socket *) ((*s_objet).objet)))
2353: .format = copie_objet(s_etat_processus,
2354: (*((struct_socket *) ((*s_objet).objet))).format, 'P'))
2355: == NULL)
1.17 bertrand 2356: {
2357: return(NULL);
2358: }
2359:
1.1 bertrand 2360: return(s_objet);
2361: }
2362:
2363: if ((s_nouvel_objet = allocation(s_etat_processus, SCK)) == NULL)
2364: {
2365: return(NULL);
2366: }
2367:
2368: (*((struct_socket *) ((*s_nouvel_objet).objet))).socket =
2369: (*((struct_socket *) ((*s_objet).objet))).socket;
2370: (*((struct_socket *) ((*s_nouvel_objet).objet))).domaine =
2371: (*((struct_socket *) ((*s_objet).objet))).domaine;
2372: (*((struct_socket *) ((*s_nouvel_objet).objet))).socket_en_ecoute =
2373: (*((struct_socket *) ((*s_objet).objet))).socket_en_ecoute;
2374: (*((struct_socket *) ((*s_nouvel_objet).objet))).socket_connectee =
2375: (*((struct_socket *) ((*s_objet).objet))).socket_connectee;
2376: (*((struct_socket *) ((*s_nouvel_objet).objet))).pid =
2377: (*((struct_socket *) ((*s_objet).objet))).pid;
2378: (*((struct_socket *) ((*s_nouvel_objet).objet))).binaire =
2379: (*((struct_socket *) ((*s_objet).objet))).binaire;
2380: (*((struct_socket *) ((*s_nouvel_objet).objet))).effacement =
2381: (*((struct_socket *) ((*s_objet).objet))).effacement;
2382: (*((struct_socket *) ((*s_nouvel_objet).objet))).protection =
2383: (*((struct_socket *) ((*s_objet).objet))).protection;
2384: (*((struct_socket *) ((*s_nouvel_objet).objet))).localisation =
2385: (*((struct_socket *) ((*s_objet).objet))).localisation;
2386: (*((struct_socket *) ((*s_nouvel_objet).objet))).pid =
2387: (*((struct_socket *) ((*s_objet).objet))).pid;
2388: (*((struct_socket *) ((*s_nouvel_objet).objet))).tid =
2389: (*((struct_socket *) ((*s_objet).objet))).tid;
2390:
2391: if (((*((struct_socket *) ((*s_nouvel_objet).objet))).format =
2392: copie_objet(s_etat_processus, (*((struct_socket *)
2393: ((*s_objet).objet))).format, type)) == NULL)
2394: {
2395: free((*s_nouvel_objet).objet);
2396: free(s_nouvel_objet);
2397: return(NULL);
2398: }
2399:
2400: if (((*((struct_socket *) ((*s_nouvel_objet).objet))).adresse =
2401: (unsigned char *) malloc((strlen((*((struct_socket *)
2402: ((*s_objet).objet))).adresse) + 1) * sizeof(unsigned char)))
2403: == NULL)
2404: {
2405: liberation(s_etat_processus, (*((struct_fichier *)
2406: (*s_nouvel_objet).objet)).format);
2407: free((*s_nouvel_objet).objet);
2408: free(s_nouvel_objet);
2409: return(NULL);
2410: }
2411:
2412: strcpy((*((struct_socket *) ((*s_nouvel_objet).objet)))
2413: .adresse, (*((struct_socket *) ((*s_objet).objet)))
2414: .adresse);
2415:
2416: if (((*((struct_socket *) ((*s_nouvel_objet).objet)))
2417: .adresse_distante = malloc((strlen((*((struct_socket *)
2418: ((*s_objet).objet))).adresse_distante) + 1) *
2419: sizeof(unsigned char))) == NULL)
2420: {
2421: liberation(s_etat_processus, (*((struct_fichier *)
2422: (*s_nouvel_objet).objet)).format);
2423: free((*s_nouvel_objet).objet);
2424: free(s_nouvel_objet);
2425: return(NULL);
2426: }
2427:
2428: strcpy((*((struct_socket *) ((*s_nouvel_objet).objet)))
2429: .adresse_distante, (*((struct_socket *) ((*s_objet).objet)))
2430: .adresse_distante);
2431:
2432: strcpy((*((struct_socket *) ((*s_nouvel_objet).objet))).type,
2433: (*((struct_socket *) ((*s_objet).objet))).type);
2434: break;
2435: }
2436:
2437: case SLB :
2438: {
2439: if (type != 'O')
2440: {
2441: incrementation_atomique(s_objet);
2442: return(s_objet);
2443: }
2444:
2445: if ((s_nouvel_objet = allocation(s_etat_processus, SLB)) == NULL)
2446: {
2447: return(NULL);
2448: }
2449:
2450: if (((*((struct_bibliotheque *) ((*s_nouvel_objet).objet))).nom =
2451: (unsigned char *) malloc((strlen((*((struct_bibliotheque *)
2452: ((*s_objet).objet))).nom) + 1) * sizeof(unsigned char)))
2453: == NULL)
2454: {
2455: free((*s_nouvel_objet).objet);
2456: free(s_nouvel_objet);
2457: return(NULL);
2458: }
2459:
2460: strcpy((*((struct_bibliotheque *) ((*s_nouvel_objet).objet))).nom,
2461: (*((struct_bibliotheque *) ((*s_objet).objet))).nom);
2462:
2463: /*
2464: * C'est objet est non modifiable et est un pointeur
2465: * sur un objet système. Seul la référence est copiée.
2466: */
2467:
2468: (*((struct_bibliotheque *) (*s_nouvel_objet).objet)).descripteur =
2469: (*((struct_bibliotheque *) (*s_objet).objet)).descripteur;
2470: (*((struct_bibliotheque *) (*s_nouvel_objet).objet)).pid =
2471: (*((struct_bibliotheque *) (*s_objet).objet)).pid;
2472: (*((struct_bibliotheque *) (*s_nouvel_objet).objet)).tid =
2473: (*((struct_bibliotheque *) (*s_objet).objet)).tid;
2474: break;
2475: }
2476:
2477: case SPH :
2478: {
2479: if (type != 'O')
2480: {
2481: incrementation_atomique(s_objet);
2482: return(s_objet);
2483: }
2484:
2485: if ((s_nouvel_objet = allocation(s_etat_processus, SPH)) == NULL)
2486: {
2487: return(NULL);
2488: }
2489:
2490: if (((*((struct_semaphore *) (*s_nouvel_objet).objet)).nom =
2491: malloc((strlen((*((struct_semaphore *) (*s_objet).objet))
2492: .nom) + 1) * sizeof(unsigned char))) == NULL)
2493: {
2494: free((*s_nouvel_objet).objet);
2495: free(s_nouvel_objet);
2496: return(NULL);
2497: }
2498:
1.75 bertrand 2499: (*((struct_semaphore *) (*s_nouvel_objet).objet)).semaphore =
2500: (*((struct_semaphore *) (*s_objet).objet)).semaphore;
1.1 bertrand 2501: strcpy((*((struct_semaphore *) (*s_nouvel_objet).objet)).nom,
2502: (*((struct_semaphore *) (*s_objet).objet)).nom);
2503: break;
2504: }
2505:
2506: case SQL :
2507: {
2508: if (type != 'O')
2509: {
2510: incrementation_atomique(s_objet);
2511: return(s_objet);
2512: }
2513:
2514: if ((s_nouvel_objet = allocation(s_etat_processus, SQL)) == NULL)
2515: {
2516: return(NULL);
2517: }
2518:
2519: (*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).pid =
2520: (*((struct_connecteur_sql *) (*s_objet).objet)).pid;
2521: (*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).tid =
2522: (*((struct_connecteur_sql *) (*s_objet).objet)).tid;
2523: (*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).descripteur =
2524: (*((struct_connecteur_sql *) (*s_objet).objet)).descripteur;
2525:
2526: if (((*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).type =
2527: malloc((strlen((*((struct_connecteur_sql *)
2528: (*s_objet).objet)).type) + 1) * sizeof(unsigned char)))
2529: == NULL)
2530: {
2531: free(s_nouvel_objet);
2532: return(NULL);
2533: }
2534:
2535: strcpy((*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).type,
2536: (*((struct_connecteur_sql *) (*s_objet).objet)).type);
2537:
2538: if ((*((struct_connecteur_sql *) (*s_objet).objet)).locale != NULL)
2539: {
2540: if (((*((struct_connecteur_sql *) (*s_nouvel_objet).objet))
2541: .locale = malloc((strlen((*((struct_connecteur_sql *)
2542: (*s_objet).objet)).locale) + 1) *
2543: sizeof(unsigned char))) == NULL)
2544: {
2545: free((*((struct_connecteur_sql *) (*s_nouvel_objet).objet))
2546: .locale);
2547: free(s_nouvel_objet);
2548: return(NULL);
2549: }
2550:
2551: strcpy((*((struct_connecteur_sql *) (*s_nouvel_objet).objet))
2552: .locale, (*((struct_connecteur_sql *)
2553: (*s_objet).objet)).locale);
2554: }
2555: else
2556: {
2557: (*((struct_connecteur_sql *) (*s_nouvel_objet).objet)).locale
2558: = NULL;
2559: }
2560:
2561: break;
2562: }
2563:
2564: case TBL :
2565: {
2566: if (type != 'P')
2567: {
2568: if ((s_nouvel_objet = allocation(s_etat_processus, TBL))
2569: == NULL)
2570: {
2571: return(NULL);
2572: }
2573:
2574: (*((struct_tableau *) (*s_nouvel_objet).objet))
2575: .nombre_elements = (*((struct_tableau *)
2576: (*s_objet).objet)).nombre_elements;
2577:
2578: if (((*((struct_tableau *) (*s_nouvel_objet).objet)).elements =
2579: malloc((*((struct_tableau *) (*s_objet).objet))
2580: .nombre_elements * sizeof(struct_objet *))) == NULL)
2581: {
2582: return(NULL);
2583: }
2584:
2585: for(i = 0; i < (*((struct_tableau *) (*s_objet).objet))
2586: .nombre_elements; i++)
2587: {
2588: if (((*((struct_tableau *) (*s_nouvel_objet).objet))
2589: .elements[i] = copie_objet(s_etat_processus,
2590: (*((struct_tableau *) (*s_objet).objet))
2591: .elements[i], type)) == NULL)
2592: {
2593: for(j = 0; j < i; j++)
2594: {
2595: liberation(s_etat_processus, (*((struct_tableau *)
2596: (*s_nouvel_objet).objet)).elements[j]);
2597: }
2598:
2599: free((*((struct_tableau *) (*s_nouvel_objet).objet))
2600: .elements);
2601: free((*s_nouvel_objet).objet);
2602: free(s_nouvel_objet);
2603:
2604: return(NULL);
2605: }
2606: }
2607: }
2608: else
2609: {
2610: incrementation_atomique(s_objet);
2611:
2612: for(i = 0; i < (*((struct_tableau *) (*s_objet).objet))
2613: .nombre_elements; i++)
2614: {
2615: (*((struct_tableau *) (*s_objet).objet)).elements[i] =
2616: copie_objet(s_etat_processus, (*((struct_tableau *)
2617: (*s_objet).objet)).elements[i], 'P');
2618: }
2619:
2620: return(s_objet);
2621: }
2622:
2623: break;
2624: }
2625:
2626: case VIN :
2627: {
2628: if (type != 'O')
2629: {
2630: incrementation_atomique(s_objet);
2631: return(s_objet);
2632: }
2633:
2634: if ((s_nouvel_objet = allocation(s_etat_processus, VIN)) == NULL)
2635: {
2636: return(NULL);
2637: }
2638:
2639: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =
2640: (void *) ((integer8 *) malloc(
2641: ((*((struct_vecteur *) ((*s_objet).objet))).taille)
2642: * sizeof(integer8)));
2643:
2644: if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
2645: == NULL)
2646: {
2647: free((*s_nouvel_objet).objet);
2648: free(s_nouvel_objet);
2649: return(NULL);
2650: }
2651:
2652: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).taille =
2653: (*((struct_vecteur *) ((*s_objet).objet))).taille;
2654: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).type =
2655: (*((struct_vecteur *) ((*s_objet).objet))).type;
2656:
2657: for(i = 0; i < (*((struct_vecteur *) ((*s_objet).objet))).taille;
2658: i++)
2659: {
2660: ((integer8 *) ((*((struct_vecteur *)
2661: ((*s_nouvel_objet).objet))).tableau))[i] =
2662: ((integer8 *) ((*((struct_vecteur *)
2663: ((*s_objet).objet))).tableau))[i];
2664: }
2665:
2666: break;
2667: }
2668:
2669: case VCX :
2670: {
2671: if (type != 'O')
2672: {
2673: incrementation_atomique(s_objet);
2674: return(s_objet);
2675: }
2676:
2677: if ((s_nouvel_objet = allocation(s_etat_processus, VCX)) == NULL)
2678: {
2679: return(NULL);
2680: }
2681:
2682: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =
2683: (void *) ((struct_complexe16 *) malloc(
2684: ((*((struct_vecteur *) ((*s_objet).objet))).taille)
2685: * sizeof(struct_complexe16)));
2686:
2687: if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
2688: == NULL)
2689: {
2690: free((*s_nouvel_objet).objet);
2691: free(s_nouvel_objet);
2692: return(NULL);
2693: }
2694:
2695: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).taille =
2696: (*((struct_vecteur *) ((*s_objet).objet))).taille;
2697: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).type =
2698: (*((struct_vecteur *) ((*s_objet).objet))).type;
2699:
2700: for(i = 0; i < (*((struct_vecteur *) ((*s_objet).objet))).taille;
2701: i++)
2702: {
2703: ((struct_complexe16 *) ((*((struct_vecteur *)
2704: ((*s_nouvel_objet).objet))).tableau))[i] =
2705: ((struct_complexe16 *) ((*((struct_vecteur *)
2706: ((*s_objet).objet))).tableau))[i];
2707: }
2708:
2709: break;
2710: }
2711:
2712: case VRL :
2713: {
2714: if (type != 'O')
2715: {
2716: incrementation_atomique(s_objet);
2717: return(s_objet);
2718: }
2719:
2720: if ((s_nouvel_objet = allocation(s_etat_processus, VRL)) == NULL)
2721: {
2722: return(NULL);
2723: }
2724:
2725: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau =
2726: (void *) ((real8 *) malloc(
2727: ((*((struct_vecteur *) ((*s_objet).objet))).taille)
2728: * sizeof(real8)));
2729:
2730: if ((*((struct_vecteur *) ((*s_nouvel_objet).objet))).tableau
2731: == NULL)
2732: {
2733: free((*s_nouvel_objet).objet);
2734: free(s_nouvel_objet);
2735: return(NULL);
2736: }
2737:
2738: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).taille =
2739: (*((struct_vecteur *) ((*s_objet).objet))).taille;
2740: (*((struct_vecteur *) ((*s_nouvel_objet).objet))).type =
2741: (*((struct_vecteur *) ((*s_objet).objet))).type;
2742:
2743: for(i = 0; i < (*((struct_vecteur *) ((*s_objet).objet))).taille;
2744: i++)
2745: {
2746: ((real8 *) ((*((struct_vecteur *)
2747: ((*s_nouvel_objet).objet))).tableau))[i] =
2748: ((real8 *) ((*((struct_vecteur *)
2749: ((*s_objet).objet))).tableau))[i];
2750: }
2751:
2752: break;
2753: }
2754:
2755: default :
2756: {
2757: return(NULL);
2758: }
2759: }
2760:
2761: return(s_nouvel_objet);
2762:
2763: #undef return
2764: }
2765:
2766:
2767: /*
2768: ================================================================================
2769: Routine de copie d'une structure de description d'un processus
2770: ================================================================================
2771: Entrées : pointeur sur la structure de description d'un processus
2772: --------------------------------------------------------------------------------
2773: Sorties : structure identique (tous les objets sont copiés)
2774: --------------------------------------------------------------------------------
2775: Effets de bord : néant
2776: ================================================================================
2777: */
2778:
2779: struct_processus *
2780: copie_etat_processus(struct_processus *s_etat_processus)
2781: {
2782: pthread_mutexattr_t attributs_mutex;
2783:
2784: struct_liste_chainee *l_element_lecture;
2785: struct_liste_chainee *l_element_precedent;
2786: struct_liste_chainee *l_element_suivant;
2787:
2788: struct_processus *s_nouvel_etat_processus;
2789:
2790: unsigned long i;
2791:
2792: if (pthread_mutex_lock(&((*s_etat_processus).mutex)) != 0)
2793: {
2794: (*s_etat_processus).erreur_systeme = d_es_processus;
2795: return(NULL);
2796: }
2797:
2798: if ((s_nouvel_etat_processus = malloc(sizeof(struct_processus))) == NULL)
2799: {
2800: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2801: return(NULL);
2802: }
2803:
2804: (*s_nouvel_etat_processus) = (*s_etat_processus);
2805:
2806: // On réinitialise l'allocateur.
2807:
2808: initialisation_allocateur(s_nouvel_etat_processus);
2809:
2810: /*
2811: * (*s_etat_processus).definition_chainee,
2812: * (*s_etat_processus).nom_fichier_source,
2813: * (*s_etat_processus).nom_fichier_historique et
2814: * (*s_etat_processus).chemin_fichier_temporaires
2815: * n'ont aucune raison de changer.
2816: */
2817:
1.67 bertrand 2818: pthread_mutexattr_init(&attributs_mutex);
2819: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
1.69 bertrand 2820:
1.71 bertrand 2821: // Les sémaphores sont initialisés dans le nouveau thread. Il
2822: // s'agit d'une limitation de l'implantation de l'émulation
2823: // de sem_init().
1.1 bertrand 2824:
1.60 bertrand 2825: initialisation_contexte_cas(s_etat_processus);
2826:
1.1 bertrand 2827: (*s_nouvel_etat_processus).var_volatile_processus_pere = 0;
1.39 bertrand 2828: (*s_nouvel_etat_processus).var_volatile_processus_racine = 0;
1.1 bertrand 2829: (*s_nouvel_etat_processus).fichiers_graphiques = NULL;
2830: (*s_nouvel_etat_processus).entree_standard = NULL;
2831: (*s_nouvel_etat_processus).s_marques = NULL;
2832: (*s_nouvel_etat_processus).requete_nouveau_plan = d_vrai;
2833: (*s_nouvel_etat_processus).mise_a_jour_trace_requise = d_faux;
2834: (*s_nouvel_etat_processus).nom_fichier_impression = NULL;
2835: (*s_nouvel_etat_processus).expression_courante = NULL;
2836: (*s_nouvel_etat_processus).objet_courant = NULL;
2837: (*s_nouvel_etat_processus).processus_detache = d_faux;
1.3 bertrand 2838: (*s_nouvel_etat_processus).evaluation_forcee = 'N';
1.1 bertrand 2839:
2840: (*s_nouvel_etat_processus).nombre_objets_envoyes_non_lus = 0;
2841: (*s_nouvel_etat_processus).nombre_objets_injectes = 0;
2842: (*s_nouvel_etat_processus).presence_fusible = d_faux;
2843: (*s_nouvel_etat_processus).thread_fusible = 0;
2844: (*s_nouvel_etat_processus).niveau_initial =
2845: (*s_etat_processus).niveau_courant;
2846: (*s_nouvel_etat_processus).presence_pipes = d_faux;
2847: (*s_nouvel_etat_processus).debug_programme = d_faux;
2848: (*s_nouvel_etat_processus).s_fichiers = NULL;
2849: (*s_nouvel_etat_processus).s_connecteurs_sql = NULL;
2850:
2851: // On réinitialise toutes les interruptions.
2852:
2853: (*s_nouvel_etat_processus).traitement_interruption = 'N';
2854: (*s_nouvel_etat_processus).traitement_interruptible = 'Y';
2855: (*s_nouvel_etat_processus).nombre_interruptions_en_queue = 0;
2856: (*s_nouvel_etat_processus).nombre_interruptions_non_affectees = 0;
2857:
1.14 bertrand 2858: (*s_nouvel_etat_processus).at_exit = NULL;
1.32 bertrand 2859: (*s_nouvel_etat_processus).at_poke = NULL;
2860: (*s_nouvel_etat_processus).traitement_at_poke = 'N';
1.13 bertrand 2861:
1.1 bertrand 2862: for(i = 0; i < d_NOMBRE_INTERRUPTIONS; i++)
2863: {
2864: (*s_nouvel_etat_processus).corps_interruptions[i] = NULL;
2865: (*s_nouvel_etat_processus).masque_interruptions[i] = 'N';
2866: (*s_nouvel_etat_processus).queue_interruptions[i] = 0;
2867: (*s_nouvel_etat_processus).pile_origine_interruptions[i] = NULL;
2868: }
2869:
2870: if ((*s_nouvel_etat_processus).generateur_aleatoire != NULL)
2871: {
1.35 bertrand 2872: if (((*s_nouvel_etat_processus).generateur_aleatoire =
2873: gsl_rng_clone((*s_etat_processus).generateur_aleatoire))
2874: == NULL)
2875: {
2876: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2877: return(NULL);
2878: }
2879:
2880: gsl_rng_set((*s_nouvel_etat_processus).generateur_aleatoire,
2881: gsl_rng_get((*s_etat_processus).generateur_aleatoire));
1.1 bertrand 2882: }
2883:
2884: // Copie de la localisation
2885:
2886: if (((*s_nouvel_etat_processus).localisation = malloc((strlen(
2887: (*s_etat_processus).localisation) + 1) * sizeof(unsigned char)))
2888: == NULL)
2889: {
2890: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2891: return(NULL);
2892: }
2893:
2894: strcpy((*s_nouvel_etat_processus).localisation,
2895: (*s_etat_processus).localisation);
2896:
2897: if ((*s_etat_processus).indep != NULL)
2898: {
2899: if (((*s_nouvel_etat_processus).indep = copie_objet(s_etat_processus,
2900: (*s_etat_processus).indep, 'P')) == NULL)
2901: {
2902: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
2903: {
2904: (*s_etat_processus).erreur_systeme = d_es_processus;
2905: return(NULL);
2906: }
2907:
2908: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2909: return(NULL);
2910: }
2911: }
2912: else
2913: {
2914: (*s_nouvel_etat_processus).indep = NULL;
2915: }
2916:
2917: if ((*s_etat_processus).depend != NULL)
2918: {
2919: if (((*s_nouvel_etat_processus).depend = copie_objet(s_etat_processus,
2920: (*s_etat_processus).depend, 'P')) == NULL)
2921: {
2922: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
2923: {
2924: (*s_etat_processus).erreur_systeme = d_es_processus;
2925: return(NULL);
2926: }
2927:
2928: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2929: return(NULL);
2930: }
2931: }
2932: else
2933: {
2934: (*s_nouvel_etat_processus).depend = NULL;
2935: }
2936:
2937: if ((*s_etat_processus).parametres_courbes_de_niveau != NULL)
2938: {
2939: if (((*s_nouvel_etat_processus).parametres_courbes_de_niveau =
2940: copie_objet(s_etat_processus, (*s_etat_processus)
2941: .parametres_courbes_de_niveau, 'P')) == NULL)
2942: {
2943: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
2944: {
2945: (*s_etat_processus).erreur_systeme = d_es_processus;
2946: return(NULL);
2947: }
2948:
2949: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2950: return(NULL);
2951: }
2952: }
2953: else
2954: {
2955: (*s_nouvel_etat_processus).parametres_courbes_de_niveau = NULL;
2956: }
2957:
2958: (*s_nouvel_etat_processus).instruction_derniere_erreur = NULL;
2959:
2960: if (((*s_etat_processus).instruction_courante != NULL) &&
2961: (*s_etat_processus).evaluation_expression_compilee == 'N')
2962: {
2963: if (((*s_nouvel_etat_processus).instruction_courante = malloc((strlen(
2964: (*s_etat_processus).instruction_courante) + 1) *
2965: sizeof(unsigned char))) == NULL)
2966: {
2967: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
2968: {
2969: (*s_etat_processus).erreur_systeme = d_es_processus;
2970: return(NULL);
2971: }
2972:
2973: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2974: return(NULL);
2975: }
2976:
2977: strcpy((*s_nouvel_etat_processus).instruction_courante,
2978: (*s_etat_processus).instruction_courante);
2979: }
2980: else
2981: {
2982: (*s_nouvel_etat_processus).instruction_courante = NULL;
2983: }
2984:
2985: if ((*s_etat_processus).label_x != NULL)
2986: {
2987: if (((*s_nouvel_etat_processus).label_x = malloc((strlen(
2988: (*s_etat_processus).label_x) + 1) *
2989: sizeof(unsigned char))) == NULL)
2990: {
2991: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
2992: {
2993: (*s_etat_processus).erreur_systeme = d_es_processus;
2994: return(NULL);
2995: }
2996:
2997: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
2998: return(NULL);
2999: }
3000:
3001: strcpy((*s_nouvel_etat_processus).label_x,
3002: (*s_etat_processus).label_x);
3003: }
3004: else
3005: {
3006: (*s_nouvel_etat_processus).label_x = NULL;
3007: }
3008:
3009: if ((*s_etat_processus).label_y != NULL)
3010: {
3011: if (((*s_nouvel_etat_processus).label_y = malloc((strlen(
3012: (*s_etat_processus).label_y) + 1) *
3013: sizeof(unsigned char))) == NULL)
3014: {
3015: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3016: {
3017: (*s_etat_processus).erreur_systeme = d_es_processus;
3018: return(NULL);
3019: }
3020:
3021: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3022: return(NULL);
3023: }
3024:
3025: strcpy((*s_nouvel_etat_processus).label_y,
3026: (*s_etat_processus).label_y);
3027: }
3028: else
3029: {
3030: (*s_nouvel_etat_processus).label_y = NULL;
3031: }
3032:
3033: if ((*s_etat_processus).label_z != NULL)
3034: {
3035: if (((*s_nouvel_etat_processus).label_z = malloc((strlen(
3036: (*s_etat_processus).label_z) + 1) *
3037: sizeof(unsigned char))) == NULL)
3038: {
3039: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3040: {
3041: (*s_etat_processus).erreur_systeme = d_es_processus;
3042: return(NULL);
3043: }
3044:
3045: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3046: return(NULL);
3047: }
3048:
3049: strcpy((*s_nouvel_etat_processus).label_z,
3050: (*s_etat_processus).label_z);
3051: }
3052: else
3053: {
3054: (*s_nouvel_etat_processus).label_z = NULL;
3055: }
3056:
3057: if ((*s_etat_processus).titre != NULL)
3058: {
3059: if (((*s_nouvel_etat_processus).titre = malloc((strlen(
3060: (*s_etat_processus).titre) + 1) *
3061: sizeof(unsigned char))) == NULL)
3062: {
3063: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3064: {
3065: (*s_etat_processus).erreur_systeme = d_es_processus;
3066: return(NULL);
3067: }
3068:
3069: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3070: return(NULL);
3071: }
3072:
3073: strcpy((*s_nouvel_etat_processus).titre,
3074: (*s_etat_processus).titre);
3075: }
3076: else
3077: {
3078: (*s_nouvel_etat_processus).titre = NULL;
3079: }
3080:
3081: if ((*s_etat_processus).legende != NULL)
3082: {
3083: if (((*s_nouvel_etat_processus).legende = malloc((strlen(
3084: (*s_etat_processus).legende) + 1) *
3085: sizeof(unsigned char))) == NULL)
3086: {
3087: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3088: {
3089: (*s_etat_processus).erreur_systeme = d_es_processus;
3090: return(NULL);
3091: }
3092:
3093: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3094: return(NULL);
3095: }
3096:
3097: strcpy((*s_nouvel_etat_processus).legende,
3098: (*s_etat_processus).legende);
3099: }
3100: else
3101: {
3102: (*s_nouvel_etat_processus).legende = NULL;
3103: }
3104:
3105: /*
3106: * Copie de la table des variables
3107: */
3108:
1.51 bertrand 3109: copie_arbre_variables(s_etat_processus, s_nouvel_etat_processus);
3110:
3111: if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
1.1 bertrand 3112: {
3113: return(NULL);
3114: }
3115:
3116: /*
3117: * Copie de la table des variables statiques
3118: */
3119:
3120: if (((*s_nouvel_etat_processus).s_liste_variables_statiques =
3121: malloc((*s_etat_processus).nombre_variables_statiques_allouees *
3122: sizeof(struct_variable_statique))) == NULL)
3123: {
3124: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3125: {
3126: (*s_etat_processus).erreur_systeme = d_es_processus;
3127: return(NULL);
3128: }
3129:
3130: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3131: return(NULL);
3132: }
3133:
3134: for(i = 0; i < (*s_etat_processus).nombre_variables_statiques; i++)
3135: {
3136: if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom =
3137: malloc((strlen((*s_etat_processus).s_liste_variables_statiques
3138: [i].nom) + 1) * sizeof(unsigned char))) == NULL)
3139: {
3140: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3141: {
3142: (*s_etat_processus).erreur_systeme = d_es_processus;
3143: return(NULL);
3144: }
3145:
3146: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3147: return(NULL);
3148: }
3149:
3150: strcpy((*s_nouvel_etat_processus).s_liste_variables_statiques[i].nom,
3151: (*s_etat_processus).s_liste_variables_statiques[i].nom);
3152:
3153: (*s_nouvel_etat_processus).s_liste_variables_statiques[i].origine =
3154: (*s_etat_processus).s_liste_variables_statiques[i].origine;
3155: (*s_nouvel_etat_processus).s_liste_variables_statiques[i].niveau =
3156: (*s_etat_processus).s_liste_variables_statiques[i].niveau;
3157: (*s_nouvel_etat_processus).s_liste_variables_statiques[i]
3158: .variable_statique = (*s_etat_processus)
3159: .s_liste_variables_statiques[i].variable_statique;
3160:
3161: if (((*s_nouvel_etat_processus).s_liste_variables_statiques[i].objet =
3162: copie_objet(s_etat_processus, (*s_etat_processus)
3163: .s_liste_variables_statiques[i].objet, 'P')) == NULL)
3164: {
3165: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3166: {
3167: (*s_etat_processus).erreur_systeme = d_es_processus;
3168: return(NULL);
3169: }
3170:
3171: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3172: return(NULL);
3173: }
3174: }
3175:
3176: /*
3177: * Copie de la pile opérationnelle
3178: */
3179:
3180: (*s_nouvel_etat_processus).l_base_pile = NULL;
3181: l_element_lecture = (*s_etat_processus).l_base_pile;
3182: l_element_precedent = NULL;
3183:
3184: while(l_element_lecture != NULL)
3185: {
3186: if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
3187: {
3188: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3189: {
3190: (*s_etat_processus).erreur_systeme = d_es_processus;
3191: return(NULL);
3192: }
3193:
3194: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3195: return(NULL);
3196: }
3197:
3198: if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
3199: (*l_element_lecture).donnee, 'P')) == NULL)
3200: {
3201: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3202: {
3203: (*s_etat_processus).erreur_systeme = d_es_processus;
3204: return(NULL);
3205: }
3206:
3207: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3208: return(NULL);
3209: }
3210:
3211: (*l_element_suivant).suivant = NULL;
3212:
3213: if ((*s_nouvel_etat_processus).l_base_pile == NULL)
3214: {
3215: (*s_nouvel_etat_processus).l_base_pile = l_element_suivant;
3216: }
3217: else
3218: {
3219: (*l_element_precedent).suivant = l_element_suivant;
3220: }
3221:
3222: l_element_precedent = l_element_suivant;
3223: l_element_lecture = (*l_element_lecture).suivant;
3224: }
3225:
3226: /*
3227: * Copie de la pile système
3228: */
3229:
3230: (*s_nouvel_etat_processus).l_base_pile_systeme = NULL;
3231: (*s_nouvel_etat_processus).hauteur_pile_systeme = 0;
3232:
3233: empilement_pile_systeme(s_nouvel_etat_processus);
3234:
3235: if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
3236: {
3237: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3238: {
3239: (*s_etat_processus).erreur_systeme = d_es_processus;
3240: return(NULL);
3241: }
3242:
3243: (*s_etat_processus).erreur_systeme =
3244: (*s_nouvel_etat_processus).erreur_systeme;
3245: return(NULL);
3246: }
3247:
3248: (*(*s_nouvel_etat_processus).l_base_pile_systeme).retour_definition = 'Y';
3249:
3250: /*
3251: * On empile deux valeurs retour_definition pour pouvoir récupérer
3252: * les variables dans le cas d'un programme compilé.
3253: */
3254:
3255: empilement_pile_systeme(s_nouvel_etat_processus);
3256:
3257: if ((*s_nouvel_etat_processus).erreur_systeme != d_es)
3258: {
3259: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3260: {
3261: (*s_etat_processus).erreur_systeme = d_es_processus;
3262: return(NULL);
3263: }
3264:
3265: (*s_etat_processus).erreur_systeme =
3266: (*s_nouvel_etat_processus).erreur_systeme;
3267: return(NULL);
3268: }
3269:
3270: (*(*s_nouvel_etat_processus).l_base_pile_systeme).retour_definition = 'Y';
3271:
3272: /*
3273: * Destruction de la pile last pour le thread en cours.
3274: */
3275:
3276: (*s_nouvel_etat_processus).l_base_pile_last = NULL;
3277: (*s_nouvel_etat_processus).l_base_pile_processus = NULL;
3278:
3279: /*
3280: * Copie des différents contextes
3281: */
3282:
1.66 bertrand 3283: (*s_nouvel_etat_processus).pointeur_signal_lecture = d_faux;
3284: (*s_nouvel_etat_processus).pointeur_signal_ecriture = d_faux;
3285:
1.1 bertrand 3286: (*s_nouvel_etat_processus).l_base_pile_contextes = NULL;
3287: l_element_lecture = (*s_etat_processus).l_base_pile_contextes;
3288:
3289: while(l_element_lecture != NULL)
3290: {
3291: if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
3292: {
3293: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3294: {
3295: (*s_etat_processus).erreur_systeme = d_es_processus;
3296: return(NULL);
3297: }
3298:
3299: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3300: return(NULL);
3301: }
3302:
3303: if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
3304: (*l_element_lecture).donnee, 'P')) == NULL)
3305: {
3306: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3307: {
3308: (*s_etat_processus).erreur_systeme = d_es_processus;
3309: return(NULL);
3310: }
3311:
3312: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3313: return(NULL);
3314: }
3315:
3316: (*l_element_suivant).suivant = NULL;
3317:
3318: if ((*s_nouvel_etat_processus).l_base_pile_contextes == NULL)
3319: {
3320: (*s_nouvel_etat_processus).l_base_pile_contextes =
3321: l_element_suivant;
3322: }
3323: else
3324: {
3325: (*l_element_precedent).suivant = l_element_suivant;
3326: }
3327:
3328: l_element_precedent = l_element_suivant;
3329: l_element_lecture = (*l_element_lecture).suivant;
3330: }
3331:
3332: (*s_nouvel_etat_processus).l_base_pile_taille_contextes = NULL;
3333: l_element_lecture = (*s_etat_processus).l_base_pile_taille_contextes;
3334:
3335: while(l_element_lecture != NULL)
3336: {
3337: if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
3338: {
3339: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3340: {
3341: (*s_etat_processus).erreur_systeme = d_es_processus;
3342: return(NULL);
3343: }
3344:
3345: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3346: return(NULL);
3347: }
3348:
3349: if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
3350: (*l_element_lecture).donnee, 'P')) == NULL)
3351: {
3352: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3353: {
3354: (*s_etat_processus).erreur_systeme = d_es_processus;
3355: return(NULL);
3356: }
3357:
3358: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3359: return(NULL);
3360: }
3361:
3362: (*l_element_suivant).suivant = NULL;
3363:
3364: if ((*s_nouvel_etat_processus).l_base_pile_taille_contextes == NULL)
3365: {
3366: (*s_nouvel_etat_processus).l_base_pile_taille_contextes =
3367: l_element_suivant;
3368: }
3369: else
3370: {
3371: (*l_element_precedent).suivant = l_element_suivant;
3372: }
3373:
3374: l_element_precedent = l_element_suivant;
3375: l_element_lecture = (*l_element_lecture).suivant;
3376: }
3377:
3378: /*
3379: * Copies des piles s_sockets, s_bibliotheques et
3380: * s_instructions_externes.
3381: */
3382:
3383: (*s_nouvel_etat_processus).s_sockets = NULL;
3384: l_element_lecture = (*s_etat_processus).s_sockets;
3385:
3386: while(l_element_lecture != NULL)
3387: {
3388: if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
3389: {
3390: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3391: {
3392: (*s_etat_processus).erreur_systeme = d_es_processus;
3393: return(NULL);
3394: }
3395:
3396: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3397: return(NULL);
3398: }
3399:
3400: if (((*l_element_suivant).donnee = copie_objet(s_etat_processus,
3401: (*l_element_lecture).donnee, 'P')) == NULL)
3402: {
3403: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3404: {
3405: (*s_etat_processus).erreur_systeme = d_es_processus;
3406: return(NULL);
3407: }
3408:
3409: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3410: return(NULL);
3411: }
3412:
3413: (*l_element_suivant).suivant = NULL;
3414:
3415: if ((*s_nouvel_etat_processus).s_sockets == NULL)
3416: {
3417: (*s_nouvel_etat_processus).s_sockets = l_element_suivant;
3418: }
3419: else
3420: {
3421: (*l_element_precedent).suivant = l_element_suivant;
3422: }
3423:
3424: l_element_precedent = l_element_suivant;
3425: l_element_lecture = (*l_element_lecture).suivant;
3426: }
3427:
3428: (*s_nouvel_etat_processus).s_bibliotheques = NULL;
3429: l_element_precedent = NULL;
3430: l_element_lecture = (*s_etat_processus).s_bibliotheques;
3431:
3432: while(l_element_lecture != NULL)
3433: {
3434: if ((l_element_suivant = malloc(sizeof(struct_liste_chainee))) == NULL)
3435: {
3436: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3437: {
3438: (*s_etat_processus).erreur_systeme = d_es_processus;
3439: return(NULL);
3440: }
3441:
3442: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3443: return(NULL);
3444: }
3445:
3446: if (((*l_element_suivant).donnee = malloc(sizeof(struct_bibliotheque)))
3447: == NULL)
3448: {
3449: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3450: return(NULL);
3451: }
3452:
3453: (*((struct_bibliotheque *) (*l_element_suivant).donnee)).descripteur
3454: = (*((struct_bibliotheque *) (*l_element_lecture).donnee))
3455: .descripteur;
3456: (*((struct_bibliotheque *) (*l_element_suivant).donnee)).pid
3457: = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).pid;
3458: (*((struct_bibliotheque *) (*l_element_suivant).donnee)).tid
3459: = (*((struct_bibliotheque *) (*l_element_lecture).donnee)).tid;
3460:
3461: if (((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom =
3462: malloc((strlen((*((struct_bibliotheque *) (*l_element_lecture)
3463: .donnee)).nom) + 1) * sizeof(unsigned char))) == NULL)
3464: {
3465: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3466: {
3467: (*s_etat_processus).erreur_systeme = d_es_processus;
3468: return(NULL);
3469: }
3470:
3471: (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
3472: return(NULL);
3473: }
3474:
3475: strcpy((*((struct_bibliotheque *) (*l_element_suivant).donnee)).nom,
3476: (*((struct_bibliotheque *) (*l_element_lecture).donnee)).nom);
3477:
3478: (*l_element_suivant).suivant = NULL;
3479:
3480: if ((*s_nouvel_etat_processus).s_bibliotheques == NULL)
3481: {
3482: (*s_nouvel_etat_processus).s_bibliotheques = l_element_suivant;
3483: }
3484: else
3485: {
3486: (*l_element_precedent).suivant = l_element_suivant;
3487: }
3488:
3489: l_element_precedent = l_element_suivant;
3490: l_element_lecture = (*l_element_lecture).suivant;
3491: }
3492:
3493: if ((*s_etat_processus).nombre_instructions_externes != 0)
3494: {
3495: if (((*s_nouvel_etat_processus).s_instructions_externes =
3496: malloc((*s_etat_processus).nombre_instructions_externes *
3497: sizeof(struct_instruction_externe))) == NULL)
3498: {
3499: (*s_etat_processus).erreur_systeme = d_es_processus;
3500: return(NULL);
3501: }
3502:
3503: for(i = 0; i < (*s_etat_processus).nombre_instructions_externes; i++)
3504: {
3505: if (((*s_nouvel_etat_processus).s_instructions_externes[i].nom =
3506: malloc((strlen((*s_etat_processus).s_instructions_externes
3507: [i].nom) + 1) * sizeof(unsigned char))) == NULL)
3508: {
3509: (*s_etat_processus).erreur_systeme = d_es_processus;
3510: return(NULL);
3511: }
3512:
3513: strcpy((*s_nouvel_etat_processus).s_instructions_externes[i].nom,
3514: (*s_etat_processus).s_instructions_externes[i].nom);
3515:
3516: if (((*s_nouvel_etat_processus).s_instructions_externes[i]
3517: .nom_bibliotheque = malloc((strlen((*s_etat_processus)
3518: .s_instructions_externes[i].nom_bibliotheque) + 1) *
3519: sizeof(unsigned char))) == NULL)
3520: {
3521: (*s_etat_processus).erreur_systeme = d_es_processus;
3522: return(NULL);
3523: }
3524:
3525: strcpy((*s_nouvel_etat_processus).s_instructions_externes[i]
3526: .nom_bibliotheque, (*s_etat_processus)
3527: .s_instructions_externes[i].nom_bibliotheque);
3528:
3529: (*s_nouvel_etat_processus).s_instructions_externes[i]
3530: .descripteur_bibliotheque = (*s_etat_processus)
3531: .s_instructions_externes[i].descripteur_bibliotheque;
3532: }
3533: }
3534: else
3535: {
3536: (*s_nouvel_etat_processus).s_instructions_externes = NULL;
3537: }
3538:
3539: pthread_mutexattr_init(&attributs_mutex);
3540: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
3541: pthread_mutex_init(&((*s_nouvel_etat_processus).mutex), &attributs_mutex);
3542: pthread_mutexattr_destroy(&attributs_mutex);
3543:
1.28 bertrand 3544: pthread_mutexattr_init(&attributs_mutex);
3545: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_NORMAL);
3546: pthread_mutex_init(&((*s_nouvel_etat_processus).mutex_allocation),
3547: &attributs_mutex);
3548: pthread_mutexattr_destroy(&attributs_mutex);
3549:
1.1 bertrand 3550: if (pthread_mutex_unlock(&((*s_etat_processus).mutex)) != 0)
3551: {
3552: (*s_etat_processus).erreur_systeme = d_es_processus;
3553: return(NULL);
3554: }
3555:
3556: return(s_nouvel_etat_processus);
3557:
3558: #undef return
3559: }
3560:
1.6 bertrand 3561:
3562: /*
3563: ================================================================================
3564: Routines de debug
3565: ================================================================================
3566: entrées :
3567: --------------------------------------------------------------------------------
3568: sorties :
3569: --------------------------------------------------------------------------------
3570: effets de bord : néant
3571: ================================================================================
3572: */
3573:
3574: #ifdef DEBUG_MEMOIRE
3575:
3576: #undef malloc
3577: #undef realloc
3578: #undef free
1.21 bertrand 3579: #undef fork
1.6 bertrand 3580:
3581: #ifdef return
3582: # undef return
3583: #endif
3584:
1.16 bertrand 3585: #ifdef __BACKTRACE
1.21 bertrand 3586: #define PROFONDEUR_PILE 64
1.6 bertrand 3587: #define return(a) { if (a == NULL) \
1.21 bertrand 3588: { BACKTRACE(PROFONDEUR_PILE); \
3589: fprintf(stderr, ">>> MEDITATION %d\n", __LINE__); } \
1.6 bertrand 3590: return(a); } while(0)
1.16 bertrand 3591: #endif
1.6 bertrand 3592:
1.21 bertrand 3593: #undef fprintf
3594: #define check(a, b) ((strcmp(#a, fonction) == 0) && (ligne == b))
3595: #undef CORE_DUMP
3596:
1.6 bertrand 3597: typedef struct memoire
3598: {
3599: void *pointeur;
3600: unsigned char *fonction;
3601: unsigned char *argument;
3602: unsigned long ligne;
3603: size_t taille;
3604: unsigned long long ordre;
1.16 bertrand 3605: # ifdef __BACKTRACE
3606: void *pile[PROFONDEUR_PILE];
3607: int profondeur;
3608: # endif
1.6 bertrand 3609: struct memoire *suivant;
3610: } struct_memoire;
3611:
3612: static struct_memoire *debug = NULL;
3613: static unsigned long long ordre = 0;
1.21 bertrand 3614: static pthread_mutex_t mutex_allocation;
3615:
3616: void
3617: debug_memoire_initialisation()
3618: {
3619: pthread_mutexattr_t attributs_mutex;
3620:
3621: pthread_mutexattr_init(&attributs_mutex);
3622: pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
3623: pthread_mutex_init(&mutex_allocation, &attributs_mutex);
3624: pthread_mutexattr_destroy(&attributs_mutex);
1.6 bertrand 3625:
1.21 bertrand 3626: return;
3627: }
1.6 bertrand 3628:
3629: void *
3630: debug_memoire_ajout(size_t taille, const unsigned char *fonction,
3631: unsigned long ligne, const unsigned char *argument)
3632: {
3633: struct_memoire *ancienne_base;
3634:
1.21 bertrand 3635: void *pointeur;
3636:
1.6 bertrand 3637: pthread_mutex_lock(&mutex_allocation);
3638:
3639: ancienne_base = debug;
3640:
3641: if ((debug = malloc(sizeof(struct_memoire))) == NULL)
3642: {
3643: pthread_mutex_unlock(&mutex_allocation);
3644: return(NULL);
3645: }
3646:
3647: if (((*debug).pointeur = malloc(taille)) == NULL)
3648: {
3649: pthread_mutex_unlock(&mutex_allocation);
3650: return(NULL);
3651: }
3652:
3653: (*debug).suivant = ancienne_base;
3654: (*debug).ligne = ligne;
3655: (*debug).taille = taille;
3656: (*debug).ordre = ordre;
1.16 bertrand 3657:
1.21 bertrand 3658: pointeur = (*debug).pointeur;
3659:
1.16 bertrand 3660: # ifdef __BACKTRACE
3661: (*debug).profondeur = backtrace((*debug).pile, PROFONDEUR_PILE);
3662: # endif
1.6 bertrand 3663:
3664: if (((*debug).fonction = malloc((strlen(fonction) + 1) *
3665: sizeof(unsigned char))) == NULL)
3666: {
1.18 bertrand 3667: pthread_mutex_unlock(&mutex_allocation);
1.6 bertrand 3668: return(NULL);
3669: }
3670:
3671: if (((*debug).argument = malloc((strlen(argument) + 1) *
3672: sizeof(unsigned char))) == NULL)
3673: {
1.18 bertrand 3674: pthread_mutex_unlock(&mutex_allocation);
1.6 bertrand 3675: return(NULL);
3676: }
3677:
3678: strcpy((*debug).fonction, fonction);
3679: strcpy((*debug).argument, argument);
3680:
1.21 bertrand 3681: memset((*debug).pointeur, 0, (*debug).taille);
3682:
1.18 bertrand 3683: pthread_mutex_unlock(&mutex_allocation);
1.6 bertrand 3684: ordre++;
3685:
1.21 bertrand 3686: return(pointeur);
1.6 bertrand 3687: }
3688:
3689: void *
3690: debug_memoire_modification(void *pointeur, size_t taille,
3691: const unsigned char *fonction, unsigned long ligne,
3692: const unsigned char *argument)
3693: {
3694: struct_memoire *element_courant;
3695:
3696: if (pointeur != NULL)
3697: {
3698: if (taille == 0)
3699: {
1.21 bertrand 3700: // Revient à free(). Il n'y a pas de parenthèses car on ne veut
3701: // pas utiliser la macro return().
3702:
1.6 bertrand 3703: debug_memoire_retrait(pointeur);
1.21 bertrand 3704: return NULL ;
1.6 bertrand 3705: }
3706: else
3707: {
3708: // Réallocation réelle
3709:
3710: pthread_mutex_lock(&mutex_allocation);
3711:
3712: element_courant = debug;
3713:
3714: while(element_courant != NULL)
3715: {
3716: if ((*element_courant).pointeur == pointeur)
3717: {
3718: break;
3719: }
3720:
3721: element_courant = (*element_courant).suivant;
3722: }
3723:
3724: if (element_courant == NULL)
3725: {
3726: pthread_mutex_unlock(&mutex_allocation);
1.21 bertrand 3727:
1.26 bertrand 3728: uprintf("[%d-%llu] ILLEGAL POINTER (realloc)\n",
1.21 bertrand 3729: getpid(), (unsigned long long) pthread_self());
3730: # ifdef __BACKTRACE
3731: BACKTRACE(PROFONDEUR_PILE);
3732: # endif
3733:
3734: return(realloc(pointeur, taille));
1.6 bertrand 3735: }
1.21 bertrand 3736: else
1.6 bertrand 3737: {
1.21 bertrand 3738: if (((*element_courant).pointeur = realloc(pointeur, taille))
3739: == NULL)
3740: {
3741: pthread_mutex_unlock(&mutex_allocation);
3742: return(NULL);
3743: }
1.6 bertrand 3744:
1.21 bertrand 3745: (*element_courant).ligne = ligne;
3746: (*element_courant).taille = taille;
3747: free((*element_courant).fonction);
3748: free((*element_courant).argument);
1.6 bertrand 3749:
1.21 bertrand 3750: if (((*element_courant).fonction = malloc((strlen(fonction)
3751: + 1) * sizeof(unsigned char))) == NULL)
3752: {
3753: pthread_mutex_unlock(&mutex_allocation);
3754: return(NULL);
3755: }
1.6 bertrand 3756:
1.21 bertrand 3757: if (((*element_courant).argument = malloc((strlen(argument)
3758: + 1) * sizeof(unsigned char))) == NULL)
3759: {
3760: pthread_mutex_unlock(&mutex_allocation);
3761: return(NULL);
3762: }
1.6 bertrand 3763:
1.21 bertrand 3764: strcpy((*element_courant).fonction, fonction);
3765: strcpy((*element_courant).argument, argument);
1.6 bertrand 3766:
1.21 bertrand 3767: pthread_mutex_unlock(&mutex_allocation);
1.18 bertrand 3768:
1.21 bertrand 3769: return((*element_courant).pointeur);
3770: }
1.6 bertrand 3771: }
3772: }
3773: else
3774: {
3775: // Revient à malloc()
3776: pointeur = debug_memoire_ajout(taille, fonction, ligne, argument);
3777: return(pointeur);
3778: }
3779: }
3780:
3781: void
3782: debug_memoire_retrait(void *pointeur)
3783: {
3784: struct_memoire *element_courant;
3785: struct_memoire *element_precedent;
3786:
3787: pthread_mutex_lock(&mutex_allocation);
3788:
3789: element_courant = debug;
3790: element_precedent = NULL;
3791:
3792: while(element_courant != NULL)
3793: {
3794: if ((*element_courant).pointeur == pointeur)
3795: {
3796: if (element_precedent == NULL)
3797: {
3798: debug = (*debug).suivant;
3799: }
3800: else
3801: {
3802: (*element_precedent).suivant = (*element_courant).suivant;
3803: }
3804:
1.21 bertrand 3805: if (pointeur != NULL)
3806: {
3807: memset(pointeur, 0, (*element_courant).taille);
3808: }
3809:
1.6 bertrand 3810: free((*element_courant).fonction);
3811: free((*element_courant).argument);
3812: free(element_courant);
3813:
3814: break;
3815: }
3816:
3817: element_precedent = element_courant;
3818: element_courant = (*element_courant).suivant;
3819: }
3820:
3821: pthread_mutex_unlock(&mutex_allocation);
3822:
1.21 bertrand 3823: if (element_courant == NULL)
3824: {
1.26 bertrand 3825: uprintf("[%d-%llu] ILLEGAL POINTER (free)\n",
1.21 bertrand 3826: getpid(), (unsigned long long) pthread_self());
3827: # ifdef __BACKTRACE
3828: BACKTRACE(PROFONDEUR_PILE);
3829: # endif
3830: }
3831:
1.6 bertrand 3832: free(pointeur);
3833: return;
3834: }
3835:
3836: void
1.17 bertrand 3837: debug_memoire_verification()
1.6 bertrand 3838: {
1.16 bertrand 3839: # ifdef __BACKTRACE
3840: char **appels;
3841:
3842: int j;
1.17 bertrand 3843: # endif
1.16 bertrand 3844:
1.6 bertrand 3845: integer8 i;
3846:
3847: struct_memoire *element_courant;
3848: struct_memoire *element_suivant;
3849:
1.17 bertrand 3850: fprintf(stderr, "[%d-%llu] LIST OF MEMORY LEAKS\n",
1.6 bertrand 3851: getpid(), (unsigned long long) pthread_self());
3852:
3853: pthread_mutex_lock(&mutex_allocation);
3854:
3855: element_courant = debug;
3856: i = 1;
3857:
3858: while(element_courant != NULL)
3859: {
1.17 bertrand 3860: fprintf(stderr, "[%d-%llu] MEDITATION %lld (%llu)\n", getpid(),
3861: (unsigned long long) pthread_self(), i,
3862: (*element_courant).ordre);
3863: fprintf(stderr, "[%d-%llu] P: %p, F: %s(), L: %lu, S: %d\n",
3864: getpid(), (unsigned long long) pthread_self(),
3865: (*element_courant).pointeur,
3866: (*element_courant).fonction, (*element_courant).ligne,
3867: (int) (*element_courant).taille);
3868: fprintf(stderr, "[%d-%llu] A: %s\n", getpid(),
3869: (unsigned long long) pthread_self(),
3870: (*element_courant).argument);
1.16 bertrand 3871:
1.18 bertrand 3872: if (strstr((*element_courant).argument, "sizeof(unsigned char)")
3873: != NULL)
3874: {
3875: fprintf(stderr, "[%d-%llu] ", getpid(),
3876: (unsigned long long) pthread_self());
3877: fprintf(stderr, "O: %s\n", (unsigned char *)
3878: (*element_courant).pointeur);
3879: }
3880: else if (strcmp((*element_courant).argument, "sizeof(struct_objet)")
3881: == 0)
3882: {
3883: fprintf(stderr, "[%d-%llu] ", getpid(),
3884: (unsigned long long) pthread_self());
3885: fprintf(stderr, "O: %d\n", (*((struct_objet *)
3886: (*element_courant).pointeur)).type);
3887: }
3888: else if (strcmp((*element_courant).argument,
3889: "sizeof(struct_liste_chainee)") == 0)
3890: {
3891: fprintf(stderr, "[%d-%llu] ", getpid(),
3892: (unsigned long long) pthread_self());
3893: fprintf(stderr, "O: data=%p next=%p\n", (*((struct_liste_chainee *)
3894: (*element_courant).pointeur)).donnee,
3895: (*((struct_liste_chainee *) (*element_courant).pointeur))
3896: .suivant);
3897: }
3898:
1.17 bertrand 3899: # ifdef __BACKTRACE
3900: appels = backtrace_symbols((*element_courant).pile,
3901: (*element_courant).profondeur);
1.16 bertrand 3902:
1.17 bertrand 3903: fprintf(stderr, "[%d-%llu] BACKTRACE\n",
3904: getpid(), (unsigned long long) pthread_self());
1.6 bertrand 3905:
1.17 bertrand 3906: if (appels != NULL)
3907: {
3908: for(j = 0; j < (*element_courant).profondeur; j++)
1.6 bertrand 3909: {
1.17 bertrand 3910: fprintf(stderr, "[%d-%llu] %s\n", getpid(),
3911: (unsigned long long) pthread_self(), appels[j]);
3912: }
1.16 bertrand 3913:
1.17 bertrand 3914: free(appels);
3915: }
3916: # endif
1.16 bertrand 3917:
1.17 bertrand 3918: fprintf(stderr, "\n");
1.16 bertrand 3919:
1.17 bertrand 3920: i++;
1.6 bertrand 3921:
3922: element_suivant = (*element_courant).suivant;
1.17 bertrand 3923:
3924: # ifndef CORE_DUMP
1.6 bertrand 3925: free((*element_courant).fonction);
3926: free((*element_courant).argument);
3927: free(element_courant);
1.17 bertrand 3928: # endif
3929:
1.6 bertrand 3930: element_courant = element_suivant;
3931: }
3932:
3933: pthread_mutex_unlock(&mutex_allocation);
1.21 bertrand 3934: pthread_mutex_destroy(&mutex_allocation);
1.6 bertrand 3935:
3936: fprintf(stderr, "[%d-%llu] END OF LIST\n", getpid(),
3937: (unsigned long long) pthread_self());
3938:
3939: return;
3940: }
3941:
1.21 bertrand 3942: pid_t
3943: debug_fork()
3944: {
3945: pid_t pid;
3946:
3947: pthread_mutex_lock(&mutex_allocation);
3948: pid = fork();
1.18 bertrand 3949:
1.21 bertrand 3950: if (pid == 0)
3951: {
1.66 bertrand 3952: liberation_queue_signaux(s_etat_processus);
3953: creation_queue_signaux(s_etat_processus);
1.37 bertrand 3954:
1.21 bertrand 3955: pthread_mutex_destroy(&mutex_allocation);
3956: debug_memoire_initialisation();
3957: }
3958: else
3959: {
3960: pthread_mutex_unlock(&mutex_allocation);
3961: }
3962:
3963: // Pas de parenthèses pour ne pas remplacer return par sa macro.
3964: return pid;
1.18 bertrand 3965: }
3966:
3967: void
1.17 bertrand 3968: analyse_post_mortem()
3969: {
3970: # ifdef CORE_DUMP
3971: BUG(debug != NULL, uprintf("[%d-%llu] CREATE CORE DUMP FILE FOR "
3972: "POST MORTEM ANALYZE\n", getpid(),
3973: (unsigned long long) pthread_self()));
3974: # endif
3975:
3976: return;
3977: }
3978:
1.6 bertrand 3979: #endif
3980:
1.1 bertrand 3981: // vim: ts=4
CVSweb interface <joel.bertrand@systella.fr>
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to gestion_objets.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [local] / rpl / src