rpl/src/instructions_r4.c - diff

Return to instructions_r4.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/instructions_r4.c between versions 1.76 and 1.120

version 1.76, 2013/03/20 22:24:37	version 1.120, 2023/11/27 13:56:46
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.13	RPL/2 (R) version 4.1.35
Copyright (C) 1989-2013 Dr. BERTRAND Joël	Copyright (C) 1989-2023 Dr. BERTRAND Joël

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

Line 850 instruction_read(struct_processus *s_eta	Line 850 instruction_read(struct_processus *s_eta

int c;	int c;
int ios;	int ios;
	int timeout;

integer8 element;	integer8 element;
integer8 i;	integer8 i;
integer8 id;	integer8 id;
	integer8 index;
	integer8 longueur;
integer8 position_clef;	integer8 position_clef;

integer8 longueur_effective;	integer8 longueur_effective;
integer8 longueur_enregistrement;	integer8 longueur_enregistrement;
integer8 longueur_questure;	integer8 longueur_questure;
Line 863 instruction_read(struct_processus *s_eta	Line 867 instruction_read(struct_processus *s_eta
integer8 position_finale;	integer8 position_finale;
integer8 position_initiale;	integer8 position_initiale;

	logical1 device;
logical1 format_degenere;	logical1 format_degenere;
	logical1 format_oriente_ligne;
logical1 indicateur_48;	logical1 indicateur_48;
logical1 presence_chaine;	logical1 presence_chaine;
logical1 presence_indicateur;	logical1 presence_indicateur;
logical1 trame_complete;	logical1 trame_complete;

long longueur;

socklen_t longueur_adresse;	socklen_t longueur_adresse;

sqlite3_stmt *ppStmt;	sqlite3_stmt *ppStmt;

struct flock lock;	struct flock lock;

	struct pollfd fds[1];

struct sockaddr_un adresse_unix;	struct sockaddr_un adresse_unix;
struct sockaddr_in adresse_ipv4;	struct sockaddr_in adresse_ipv4;
# ifdef IPV6	# ifdef IPV6
struct sockaddr_in6 adresse_ipv6;	struct sockaddr_in6 adresse_ipv6;
# endif	# endif

struct pollfd poll_fd;	struct termios tc;

struct timespec attente;	struct timespec attente;

Line 907 instruction_read(struct_processus *s_eta	Line 913 instruction_read(struct_processus *s_eta
unsigned char *tampon_lecture;	unsigned char *tampon_lecture;
unsigned char *tampon;	unsigned char *tampon;
unsigned char *tampon2;	unsigned char *tampon2;
	unsigned char *tampon3;

	int vitesses[] =
	{
	50, 75, 110, 134, 150, 200, 300, 600,
	1200, 1800, 2400, 4800, 9600, 19200, 38400,
	#ifdef B57600
	57600,
	#endif
	#ifdef B115200
	115200,
	#endif
	#ifdef B230400
	230400,
	#endif
	0
	};

	tcflag_t vitesses_constantes[] =
	{
	B50, B75, B110, B134, B150, B200, B300, B600,
	B1200, B1800, B2400, B4800, B9600, B19200, B38400,
	#ifdef B57600
	B57600,
	#endif
	#ifdef B115200
	B115200,
	#endif
	#ifdef B230400
	B230400,
	#endif
	0
	};

(*s_etat_processus).erreur_execution = d_ex;	(*s_etat_processus).erreur_execution = d_ex;

Line 923 instruction_read(struct_processus *s_eta	Line 962 instruction_read(struct_processus *s_eta
printf("(read a record of a file)\n\n");	printf("(read a record of a file)\n\n");
}	}

printf(" 1: %s, %s\n\n", d_FCH, d_SCK);	printf(" 1: %s, %s\n", d_FCH, d_SCK);
	printf("-> 1: %s\n\n", d_LST);

printf(" 2: %s, %s\n", d_INT, d_CHN);	printf(" 2: %s, %s\n", d_INT, d_CHN);
printf(" 1: %s\n", d_FCH);	printf(" 1: %s\n", d_FCH);
	printf("-> 1: %s\n\n", d_LST);
return;	return;
}	}
else if ((*s_etat_processus).test_instruction == 'Y')	else if ((*s_etat_processus).test_instruction == 'Y')
Line 1111 instruction_read(struct_processus *s_eta	Line 1152 instruction_read(struct_processus *s_eta
presence_chaine = d_faux;	presence_chaine = d_faux;
niveau = 1;	niveau = 1;

if (fseek((*descripteur).descripteur_c, position_finale,	if (fseek((*descripteur).descripteur_c, (long) position_finale,
SEEK_SET) != 0)	SEEK_SET) != 0)
{	{
liberation(s_etat_processus, s_objet_argument_1);	liberation(s_etat_processus, s_objet_argument_1);
Line 1201 instruction_read(struct_processus *s_eta	Line 1242 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (fseek((*descripteur).descripteur_c, position_initiale,	if (fseek((*descripteur).descripteur_c,
SEEK_SET) != 0)	(long) position_initiale, SEEK_SET) != 0)
{	{
liberation(s_etat_processus, s_objet_argument_1);	liberation(s_etat_processus, s_objet_argument_1);
free(tampon_lecture);	free(tampon_lecture);
Line 1237 instruction_read(struct_processus *s_eta	Line 1278 instruction_read(struct_processus *s_eta
indicateur_48 = test_cfsf(s_etat_processus, 48);	indicateur_48 = test_cfsf(s_etat_processus, 48);
cf(s_etat_processus, 48);	cf(s_etat_processus, 48);

	(*s_etat_processus).type_en_cours = NON;
recherche_type(s_etat_processus);	recherche_type(s_etat_processus);
free((*s_etat_processus).instruction_courante);	free((*s_etat_processus).instruction_courante);

Line 1292 instruction_read(struct_processus *s_eta	Line 1334 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (alsprintf(&commande, "select data from data where "	if (alsprintf(s_etat_processus, &commande,
"id = %lld", (((integer8 ) (*s_objet_argument_2)	"select data from data where id = %lld",
.objet))) < 0)	(((integer8 ) (*s_objet_argument_2).objet))) < 0)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_allocation_memoire;	d_es_allocation_memoire;
Line 1391 instruction_read(struct_processus *s_eta	Line 1433 instruction_read(struct_processus *s_eta
indicateur_48 = test_cfsf(s_etat_processus, 48);	indicateur_48 = test_cfsf(s_etat_processus, 48);
cf(s_etat_processus, 48);	cf(s_etat_processus, 48);

	(*s_etat_processus).type_en_cours = NON;
recherche_type(s_etat_processus);	recherche_type(s_etat_processus);

if ((*s_etat_processus).erreur_execution != d_ex)	if ((*s_etat_processus).erreur_execution != d_ex)
Line 1464 instruction_read(struct_processus *s_eta	Line 1507 instruction_read(struct_processus *s_eta

// Récupération de la position de la clef	// Récupération de la position de la clef

if (alsprintf(&commande, "select key from control "	if (alsprintf(s_etat_processus, &commande,
"where id = 1") < 0)	"select key from control where id = 1") < 0)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_allocation_memoire;	d_es_allocation_memoire;
Line 1538 instruction_read(struct_processus *s_eta	Line 1581 instruction_read(struct_processus *s_eta

// Récupération de l'identifiant de la clef	// Récupération de l'identifiant de la clef

if (alsprintf(&commande, "select id from key where key = "	if (alsprintf(s_etat_processus, &commande,
"'{ \"%s\" }'", clef_utf8) < 0)	"select id from key where key = '{ \"%s\" }'",
	clef_utf8) < 0)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_allocation_memoire;	d_es_allocation_memoire;
Line 1631 instruction_read(struct_processus *s_eta	Line 1675 instruction_read(struct_processus *s_eta

free(commande);	free(commande);

if (alsprintf(&commande, "select data from data where "	if (alsprintf(s_etat_processus, &commande,
	"select data from data where "
"key_id = %lld order by sequence asc", id) < 0)	"key_id = %lld order by sequence asc", id) < 0)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
Line 1698 instruction_read(struct_processus *s_eta	Line 1743 instruction_read(struct_processus *s_eta
indicateur_48 = test_cfsf(s_etat_processus, 48);	indicateur_48 = test_cfsf(s_etat_processus, 48);
cf(s_etat_processus, 48);	cf(s_etat_processus, 48);

	(*s_etat_processus).type_en_cours = NON;
recherche_type(s_etat_processus);	recherche_type(s_etat_processus);

if ((*s_etat_processus).erreur_execution != d_ex)	if ((*s_etat_processus).erreur_execution != d_ex)
Line 1760 instruction_read(struct_processus *s_eta	Line 1806 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (alsprintf(&tampon2, "{ \"%s\" }",	if (alsprintf(s_etat_processus, &tampon2,
(*s_etat_processus)	"{ \"%s\" }", (*s_etat_processus)
.instruction_courante) < 0)	.instruction_courante) < 0)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
Line 1776 instruction_read(struct_processus *s_eta	Line 1822 instruction_read(struct_processus *s_eta
indicateur_48 = test_cfsf(s_etat_processus, 48);	indicateur_48 = test_cfsf(s_etat_processus, 48);
cf(s_etat_processus, 48);	cf(s_etat_processus, 48);

	(*s_etat_processus).type_en_cours = NON;
recherche_type(s_etat_processus);	recherche_type(s_etat_processus);

if ((*s_etat_processus).erreur_execution	if ((*s_etat_processus).erreur_execution
Line 1976 instruction_read(struct_processus *s_eta	Line 2023 instruction_read(struct_processus *s_eta
BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n"));	BUG(((*descripteur).type != 'C'), uprintf("Bad filtype !\n"));
longueur_enregistrement = 0;	longueur_enregistrement = 0;

	device = d_faux;

if ((position_initiale = ftell((*descripteur).descripteur_c))	if ((position_initiale = ftell((*descripteur).descripteur_c))
== -1)	== -1)
{	{
(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;	if (errno == ESPIPE)
return;	{
	device = d_vrai;
	}
	else
	{
	(*s_etat_processus).erreur_systeme =
	d_es_erreur_fichier;
	return;
	}
}	}

l_element_courant_format = (struct_liste_chainee *)	l_element_courant_format = (struct_liste_chainee *)
Line 2008 instruction_read(struct_processus *s_eta	Line 2065 instruction_read(struct_processus *s_eta
return;	return;
}	}

if ((format_chaine = conversion_majuscule((unsigned char *)	if ((format_chaine = conversion_majuscule(
	s_etat_processus, (unsigned char *)
((l_element_courant_format).donnee).objet))	((l_element_courant_format).donnee).objet))
== NULL)	== NULL)
{	{
Line 2017 instruction_read(struct_processus *s_eta	Line 2075 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (strncmp("LENGTH*(", format_chaine, 8) != 0)	if (strcmp("LINE()", format_chaine) == 0)
{	{
liberation(s_etat_processus, s_objet_argument_1);	format_degenere = d_vrai;
liberation(s_etat_processus, s_objet_resultat);	format_oriente_ligne = d_vrai;
free(format_chaine);

(*s_etat_processus).erreur_execution =
d_ex_erreur_format_fichier;
return;
}	}
	else
longueur = (integer8) strlen(format_chaine);

if (format_chaine[longueur - 1] != ')')
{	{
liberation(s_etat_processus, s_objet_argument_1);	format_oriente_ligne = d_faux;
liberation(s_etat_processus, s_objet_resultat);
free(format_chaine);

(*s_etat_processus).erreur_execution =	if (strncmp("LENGTH*(", format_chaine, 8) != 0)
d_ex_erreur_format_fichier;	{
return;	liberation(s_etat_processus, s_objet_argument_1);
}	liberation(s_etat_processus, s_objet_resultat);
	free(format_chaine);

format_chaine[longueur] = d_code_fin_chaine;	(*s_etat_processus).erreur_execution =
	d_ex_erreur_format_fichier;
	return;
	}

if (format_chaine[8] == '*')	longueur = (integer8) strlen(format_chaine);
{
format_degenere = d_vrai;
}
else
{
// Détermination de la longueur
format_degenere = d_faux;

if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1)	if (format_chaine[longueur - 1] != ')')
{	{
liberation(s_etat_processus, s_objet_argument_1);	liberation(s_etat_processus, s_objet_argument_1);
liberation(s_etat_processus, s_objet_resultat);	liberation(s_etat_processus, s_objet_resultat);
Line 2062 instruction_read(struct_processus *s_eta	Line 2107 instruction_read(struct_processus *s_eta
d_ex_erreur_format_fichier;	d_ex_erreur_format_fichier;
return;	return;
}	}

	format_chaine[longueur] = d_code_fin_chaine;

	if (format_chaine[8] == '*')
	{
	format_degenere = d_vrai;
	}
	else
	{
	// Détermination de la longueur
	format_degenere = d_faux;

	if (sscanf(&(format_chaine[8]), "%lld", &longueur)
	!= 1)
	{
	liberation(s_etat_processus,
	s_objet_argument_1);
	liberation(s_etat_processus, s_objet_resultat);
	free(format_chaine);

	(*s_etat_processus).erreur_execution =
	d_ex_erreur_format_fichier;
	return;
	}
	}
}	}

free(format_chaine);	free(format_chaine);
	tampon3 = NULL;

if (format_degenere == d_vrai)	if (format_degenere == d_vrai)
{	{
	if (device == d_vrai)
	{
	longueur_questure = 4096;
	index = 0;

	if ((tampon3 = malloc(((size_t) longueur_questure) *
	sizeof(unsigned char))) == NULL)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_allocation_memoire;
	return;
	}

	tampon3[index] = d_code_fin_chaine;

	fds[0].fd = fileno((*descripteur).descripteur_c);
	fds[0].events = POLLIN;
	fds[0].revents = 0;

	tcgetattr(fileno((*descripteur).descripteur_c),
	&tc);
	timeout = 0;

	for(i = 0; vitesses[i] != 0; i++)
	{
	if (cfgetispeed(&tc) == vitesses_constantes[i])
	{
	// La durée entre deux caractères sur le
	// périphérique série ne doit pas dépasser
	// la moitié de la durée de transmission
	// d'un caractère complet.

	timeout = (int) (((double) 1000) /
	(((double) vitesses_constantes[i]) /
	4));
	break;
	}
	}
	}
	else
	{
	// Évite un warning de gcc.
	longueur_questure = 0;
	index = 0;
	timeout = 0;
	}

do	do
{	{
	if (device == d_vrai)
	{
	if (poll(fds, 1, timeout) == 0)
	{
	break;
	}
	}

c = getc((*descripteur).descripteur_c);	c = getc((*descripteur).descripteur_c);
longueur_enregistrement++;	longueur_enregistrement++;
} while((c != '\n') && (c != EOF));

if (fseek((*descripteur).descripteur_c,	if (device == d_vrai)
position_initiale, SEEK_SET) != 0)	{
	if (longueur_enregistrement >=
	longueur_questure)
	{
	if ((tampon3 = realloc(tampon3,
	(size_t) (longueur_questure *= 2)))
	== NULL)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_allocation_memoire;
	return;
	}
	}

	tampon3[index++] = (unsigned char) c;
	}

	if (format_oriente_ligne == d_vrai)
	{
	if (c == '\n')
	{
	break;
	}
	}
	} while(c != EOF);

	if (device == d_faux)
{	{
liberation(s_etat_processus, s_objet_argument_1);	if (fseek((*descripteur).descripteur_c,
liberation(s_etat_processus, s_objet_resultat);	(long) position_initiale, SEEK_SET) != 0)
	{
	liberation(s_etat_processus,
	s_objet_argument_1);
	liberation(s_etat_processus, s_objet_resultat);

(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_erreur_fichier;	d_es_erreur_fichier;
return;	return;
	}
}	}
}	}
else	else
Line 2090 instruction_read(struct_processus *s_eta	Line 2246 instruction_read(struct_processus *s_eta
longueur_enregistrement = longueur;	longueur_enregistrement = longueur;
}	}

if ((tampon_lecture = malloc(((size_t)	if ((device == d_vrai) && (format_degenere == d_vrai))
longueur_enregistrement) * sizeof(unsigned char)))
== NULL)
{	{
(*s_etat_processus).erreur_systeme =	longueur_effective = longueur_enregistrement;
d_es_allocation_memoire;	tampon_lecture = tampon3;
return;
}	}
	else
	{
	if ((tampon_lecture = malloc(((size_t)
	longueur_enregistrement) *
	sizeof(unsigned char))) == NULL)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_allocation_memoire;
	return;
	}

longueur_effective = (integer8) fread(tampon_lecture,	longueur_effective = (integer8) fread(tampon_lecture,
sizeof(unsigned char),	sizeof(unsigned char),
(size_t) longueur_enregistrement,	(size_t) longueur_enregistrement,
(*descripteur).descripteur_c);	(*descripteur).descripteur_c);
	}

if (l_element_courant == NULL)	if (l_element_courant == NULL)
{	{
Line 2142 instruction_read(struct_processus *s_eta	Line 2306 instruction_read(struct_processus *s_eta

if (format_degenere == d_vrai)	if (format_degenere == d_vrai)
{	{
if ((((l_element_courant).donnee).objet =	if (device == d_faux)
analyse_flux(s_etat_processus, tampon_lecture,
longueur_enregistrement - 1)) == NULL)
{	{
return;	if ((((l_element_courant).donnee).objet =
	analyse_flux(s_etat_processus, tampon_lecture,
	longueur_enregistrement - 1)) == NULL)
	{
	return;
	}
	}
	else
	{
	if ((((l_element_courant).donnee).objet =
	analyse_flux(s_etat_processus, tampon_lecture,
	longueur_enregistrement)) == NULL)
	{
	return;
	}
}	}
}	}
else	else
Line 2360 instruction_read(struct_processus *s_eta	Line 2536 instruction_read(struct_processus *s_eta
}	}

// Une donnée a été reçue.	// Une donnée a été reçue.
	// Attention : on peut TOUJOURS recevoir 0
	// indiquant que la socket est close.

if (ios >= 0)	if (ios >= 0)
{	{
Line 2367 instruction_read(struct_processus *s_eta	Line 2545 instruction_read(struct_processus *s_eta
position_initiale = 0;	position_initiale = 0;
presence_indicateur = d_faux;	presence_indicateur = d_faux;

do	if (ios > 0)
{	{
if (tampon_lecture[position_initiale] == '{')	do
{	{
presence_indicateur = d_vrai;	if (tampon_lecture[position_initiale] == '{')
break;	{
}	presence_indicateur = d_vrai;
	break;
	}

position_initiale++;	position_initiale++;
} while(position_initiale < longueur_effective);	} while(position_initiale < longueur_effective);
	}
	else
	{
	presence_indicateur = d_vrai;
	}

if (presence_indicateur == d_vrai)	if (presence_indicateur == d_vrai)
{	{
position_finale = position_initiale + 1;	position_finale = position_initiale + 1;
presence_chaine = d_faux;	presence_chaine = d_faux;
presence_indicateur = d_faux;	presence_indicateur = d_faux;
niveau = 1;	niveau = 0;

while(position_finale < longueur_effective)	while(position_finale < longueur_effective)
{	{
Line 2391 instruction_read(struct_processus *s_eta	Line 2576 instruction_read(struct_processus *s_eta

if (caractere == '"')	if (caractere == '"')
{	{
if (position_finale > 0)	if (tampon_lecture[position_finale - 1]
{	!= '\\')
if (tampon_lecture[position_finale - 1]
!= '\\')
{
presence_chaine = (presence_chaine ==
d_vrai) ? d_faux : d_vrai;
}
}
else
{	{
presence_chaine =	presence_chaine = (presence_chaine ==
(presence_chaine == d_vrai)	d_vrai) ? d_faux : d_vrai;
? d_faux : d_vrai;
}	}
}	}
else	else
Line 2498 instruction_read(struct_processus *s_eta	Line 2674 instruction_read(struct_processus *s_eta
}	}
else	else
{	{
// Installation d'un timeout pour sortir de	// Si on a lu toute une trame et qu'on n'a pas
// l'instruction dans le cas où la transmission serait	// réussi à en trouver la structure, on remonte
// invalide et que la trame reçue serait erronée.	// une erreur de syntaxe.

poll_fd.fd = (((struct_socket )
(*s_objet_argument_1).objet)).socket;
poll_fd.events = POLLIN;

while((ios = poll(&poll_fd, 1, 10000)) <= 0)	if (longueur_effective == ios)
{	{
// La fin de la trame n'est pas atteinte.	if ((((struct_socket ) (*s_objet_argument_1)
	.objet)).domaine == PF_UNIX)
switch(ios)
{	{
case EINTR:	do
{	{
if ((*s_etat_processus)	longueur_adresse = sizeof(adresse_unix);
.var_volatile_requete_arret == -1)	recvfrom((((struct_socket )
{	(*s_objet_argument_1).objet))
liberation(s_etat_processus,	.socket, tampon_lecture,
s_objet_argument_1);	(size_t) longueur_effective,
free(tampon_lecture);	0, (struct sockaddr *)
return;	&adresse_unix, &longueur_adresse);
}	} while((ios == -1) && (errno == EINTR));
	}
break;	else if ((((struct_socket ) (*s_objet_argument_1)
	.objet)).domaine == PF_INET)
	{
	do
	{
	longueur_adresse = sizeof(adresse_ipv4);
	recvfrom((((struct_socket )
	(*s_objet_argument_1).objet))
	.socket, tampon_lecture,
	(size_t) longueur_effective,
	0, (struct sockaddr *)
	&adresse_ipv4, &longueur_adresse);
	} while((ios == -1) && (errno == EINTR));
	}
	else if ((((struct_socket ) (*s_objet_argument_1)
	.objet)) .domaine == PF_INET6)
	{
	# ifdef IPV6
	do
	{
	longueur_adresse = sizeof(adresse_ipv6);
	recvfrom((((struct_socket )
	(*s_objet_argument_1).objet))
	.socket, tampon_lecture,
	(size_t) longueur_effective,
	0, (struct sockaddr *)
	&adresse_ipv6, &longueur_adresse);
	} while((ios == -1) && (errno == EINTR));
	# else
	if ((*s_etat_processus).langue == 'F')
	{
	printf("+++Attention : Support du protocole"
	" IPv6 indisponible\n");
}	}
	else
case 0:
{	{
liberation(s_etat_processus,	printf("+++Warning : IPv6 support "
s_objet_argument_1);	"unavailable\n");
free(tampon_lecture);

(*s_etat_processus).erreur_execution =
d_ex_fin_de_fichier_atteinte;
return;
}	}

	# endif
}	}

	liberation(s_etat_processus, s_objet_argument_1);
	free(tampon_lecture);

	(*s_etat_processus).erreur_execution = d_ex_syntaxe;
	return;
}	}
}	}
}	}
Line 2580 instruction_read(struct_processus *s_eta	Line 2785 instruction_read(struct_processus *s_eta
}	}
} while(trame_complete == d_faux);	} while(trame_complete == d_faux);

tampon_lecture[++position_finale] = d_code_fin_chaine;
tampon = (*s_etat_processus).instruction_courante;	tampon = (*s_etat_processus).instruction_courante;
(*s_etat_processus).instruction_courante = tampon_lecture;	(*s_etat_processus).instruction_courante = tampon_lecture;

indicateur_48 = test_cfsf(s_etat_processus, 48);	indicateur_48 = test_cfsf(s_etat_processus, 48);
cf(s_etat_processus, 48);	cf(s_etat_processus, 48);

	(*s_etat_processus).type_en_cours = NON;
recherche_type(s_etat_processus);	recherche_type(s_etat_processus);

if ((*s_etat_processus).erreur_execution != d_ex)	if ((*s_etat_processus).erreur_execution != d_ex)
Line 2973 instruction_read(struct_processus *s_eta	Line 3178 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (ios <= 0)	if (ios < 0)
{	{
nanosleep(&attente, NULL);	nanosleep(&attente, NULL);
INCR_GRANULARITE(attente.tv_nsec);	INCR_GRANULARITE(attente.tv_nsec);
Line 3004 instruction_read(struct_processus *s_eta	Line 3209 instruction_read(struct_processus *s_eta
position_initiale = 0;	position_initiale = 0;
presence_indicateur = d_faux;	presence_indicateur = d_faux;
}	}
else if (ios > 0)	else if (ios >= 0)
{	{
// On retire une trame du buffer.	// On retire une trame du buffer.

Line 3339 instruction_read(struct_processus *s_eta	Line 3544 instruction_read(struct_processus *s_eta
}	}
else	else
{ // FLOW	{ // FLOW
#if 0
longueur_questure = 256;	longueur_questure = 256;

do	do
{	{
if ((tampon_lecture = malloc((longueur_questure + 1) *	if ((tampon_lecture = malloc((((size_t) longueur_questure) + 1)
sizeof(unsigned char))) == NULL)	* sizeof(unsigned char))) == NULL)
{	{
(*s_etat_processus).erreur_systeme =	(*s_etat_processus).erreur_systeme =
d_es_allocation_memoire;	d_es_allocation_memoire;
Line 3373 instruction_read(struct_processus *s_eta	Line 3577 instruction_read(struct_processus *s_eta
longueur_adresse = sizeof(adresse_unix);	longueur_adresse = sizeof(adresse_unix);
longueur_effective = recvfrom((((struct_socket )	longueur_effective = recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket,	(*s_objet_argument_1).objet)).socket,
tampon_lecture, longueur_questure,	tampon_lecture, (long unsigned int)
	longueur_questure,
MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)	MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)
&adresse_unix, &longueur_adresse);	&adresse_unix, &longueur_adresse);
}	}
Line 3383 instruction_read(struct_processus *s_eta	Line 3588 instruction_read(struct_processus *s_eta
longueur_adresse = sizeof(adresse_ipv4);	longueur_adresse = sizeof(adresse_ipv4);
longueur_effective = recvfrom((((struct_socket )	longueur_effective = recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket,	(*s_objet_argument_1).objet)).socket,
tampon_lecture, longueur_questure,	tampon_lecture, (long unsigned int)
	longueur_questure,
MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)	MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)
&adresse_ipv4, &longueur_adresse);	&adresse_ipv4, &longueur_adresse);
}	}
Line 3394 instruction_read(struct_processus *s_eta	Line 3600 instruction_read(struct_processus *s_eta
longueur_adresse = sizeof(adresse_ipv6);	longueur_adresse = sizeof(adresse_ipv6);
longueur_effective = recvfrom((((struct_socket )	longueur_effective = recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket,	(*s_objet_argument_1).objet)).socket,
tampon_lecture, longueur_questure,	tampon_lecture, (long unsigned int)
	longueur_questure,
MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)	MSG_PEEK \| MSG_DONTWAIT, (struct sockaddr *)
&adresse_ipv6, &longueur_adresse);	&adresse_ipv6, &longueur_adresse);
# else	# else
Line 3493 instruction_read(struct_processus *s_eta	Line 3700 instruction_read(struct_processus *s_eta

if (longueur_effective == longueur_questure)	if (longueur_effective == longueur_questure)
{	{
	trame_complete = d_faux;
free(tampon_lecture);	free(tampon_lecture);
longueur_questure *= 2;
	// Taille standard des jumbo frames
	if (longueur_questure <= 9000)
	{
	longueur_questure *= 2;
	}
	else
	{
	longueur_questure += 9000;
	}
}	}
} while(longueur_effective == longueur_questure);	else
	{
	trame_complete = d_vrai;
	}
	} while(trame_complete == d_faux);

longueur_enregistrement = 1;	longueur_enregistrement = 1;

for(i = 0; i < longueur_effective; i++)	for(i = 0; i < longueur_effective; i++)
{	{
if (isprint(tampon_lecture[i]) != 0)	if (isprint(tampon_lecture[i]) == 0)
{	{
longueur_enregistrement += 4;	longueur_enregistrement += 4;
}	}
else	else
{	{
longueur_enregistrement++;	if ((tampon_lecture[i] == '"') \|\|
	(tampon_lecture[i] == '"'))
	{
	longueur_enregistrement += 2;
	}
	else
	{
	longueur_enregistrement++;
	}
}	}
}	}

Line 3522 instruction_read(struct_processus *s_eta	Line 3751 instruction_read(struct_processus *s_eta
return;	return;
}	}

if (((s_objet_type).objet = malloc(longueur_enregistrement	if (((*s_objet_type).objet = malloc((size_t) longueur_enregistrement
sizeof(unsigned char))) == NULL)	* sizeof(unsigned char))) == NULL)
{	{
(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;	(*s_etat_processus).erreur_systeme = d_es_allocation_memoire;
return;	return;
Line 3535 instruction_read(struct_processus *s_eta	Line 3764 instruction_read(struct_processus *s_eta
{	{
if (isprint(tampon_lecture[i]) != 0)	if (isprint(tampon_lecture[i]) != 0)
{	{
(*ptr) = tampon_lecture[i];	if ((tampon_lecture[i] == '"') \|\|
ptr++;	(tampon_lecture[i] == '"'))
	{
	(*ptr) = '\\';
	ptr++;
	(*ptr) = tampon_lecture[i];
	ptr++;
	}
	else
	{
	(*ptr) = tampon_lecture[i];
	ptr++;
	}
}	}
else	else
{	{
Line 3606 instruction_read(struct_processus *s_eta	Line 3846 instruction_read(struct_processus *s_eta
longueur_adresse = 0;	longueur_adresse = 0;
recvfrom((((struct_socket )	recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket, tampon_lecture,	(*s_objet_argument_1).objet)).socket, tampon_lecture,
position_finale, MSG_DONTWAIT,	(long unsigned int) longueur_effective, MSG_DONTWAIT,
NULL, &longueur_adresse);	NULL, &longueur_adresse);

(*s_objet_adresse).objet = NULL;	(*s_objet_adresse).objet = NULL;
Line 3617 instruction_read(struct_processus *s_eta	Line 3857 instruction_read(struct_processus *s_eta
longueur_adresse = sizeof(adresse_ipv4);	longueur_adresse = sizeof(adresse_ipv4);
recvfrom((((struct_socket )	recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket, tampon_lecture,	(*s_objet_argument_1).objet)).socket, tampon_lecture,
position_finale, MSG_DONTWAIT,	(long unsigned int) longueur_effective, MSG_DONTWAIT,
(struct sockaddr *) &adresse_ipv4, &longueur_adresse);	(struct sockaddr *) &adresse_ipv4, &longueur_adresse);

if (((*s_objet_adresse).objet =	if (((*s_objet_adresse).objet =
Line 3697 instruction_read(struct_processus *s_eta	Line 3937 instruction_read(struct_processus *s_eta
longueur_adresse = sizeof(adresse_ipv6);	longueur_adresse = sizeof(adresse_ipv6);
recvfrom((((struct_socket )	recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket, tampon_lecture,	(*s_objet_argument_1).objet)).socket, tampon_lecture,
position_finale, MSG_DONTWAIT,	(long unsigned int) longueur_effective, MSG_DONTWAIT,
(struct sockaddr *) &adresse_ipv6, &longueur_adresse);	(struct sockaddr *) &adresse_ipv6, &longueur_adresse);

if (((*s_objet_adresse).objet =	if (((*s_objet_adresse).objet =
Line 3778 instruction_read(struct_processus *s_eta	Line 4018 instruction_read(struct_processus *s_eta
longueur_adresse = 0;	longueur_adresse = 0;
recvfrom((((struct_socket )	recvfrom((((struct_socket )
(*s_objet_argument_1).objet)).socket, tampon_lecture,	(*s_objet_argument_1).objet)).socket, tampon_lecture,
position_finale, MSG_DONTWAIT,	(long unsigned int) longueur_effective, MSG_DONTWAIT,
NULL, &longueur_adresse);	NULL, &longueur_adresse);
}	}

Line 3789 instruction_read(struct_processus *s_eta	Line 4029 instruction_read(struct_processus *s_eta
{	{
return;	return;
}	}
#endif
}	}
}	}
else	else

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.76
changed lines
	Added in v.1.120