#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h> 
#include <sys/ipc.h> 
#include <sys/shm.h>
#include <curses.h>
#include <ctype.h>
#include "constantes.h"
#include "types.h"
#include "sema.h"

WINDOW *creation_fenetre(int n,int d,char *t);
int main( int argc, char **argv)
{
	if(argc < 2) { printf("Usage %s numIPC\n", argv[0]); exit(EXIT_FAILURE); }
	MEMP *memoireP; 
	MSG temp;
	int mutex_data, mutex_tpa, sem_global, continuer = 0, i=0, tete;
	char c;
	MSG message;
    const char CTRL_D = 4 ;
	int shmid; 
	int shm_key = atoi(argv[1]);

    WINDOW * fenetre ;

    initscr() ;			/* initialisation (obligatoire) de curses */
    noecho() ;			/* suppression de l'echo des caracteres tapes*/
    cbreak() ;			/* lecture non bufferisee */

	key_t sem_key_data = MUTEX_DATA;
	key_t sem_key_glob = MUTEX_GLOB;
	key_t sem_key_tpa = MUTEX_TPA;

	shmid = shmget(shm_key, sizeof(MEMP), 0766 | IPC_CREAT); 

	if (shmid == -1) { perror("shmget"); exit(EXIT_FAILURE); }

	if((memoireP = (MEMP *) shmat(shmid, 0 , 0766)) ==(void *) -1)	{ perror("shmat"); exit(EXIT_FAILURE); }
	if((mutex_data = open_sem( sem_key_data)) == -1)	{ perror("open_sem"); exit(EXIT_FAILURE); }
	if((mutex_tpa = open_sem( sem_key_tpa)) == -1)		{ perror("open_sem"); exit(EXIT_FAILURE); }
	if((sem_global = open_sem( sem_key_glob)) == -1)	{ perror("open_sem"); exit(EXIT_FAILURE); }

	// sem_global est un sémaphore à MAX_PROD entrants.
	//P(sem_global);
	P(mutex_tpa);
		for(i = 0; i < MAX_PROD && memoireP->tpa[i] != -1 ; i++);
	V(mutex_tpa);
	
	if(memoireP->tpa[i] != -1) { exit(EXIT_FAILURE); }
	memoireP->tpa[i] = 0;

    fenetre = creation_fenetre(LINES,0,"PRODUCTEUR") ;

	// On quitte le producteur en tappant CTRL_D
    while (( c = wgetch(fenetre)) != CTRL_D)
	{

		P(mutex_data);
			if(((memoireP->queue -1) % MAX_BUF) != (memoireP->tete % MAX_BUF) )
			{
				temp = (MSG) memoireP->f[memoireP->tete];
				temp.c = (char) c;
				temp.idp = i;
				tete = (int) memoireP->tete;
				memoireP->f[tete] = (MSG) temp;
				tete++;
				memoireP->tete = (int) tete;
			}
		V(mutex_data);

        waddch(fenetre,c) ;
        wrefresh(fenetre) ; 
	}
	// On a fini, on remet la valeur de l'indice du processus à -1 dans le tableau des producteurs
	P(mutex_tpa);
		memoireP->tpa[i] = -1;	
	V(mutex_tpa);

	// On a fini, on libère l'accès à un autre producteur
	//V(sem_global);

    endwin();
	return (EXIT_SUCCESS); 

}

WINDOW *creation_fenetre(int n,int d,char *t)
{
    WINDOW *cadre ;			/* la fenetre pour le cadre */
    WINDOW *w ;			/* la fenetre de dialogue */
    
    /* creation du cadre */

    cadre= newwin(n,COLS,d,0) ;
    box(cadre,0,0) ;
    mvwprintw(cadre,0,COLS/2-strlen(t)/2,t) ;
    wrefresh(cadre) ;
    
    /* creation de la fenetre de dialogue */

    w= newwin(n-2,COLS-2,d+1,1) ;
    idlok(w,TRUE) ;
    scrollok(w,TRUE) ;	   /* mise en place du defilement (scrolling) */
    wclear(w) ;
    wrefresh(w) ;
    return w ;
}