Productores

SO_Proy_Prod.c

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/sem.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <unistd.h>


#define CONSUMIDOR 1
#define PRODUCTOR 0

 typedef struct mystruct{
      char tipo; //Llam o msg
	  char msg[100];
	  char edo; //Vacio / Lleno
	  char destino;
} memoria;

void wait(int who, int control){
	struct sembuf operacion;
	operacion.sem_num = who;
	operacion.sem_op = -1;
	operacion.sem_flg = SEM_UNDO;
	semop(control, &operacion, 1 );
}

void signal(int who, int control){
	struct sembuf operacion;
	operacion.sem_num = who;
	operacion.sem_op = 1;
	operacion.sem_flg = SEM_UNDO;
	semop(control, &operacion, 1 );
}

int main(){
	int shmid, clean;
	memoria *globales;
	key_t key;

	if ((key = ftok("1.c", 'J')) == -1) {
		perror("ftok");
		exit(1);
	}

	if ((shmid = shmget(key, 20 * sizeof(memoria), (memoria)IPC_CREAT | 0666)) < 0) {
		perror("shmget");
		exit(1);
	}

	if ((globales = (memoria)shmat(shmid, 0, 0)) == (int*)-1) {
		perror("shmat");
		exit(1);
	}

	if ( (globales[0] = semget(key, 20, IPC_CREAT | 0600)) < 0 ) {
		printf("Error SEMGET\n");
		exit(-1);
	}

	//Verificar cuando es que el productor mete datos
	// Cada proceso opera 10 veces * 3 procesos
	/*
	for (size_t k = 0; k < 10; k++) {
		wait(PRODUCTOR,globales[0]);
		printf("Productor: [");
		for (size_t g = 0; g < 10; g++) {       // Cada operacion llena 10 espacios
			globales[g+2] = globales[1]++;
			printf("%d", globales[g+2] + 1);
			if(g!=9) printf(",");
		}
		printf("]\n");
		signal(CONSUMIDOR,globales[0]);
	}
	*/


	shmdt(globales);
	return 0;
}