rpl/src/instructions_s1.c - diff

Return to instructions_s1.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/instructions_s1.c between versions 1.111 and 1.124

version 1.111, 2019/07/16 16:04:04	version 1.124, 2025/04/15 10:17:55
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.31	RPL/2 (R) version 4.1.36
Copyright (C) 1989-2019 Dr. BERTRAND Joël	Copyright (C) 1989-2025 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.

Line 19	Line 19
================================================================================	================================================================================
*/	*/

#define DEBUG_ERREURS
#include "rpl-conv.h"	#include "rpl-conv.h"


Line 3454 instruction_syseval(struct_processus *s_	Line 3454 instruction_syseval(struct_processus *s_
{	{
char **arguments;	char **arguments;

int etape;
int ios;	int ios;
int pipes_entree[2];	int pipes_entree[2];
int pipes_erreur[2];	int pipes_erreur[2];
int pipes_sortie[2];	int pipes_sortie[2];
int registre_ios;
int status;	int status;

file *fpipe;	file *fpipe;

logical1 drapeau_fin;	logical1 drapeau_fin;
logical1 presence_stdin;	logical1 presence_stdin;
	logical1 processus_tue;

long i;	long i;
long nombre_arguments;	long nombre_arguments;
Line 3485 instruction_syseval(struct_processus *s_	Line 3484 instruction_syseval(struct_processus *s_
struct_objet *s_objet_resultat;	struct_objet *s_objet_resultat;
struct_objet *s_objet_temporaire;	struct_objet *s_objet_temporaire;

	struct pollfd fds;

struct sigaction action_courante;	struct sigaction action_courante;
struct sigaction action_passee;	struct sigaction action_passee;

Line 3665 instruction_syseval(struct_processus *s_	Line 3666 instruction_syseval(struct_processus *s_
.instruction_courante;	.instruction_courante;

/*	/*
* S'il y a des guillemets en début de chaîne, il y en	* S'il y a des guillemets ou une apostrophe en début de
* a aussi à la fin de la chaîne et on les ôte. Les	* chaîne, il y en * a aussi à la fin de la chaîne et on les
* guillements intermédiaires sont protégés par une	* ôte. Les guillements intermédiaires sont protégés par une
* séquence d'échappement qui est enlevée.	* séquence d'échappement qui est enlevée.
*/	*/

if ((*s_etat_processus).instruction_courante[0] == '"')	if (((*s_etat_processus).instruction_courante[0] == '"') \|\|
	((*s_etat_processus).instruction_courante[0] == '\''))
{	{
if (strlen((*s_etat_processus).instruction_courante) >= 2)	if (strlen((*s_etat_processus).instruction_courante) >= 2)
{	{
Line 3876 instruction_syseval(struct_processus *s_	Line 3878 instruction_syseval(struct_processus *s_
if (dup2(pipes_entree[0], STDIN_FILENO) == -1)	if (dup2(pipes_entree[0], STDIN_FILENO) == -1)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
printf("%d\n",__LINE__);	printf("%d\n",__LINE__);
}	}
}	}

Line 3885 instruction_syseval(struct_processus *s_	Line 3887 instruction_syseval(struct_processus *s_
if (dup2(pipes_sortie[1], STDOUT_FILENO) == -1)	if (dup2(pipes_sortie[1], STDOUT_FILENO) == -1)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
printf("%d\n",__LINE__);	printf("%d\n",__LINE__);
}	}
}	}

Line 3894 instruction_syseval(struct_processus *s_	Line 3896 instruction_syseval(struct_processus *s_
if (dup2(pipes_sortie[1], STDERR_FILENO) == -1)	if (dup2(pipes_sortie[1], STDERR_FILENO) == -1)
{	{
(*s_etat_processus).erreur_systeme = d_es_processus;	(*s_etat_processus).erreur_systeme = d_es_processus;
printf("%d\n",__LINE__);	printf("%d\n",__LINE__);
}	}
}	}

Line 4046 instruction_syseval(struct_processus *s_	Line 4048 instruction_syseval(struct_processus *s_
return;	return;
}	}

	processus_tue = d_faux;

while((ios = (int) read_atomic_signal(s_etat_processus,	while((ios = (int) read_atomic_signal(s_etat_processus,
pipes_sortie[0], &(tampon[pointeur]),	pipes_sortie[0], &(tampon[pointeur]),
(size_t) longueur_lecture)) >= 0)	(size_t) longueur_lecture)) >= 0)
Line 4096 instruction_syseval(struct_processus *s_	Line 4100 instruction_syseval(struct_processus *s_
if ((*s_etat_processus).var_volatile_requete_arret == -1)	if ((*s_etat_processus).var_volatile_requete_arret == -1)
{	{
gettimeofday(&horodatage_initial, NULL);	gettimeofday(&horodatage_initial, NULL);
	kill(pid, SIGTERM);
if ((*s_etat_processus).var_volatile_alarme == -1)
{
kill(pid, SIGKILL);
}
else
{
kill(pid, SIGTERM);
}

if ((fpipe = fdopen(pipes_sortie[0], "r")) == NULL)	if ((fpipe = fdopen(pipes_sortie[0], "r")) == NULL)
{	{
Line 4113 instruction_syseval(struct_processus *s_	Line 4109 instruction_syseval(struct_processus *s_
return;	return;
}	}

etape = 1;	attente.tv_sec = 0;
registre_ios = ios;	attente.tv_nsec = GRANULARITE_us * 1000;

while((ios = getc(fpipe)) != EOF)	if (kill(pid, 0) == 0)
{	{
if (etape == 1)	while(feof(fpipe) == 0)
{	{
	fds.fd = pipes_sortie[0];
	fds.events = POLLIN;

	if (poll(&fds, 1, 0) > 0)
	{
	getc(fpipe);
	attente.tv_sec = 0;
	attente.tv_nsec = GRANULARITE_us * 1000;
	}
	else
	{
	nanosleep(&attente, NULL);
	INCR_GRANULARITE(attente.tv_nsec);
	}

gettimeofday(&horodatage_final, NULL);	gettimeofday(&horodatage_final, NULL);

// Si au bout de 10 secondes après le premier	// Si au bout de 10 secondes après le premier
Line 4130 instruction_syseval(struct_processus *s_	Line 4141 instruction_syseval(struct_processus *s_
if ((horodatage_final.tv_sec -	if ((horodatage_final.tv_sec -
horodatage_initial.tv_sec) > 10)	horodatage_initial.tv_sec) > 10)
{	{
etape = 2;
kill(pid, SIGKILL);	kill(pid, SIGKILL);
gettimeofday(&horodatage_initial, NULL);	gettimeofday(&horodatage_initial, NULL);
	processus_tue = d_vrai;
}	}
}	}
}	}
	}

ios = registre_ios;	if (processus_tue == d_vrai)
	{
break;	break;
}	}
}	}

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.111
changed lines
	Added in v.1.124