/* ========================================================================== */
/*                                                                            */
/*   FUNKCE.CPP                                                               */
/*   JAN DVORAK                                                               */
/*                                                                            */
/*   Pomocné funkce aplikace letiště                                          */
/*                                                                            */
/* ========================================================================== */
#ifndef _LETISTE_FUNKCE_
#define _LETISTE_FUNKCE_

/******************************************************************************/
/* Procedura načti řádek - načte řádek ze standartního vstupu                 */
/******************************************************************************/
void nactiRadek(char *rdk)
{
    char z;
    int pocet=0;
    while(scanf("%c",&z))
    {
      if( (int)z==13 )scanf("%c",&z); //eliminace řádkování windows
      if(z=='\n' || (int)z<32 || feof(stdin) )break; //jsme na konci řádku, končíme      
      rdk[pocet]=z;
      pocet++;      
    }         
    rdk[pocet]='\0';  //nahradíme koncový znak        
}

/******************************************************************************/
/* Procedura vyhodnoť řádek - vezme řádek, určí typ, rozparsuje               */
/******************************************************************************/
void vyhodnotRadek(char *rdk)
{  
  struct Letiste pomLet;
  struct Let pomL;
  struct Pasazer pomP;
  
  int delka=100;
  char z;
  
  char vstup[51];
  int vstupDelka=0;
  int vstupCast=0;
  int typVstupu=0;
  
  for(int i=0;i<delka;i++)
  {
    z=rdk[i];    
    if(z==':' || z=='\0')
    {            
      vstup[vstupDelka]='\0';//ukončíme vstup
      //vyhodnotíme
      if(vstupCast==0)
      {           
        if(strcmp (vstup,"letiste")==0) typVstupu=1; //jedná se o letiště  
        else if(strcmp (vstup,"let")==0) typVstupu=2; //jedná se o let
        else if(strcmp (vstup,"pasazer")==0) typVstupu=3; //jedná se o pasažéra                                  
        
      }else{
        switch(typVstupu)
        {
          case 1:  //letiště
              strcpy(pomLet.nazev,vstup); 
              break;
          
          case 2: //let
              if(vstupCast==1)sscanf(vstup,"%d",&pomL.ID);
              else if(vstupCast==2)strcpy(pomL.start,vstup);
              else if(vstupCast==3)strcpy(pomL.cil,vstup);
              else if(vstupCast==4)sscanf(vstup,"%d",&pomL.odlet);
              else if(vstupCast==5)sscanf(vstup,"%d",&pomL.doba);
              else if(vstupCast==6)sscanf(vstup,"%d",&pomL.kapacita);
              else if(vstupCast==7)sscanf(vstup,"%d",&pomL.cena);        
              
              break;

         case 3: //pasažér
              if(vstupCast==1)sscanf(vstup,"%d",&pomP.ID);
              else if(vstupCast==2)strcpy(pomP.start,vstup);
              else if(vstupCast==3)strcpy(pomP.cil,vstup);
              else if(vstupCast==4)sscanf(vstup,"%d",&pomP.penize);
              
              break;                            
        }
      }                     
      //
      vstupDelka=0;
      vstupCast++;
      if(z=='\0') break;
      
    }else{
      //pokračujeme ve vstupu
      vstup[vstupDelka++]=z;
    }  
  }
   
  //přidání prvku, spuštění vlákna
  struct Letiste *pom;
  struct Let *pom2;
  struct Pasazer *pom3;
  pom=NULL;
  pom2=NULL;
  pom3=NULL;
  
  sem_wait(&zamknutiVytvareniStruktur);   
  
  switch(typVstupu)
  {
    case 1:        
       if(vstupCast!=2)ukonciUlohu();       
       
       sem_wait(&zamknutiVytvareniLetist);  //uzamkneme (kvůli realokacím)
              
       //realokace pole letišt a láken letišt
       struct Letiste* pom= (struct Letiste*) realloc(  (void*)seznamLetist, sizeof(*pom)*(pocetLetist+1)  );
       if(!pom)ukonciUlohu();
       seznamLetist=pom;

       pthread_t *NLeP=(pthread_t*) realloc ( (void*)vlaknaLetist, sizeof(*NLeP)*(pocetLetist+1) );       
       if(!NLeP)ukonciUlohu();
       vlaknaLetist=NLeP;       
       //
       seznamLetist[pocetLetist]=pomLet;
       //            
       if(    pthread_create(&vlaknaLetist[pocetLetist],NULL,letisteProcedura,(void*) (pocetLetist) )  )
          ukonciUlohu();                  
       //       
       pocetLetist++;
       sem_post(&zamknutiVytvareniLetist);
       break;
       
    case 2:   
       if(vstupCast!=8)ukonciUlohu();       
       
       if(MAX_POCET_LETU==pocetLetu)
       {
        printf("Byla prekrocena maximalni hranice poctu letu\n");
        ukonciUlohu();
       }
             
       sem_wait(&zamknutiVytvareniLetu);
           
       //realokace pole letů, vláken letů
       pthread_t *nLP=(pthread_t*) realloc ( (void*)vlaknaLetu, sizeof(*nLP)*(pocetLetu+1) );
       if(!nLP)ukonciUlohu();
       vlaknaLetu=nLP;

       struct Let* pom2= (struct Let*) realloc( (void*)seznamLetu, sizeof(Let)*(pocetLetu+1) );
       if(!pom2)ukonciUlohu();
       seznamLetu=pom2;  
             
       //nalezení letiště
       pomL.poziceLetisteVpoli=-1;       
       sem_wait(&zamknutiVytvareniLetist); //uzamkneme zápis do letišť
              
       for(int o=0;o<pocetLetist;o++)
       {
          if(strcmp(pomL.start,seznamLetist[o].nazev)==0){pomL.poziceLetisteVpoli=o;break;}
       }              
       sem_post(&zamknutiVytvareniLetist); //zápis do letišt povolen - už nepotřebujeme číst data letiště
       
       //kontrola vstupu       
       if(pomL.poziceLetisteVpoli==-1)
       {
          printf("Let %d nema odkud odstartovat - chyba na vstupu\n",pomL.ID);
          ukonciUlohu();
       }
       //
       pomL.obsazeno=0;
       pomL.stav=-1;
       pomL.poziceVpoli=pocetLetu;
       seznamLetu[pocetLetu]=pomL;       
       //inicializace synchronizačních prvků              
       sem_init(&zamkyLetu[pocetLetu],0,1);
       pthread_mutex_init(&mutexPasazeru[pocetLetu],NULL);
       pthread_cond_init(&condPasazeru[pocetLetu],NULL);
       //snížíme semafor- uspí se na něm vytvořené vlákno                                                             
       sem_wait(&zamkyLetu[pocetLetu]);
                                                                                             
       pocetLetu++;       
       sem_post(&zamknutiVytvareniLetu);
       break;
       
    case 3:
       if(vstupCast!=5)ukonciUlohu();
              
       sem_wait(&zamknutiVytvareniPasazeru);       
       
       //realokace vláken pasažerů a pole pasažerů
       struct Pasazer* pom3= (struct Pasazer*) realloc( (void*)seznamPasazeru, sizeof(Pasazer)*(pocetPasazeru+1) );
       if(!pom3)ukonciUlohu();
       seznamPasazeru=pom3;

       pthread_t *nVP=(pthread_t*) realloc ( (void*)vlaknaPasazeru, sizeof(*nVP)*(pocetPasazeru+1)  );
       if(!nVP)ukonciUlohu();
       vlaknaPasazeru=nVP;    
       //
       pomP.nalezenLet=false;
       pomP.letID=-1;
       pomP.cenaCelkem=0;
       seznamPasazeru[pocetPasazeru]=pomP;
       //               
       if(    pthread_create(&vlaknaPasazeru[pocetPasazeru],NULL,pasazerProcedura,(void*) (pocetPasazeru) )  )
          ukonciUlohu();                    
       //         
       pocetPasazeru++;
       sem_post(&zamknutiVytvareniPasazeru);  
       break;
  }
  
  sem_post(&zamknutiVytvareniStruktur);
  
}

/******************************************************************************/
/*  Vypsání hodnot jednotlivých polí struktur                                 */
/******************************************************************************/
void ukonciUlohu()
{
  printf("\n\nPri behu programu nastala zavazna chyba dana spatnym vstupem nebo nedostatek pameti\nProgram se nechava spadnout...");
  exit(1);
}

void vypisVstup()
{
  int i;
  printf("\n------------------------------------------------------");  
  printf("\n\nLETISTE:\n");
  for(i=0;i<pocetLetist;i++)printf("%s\n",seznamLetist[i].nazev);
  
  printf("\n\nLETY:\n");
  for(i=0;i<pocetLetu;i++)printf("ID %d, %s->%s, odlet %d, doba %d, kap. %d, cena %d, obsaz. %d, index %d\n",seznamLetu[i].ID,seznamLetu[i].start,seznamLetu[i].cil,seznamLetu[i].odlet,seznamLetu[i].doba,seznamLetu[i].kapacita,seznamLetu[i].cena,seznamLetu[i].obsazeno,seznamLetu[i].poziceLetisteVpoli);
  
  printf("\n\nPASAZERI:\n");
  for(i=0;i<pocetPasazeru;i++)printf("ID %d, %s->%s, %d,- Let nalezen: %d <ID %d>\n",seznamPasazeru[i].ID,seznamPasazeru[i].start,seznamPasazeru[i].cil,seznamPasazeru[i].penize,seznamPasazeru[i].nalezenLet,seznamPasazeru[i].letID);
}

#endif