File:  [local] / rpl / src / gestion_pile.c
Revision 1.52: download - view: text, annotated - select for diffs - revision graph
Fri Sep 6 10:30:51 2013 UTC (10 years, 7 months ago) by bertrand
Branches: MAIN
CVS tags: rpl-4_1_16, HEAD
En route pour la 4.1.16.

    1: /*
    2: ================================================================================
    3:   RPL/2 (R) version 4.1.16
    4:   Copyright (C) 1989-2013 Dr. BERTRAND Joël
    5: 
    6:   This file is part of RPL/2.
    7: 
    8:   RPL/2 is free software; you can redistribute it and/or modify it
    9:   under the terms of the CeCILL V2 License as published by the french
   10:   CEA, CNRS and INRIA.
   11:  
   12:   RPL/2 is distributed in the hope that it will be useful, but WITHOUT
   13:   ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
   14:   FITNESS FOR A PARTICULAR PURPOSE.  See the CeCILL V2 License
   15:   for more details.
   16:  
   17:   You should have received a copy of the CeCILL License
   18:   along with RPL/2. If not, write to info@cecill.info.
   19: ================================================================================
   20: */
   21: 
   22: 
   23: #include "rpl-conv.h"
   24: 
   25: 
   26: /*
   27: ================================================================================
   28:   Procédure d'estimation de la longueur du tampon
   29: ================================================================================
   30:   Entrée :
   31: --------------------------------------------------------------------------------
   32:   Sortie :
   33: --------------------------------------------------------------------------------
   34:   Effets de bord : néant
   35: ================================================================================
   36: */
   37: 
   38: static inline void
   39: estimation_taille_pile(struct_processus *s_etat_processus)
   40: {
   41:     /*
   42:      * Cette fonction permet d'estimer un volant de structures de maillons
   43:      * de liste chaînée pour le programme courant et évite un certain nombre
   44:      * d'allocations de mémoire lors des manipulations de la pile. Cette taille
   45:      * est estimée au travers d'une chaîne de Markov.
   46:      */
   47: 
   48:     if ((*s_etat_processus).hauteur_pile_operationnelle >
   49:             (*s_etat_processus).estimation_taille_pile_tampon)
   50:     {
   51:         (*s_etat_processus).estimation_taille_pile_tampon =
   52:                 (*s_etat_processus).estimation_taille_pile_tampon;
   53:     }
   54:     else
   55:     {
   56:         (*s_etat_processus).estimation_taille_pile_tampon =
   57:                 (((double) (*s_etat_processus).estimation_taille_pile_tampon) *
   58:                 ((double) 0.95)) + (((double) (*s_etat_processus)
   59:                 .hauteur_pile_operationnelle) * ((double) 0.05));
   60:     }
   61: 
   62:     return;
   63: }
   64: 
   65: 
   66: /*
   67: ================================================================================
   68:   Procédure d'empilement d'un nouvel élément
   69: ================================================================================
   70:   Entrée :
   71: --------------------------------------------------------------------------------
   72:   Sortie :
   73: --------------------------------------------------------------------------------
   74:   Effets de bord : néant
   75: ================================================================================
   76: */
   77: 
   78: logical1
   79: empilement(struct_processus *s_etat_processus,
   80:         struct_liste_chainee **l_base_pile, struct_objet *s_objet)
   81: {
   82:     struct_liste_chainee        *l_ancienne_base_liste;
   83:     struct_liste_chainee        *l_nouvelle_base_liste;
   84: 
   85:     logical1                    erreur;
   86: 
   87:     l_ancienne_base_liste = *l_base_pile;
   88: 
   89:     if ((*s_etat_processus).pile_tampon == NULL)
   90:     {
   91:         // Tampon vide, on alloue un élément.
   92: 
   93:         if ((l_nouvelle_base_liste = malloc(sizeof(struct_liste_chainee)))
   94:                 == NULL)
   95:         {
   96:             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
   97:             return(d_erreur);
   98:         }
   99:     }
  100:     else
  101:     {
  102:         // Tampon utilisable, on retire un élément du tampon.
  103: 
  104:         l_nouvelle_base_liste = (*s_etat_processus).pile_tampon;
  105:         (*s_etat_processus).pile_tampon = (*l_nouvelle_base_liste).suivant;
  106:         (*s_etat_processus).taille_pile_tampon--;
  107:     }
  108: 
  109:     *l_base_pile = l_nouvelle_base_liste;
  110:     (**l_base_pile).donnee = s_objet;
  111:     (**l_base_pile).suivant = l_ancienne_base_liste;
  112: 
  113:     erreur = d_absence_erreur;
  114: 
  115: /*
  116: -- Ne considère que la pile opérationnelle -------------------------------------
  117: */
  118: 
  119:     if ((*s_etat_processus).l_base_pile == *l_base_pile)
  120:     {
  121:         (*s_etat_processus).hauteur_pile_operationnelle++;
  122:         estimation_taille_pile(s_etat_processus);
  123: 
  124:         if ((*s_etat_processus).debug == d_vrai)
  125:             if (((*s_etat_processus).type_debug &
  126:                     d_debug_pile_utilisateur) != 0)
  127:         {
  128:             if ((*s_etat_processus).langue == 'F')
  129:             {
  130:                 printf("[%d] Empilement de type %d "
  131:                         "(profondeur %lld)\n", (int) getpid(),
  132:                         (*s_objet).type,
  133:                         (*s_etat_processus).hauteur_pile_operationnelle);
  134:             }
  135:             else
  136:             {
  137:                 printf("[%d] Pushing a type %d object "
  138:                         "(depth %lld)\n", (int) getpid(), (*s_objet).type,
  139:                         (*s_etat_processus).hauteur_pile_operationnelle);
  140:             }
  141: 
  142:             fflush(stdout);
  143:         }
  144:     }
  145: 
  146:     return erreur;
  147: }
  148: 
  149: 
  150: /*
  151: ================================================================================
  152:   Procédure de dépilement d'un élément. L'emplacement est libéré dans la pile.
  153: ================================================================================
  154:   Entrée :
  155: --------------------------------------------------------------------------------
  156:   Sortie :
  157: --------------------------------------------------------------------------------
  158:   Effets de bord : néant
  159: ================================================================================
  160: */
  161: 
  162: logical1
  163: depilement(struct_processus *s_etat_processus,
  164:         struct_liste_chainee **l_base_pile, struct_objet **s_objet)
  165: {
  166:     struct_liste_chainee        *l_ancienne_base_liste;
  167:     struct_liste_chainee        *l_nouvelle_base_liste;
  168: 
  169:     logical1                    erreur;
  170: 
  171:     if (*l_base_pile == NULL)
  172:     {
  173:         (*s_etat_processus).erreur_execution = d_ex_pile_vide;
  174:         erreur = d_erreur;
  175:     }
  176:     else
  177:     {
  178: 
  179: /*
  180: -- Ne considère que la pile opérationnelle -------------------------------------
  181: */
  182: 
  183:         l_ancienne_base_liste = *l_base_pile;
  184:         *s_objet = (*l_ancienne_base_liste).donnee;
  185: 
  186:         if ((*s_etat_processus).l_base_pile == *l_base_pile)
  187:         {
  188:             if ((*s_etat_processus).debug == d_vrai)
  189:                 if (((*s_etat_processus).type_debug &
  190:                         d_debug_pile_utilisateur) != 0)
  191:             {
  192:                 if ((*s_etat_processus).langue == 'F')
  193:                 {
  194:                     printf("[%d] Dépilement de type %d "
  195:                             "(profondeur %lld)\n", (int) getpid(),
  196:                             (*(*s_objet)).type,
  197:                             (*s_etat_processus).hauteur_pile_operationnelle);
  198:                 }
  199:                 else
  200:                 {
  201:                     printf("[%d] Pulling a type %d object "
  202:                             "(depth %lld)\n", (int) getpid(),
  203:                             (*(*s_objet)).type,
  204:                             (*s_etat_processus).hauteur_pile_operationnelle);
  205:                 }
  206: 
  207:                 fflush(stdout);
  208:             }
  209: 
  210:             (*s_etat_processus).hauteur_pile_operationnelle--;
  211:             estimation_taille_pile(s_etat_processus);
  212:         }
  213: 
  214:         l_nouvelle_base_liste = (*l_ancienne_base_liste).suivant;
  215: 
  216:         *l_base_pile = l_nouvelle_base_liste;
  217:         erreur = d_absence_erreur;
  218: 
  219:         if ((*s_etat_processus).taille_pile_tampon <= (10 * ((*s_etat_processus)
  220:                 .estimation_taille_pile_tampon + 1)))
  221:         {
  222:             // Enregistrement de la structure pour usage ultérieur.
  223: 
  224:             (*l_ancienne_base_liste).donnee = NULL;
  225:             (*l_ancienne_base_liste).suivant = (*s_etat_processus).pile_tampon;
  226:             (*s_etat_processus).pile_tampon = l_ancienne_base_liste;
  227:             (*s_etat_processus).taille_pile_tampon++;
  228:         }
  229:         else
  230:         {
  231:             // Libération car le tampon est plein.
  232: 
  233:             free(l_ancienne_base_liste);
  234:         }
  235:     }
  236: 
  237:     return erreur;
  238: }
  239: 
  240: 
  241: /*
  242: ================================================================================
  243:   Procédures affichant la pile opérationnelle
  244: ================================================================================
  245:   Entrée :
  246: --------------------------------------------------------------------------------
  247:   Sortie :
  248: --------------------------------------------------------------------------------
  249:   Effets de bord : néant
  250: ================================================================================
  251: */
  252: 
  253: void
  254: affichage_pile(struct_processus *s_etat_processus, struct_liste_chainee
  255:         *l_element_courant, integer8 niveau_courant)
  256: {
  257:     unsigned char           registre;
  258: 
  259:     registre = (*s_etat_processus).autorisation_conversion_chaine;
  260:     (*s_etat_processus).autorisation_conversion_chaine = 'N';
  261: 
  262:     routine_recursive = 1;
  263:     ecriture_pile(s_etat_processus, stdout, l_element_courant, niveau_courant);
  264:     routine_recursive = 0;
  265: 
  266:     (*s_etat_processus).autorisation_conversion_chaine = registre;
  267:     return;
  268: }
  269: 
  270: void
  271: ecriture_pile(struct_processus *s_etat_processus, file *flux,
  272:         struct_liste_chainee *l, integer8 niveau_courant)
  273: {
  274:     unsigned char               *chaine;
  275:     unsigned char               *registre;
  276:     unsigned char               tampon[32 + 1];
  277: 
  278:     // Évite le warning : argument l_element_courant might be clobbered by
  279:     // longjmp or vfork
  280:     volatile struct_liste_chainee   *l_element_courant;
  281: 
  282:     l_element_courant = l;
  283: 
  284:     if (l_element_courant != NULL)
  285:     {
  286:         if (setjmp(contexte_ecriture) == 0)
  287:         {
  288:             (*s_etat_processus).var_volatile_recursivite = -1;
  289:             ecriture_pile(s_etat_processus, flux,
  290:                     (*l_element_courant).suivant, niveau_courant + 1);
  291: 
  292:             if ((*s_etat_processus).var_volatile_recursivite > 0)
  293:             {
  294:                 (*s_etat_processus).var_volatile_recursivite--;
  295: 
  296:                 if ((*s_etat_processus).var_volatile_recursivite == 0)
  297:                 {
  298:                     if (fprintf(flux, "%lld: ...\n", niveau_courant) < 0)
  299:                     {
  300:                         (*s_etat_processus).erreur_systeme =
  301:                                 d_es_erreur_fichier;
  302:                         return;
  303:                     }
  304: 
  305:                     while(l_element_courant != NULL)
  306:                     {
  307:                         l_element_courant = (*l_element_courant).suivant;
  308:                     }
  309:                 }
  310: 
  311:                 return;
  312:             }
  313: 
  314:             (*s_etat_processus).var_volatile_recursivite = 0;
  315:         }
  316:         else
  317:         {
  318:             // Libération de n appels de la pile système qui permet de
  319:             // terminer la récursion sans autre dépassement de pile.
  320: 
  321:             (*s_etat_processus).var_volatile_recursivite = 64;
  322:             return;
  323:         }
  324: 
  325:         sprintf(tampon, "%lld: ", niveau_courant);
  326: 
  327:         if ((chaine = formateur(s_etat_processus, (long) strlen(tampon),
  328:                 (*l_element_courant).donnee)) == NULL)
  329:         {
  330:             (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
  331:             return;
  332:         }
  333: 
  334:         if ((*(*l_element_courant).donnee).type == CHN)
  335:         {
  336:             registre = chaine;
  337: 
  338:             if ((chaine = (unsigned char *) malloc((strlen(registre) + 3) *
  339:                     sizeof(unsigned char))) == NULL)
  340:             {
  341:                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
  342:                 return;
  343:             }
  344: 
  345:             sprintf(chaine, "\"%s\"", registre);
  346:             free(registre);
  347:         }
  348: 
  349:         if (fprintf(flux, "%lld: %s\n", niveau_courant, chaine) < 0)
  350:         {
  351:             (*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
  352:             return;
  353:         }
  354: 
  355:         free(chaine);
  356:     }
  357: 
  358:     return;
  359: }
  360: 
  361: 
  362: /*
  363: ================================================================================
  364:   Procédure imprimant la pile opérationnelle
  365: ================================================================================
  366:   Entrée : méthode 'C' = compacte, 'E' = étendue
  367: --------------------------------------------------------------------------------
  368:   Sortie :
  369: --------------------------------------------------------------------------------
  370:   Effets de bord : néant
  371: ================================================================================
  372: */
  373: 
  374: void
  375: impression_pile(struct_processus *s_etat_processus,
  376:         struct_liste_chainee *l, unsigned char methode, integer8 niveau_courant)
  377: {
  378:     struct_objet                s_objet;
  379: 
  380:     unsigned char               *chaine;
  381:     unsigned char               *registre;
  382:     unsigned char               tampon[32 + 1];
  383: 
  384:     // Évite le warning : argument l_element_courant might be clobbered by
  385:     // longjmp or vfork
  386:     volatile struct_liste_chainee   *l_element_courant;
  387: 
  388:     l_element_courant = l;
  389: 
  390:     if (l_element_courant != NULL)
  391:     {
  392:         if (setjmp(contexte_impression) == 0)
  393:         {
  394:             (*s_etat_processus).var_volatile_recursivite = -1;
  395:             impression_pile(s_etat_processus, (*l_element_courant).suivant,
  396:                     methode, niveau_courant + 1);
  397: 
  398:             if ((*s_etat_processus).var_volatile_recursivite > 0)
  399:             {
  400:                 (*s_etat_processus).var_volatile_recursivite--;
  401: 
  402:                 if ((*s_etat_processus).var_volatile_recursivite == 0)
  403:                 {
  404:                     while(l_element_courant != NULL)
  405:                     {
  406:                         l_element_courant = (*l_element_courant).suivant;
  407:                     }
  408:                 }
  409: 
  410:                 return;
  411:             }
  412: 
  413:             (*s_etat_processus).var_volatile_recursivite = 0;
  414:         }
  415:         else
  416:         {
  417:             (*s_etat_processus).var_volatile_recursivite = 16;
  418:             return;
  419:         }
  420: 
  421:         if (methode == 'C')
  422:         {
  423:             s_objet.type = CHN;
  424:             sprintf(tampon, "%lld: ", niveau_courant);
  425: 
  426:             if ((chaine = formateur(s_etat_processus, (long) strlen(tampon),
  427:                     (*l_element_courant).donnee)) == NULL)
  428:             {
  429:                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
  430:                 return;
  431:             }
  432: 
  433:             if ((*(*l_element_courant).donnee).type == CHN)
  434:             {
  435:                 registre = chaine;
  436: 
  437:                 if ((chaine = (unsigned char *) malloc((strlen(registre) + 3) *
  438:                         sizeof(unsigned char))) == NULL)
  439:                 {
  440:                     (*s_etat_processus).erreur_systeme =
  441:                             d_es_allocation_memoire;
  442:                     return;
  443:                 }
  444: 
  445:                 sprintf(chaine, "\"%s\"", registre);
  446:                 free(registre);
  447:             }
  448: 
  449:             if ((s_objet.objet = malloc((strlen(chaine) + 64) *
  450:                     sizeof(unsigned char))) == NULL)
  451:             {
  452:                 (*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
  453:                 return;
  454:             }
  455: 
  456:             sprintf((unsigned char *) s_objet.objet,
  457:                     "\n\\noindent\\begin{verbatim}\n%lld: %s\n\\end{verbatim}",
  458:                     niveau_courant, chaine);
  459:             free(chaine);
  460: 
  461:             formateur_tex(s_etat_processus, &s_objet, 'V');
  462:             free(s_objet.objet);
  463:         }
  464:         else
  465:         {
  466:             formateur_tex(s_etat_processus, (*l_element_courant).donnee, 'N');
  467:         }
  468:     }
  469: 
  470:     return;
  471: }
  472: 
  473: // vim: ts=4

CVSweb interface <joel.bertrand@systella.fr>