--- rpl/src/transliteration.c	2010/03/17 14:14:38	1.7
+++ rpl/src/transliteration.c	2011/09/14 17:56:00	1.40
@@ -1,7 +1,7 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.13
-  Copyright (C) 1989-2010 Dr. BERTRAND Joël
+  RPL/2 (R) version 4.1.3
+  Copyright (C) 1989-2011 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
 
@@ -20,8 +20,8 @@
 */
 
 
-#include "rpl.conv.h"
-#include "tex.conv.h"
+#include "rpl-conv.h"
+#include "tex-conv.h"
 
 #include <stdarg.h>
 
@@ -105,7 +105,8 @@ reencodage(struct_processus *s_etat_proc
 
 	chaine_sortie[0] = d_code_fin_chaine;
 
-	if ((buffer_sortie = malloc((d_LONGUEUR + 1) * sizeof(char))) == NULL)
+	if ((buffer_sortie = malloc((d_LONGUEUR + 1) * sizeof(unsigned char)))
+			== NULL)
 	{
 		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
 		return(NULL);
@@ -131,7 +132,7 @@ reencodage(struct_processus *s_etat_proc
 			}
 		}
 
-		tampon = (unsigned char *) chaine_sortie;
+		tampon = chaine_sortie;
 		(*pointeur) = d_code_fin_chaine;
 
 		if ((chaine_sortie = malloc((strlen(tampon) + strlen(buffer_sortie) + 1)
@@ -175,8 +176,6 @@ localisation_courante(struct_processus *
 	int							pipes_sortie[2];
 	int							status;
 
-	logical1					drapeau_fin;
-
 	long						i;
 	long						nombre_arguments;
 
@@ -216,7 +215,6 @@ localisation_courante(struct_processus *
 	arguments[2] = NULL;
 
 	nombre_arguments = 2;
-	drapeau_fin = d_faux;
 
 	if (pipe(pipes_entree) != 0)
 	{
@@ -407,8 +405,7 @@ localisation_courante(struct_processus *
 			 * Récupération de la valeur de retour du processus détaché
 			 */
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork))
-					!= 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
@@ -416,26 +413,20 @@ localisation_courante(struct_processus *
 
 			if (waitpid(pid, &status, 0) == -1)
 			{
-				if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+				if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 				{
-					if (errno != EINTR)
-					{
-						(*s_etat_processus).erreur_systeme = d_es_processus;
-						return;
-					}
+					(*s_etat_processus).erreur_systeme = d_es_processus;
+					return;
 				}
 
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
 
-			if (sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 		} while((!WIFEXITED(status)) && (!WIFSIGNALED(status)));
 
@@ -450,7 +441,9 @@ localisation_courante(struct_processus *
 			return;
 		}
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+		tampon[0] = d_code_fin_chaine;
+
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
@@ -460,13 +453,10 @@ localisation_courante(struct_processus *
 				pipes_sortie[0], &(tampon[pointeur]),
 				longueur_lecture)) > 0)
 		{
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+			if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 
 			tampon[pointeur + ios] = d_code_fin_chaine;
@@ -482,20 +472,17 @@ localisation_courante(struct_processus *
 				return;
 			}
 
-			if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+			if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 			{
 				(*s_etat_processus).erreur_systeme = d_es_processus;
 				return;
 			}
 		}
 
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 
 		if (strlen(tampon) == 0)
@@ -518,7 +505,23 @@ localisation_courante(struct_processus *
 			return;
 		}
 
-		(*s_etat_processus).localisation = tampon;
+		if (strlen(tampon) > 0)
+		{
+			(*s_etat_processus).localisation = tampon;
+		}
+		else
+		{
+			free(tampon);
+
+			if (((*s_etat_processus).localisation = malloc((strlen(d_locale)
+					+ 1) * sizeof(unsigned char))) == NULL)
+			{
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
+			}
+
+			strcpy((*s_etat_processus).localisation, d_locale);
+		}
 
 		if (sigaction(SIGINT, &action_passee, NULL) != 0)
 		{
@@ -539,7 +542,7 @@ localisation_courante(struct_processus *
 
 		free(arguments);
 
-		if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+		if (pthread_mutex_unlock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
 			(*s_etat_processus).erreur_systeme = d_es_processus;
 			return;
@@ -549,26 +552,22 @@ localisation_courante(struct_processus *
 		{
 			// Le processus fils renvoie une erreur.
 
-			while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+			free(tampon);
+
+			if (((*s_etat_processus).localisation = malloc((strlen(d_locale)
+					+ 1) * sizeof(unsigned char))) == NULL)
 			{
-				if (errno != EINTR)
-				{
-					(*s_etat_processus).erreur_systeme = d_es_processus;
-					return;
-				}
+				(*s_etat_processus).erreur_systeme = d_es_processus;
+				return;
 			}
 
-			(*s_etat_processus).erreur_execution = d_ex_erreur_processus;
-			return;
+			strcpy((*s_etat_processus).localisation, d_locale);
 		}
 
-		while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+		if (pthread_mutex_lock(&((*s_etat_processus).mutex_fork)) != 0)
 		{
-			if (errno != EINTR)
-			{
-				(*s_etat_processus).erreur_systeme = d_es_processus;
-				return;
-			}
+			(*s_etat_processus).erreur_systeme = d_es_processus;
+			return;
 		}
 
 		if (close(pipes_erreur[0]) != 0)
@@ -595,6 +594,14 @@ transliterated_fprintf(struct_processus
 
 	va_start(arguments, format);
 
+#	ifdef OS2
+	unsigned char		*ptr_e;;
+	unsigned char		*ptr_l;;
+	unsigned char		*tampon3;
+
+	unsigned long		i;
+#	endif
+
 	if (valsprintf(&tampon, format, arguments) < 0)
 	{
 		va_end(arguments);
@@ -625,6 +632,56 @@ transliterated_fprintf(struct_processus
 		tampon2 = tampon;
 	}
 
+#	ifdef OS2
+	if ((flux == stdin) || (flux == stdout))
+	{
+		i = 0;
+		ptr_l = tampon2;
+
+		while((*ptr_l) != d_code_fin_chaine)
+		{
+			if ((*ptr_l) == '\n')
+			{
+				i++;
+			}
+
+			ptr_l++;
+		}
+
+		if ((tampon3 = malloc((strlen(tampon2) + i + 1) *
+				sizeof(unsigned char))) == NULL)
+		{
+			(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+			return(NULL);
+		}
+
+		ptr_e = tampon3;
+		ptr_l = tampon2;
+
+		while((*ptr_l) != d_code_fin_chaine)
+		{
+			(*ptr_e) = (*ptr_l);
+
+			if ((*ptr_l) == '\n')
+			{
+				(*(++ptr_e)) = '\r';
+				ptr_e++;
+				ptr_l++;
+			}
+			else
+			{
+				ptr_e++;
+				ptr_l++;
+			}
+		}
+
+		(*ptr_e) = d_code_fin_chaine;
+
+		free(tampon2);
+		tampon2 = tampon3;
+	}
+#	endif
+
 #	ifdef SunOS
 	while((ios = fprintf(flux, "%s", tampon2)) < 0)
 	{
@@ -696,6 +753,20 @@ tex_fprintf(struct_processus *s_etat_pro
 	return(ios);
 }
 
+#undef readline
+
+unsigned char *
+readline_wrapper(unsigned char *invite)
+{
+	unsigned char		*chaine;
+
+	chaine = readline(invite);
+	printf("\r");
+
+	return(chaine);
+}
+
+
 #define fprintf NULL
 #define printf NULL