#include <stdio.h>
#include <string.h> /* strerror */
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include "LRMonitor.h"

#define NB_MAX_LECTEURS   10
#define NB_MAX_REDACTEURS 10
#define NB_LECTURES        5
#define NB_ECRITURES       6

// Moniteur de Hoare
LRMonitor m;
int fd;

/*---------------------------------------------------------------------*/
void thdErreur(int codeErr, const char *msgErr, void *codeArret) {
/*---------------------------------------------------------------------*/
  fprintf(stderr, "%s: %d soit %s \n", msgErr, codeErr, strerror(codeErr));
  pthread_exit(codeArret);
}

/*---------------------------------------------------------------------*/
void *threadLecteur(void *arg) {
/*---------------------------------------------------------------------*/
  int nbLus, i;
  int *monNum = (int *)arg;
  char unCar;

  for (i = 0; i < NB_LECTURES; i++) {
    // Demander a pouvoir acceder en lecture au fichier partage
    m.debutLecture();

    // Se positionner au debut de fichier
    if (lseek(fd, 0, SEEK_SET) < 0)
      thdErreur(errno, "Lseek debut fichier", monNum);

    printf("Lecteur %d: Lecture de :\n", *monNum);
    // Lire caractere par caractere jusqu'� fin fichier
    // en affichant les caracteres lus
    do {
      if ((nbLus = read(fd, &unCar, sizeof(char))) < 0)
        thdErreur(errno, "Read fichier lecture", monNum);
      if (nbLus > 0)
        printf("%c", unCar);

      // Temporiser eventuellement avec usleep() pour perdre du temps
    } while (nbLus > 0);
    printf("\n");

    // Signaler la fin de l'acces en lecture au fichier partage
    m.finLecture();
    }
  printf ("Lecteur %d, j'ai fini mon execution \n", *monNum);
  pthread_exit(NULL);
}

/*---------------------------------------------------------------------*/
void *threadRedacteur(void *arg) {
/*---------------------------------------------------------------------*/
  int i, nbEcrits;
  int *monNum = (int *)arg;
  char monCar = *monNum+65;

  for (i = 0; i < NB_ECRITURES; i++) {
    // Demander a pouvoir acceder en ecriture au fichier partage
    m.debutEcriture();

    // S'appreter a ecrire en fin de fichier
    if (lseek(fd, 0, SEEK_END) < 0)
      thdErreur(errno, "Lseek fin fichier", monNum);

    if ((nbEcrits = write(fd, &monCar, 1)) < 0)
      thdErreur(errno, "Write fichier", monNum);

    // Temporiser eventuellement avec usleep() pour prendre plus de temps

    printf("Redacteur %d: Ecriture de %c \n", *monNum, monCar);

    // Signaler la fin de l'acces en ecriture au fichier partage
    m.finEcriture();
    }
  printf ("Redacteur %d, j'ai fini mon execution \n", *monNum);
  pthread_exit(NULL);
}

int main(int argc, char*argv[]) {
/*---------------------------------------------------------------------*/
  pthread_t lesLecteurs[NB_MAX_LECTEURS];
  pthread_t lesRedacteurs[NB_MAX_REDACTEURS];
  int       rangLecteurs[NB_MAX_LECTEURS];
  int       rangRedacteurs[NB_MAX_REDACTEURS];
  int nbLecteurs, nbRedacteurs;
  int i, etat;

  if (argc != 3) {
    printf("Usage: %s <Nb lecteurs <= %d> <Nb redacteurs <= %d> \n",
            argv[0], NB_MAX_LECTEURS, NB_MAX_REDACTEURS);
    exit(1);
  }

  nbLecteurs = atoi(argv[1]);
  if (nbLecteurs > NB_MAX_LECTEURS)
    nbLecteurs = NB_MAX_LECTEURS;

  nbRedacteurs = atoi(argv[2]);
  if (nbRedacteurs > NB_MAX_REDACTEURS)
    nbRedacteurs = NB_MAX_REDACTEURS;

  /* Creation du fichier partage */
  if ((fd = open("LectRed_shared", O_RDWR|O_CREAT, 0666)) < 0) {
    printf("Erreur ouverture fichier %s\n", strerror(errno));
    exit(1);
  }

  /* Lancement des threads lecteurs et redacteurs */
  for (i = 0; i < nbLecteurs; i++) {
    rangLecteurs[i] = i;
    if ((etat = pthread_create(&lesLecteurs[i], NULL,
                               threadLecteur, &rangLecteurs[i])) != 0)
      thdErreur(etat, "Creation lecteurs", NULL);
  }

  for (i = 0; i < nbRedacteurs; i++) {
    rangRedacteurs[i] = i;
    if ((etat = pthread_create(&lesRedacteurs[i], NULL,
                               threadRedacteur, &rangRedacteurs[i])) != 0)
      thdErreur(etat, "Creation redacteurs", NULL);
  }

  /* Attente de la fin des threads */
  for (i = 0; i < nbLecteurs; i++)
    if ((etat = pthread_join(lesLecteurs[i], NULL)) != 0)
      thdErreur(etat, "Join lecteurs", NULL);

  for (i = 0; i < nbRedacteurs; i++)
    if ((etat = pthread_join(lesRedacteurs[i], NULL)) != 0)
      thdErreur(etat, "Join lecteurs", NULL);

  /* Fermeture du fichier partage */
  close(fd);

  printf ("\nFin de l'execution du main \n");
}