/* ========================================================================== */
/*                                                                            */
/*   MAIN.CPP                                                                 */
/*   JAN DVORAK z VOZEROVIC                                                   */
/*                                                                            */
/* ========================================================================== */

#define RYCHLOST_SIMULACE 100000 //argument usleep() ve vláknu hodin  

#define MAX_POCET_LETU 150

#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include <pthread.h>
#include <unistd.h>
#include <string.h>
#include <semaphore.h>

#include "struktury.cpp"
#include "hlavicky.h"
/******************************************************************************/
int systemovyCas=0;

int pocetLetist=0;
int pocetLetu=0;
int pocetPasazeru=0;

pthread_mutex_t zapsaniNaLet;
sem_t zamknutiVytvareniLetist;
sem_t zamknutiVytvareniLetu;
sem_t zamknutiVytvareniPasazeru;
sem_t zamknutiVytvareniStruktur;

bool KONEC_VSTUPU=false;
bool KONEC_APLIKACE=false;

struct Letiste *seznamLetist=NULL;
struct Let *seznamLetu=NULL;
struct Pasazer *seznamPasazeru=NULL;

pthread_t *vlaknaLetist;

pthread_t *vlaknaPasazeru;
pthread_cond_t *condPasazeru;    //nástup do letadla
pthread_mutex_t *mutexPasazeru;  // - povoluje vlákno letu


pthread_t *vlaknaLetu;
sem_t *zamkyLetu; //povolení od letiště
pthread_barrier_t *barieryLetu; //počkání na pasažéry letu

pthread_t hodiny;

/******************************************************************************/
#include "hodiny.cpp"
#include "pasazer.cpp"
#include "let.cpp"
#include "letiste.cpp"
#include "funkce.cpp" 

/******************************************************************************/
int main(int argv, char*argc[])
{
  printf("/*******************************************\\\n");
  printf("| SIMULACE LETOVEHO PROVOZU:                |\n");
  printf("| (naprogramoval Jan Dvorak - dvoraj19@fel) | \n");
 printf("\\*******************************************/\n\n");

  alokujSynchronizacniPrvky();
  
  //hodiny  
  pthread_create(&hodiny, NULL, systemoveHodiny,(void*)RYCHLOST_SIMULACE);  
  //zámky  - inicializace semaforů a mutexu
  sem_init(&zamknutiVytvareniLetist,0,1);
  sem_init(&zamknutiVytvareniLetu,0,1);
  sem_init(&zamknutiVytvareniPasazeru,0,1);
  pthread_mutex_init(&zapsaniNaLet,NULL);  
  sem_init(&zamknutiVytvareniStruktur,0,1);      
  //
  char radek[100];

  while(!feof(stdin))
  {
    nactiRadek(radek);
    if(radek[0]!='\0')
    {      
      vyhodnotRadek(radek);                              
    }    
    usleep(1); // - slouží pro testování zpoždění z klávesnice    
  }
  
  //až všechna vlákna dočtou, nastavíme konec vstupu
  sem_wait(&zamknutiVytvareniStruktur);
  sem_wait(&zamknutiVytvareniLetist);
  sem_wait(&zamknutiVytvareniLetu);
  sem_wait(&zamknutiVytvareniPasazeru);
  KONEC_VSTUPU=true;
  sem_post(&zamknutiVytvareniLetist);
  sem_post(&zamknutiVytvareniLetu);
  sem_post(&zamknutiVytvareniPasazeru);
  sem_post(&zamknutiVytvareniStruktur);

  int i;  
  //sloučení vláken pasažerů
  for(i=0;i<pocetPasazeru;i++)
  {
    pthread_join(vlaknaPasazeru[i],NULL);          
  }  

  //nyní můžeme ukončit letiště a hodiny
  KONEC_APLIKACE=true;
  
  //sloučení vláken letist
  for(i=0;i<pocetLetist;i++)
  {
      pthread_join(vlaknaLetist[i],NULL);      
  } 
   
  //uvolnění synchroznizačních prvků vláken letů (vlákna jsou sloučena ve vlákně letiste)
  for(i=0;i<pocetLetu;i++)
  {           
      sem_destroy(&zamkyLetu[i]);
      pthread_barrier_destroy(&barieryLetu[i]);
      pthread_cond_destroy(&condPasazeru[i]);
      pthread_mutex_destroy(&mutexPasazeru[i]); 
  }  
     
     
  //systémové hodiny
  pthread_join(hodiny,NULL);
  //

  //uvolnění paměti - pole vláken a pole dat
  free(seznamPasazeru);
  free(vlaknaPasazeru);
  free(seznamLetu);
  free(vlaknaLetu);
  free(seznamLetist);
  free(vlaknaLetist);
  //
  
  //uvolnění zámků pro blokaci vícečetných přístupů 
  sem_destroy(&zamknutiVytvareniLetist);
  sem_destroy(&zamknutiVytvareniLetu);
  sem_destroy(&zamknutiVytvareniPasazeru);
  pthread_mutex_destroy(&zapsaniNaLet);   
  sem_destroy(&zamknutiVytvareniStruktur);  
  //
    
  return 0;
}


/******************************************************************************/
void alokujSynchronizacniPrvky(void)
{
   pthread_cond_t *nCP=(pthread_cond_t*) realloc ( (void*)condPasazeru, sizeof(*nCP)*(MAX_POCET_LETU+1) );
   if(!nCP)ukonciUlohu();
   condPasazeru=nCP;

   pthread_barrier_t *nBL=(pthread_barrier_t*) realloc ( (void*)barieryLetu, sizeof(*nBL)*(MAX_POCET_LETU+1) );
   if(!nBL)ukonciUlohu();
   barieryLetu=nBL;
   
   sem_t *nZL=(sem_t*) realloc ( (void*)zamkyLetu, sizeof(*nZL)*(MAX_POCET_LETU+1) );
   if(!nZL)ukonciUlohu();
   zamkyLetu=nZL;    
     
   pthread_mutex_t *nMP=(pthread_mutex_t*) realloc ( (void*)mutexPasazeru, sizeof(*nMP)*(MAX_POCET_LETU+1) );
   if(!nMP)ukonciUlohu();
   mutexPasazeru=nMP;          
}