rpl/src/instructions_o1.c - diff

Return to instructions_o1.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/instructions_o1.c between versions 1.47 and 1.55

version 1.47, 2012/02/23 15:53:27	version 1.55, 2012/05/21 17:25:44
Line 1	Line 1
/*	/*
================================================================================	================================================================================
RPL/2 (R) version 4.1.6	RPL/2 (R) version 4.1.9
Copyright (C) 1989-2012 Dr. BERTRAND Joël	Copyright (C) 1989-2012 Dr. BERTRAND Joël

This file is part of RPL/2.	This file is part of RPL/2.
Line 919 instruction_open(struct_processus *s_eta	Line 919 instruction_open(struct_processus *s_eta

logical1 erreur;	logical1 erreur;
logical1 existence;	logical1 existence;
	logical1 negation;
logical1 ouverture;	logical1 ouverture;
logical1 presence_port;	logical1 presence_port;

Line 1030 instruction_open(struct_processus *s_eta	Line 1031 instruction_open(struct_processus *s_eta
" { \"stty\" { \"stty parameters\" ... } } } OPEN\n");	" { \"stty\" { \"stty parameters\" ... } } } OPEN\n");
printf(" { \"sockettype\" { \"name\" \"local name\" } } OPEN\n");	printf(" { \"sockettype\" { \"name\" \"local name\" } } OPEN\n");
printf(" { \"sockettype\" \"socketdomain\" \"protection\" } OPEN\n");	printf(" { \"sockettype\" \"socketdomain\" \"protection\" } OPEN\n");
printf(" \"/semaphore\" OPEN\n");	printf(" \"/semaphore\" OPEN\n\n");

printf(" File type : NEW/OLD/REPLACE/UNKNOWN/SCRATCH\n");	printf(" File type : NEW/OLD/REPLACE/UNKNOWN/SCRATCH\n");
printf(" File access : SEQUENTIAL/DIRECT/KEYED\n");	printf(" File access : SEQUENTIAL/DIRECT/KEYED\n");
Line 1046 instruction_open(struct_processus *s_eta	Line 1047 instruction_open(struct_processus *s_eta
printf(" IMAXBEL, OPOST, ONLCR, OCRNL, ONOCR, ONLRET,\n");	printf(" IMAXBEL, OPOST, ONLCR, OCRNL, ONOCR, ONLRET,\n");
printf(" OFILL, HUPCL, CLOCAL, CRTSCTS, ISIG, ICANON,\n");	printf(" OFILL, HUPCL, CLOCAL, CRTSCTS, ISIG, ICANON,\n");
printf(" ECHO, ECHOE, ECHOK, ECHONL, NOFLSH, TOSTOP,\n");	printf(" ECHO, ECHOE, ECHOK, ECHONL, NOFLSH, TOSTOP,\n");
printf(" IEXTEN, VEOF, VEOL, VERASE, VINTR, VKILL,\n");	printf(" IEXTEN\n");
printf(" VQUIT, VSTART, VSTOP, VSUSP\n");

printf(" Address : { \"ADDRESS\" [ 127 0 0 1 ] }\n");	printf(" Address : { \"ADDRESS\" [ 127 0 0 1 ] }\n");
printf(" { \"HOST\" \"hostname\" }\n");	printf(" { \"HOST\" \"hostname\" }\n");
Line 1069 instruction_open(struct_processus *s_eta	Line 1069 instruction_open(struct_processus *s_eta
printf(" Port : { \"PORT\" port number }\n");	printf(" Port : { \"PORT\" port number }\n");
printf(" Protocol : { \"PROTOCOL\" \"protocol\" }\n\n");	printf(" Protocol : { \"PROTOCOL\" \"protocol\" }\n\n");

printf(" { { \"NAME\" \"filename\" } } OPEN\n");	printf(" { { \"NAME\" \"filename\" } \"SEQUENTIAL\" } OPEN\n");
printf(" { \"SCRATCH\" } OPEN\n");	printf(" { \"SCRATCH\" } OPEN\n");
printf(" { { \"NAME\" \"filename\" } \"UNKNOWN\" \"FORMATTED\" "	printf(" { { \"NAME\" \"filename\" } \"UNKNOWN\" \"FORMATTED\" "
"\"DIRECT\" } OPEN\n");	"\"DIRECT\" } OPEN\n");
Line 1078 instruction_open(struct_processus *s_eta	Line 1078 instruction_open(struct_processus *s_eta
printf(" { \"STREAM\" \"READWRITE\" } OPEN\n");	printf(" { \"STREAM\" \"READWRITE\" } OPEN\n");
printf(" { \"FOREIGN\" \"DATAGRAM\" } OPEN\n");	printf(" { \"FOREIGN\" \"DATAGRAM\" } OPEN\n");
printf(" { \"LOCAL\" { \"NAME\" \"socket.sock\" } } OPEN\n");	printf(" { \"LOCAL\" { \"NAME\" \"socket.sock\" } } OPEN\n");
printf(" { \"/dev/ttyS1\" { \"STTY\" { \"9600,8,N,1\" "	printf(" { { \"NAME\" \"/dev/ttyS1\" } { \"STTY\" { \"9600,8,N,1\" "
"\"NO ICANON\" \"IGNBRK\" } }\n");	"\n { \"NO ICANON\" \"IGNBRK\" } } } OPEN\n");

return;	return;
}	}
Line 2272 instruction_open(struct_processus *s_eta	Line 2272 instruction_open(struct_processus *s_eta
else if (strcmp(argument_majuscule, "STTY") == 0)	else if (strcmp(argument_majuscule, "STTY") == 0)
{	{
if (((l_element_courant_sous_objet)	if (((l_element_courant_sous_objet)
.donnee).type == LST)	.donnee).type == CHN)
{	{
if (type_arguments == ' ')	if (type_arguments == ' ')
{	{
Line 2289 instruction_open(struct_processus *s_eta	Line 2289 instruction_open(struct_processus *s_eta
return;	return;
}	}

s_parametres_tty =	s_parametres_tty = (*l_element_courant).donnee;
(*l_element_courant_sous_objet).donnee;
}	}
}	}
else	else
Line 2646 instruction_open(struct_processus *s_eta	Line 2645 instruction_open(struct_processus *s_eta

free(argument_majuscule);	free(argument_majuscule);
}	}
	else if (strcmp(argument_majuscule, "STTY") == 0)
	{
	if (type_arguments == ' ')
	{
	type_arguments = 'F';
	}
	else if (type_arguments == 'S')
	{
	liberation(s_etat_processus, s_objet_argument);
	free(argument_majuscule);

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

	free(argument_majuscule);

	l_element_courant_sous_objet =
	(*l_element_courant_sous_objet).suivant;

	if (((l_element_courant_sous_objet)
	.donnee).type != CHN)
	{
	liberation(s_etat_processus, s_objet_argument);

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

	l_element_courant_sous_objet =
	(*l_element_courant_sous_objet).suivant;

	if (((l_element_courant_sous_objet)
	.donnee).type != LST)
	{
	liberation(s_etat_processus, s_objet_argument);

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

	s_parametres_tty = (*l_element_courant).donnee;
	}
else	else
{	{
liberation(s_etat_processus, s_objet_argument);	liberation(s_etat_processus, s_objet_argument);
Line 3537 instruction_open(struct_processus *s_eta	Line 3582 instruction_open(struct_processus *s_eta
return;	return;
}	}

parametre_courant = (*s_parametres_tty).objet;	// Un test a déjà été fait pour vérifier que s_parametres_tty
	// contient deux ou trois arguments.

	parametre_courant = (((struct_liste_chainee )
	(*s_parametres_tty).objet)).suivant;

// Le premier paramètre concerne la vitesse du port. Il doit	// Le premier paramètre concerne la vitesse du port. Il doit
// toujours être présent.	// toujours être présent.
Line 3600 instruction_open(struct_processus *s_eta	Line 3649 instruction_open(struct_processus *s_eta
// Vitesse	// Vitesse

unsigned char *vitesses[] =	unsigned char *vitesses[] =
{ "B0", "B50", "B75", "B110", "B134", "B150",	{ "0", "50", "75", "110", "134", "150",
"B200", "B300", "B600", "B1200", "B1800", "B2400",	"200", "300", "600", "1200", "1800", "2400",
"B4800", "B9600", "B19200", "B38400", "B57600",	"4800", "9600", "19200", "38400", "57600",
"B115200", "B230400", NULL };	"115200", "230400", NULL };
int vitesses_constantes[] =	int vitesses_constantes[] =
{ B0, B50, B75, B110, B134, B150, B200, B300, B600,	{ B0, B50, B75, B110, B134, B150, B200, B300, B600,
B1200, B1800, B2400, B4800, B9600, B19200, B38400,	B1200, B1800, B2400, B4800, B9600, B19200, B38400,
Line 3757 instruction_open(struct_processus *s_eta	Line 3806 instruction_open(struct_processus *s_eta
}	}
}	}

	position++;

if ((*position) != d_code_espace)	if ((*position) != d_code_espace)
{	{
free(parametre_courant_majuscule);	free(parametre_courant_majuscule);
Line 3809 instruction_open(struct_processus *s_eta	Line 3860 instruction_open(struct_processus *s_eta
// S'il reste autre chose que des espaces, il y a un	// S'il reste autre chose que des espaces, il y a un
// problème de paramètres.	// problème de paramètres.

	position++;

while((*position) != d_code_fin_chaine)	while((*position) != d_code_fin_chaine)
{	{
if ((*position) != d_code_espace)	if ((*position) != d_code_espace)
Line 3828 instruction_open(struct_processus *s_eta	Line 3881 instruction_open(struct_processus *s_eta
// Autres paramètres	// Autres paramètres

free(parametre_courant_majuscule);	free(parametre_courant_majuscule);
	parametre_courant = (*parametre_courant).suivant;

	if (parametre_courant != NULL)
	{
	parametre_courant = ((parametre_courant).donnee).objet;
	}

while(parametre_courant != NULL)	while(parametre_courant != NULL)
{	{
	if (((parametre_courant).donnee).type != CHN)
	{
	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

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

	if ((parametre_courant_majuscule = conversion_majuscule(
	((parametre_courant).donnee).objet)) == NULL)
	{
	(*s_etat_processus).erreur_systeme =
	d_es_allocation_memoire;
	return;
	}

	position = parametre_courant_majuscule;
	negation = d_faux;

	unsigned char *fonctions[] =
	{ "IGNBRK", "BRKINT", "IGNPAR", "PARMRK",
	"INPCK", "ISTRIP", "INLCR", "IGNCR", "ICRNL",
	"IXON", "IXANY", "IXOFF", "OPOST",
	"ONLCR", "OCRNL", "ONOCR", "ONLRET",
	"OFILL", "HUPCL", "CLOCAL", "CRTSCTS",
	"ISIG", "ICANON", "ECHO", "ECHOE", "ECHOK",
	"ECHONL", "NOFLSH", "TOSTOP", "IEXTEN", NULL };
	int fonctions_constantes[] =
	{ /* c_iflag */
	1, IGNBRK, 1, BRKINT, 1, IGNPAR, 1, PARMRK,
	1, INPCK, 1, ISTRIP, 1, INLCR, 1, IGNCR, 1, ICRNL,
	1, IXON, 1, IXANY, 1, IXOFF,
	/* c_oflag */
	2 , OPOST, 2, ONLCR, 2, OCRNL, 2, ONOCR, 2, ONLRET,
	2, OFILL, 2, HUPCL,
	/* c_cflag */
	3, CLOCAL, 3, CRTSCTS,
	/* c_lfkag */
	4, ISIG, 4, ICANON, 4, ECHO, 4, ECHOE, 4, ECHOK,
	4, ECHONL, 4, NOFLSH, 4, TOSTOP, 4, IEXTEN };
	unsigned int fonction_courante;

	// On vient de trouver quelque chose à interpréter.

	if (strncmp(position, "NO ", 3) == 0)
	{
	position += 3;
	negation = d_vrai;
	}

	for(fonction_courante = 0;
	fonctions[fonction_courante] != NULL;
	fonction_courante++)
	{
	if (strcmp(fonctions[fonction_courante], position)
	== 0)
	{
	if (negation == d_vrai)
	{
	switch(fonctions_constantes
	[fonction_courante * 2])
	{
	case 1:
	{
	tc.c_iflag &= ~fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 2:
	{
	tc.c_oflag &= ~fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 3:
	{
	tc.c_cflag &= ~fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 4:
	{
	tc.c_lflag &= ~fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}
	}
	}
	else
	{
	switch(fonctions_constantes
	[fonction_courante * 2])
	{
	case 1:
	{
	tc.c_iflag \|= fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 2:
	{
	tc.c_oflag \|= fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 3:
	{
	tc.c_cflag \|= fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}

	case 4:
	{
	tc.c_lflag \|= fonctions_constantes
	[(fonction_courante * 2) + 1];
	break;
	}
	}
	}

	break;
	}
	}

	if (fonctions[fonction_courante] == NULL)
	{
	free(parametre_courant_majuscule);
	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

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

	free(parametre_courant_majuscule);
parametre_courant = (*parametre_courant).suivant;	parametre_courant = (*parametre_courant).suivant;
}	}

Line 4512 instruction_open(struct_processus *s_eta	Line 4715 instruction_open(struct_processus *s_eta
= protection;	= protection;
((((struct_socket ) (s_objet_resultat).objet))	((((struct_socket ) (s_objet_resultat).objet))
.format).objet = NULL;	.format).objet = NULL;
	(((struct_socket ) (*s_objet_resultat).objet)).adresse = NULL;

switch(type_socket)	switch(type_socket)
{	{
Line 4775 instruction_open(struct_processus *s_eta	Line 4979 instruction_open(struct_processus *s_eta
return;	return;
}	}

	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(22 *	.objet)).adresse = malloc(22 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 4879 instruction_open(struct_processus *s_eta	Line 5086 instruction_open(struct_processus *s_eta
return;	return;
}	}

	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(55 *	.objet)).adresse = malloc(55 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 4910 instruction_open(struct_processus *s_eta	Line 5120 instruction_open(struct_processus *s_eta
printf("+++Warning : IPv6 support "	printf("+++Warning : IPv6 support "
"unavailable\n");	"unavailable\n");
}	}

	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

	freeaddrinfo(resolution);

	(*s_etat_processus).erreur_execution =
	d_ex_instruction_indisponible;
	return;
# endif	# endif
}	}

Line 4924 instruction_open(struct_processus *s_eta	Line 5143 instruction_open(struct_processus *s_eta
{ // Hôte défini par une adresse	{ // Hôte défini par une adresse
if (strcmp(protocole, "IPV4") == 0)	if (strcmp(protocole, "IPV4") == 0)
{ // Accès en IPv4	{ // Accès en IPv4
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(22 *	.objet)).adresse = malloc(22 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 4999 instruction_open(struct_processus *s_eta	Line 5221 instruction_open(struct_processus *s_eta
else	else
{ // Accès en IPv6	{ // Accès en IPv6
# ifdef IPV6	# ifdef IPV6
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(55 *	.objet)).adresse = malloc(55 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5080 instruction_open(struct_processus *s_eta	Line 5305 instruction_open(struct_processus *s_eta
printf("+++Warning : IPv6 support "	printf("+++Warning : IPv6 support "
"unavailable\n");	"unavailable\n");
}	}

	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

	(*s_etat_processus).erreur_execution =
	d_ex_instruction_indisponible;
	return;
# endif	# endif
}	}
}	}
Line 5313 instruction_open(struct_processus *s_eta	Line 5545 instruction_open(struct_processus *s_eta
.socket_en_ecoute = 'N';	.socket_en_ecoute = 'N';
}	}

	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(22 *	.objet)).adresse = malloc(22 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5419 instruction_open(struct_processus *s_eta	Line 5654 instruction_open(struct_processus *s_eta
.socket_en_ecoute = 'N';	.socket_en_ecoute = 'N';
}	}

	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(55 *	.objet)).adresse = malloc(55 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5450 instruction_open(struct_processus *s_eta	Line 5688 instruction_open(struct_processus *s_eta
printf("+++Warning : IPv6 support "	printf("+++Warning : IPv6 support "
"unavailable\n");	"unavailable\n");
}	}

	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

	freeaddrinfo(resolution);

	(*s_etat_processus).erreur_execution =
	d_ex_instruction_indisponible;
	return;
# endif	# endif
}	}

Line 5466 instruction_open(struct_processus *s_eta	Line 5713 instruction_open(struct_processus *s_eta
{ // Accès en IPv4	{ // Accès en IPv4
if (type_adresse == '4')	if (type_adresse == '4')
{	{
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(22 *	.objet)).adresse = malloc(22 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5495 instruction_open(struct_processus *s_eta	Line 5745 instruction_open(struct_processus *s_eta
}	}
else	else
{	{
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(	.objet)).adresse = malloc(
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5562 instruction_open(struct_processus *s_eta	Line 5815 instruction_open(struct_processus *s_eta
# ifdef IPV6	# ifdef IPV6
if (type_adresse == '6')	if (type_adresse == '6')
{	{
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(55 *	.objet)).adresse = malloc(55 *
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5592 instruction_open(struct_processus *s_eta	Line 5848 instruction_open(struct_processus *s_eta
}	}
else	else
{	{
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(	.objet)).adresse = malloc(
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)
Line 5662 instruction_open(struct_processus *s_eta	Line 5921 instruction_open(struct_processus *s_eta
printf("+++Warning : IPv6 support "	printf("+++Warning : IPv6 support "
"unavailable\n");	"unavailable\n");
}	}

	liberation(s_etat_processus, s_objet_argument);
	liberation(s_etat_processus, s_objet_resultat);

	(*s_etat_processus).erreur_execution =
	d_ex_instruction_indisponible;
	return;
# endif	# endif
}	}
else	else
{ // Socket UNIX	{ // Socket UNIX
	free((((struct_socket ) (*s_objet_resultat)
	.objet)).adresse);

if (((((struct_socket ) (*s_objet_resultat)	if (((((struct_socket ) (*s_objet_resultat)
.objet)).adresse = malloc(	.objet)).adresse = malloc(
sizeof(unsigned char))) == NULL)	sizeof(unsigned char))) == NULL)

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.47
changed lines
	Added in v.1.55