Procesos en C - Linux

-

-Willyam- #1 Nov '10

Un proceso padre tiene que generar dos procesos hijos.

El padre tiene que leer los datos de stdin ( por teclado) y tiene que enviarlos a los hijos.

El hijo 1: -Sacará por pantalla el texto leído del padre, a la salida estándar.
El hijo 2: -Sacará lo leído a un fichero.

Cuando el padre reciba “exit” como entrada, enviará señales de terminación a los hijos y se cerrará.

spoiler

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <signal.h>

pid_t pidHijo1();
pid_t pidHijo2();
int tuberia[2];

void procesoHijo1()
{
	char buffer[255];

close(tuberia[1]);
close(0);
dup (tuberia[0]);

for (;;)
{
	fgets(buffer,254,stdin);
	while (getc(stdin) != '\n');
	printf("[H] %s", buffer);
}
}

void procesoHijo2()
{
	char buffer[255];

close(tuberia[1]);
close(0);
dup (tuberia[0]);

for (;;)
{
	fgets(buffer,254,stdin);
	while (getc(stdin) != '\n');
	printf("[H] %s", buffer);
}
}
void procesoPadre()
{
	char buffer[255];

close(tuberia[0]);
close(2);
dup(tuberia[1],2);

fgets(buffer, 254, stdin);	

while(strlen(buffer) != 0 && buffer[0] != '\n')
{
	fprintf(stderr, "%s\n ", buffer);
	fgets(buffer, 254, stdin);
}

kill(pidHijo1, SIGTERM);
kill(pidHijo2, SIGTERM);
exit(0);
}

int main()
{
	pipe(tuberia);

pidHijo1 = fork();
pidHijo2 = fork();

if (pidHijo < 0)
{
	fprint(stderr, "Error en fork()\n");
	exit(-1);
}

if (pidHijo == 0)
{
	procesoHijo1();
	procesoHijo2();
}
else
{
	procesoPadre();
}
}

Esta es la idea inicial del ejercicio. Falta todavía organizar un poco el código ( es de 3º de Ing. Informática XD )...

Cualquier idea vuestra será bien recibida =)

P.D: Iré editando el código a medida que vaya avanzando.

Un saludo y gracias

Thanat0s #2 Nov '10 Cofrade

Buenas, ¿el enunciado no te dice que uses pipes? porque tiene toda la pinta y sería la forma más correcta de hacerlo.

pd: una vez digas si tienes que usar pipes o no te pasteo un código que te puede servir u otro

-

-Willyam- #3 Nov '10

Umm... Me había fijado en fork() en vez de en pipe()... Sí... Puedo utilizar pipe()... No tenía en mente en un principio usarlo pero ahora que lo mencionas voy a echarle un vistazo.

P.D: Pastea el código y lo comparo con lo que tengo en los apuntes para comprenderlo. Gracias Thanat0s

Thanat0s #4 Nov '10 Cofrade

El fork() lo tienes que seguir usando, pero el pipe además es la forma en que se comunican los procesos entre sí (ya que te dice que el padre lee y los hijos hacen cada uno una cosa diferente).

Te pasteo un programa resumen que me hice para aprobar una asignatura de linux en septiembre:

spoiler

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <fcntl.h>
#include <string.h>

#define MAX 128

//Cabeceras de métodos o funciones
void lectorEscritor1();
void lectorEscritor2();
void abanico1();
void abanico2();
void cadena1();
void cadena2();

//Programa principal
int main()
{
	char m[1];
	printf("Menú\n");
	printf("1- Lector-escritor entre proceso hijo y padre\n");
	printf("2- Lector-escritor con tubería con nombre\n");
	printf("3- Abanico de procesos\n");
	printf("4- Abanico en espera\n");
	printf("5- Cadena de procesos mostrando PID y PPID\n");
	printf("6- Cadena de procesos mostrando PID e hijo\n");
	if(read(0, m, 1)==-1) { perror("Error en el read"); close(1); }
	switch(atoi(m))
	{
		case 1:
			lectorEscritor1();
			break;
		case 2:
			lectorEscritor2();
			break;
		case 3:
			abanico1();
			break;
		case 4:
			abanico2();
			break;
		case 5:
			cadena1();
			break;
		case 6:
			cadena2();
			break;
		default: 
			printf("Error al introducir un número, cerrando el programa\n");
	}
	close(0);
}

//Lector escritor entre proceso padre e hijo
void lectorEscritor1()
{
	printf("Ejecutando programa 1\n");
	//Declaracion de variables
	int tub[2], nbytes;
	char mensaje[MAX];
	pid_t hijo;
	
//Creamos la tubería
pipe(tub);
//Creamos el hijo
hijo=fork();

switch (hijo)
{
	case -1: //Si se ha producido un error
		perror("Error en el fork");
		close(1);
		break;
		
	case 0: //Parte correspondiente al hijo
		close(tub[0]);
		do
		{
			nbytes=read(0, mensaje, MAX);
			if(mensaje[nbytes-1]=='\n') mensaje[nbytes-1]=0; //Para eliminar el salto de renglón
			write(tub[1], mensaje, strlen(mensaje));
		} while(strcmp(mensaje, "Q")!=0);
		close(tub[1]);
		close(0);
		break;
		
	default: //Parte correspondiente al padre
		close(tub[1]);
		while( (nbytes=read(tub[0], mensaje, MAX))>0 && strcmp(mensaje, "Q")!=0 )
		{
			mensaje[nbytes]='\0'; //Para hacer que sólo lea hasta donde ha leído y no la basura que hay en el array
			printf("Receptor: %d | %s\n", nbytes, mensaje);
		}
		close(tub[0]);
		break;
}
close(0);
}

//Lector escritor con tubería con nombre
void lectorEscritor2()
{
	printf("Ejecutando programa 2\n");
	//Declaracion de variables
	int fd, nbytes;
	char mensaje[MAX];
	pid_t hijo;
	
//Creamos el hijo
hijo=fork();

switch (hijo)
{
	case -1: //Si se ha producido un error
		perror("Error en el fork");
		close(1);
		break;
		
	case 0: //Parte correspondiente al hijo
		//Abrimos la tubería
		fd=open("tub", O_WRONLY);
		if(fd==-1)
		{
			perror("Error en la tubería");
			exit(1);
		}
		do
		{
			nbytes=read(0, mensaje, MAX);
			if(mensaje[nbytes-1]=='\n') mensaje[nbytes-1]=0; //Para eliminar el salto de renglón
			write(fd, mensaje, strlen(mensaje));
		} while(strcmp(mensaje, "Q")!=0);
		close(fd);
		close(0);
		break;
		
	default: //Parte correspondiente al padre
		//Abrimos la tubería
		fd=open("tub", O_RDONLY);
		if(fd==-1)
		{
			perror("Error en la tubería");
			exit(1);
		}
		while( (nbytes=read(fd, mensaje, MAX))>0 && strcmp(mensaje, "Q")!=0 )
		{
			mensaje[nbytes]='\0'; //Para hacer que sólo lea hasta donde ha leído y no la basura que hay en el array
			printf("Receptor: %d | %s\n", nbytes, mensaje);
		}
		close(fd);
		break;
}
}

//Abanico de procesos
void abanico1()
{
	printf("Ejecutando programa 3\n");
	//Declaración de variables
	int n=2,i;
	pid_t hijo;
	//Vamos creando los hijos
	for(i=0; i<n; i++)
	{
		hijo=fork();
		if(hijo==0) 
		{
			printf("Proceso %d con padre %d acaba de empezar en la posición %d\n", getpid(), getppid(),i+2);
			break;
		}
	}
	printf("El proceso %d ha terminado\n", getpid());
}

//Abanico de procesos en espera
void abanico2()
{
	printf("Ejecutando programa 4\n");
	//Declaración de variables
	int n=2,i,ret;
	pid_t hijo,estado;
	//Vamos creando los hijos
	for(i=0; i<n; i++)
	{
		hijo=fork();
		if(hijo==0) 
		{
			printf("Proceso %d con padre %d acaba de empezar en la posición %d\n", getpid(), getppid(),i+2);
			exit(i+2);
			break;
		}
	}
	while((ret=wait(&estado))!=-1)
	{
		printf("El proceso %d ha terminado en la posición %d\n", ret, estado >> 8);
	}
	printf("El proceso padre %d ha terminado\n", getpid());
}

//Cadena de procesos mostrando padre
void cadena1()
{
	printf("Ejecutando programa 5\n");
	//Declaración de variables
	int n=2,i,ret;
	pid_t hijo,estado;
	//Vamos creando los hijos
	for(i=0; i<n; i++)
	{
		hijo=fork();
		if(hijo>0)
			break;
	}
	wait(NULL);
	printf("Proceso con PID %d y padre con PPID %d\n",getpid(),getppid());
}

//Cadena de procesos mostrando hijos
void cadena2()
{
	printf("Ejecutando programa 6\n");
	//Declaración de variables
	int n=2,i,ret;
	pid_t hijo,estado;
	//Vamos creando los hijos
	for(i=0; i<n; i++)
	{
		hijo=fork();
		if(hijo>0)
			break;
	}
	ret=wait(NULL);
	if(ret!=-1) printf("Proceso con PID %d y con hijo %d\n",getpid(),ret);
	else printf("Proceso con PID %d no tiene hijos\n",getpid());
}

[/spolier]

Tienes ejemplos de lector-escritor con tubería anónima y una tubería normal.
Creación de procesos en abanico y cadena de procesos.

Vamos, un poco de todo lo que te pueden pedir este año (sin contar la parte de shell, que también tengo un resumen por si te interesa )

Saludos

1

-

-Willyam- #5 Nov '10

Madre qué crack XDDD

Gracias, voy a echarle un vistazo =)