/*************************************************************************************************************************************/
/* */
/* G E S T I O N " I N T E R N E " D U P A R A L L E L I S M E : */
/* */
/* */
/* Nota : */
/* */
/* Le 20090414184411, le programme 'v $xcg/parallele.14$K' */
/* a ete remplace par le programme 'v $xcg/parallele.1N$K' */
/* beaucoup plus general, en particulier parce que ce dernier */
/* ne fait pas, contrairement au premier, l'hypothese de */
/* "dichotomie binaire" et qu'il permet de mettre en */
/* parallele autant de process que l'on souhaite (a condition */
/* evidemment de rester dans des limites physiques raisonnables...). */
/* */
/* */
/* Utilisation : */
/* */
/* Cette commande s'utilisera par exemple */
/* de la facon suivante : */
/* */
/* $xcg/parallele.14$X commande11="COMMANDE_11" \ */
/* commande12="COMMANDE_12" \ */
/* commande21="COMMANDE_21" \ */
/* commande22="COMMANDE_22" */
/* */
/* Soit 'NP' le nombre de processus parallelisables, */
/* alors : */
/* */
/* 1-si NP=1, l'execution des commandes est sequentiel */
/* suivant l'ordre : */
/* */
/* | */
/* | */
/* */
/* COMMANDE_11 */
/* COMMANDE_12 */
/* COMMANDE_21 */
/* COMMANDE_22 */
/* */
/* */
/* 2-si NP=2, l'execution des commandes est partiellement */
/* parallele suivant l'ordre : */
/* */
/* | */
/* | */
/* ------------------- */
/* | | */
/* | | */
/* */
/* COMMANDE_11 COMMANDE_21 */
/* COMMANDE_12 COMMANDE_22 */
/* */
/* */
/* 3-si NP=4, l'execution des commandes est totalement */
/* parallele suivant l'ordre : */
/* */
/* | */
/* | */
/* --------------------------------------- */
/* | | */
/* | | */
/* ------------------- ------------------- */
/* | | | | */
/* | | | | */
/* */
/* COMMANDE_11 COMMANDE_12 COMMANDE_21 COMMANDE_22 */
/* */
/* */
/* Il est evidenet que ce principe peut se */
/* generaliser recursivement avec des etages */
/* successifs en puissance de deux. */
/* */
/* */
/* Author of '$xcg/parallele.14$K' : */
/* */
/* Jean-Francois COLONNA (LACTAMME, 1998??????????). */
/* */
/*************************************************************************************************************************************/
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* I N T E R F A C E ' listG ' : */
/* */
/* */
/* :Debut_listG: */
/* :Fin_listG: */
/* */
/*************************************************************************************************************************************/
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* D I R E C T I V E S S P E C I F I Q U E S D E C O M P I L A T I O N : */
/* */
/*************************************************************************************************************************************/
@define PRAGMA_CL_____PAS_DE_LIBRAIRIES_DYNAMIQUES
/* Introduit le 20090321091104 (a cause de 'v $xcg/FindExec.01$Z .xcg.parallele.14.X', c'est */
/* plus prudent...). */
@define PRAGMA_CL_____PAS_DE_FICHIER_____PARAM
/* Introduit le 20170416143258 a cause de l'argument 'nombre_de_processus_parallelisables' */
/* qui est local a chaque MACHINE ('v $xcg/parallele.14$I ProcessorNumber')... */
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* F I C H I E R S D ' I N C L U D E S : */
/* */
/*************************************************************************************************************************************/
#include INCLUDES_MINI
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* P A R A M E T R E S : */
/* */
/*===================================================================================================================================*/
#include xcg/parallele.14.I"
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* M A C R O S U T I L E S : */
/* */
/*************************************************************************************************************************************/
#define INITIALISATION_COMMANDE(commande) \
Bblock \
INCR(nombre_de_commandes_initialisees,I); \
\
Test(IFLE(nombre_de_commandes_initialisees,nombre_de_processus_parallelises)) \
Bblock \
EGAL(commande,chain_Acopie(commande_unique_a_paralleliser)); \
Eblock \
ATes \
Bblock \
Eblock \
ETes \
Eblock \
/* Procedure destinee a limiter a 'nombre_de_processus_parallelises' les commandes */ \
/* initialisees a partir d'une commande unique (introduit le 20090415073930). */
/*===================================================================================================================================*/
/*************************************************************************************************************************************/
/* */
/* G E S T I O N " I N T E R N E " D U P A R A L L E L I S M E : */
/* */
/*************************************************************************************************************************************/
BCommande(nombre_d_arguments,arguments)
/*-----------------------------------------------------------------------------------------------------------------------------------*/
Bblock
DEFV(Logical,INIT(faire_du_parallelisme,FAIRE_DU_PARALLELISME));
/* Faut-il faire du parallelisme ('VRAI') ou pas ('FAUX') ? */
DEFV(Positive,INIT(nombre_de_processus_parallelisables,NOMBRE_DE_PROCESSUS_PARALLELISABLES));
DEFV(Positive,INIT(nombre_de_processus_parallelises,UNDEF));
/* Nombre de processus parallelisables. */
DEFV(CHAR,INIC(POINTERc(commande_unique_a_paralleliser),C_VIDE));
/* Chaine de caracteres introduite le 20090408180948 et qui, si elle est non vide, definit */
/* simultanement les 'nombre_de_processus_parallelises' premieres 'commande??' (a condition */
/* qu'elles soient vides toutes les quatre...). */
DEFV(CHAR,INIC(POINTERc(commande11),C_VIDE));
DEFV(CHAR,INIC(POINTERc(commande12),C_VIDE));
DEFV(CHAR,INIC(POINTERc(commande21),C_VIDE));
DEFV(CHAR,INIC(POINTERc(commande22),C_VIDE));
/* Chaine de caracteres donnant les commandes a lancer en parallele. */
/*..............................................................................................................................*/
GET_ARGUMENTS_(nombre_d_arguments
,BLOC(GET_ARGUMENT_C("commande=""cm=""c=""C=",commande_unique_a_paralleliser);
GET_ARGUMENT_C("commande1=""commande11=""cm1=""c1=""c11=""C1=""C11=",commande11);
GET_ARGUMENT_C("commande2=""commande12=""cm2=""c2=""c12=""C2=""C12=",commande12);
GET_ARGUMENT_C("commande3=""commande21=""cm3=""c3=""c21=""C3=""C21=",commande21);
GET_ARGUMENT_C("commande4=""commande22=""cm4=""c4=""c22=""C4=""C22=",commande22);
/* Le 20090415111840, je note que les cinq 'GET_ARGUMENT_C(...)'s qui precedent doivent etre */
/* identiques a ceux de 'v $xcg/parallele.1N$K GET_ARGUMENT_C' pour assurer la compatibilite */
/* de 'v $xcg/parallele.1N$K' et de 'v $xcg/parallele.14$K'. */
GET_ARGUMENT_I("NombreProcessParalleles=""process=""processus=""np=""nombre=""NP="
,nombre_de_processus_parallelisables
);
/* Le 20090115172425, introduction de {"NombreProcessParalleles=","process="}. */
GET_ARGUMENT_L("parallelisme=",faire_du_parallelisme);
)
);
EGAL(nombre_de_processus_parallelises,INTE(PUIX(BASE2,INTE(LO2X(nombre_de_processus_parallelisables)))));
/* Nombre de processus parallelises. */
Test(IFNE(nombre_de_processus_parallelisables,nombre_de_processus_parallelises))
Bblock
PRINT_ATTENTION("le nombre de processus parallelisables n'est pas une puissance de 2");
CAL1(Prer1("Il vaut %d,\n",nombre_de_processus_parallelisables));
CAL1(Prer1("Le nombre de processus parallelises sera %d.\n",nombre_de_processus_parallelises));
Eblock
ATes
Bblock
Eblock
ETes
Test(IFNE_chaine(commande_unique_a_paralleliser,C_VIDE))
Bblock
Test(I4ET(IFEQ_chaine(commande11,C_VIDE)
,IFEQ_chaine(commande12,C_VIDE)
,IFEQ_chaine(commande21,C_VIDE)
,IFEQ_chaine(commande22,C_VIDE)
)
)
/* Test introduit le 20090408180948 pour 'v $xiirs/.CAYA.D1.2.$U Linda'. */
Bblock
DEFV(Int,INIT(nombre_de_commandes_initialisees,ZERO));
INITIALISATION_COMMANDE(commande11);
INITIALISATION_COMMANDE(commande12);
INITIALISATION_COMMANDE(commande21);
INITIALISATION_COMMANDE(commande22);
/* Possibilite introduite le 20090408180948 pour 'v $xiirs/.CAYA.D1.2.$U Linda'. */
Eblock
ATes
Bblock
PRINT_ATTENTION("la 'commande unique' est ignoree, l'une au moins des quatre commandes etant definie");
CAL1(Prer1("(elle etait '%s')\n",commande_unique_a_paralleliser));
Eblock
ETes
Eblock
ATes
Bblock
Eblock
ETes
SEQUENCES_PARALLELES_04(BLOC(CALS(SYSTEM(commande11));)
,BLOC(CALS(SYSTEM(commande12));)
,BLOC(CALS(SYSTEM(commande21));)
,BLOC(CALS(SYSTEM(commande22));)
,faire_du_parallelisme
,nombre_de_processus_parallelisables
);
/* La procedure 'SEQUENCES_PARALLELES_04(...)' a ete introduite le 20090407085333 en */
/* remplacement d'une "structure" plus compliquee... */
RETU_Commande;
Eblock
ECommande