procesoc.c

来自「three concurrent process in linux」· C语言 代码 · 共 98 行

#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 *mensajeMC2;	//El que se comparte con el proceso B
mensaje_completo *mensajeMC3;	//El que se comparte con el proceso A


int main ()
{
	int shm3; 			//Identificador de la zona de memoria MC3
	int shm2;			//Identificador de la zona de memoria MC2
	int i;				//Para controlar ciclos
	int size;
	char pc [] = ":PC";

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

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

	
	/**************ACCESO A MEMORIA COMPARTIDA MC2***********************/
	printf("Estoy accesando la memoria compartida MC2\n");
   	shm2 = shmget(200, sizeof(mensaje_completo), SHM_R);
	mensajeMC2=(mensaje_completo *)shmat(shm2,NULL,0);
	/*************FIN DE ACCESO A LA MEMORIA COMPARTIDA MC2**************/
	
	while (1)
	{
		P(obtenSemaforo(4000));
		
			for(i = 0; i<size_info; i++)
			{
				mensajeMC3->cadena[i] = '\0';
			}
			mensajeMC3->tamanio = 0;
			mensajeMC3->K='B';

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

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

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

}