--- rpl/src/instructions_p7.c	2010/01/26 15:22:44	1.1
+++ rpl/src/instructions_p7.c	2010/09/11 16:46:19	1.18
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.9
+  RPL/2 (R) version 4.0.19
   Copyright (C) 1989-2010 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -846,12 +846,19 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-					if (sem_post(&((*s_etat_processus).semaphore_fork))
-							!= 0)
+#					ifndef SEMAPHORES_NOMMES
+					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
 					}
+#					else
+					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+					{
+						(*s_etat_processus).erreur_systeme = d_es_processus;
+						return;
+					}
+#					endif
 
 					while((longueur_ecriture = write_atomic(s_etat_processus,
 							(*(*((struct_processus_fils *)
@@ -859,8 +866,13 @@ instruction_poke(struct_processus *s_eta
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
+#						ifndef SEMAPHORES_NOMMES
 						while(sem_wait(&((*s_etat_processus)
 								.semaphore_fork)) == -1)
+#						else
+						while(sem_wait((*s_etat_processus)
+								.semaphore_fork) == -1)
+#						endif
 						{
 							if (errno != EINTR)
 							{
@@ -907,8 +919,13 @@ instruction_poke(struct_processus *s_eta
 							return;
 						}
 
+#						ifndef SEMAPHORES_NOMMES
 						if (sem_post(&((*s_etat_processus)
 								.semaphore_fork)) != 0)
+#						else
+						if (sem_post((*s_etat_processus)
+								.semaphore_fork) != 0)
+#						endif
 						{
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
@@ -929,8 +946,11 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-					while(sem_wait(&((*s_etat_processus).semaphore_fork))
-							== -1)
+#					ifndef SEMAPHORES_NOMMES
+					while(sem_wait(&((*s_etat_processus).semaphore_fork)) == -1)
+#					else
+					while(sem_wait((*s_etat_processus).semaphore_fork) == -1)
+#					endif
 					{
 						if (errno == EINTR)
 						{
@@ -1076,8 +1096,11 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
-					if (sem_post(&((*s_etat_processus).semaphore_fork))
-							!= 0)
+#					ifndef SEMAPHORES_NOMMES
+					if (sem_post(&((*s_etat_processus).semaphore_fork)) != 0)
+#					else
+					if (sem_post((*s_etat_processus).semaphore_fork) != 0)
+#					endif
 					{
 						(*s_etat_processus).erreur_systeme = d_es_processus;
 						return;
@@ -1089,8 +1112,13 @@ instruction_poke(struct_processus *s_eta
 							.pipe_nombre_injections[1], "-",
 							sizeof(unsigned char))) != sizeof(unsigned char))
 					{
+#						ifndef SEMAPHORES_NOMMES
 						while(sem_wait(&((*s_etat_processus)
 								.semaphore_fork)) == -1)
+#						else
+						while(sem_wait((*s_etat_processus)
+								.semaphore_fork) == -1)
+#						endif
 						{
 							if (errno != EINTR)
 							{
@@ -1137,8 +1165,13 @@ instruction_poke(struct_processus *s_eta
 							return;
 						}
 
+#						ifndef SEMAPHORES_NOMMES
 						if (sem_post(&((*s_etat_processus)
 								.semaphore_fork)) != 0)
+#						else
+						if (sem_post((*s_etat_processus)
+								.semaphore_fork) != 0)
+#						endif
 						{
 							(*s_etat_processus).erreur_systeme = d_es_processus;
 							return;
@@ -1159,8 +1192,13 @@ instruction_poke(struct_processus *s_eta
 						}
 					}
 
+#					ifndef SEMAPHORES_NOMMES
 					while(sem_wait(&((*s_etat_processus)
 							.semaphore_fork)) == -1)
+#					else
+					while(sem_wait((*s_etat_processus)
+							.semaphore_fork) == -1)
+#					endif
 					{
 						if (errno != EINTR)
 						{
@@ -1687,5 +1725,104 @@ instruction_plot(struct_processus *s_eta
 
 	return;
 }
+
+
+/*
+================================================================================
+  Fonction 'procid'
+================================================================================
+  Entrées : pointeur sur une structure struct_processus
+--------------------------------------------------------------------------------
+  Sorties :
+--------------------------------------------------------------------------------
+  Effets de bord : néant
+================================================================================
+*/
+
+void
+instruction_procid(struct_processus *s_etat_processus)
+{
+	pthread_mutexattr_t		attributs_mutex;
+
+	struct_objet			*s_objet;
+
+	(*s_etat_processus).erreur_execution = d_ex;
+
+	if ((*s_etat_processus).affichage_arguments == 'Y')
+	{
+		printf("\n  PROCID ");
+
+		if ((*s_etat_processus).langue == 'F')
+		{
+			printf("(identifiant du processus)\n\n");
+		}
+		else
+		{
+			printf("(process identifier)\n\n");
+		}
+
+		printf("->  1: %s\n", d_PRC);
+
+		return;
+	}
+	else if ((*s_etat_processus).test_instruction == 'Y')
+	{
+		(*s_etat_processus).nombre_arguments = -1;
+		return;
+	}
+
+	if (test_cfsf(s_etat_processus, 31) == d_vrai)
+	{
+		if (empilement_pile_last(s_etat_processus, 0) == d_erreur)
+		{
+			return;
+		}
+	}
+
+	if ((s_objet = allocation(s_etat_processus, PRC)) == NULL)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+		return;
+	}
+
+	if (((*((struct_processus_fils *) (*s_objet).objet)).thread =
+			malloc(sizeof(struct_descripteur_thread))) == NULL)
+	{
+		(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
+		return;
+	}
+
+	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+			.nombre_references = 1;
+	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+			.pid = getpid();
+	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+			.tid = pthread_self();
+	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+			.processus_detache = (*s_etat_processus).processus_detache;
+	(*(*((struct_processus_fils *) (*s_objet).objet)).thread)
+			.argument = NULL;
+
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+	pthread_mutex_init(&((*(*((struct_processus_fils *)
+			(*s_objet).objet)).thread).mutex), &attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
+	pthread_mutexattr_init(&attributs_mutex);
+	pthread_mutexattr_settype(&attributs_mutex, PTHREAD_MUTEX_RECURSIVE);
+	pthread_mutex_init(&((*(*((struct_processus_fils *)
+			(*s_objet).objet)).thread).mutex_nombre_references),
+			&attributs_mutex);
+	pthread_mutexattr_destroy(&attributs_mutex);
+
+	if (empilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
+			s_objet) == d_erreur)
+	{
+		return;
+	}
+
+	return;
+}
 
 // vim: ts=4