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