procesob.c

three concurrent process in linux

#include <stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <sys/semaforo.h>
#include <errno.h>
#include <string.h>

#define size_info 45

typedef struct mensaje_completo 
{
	char cadena [size_info];	//campo de informacion
	int tamanio;			//campo tamanio
	char K;				//campo K remitente
	
} mensaje_completo;

mensaje_completo *mensajeMC1;	//El que se comparte con el proceso A
mensaje_completo *mensajeMC2;	//El que se comparte con el proceso C


int main ()
{
	int shm1; 			//Identificador de la zona de memoria MC1
	int shm2;			//Identificador de la zona de memoria MC2
	int i;				//Para controlar ciclos
	int size;
	char pb [] = ":PB";

	/*****************CREAR MEMORIA COMPARTIDA MC2**********************/
	//Lave para MC2 : 20
	shm2 = shmget(200, sizeof(mensaje_completo), IPC_CREAT|IPC_EXCL|SHM_R|SHM_W);
   	if(shm2 == -1 && errno == EEXIST)
      		shm2 = shmget(200, sizeof(mensaje_completo), SHM_R|SHM_W);
   	printf("Cree la zona de memoria MC2 %d\n",shm2);

	//lo enlazo a un proceso, mensaje apunta a la memoria compartida MC2
	mensajeMC2=(mensaje_completo *)shmat(shm2,NULL,0);
	/***************FIN MEMORIA COMPARTIDA*******************************/

	/************************CREAR SEMAFOROS************************/
	destruyeSemaforo(obtenSemaforo(3000));
	destruyeSemaforo(obtenSemaforo(4000));
	//Crear semaforo
	Crea_Semaforo (3000,1);	//Se_puede_escribir	(Proceso B - Proceso C)
	Crea_Semaforo (4000,0);	//Se_vale_leer		(Proceso B - Proceso C)
	
	/**************ACCESO A MEMORIA COMPARTIDA MC1***********************/
	printf("Estoy accesando la memoria compartida MC1\n");
   	shm1 = shmget(100, sizeof(mensaje_completo), SHM_R);
	mensajeMC1=(mensaje_completo *)shmat(shm1,NULL,0);
	/*************FIN DE ACCESO A LA MEMORIA COMPARTIDA MC1**************/
	
	while (1)
	{
			P(obtenSemaforo(2000));
			
			for(i = 0; i<size_info; i++)
			{
				mensajeMC2->cadena[i] = '\0';
			}
			mensajeMC2->tamanio = 0;
			mensajeMC2->K='A';

			//Copiar datos de MC1 a MC2
			mensajeMC2->tamanio = mensajeMC1->tamanio;
			mensajeMC2->K = mensajeMC1->K;
			size = mensajeMC2->tamanio;

			for(i = 0; i<size; i++)
			{
				mensajeMC2->cadena[i] = mensajeMC1->cadena[i];
			}
			V(obtenSemaforo(1000));
			//Como viene el mensaje
			/*printf("\nEl mensaje viene asi: \n");	
			printf("Mensaje: %s\n",mensajeMC2->cadena);
			printf("Tamanio: %d\n", mensajeMC2->tamanio);
			printf("Envia: %c\n\n",mensajeMC2->K);	
			*/

			P(obtenSemaforo(3000));
			//Concatenar :PB y actualizar tamanio del campo informacion		
			strcat(mensajeMC2->cadena,pb);
			mensajeMC2->tamanio = strlen(mensajeMC2->cadena);
			//Cambiar remitente
			mensajeMC2->K = 'B';
			
			//Mostrar informacion
			printf("\nInformacion: \n");	
			printf("Mensaje: %s\n",mensajeMC2->cadena);
			printf("Tamanio: %d\n", mensajeMC2->tamanio);
			printf("Envia: %c\n\n",mensajeMC2->K);	
			
			V(obtenSemaforo(4000));	
			
		
			
	}
	return 0;

}