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.88 and 1.115

version 1.88, 2014/04/25 07:37:33	version 1.115, 2022/09/07 13:40:38
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.18	RPL/2 (R) version 4.1.34
Copyright (C) 1989-2014 Dr. BERTRAND Joël	Copyright (C) 1989-2021 Dr. BERTRAND Joël

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

Line 869 instruction_read(struct_processus *s_eta	Line 869 instruction_read(struct_processus *s_eta

logical1 device;	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;
Line 1275 instruction_read(struct_processus *s_eta	Line 1276 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 1330 instruction_read(struct_processus *s_eta	Line 1332 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 1429 instruction_read(struct_processus *s_eta	Line 1431 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 1502 instruction_read(struct_processus *s_eta	Line 1505 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 1576 instruction_read(struct_processus *s_eta	Line 1579 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 1669 instruction_read(struct_processus *s_eta	Line 1673 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 1736 instruction_read(struct_processus *s_eta	Line 1741 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 1798 instruction_read(struct_processus *s_eta	Line 1804 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 1814 instruction_read(struct_processus *s_eta	Line 1820 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 2056 instruction_read(struct_processus *s_eta	Line 2063 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 2065 instruction_read(struct_processus *s_eta	Line 2073 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]), "%lld", &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 2110 instruction_read(struct_processus *s_eta	Line 2105 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);
Line 2156 instruction_read(struct_processus *s_eta	Line 2176 instruction_read(struct_processus *s_eta
}	}
}	}
}	}
	else
	{
	// Évite un warning de gcc.
	longueur_questure = 0;
	index = 0;
	timeout = 0;
	}

do	do
{	{
Line 2187 instruction_read(struct_processus *s_eta	Line 2214 instruction_read(struct_processus *s_eta

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

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

if (device == d_faux)	if (device == d_faux)
Line 2755 instruction_read(struct_processus *s_eta	Line 2790 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 3507 instruction_read(struct_processus *s_eta	Line 3543 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 3541 instruction_read(struct_processus *s_eta	Line 3576 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 3551 instruction_read(struct_processus *s_eta	Line 3587 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 3562 instruction_read(struct_processus *s_eta	Line 3599 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 3690 instruction_read(struct_processus *s_eta	Line 3728 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 3774 instruction_read(struct_processus *s_eta	Line 3812 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 3785 instruction_read(struct_processus *s_eta	Line 3823 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 3865 instruction_read(struct_processus *s_eta	Line 3903 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 3946 instruction_read(struct_processus *s_eta	Line 3984 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 3957 instruction_read(struct_processus *s_eta	Line 3995 instruction_read(struct_processus *s_eta
{	{
return;	return;
}	}
#endif
}	}
}	}
else	else

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.88
changed lines
	Added in v.1.115