lab8-4

#include <semaphore.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <sys/stat.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <err.h>
#include <unistd.h>

#define MAX 50

int counter=0;// licznik

static struct sembuf semaphor; // deklaracja semafora

void push(int, int); // podnoszenie

void pop(int, int); // opuszczanie

//--MAIN

int main(){
	int shmid, semid;
	char* buf;

	//tworzenie tablicy semaforow
	semid = semget(34170, 2, IPC_CREAT | 0600);

	//nadawanie wartosci semaforowi
	semctl(semid, 0, SETVAL, (int) 1);
    semctl(semid, 1, SETVAL, (int) 0);


	//tworzenie segmentu pamieci wspoldzielonej
	shmid = shmget(56392, MAX, IPC_CREAT | 0600);

	// przylaczanie pamieci wspoldzielonej
    buf = shmat(shmid, NULL, 0);


    pid_t p1, p2, p3;

    // KONSUMENT 1
    if ((p1 = fork()) == 0) { // in child process
        while (1) {
            if (buf[0] != '/') {
                pop(semid, 1);
                fflush(stdout);
                printf("\tp1 PID: %d : %s \n", getpid(), buf);
                fflush(stdout);
                push(semid, 0);
            }
            //exit(1);
        }

    }

    // KONSUMENT 2
    if ((p2 = fork()) == 0) {
        while (1) {
            if (buf[0] != '/') {
                pop(semid, 1);
                fflush(stdout);
                printf("\tp2 PID: %d : %s \n", getpid(), buf);
                fflush(stdout);
                push(semid, 0);
            }
            //exit(1);
        }

    }

    // KONSUMENT 3
    if ((p3 = fork()) == 0) {
        while (1) {
            if (buf[0] != '/') {
                pop(semid, 1);
                fflush(stdout);
                printf("\tp3 PID: %d : %s \n", getpid(), buf);
                fflush(stdout);
                push(semid, 0);
            }
            //exit(1);
        }

    }

 int i=0,j=0;
	//-- PRODUCENT
    for(;;){
        char input[50];

        if(i==0){
			printf("p0 %d produkt:", getpid());
			scanf("%s", input);
		}
        pop(semid, 0);

        if((i!=0)!=0){
			printf("p0 %d produkt:", getpid());
			scanf("%s", input);

        strcpy(buf, input);
        for(j=(i%3)+1; j!=0;j--) push(semid, 1);
	}else push(semid,1);
        i++;
    }

    exit(0);
}

//--SEMAFORY
void push(int semid, int semnum){
	semaphor.sem_flg=0; // flaga
	semaphor.sem_num=semnum; // numer
	semaphor.sem_op = 1; // operacja
	if(semop(semid, &semaphor, 1) == -1){
		printf("Semafor podniesiony");
		exit(1);
	}
	//else printf("ERROR push");
}

void pop(int semid, int semnum){
	semaphor.sem_flg=0; // flaga
	semaphor.sem_num=semnum; // numer
	semaphor.sem_op = -1; // operacja
	if(semop(semid, &semaphor, 1) == -1){
		printf("Semafor podniesiony");
		exit(1);
	}
	 //else printf("ERROR pop");
}