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.80

version 1.76, 2013/03/20 22:24:37	version 1.80, 2013/06/21 14:15:55
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.13	RPL/2 (R) version 4.1.15
Copyright (C) 1989-2013 Dr. BERTRAND Joël	Copyright (C) 1989-2013 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.
Line 855 instruction_read(struct_processus *s_eta	Line 855 instruction_read(struct_processus *s_eta
integer8 i;	integer8 i;
integer8 id;	integer8 id;
integer8 position_clef;	integer8 position_clef;
	integer8 longueur;

integer8 longueur_effective;	integer8 longueur_effective;
integer8 longueur_enregistrement;	integer8 longueur_enregistrement;
integer8 longueur_questure;	integer8 longueur_questure;
Line 869 instruction_read(struct_processus *s_eta	Line 871 instruction_read(struct_processus *s_eta
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;
Line 883 instruction_read(struct_processus *s_eta	Line 883 instruction_read(struct_processus *s_eta
struct sockaddr_in6 adresse_ipv6;	struct sockaddr_in6 adresse_ipv6;
# endif	# endif

struct pollfd poll_fd;

struct timespec attente;	struct timespec attente;

struct_descripteur_fichier *descripteur;	struct_descripteur_fichier *descripteur;
Line 1111 instruction_read(struct_processus *s_eta	Line 1109 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 1199 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 2052 instruction_read(struct_processus *s_eta	Line 2050 instruction_read(struct_processus *s_eta
// Détermination de la longueur	// Détermination de la longueur
format_degenere = d_faux;	format_degenere = d_faux;

if (sscanf(&(format_chaine[8]), "%ld", &longueur) != 1)	if (sscanf(&(format_chaine[8]), "%lld", &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 2075 instruction_read(struct_processus *s_eta	Line 2073 instruction_read(struct_processus *s_eta
} while((c != '\n') && (c != EOF));	} while((c != '\n') && (c != EOF));

if (fseek((*descripteur).descripteur_c,	if (fseek((*descripteur).descripteur_c,
position_initiale, 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);
liberation(s_etat_processus, s_objet_resultat);	liberation(s_etat_processus, s_objet_resultat);
Line 2498 instruction_read(struct_processus *s_eta	Line 2496 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 )	if (longueur_effective == ios)
(*s_objet_argument_1).objet)).socket;
poll_fd.events = POLLIN;

while((ios = poll(&poll_fd, 1, 10000)) <= 0)
{	{
// 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;
}	}
}	}
}	}

CVSweb interface <joel.bertrand@systella.fr>

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