#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
#include <sys/fcntl.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/wait.h>
#include <string.h>
#include <time.h>
#include <assert.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/msg.h>
#include <signal.h>

#define DEBUG
#define MAX 1024
#define MAX2 50
#define PIPE_NAME "input_pipe"

/****************************ESTRUTURAS********************/

typedef struct Voo_partida *lista_voo_partida;
typedef struct Voo_chegada *lista_voo_chegada;
typedef struct Voo_aux *lista_voos;


typedef struct Voo{
  char nome[MAX2];
  int inicial;
}voo;

typedef struct Voo_aux{
  char nome[MAX2];
  int inicial;
  lista_voos next;
}voo_aux;

typedef struct Mensagem{
  long msgtyp;
  char nome[MAX2];
  int combustivel;
  int instante_partida;
  int eta;
  int init;
  int id_thread;
} mensagem;

typedef struct Callback_id{
  long msgtype;
  int id_sh;
} callback_id;

typedef struct Voo_partida{
    voo dep;
    int descolagem;
    lista_voo_partida next;
}voo_partida;

typedef struct Voo_chegada{
    voo arr;
    int eta;
    int combustivel;
    lista_voo_chegada next;
}voo_chegada;

typedef struct Estatistica{
	int total_voos_criados;
	int total_voos_aterraram;
	time_t tempo_medio_espera_aterrar;
	int total_voos_descolaram;
	time_t tempo_medio_espera_descolar;
	int media_manobras_aterragem;
	int media_manobras_emergencia;
	int voos_redirecionados;
	int voos_rejeitados;
}estatistica;

/*********************HEADER DE FUNCOES**********************/

void criar_processo_torre();
char * horas();
void escreve_log();
void ler_config();
void cria_semaforos();
void cria_pipe();
void cria_mq();
void cria_shm_stats();
void cria_shm_partida();
void cria_shm_chegada();
void *abre_pipe();
void gestor();
void *thread_manage();
void *thread_msq();
void *thread_worker(void* a);
int condition();
void imprime_lista_chegada(lista_voo_chegada head);
lista_voo_partida cria_lista_partida();
lista_voo_chegada cria_lista_chegada();
lista_voos cria_lista_voos();
void insere_lista_chegada(lista_voo_chegada head, char * n, int init, int eta, int fuel);
void insere_fila_chegada(lista_voo_chegada head, char * n, int init, int eta, int fuel);
void insere_lista_partida(lista_voo_partida head, char * n, int init, int desc);
void insere_fila_partida(lista_voo_partida head, char * n, int init, int desc);
void procura_lista_partida(lista_voo_partida lista, int chave, lista_voo_partida *ant, lista_voo_partida *atual);
void procura_fila_partida(lista_voo_partida lista, int chave, lista_voo_partida *ant, lista_voo_partida *atual);
void procura_lista_chegada(lista_voo_chegada lista, int chave, lista_voo_chegada *ant, lista_voo_chegada *atual);
void procura_fila_chegada(lista_voo_chegada lista, int chave, lista_voo_chegada *ant, lista_voo_chegada *atual);
void remove_lista_partida(lista_voo_partida partida, char *nome);
void remove_lista_chegada(lista_voo_chegada chegada, char *nome);
void imprime_lista_partida(lista_voo_partida teste);
void insere_lista_voos(lista_voos head, char * n, int init);
void procura_lista_voos(lista_voos lista, int chave, lista_voos *ant, lista_voos *atual);
int hora_ut();
int checkNome(lista_voos lista,char *nome);
int checkLista(lista_voo_chegada chegadas, lista_voo_partida partidas,char *nome);
double calcula_init(int init);
void ms2ts( struct timespec *ts, unsigned long ms);
void termina_programa(int signum);
void remove_lista_voo(lista_voos voo, char *nome);
/***********************VARIAVEIS GLOBAIS********************/

int ut_inicial;     //variavel que guarda a hora inicial do sistema em segundos
int ut_atual;
pid_t pid_torre;		//pid do processo da Torre de Controle
FILE* flog;			    //ficheiro de log
sem_t *log_mutex;   //mutex do log
int shm_stats_id,shm_partida_id, shm_chegad_id, mq_id,pipe_id; //variaveis de shm
estatistica * stats;
voo_chegada *shm_chegada;
voo_partida *shm_partida;

pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
pthread_mutex_t mutex_thread = PTHREAD_MUTEX_INITIALIZER;

int ut,dur_descolagem,dur_aterragem,int_descolagem,int_aterragem, holding_min, holding_max, max_partidas, max_chegadas; //variaveis de leitura da config
pthread_t thread_voo[MAX2],thread_pipe, thread_manage_id,thread_mq_id;

lista_voo_chegada fila_espera_chegada;
lista_voo_partida fila_espera_partida;


lista_voo_chegada lista_chegada;
lista_voo_partida lista_partida;
lista_voos lista_voo_aux;

double time_to_wait;
unsigned long value;
 struct timespec ts;
int ids = 1;

/****************************FUNCOES*****************************/

//funcao para debug print
void debug_print(char * aux){
  #ifdef DEBUG
  printf("[DEBUG] %s\n",aux);
  #endif
}


void criar_processo_torre(){
  debug_print("Processo Torre criado");
  int i;

  fila_espera_partida = cria_lista_partida();
  fila_espera_chegada = cria_lista_chegada();
  mensagem msg;
  callback_id index_number;

    // fica à espera de mensagens das threads
  while(1){

    if(msgrcv(mq_id, &msg, sizeof(mensagem)-sizeof(long), -3, 0) != -1) {

    // nº negativo funciona por prioridades ->  1º valor <= msgtype

    if(msg.msgtyp == 3){
      printf("--------TORRE DE CONTROLO--------\n\n");

      printf("NAME: %s \n",msg.nome);
      printf("TAKEOFF: %d \n",msg.instante_partida);
      printf("----------------\n");
      i = 0;
      while(strcmp(shm_partida[i].dep.nome,"\0") != 0){
        i++;
      }

      strcpy(shm_partida[i].dep.nome,msg.nome);
      shm_partida[i].descolagem = msg.instante_partida;
      shm_partida[i].dep.inicial = msg.init;

      index_number.msgtype = msg.id_thread;
      index_number.id_sh = i;

      insere_fila_partida(fila_espera_partida,msg.nome,msg.init,msg.instante_partida);
      imprime_lista_partida(fila_espera_partida);
      msgsnd(mq_id, &index_number, sizeof(index_number)-sizeof(long), 0);
    //signal(SIGINT,termina_programa);

    //falta o id
    }
    else if(msg.msgtyp == 2){
      i=0;
      printf("--------TORRE DE CONTROLO--------\n\n");


      //adiciona o novo elemento à shm memory e envia o id para a thread
       while (strcmp(shm_chegada[i].arr.nome,"\0") != 0)
      {
        i++;
      }
      strcpy(shm_chegada[i].arr.nome,msg.nome);
      shm_chegada[i].arr.inicial = msg.init;
      shm_chegada[i].eta = msg.eta;
      shm_chegada[i].combustivel = msg.combustivel;

      index_number.msgtype = msg.id_thread;
      index_number.id_sh = i;
      insere_fila_chegada(fila_espera_chegada,msg.nome,msg.init, msg.eta,msg.combustivel);
      //falta o id
      imprime_lista_chegada(fila_espera_chegada);
      msgsnd(mq_id, &index_number, sizeof(index_number)-sizeof(long), 0);
        //adiciona o novo elemento a lista de espera  e ordena-o
    //signal(SIGINT,termina_programa);

    }
    else if(msg.msgtyp == 1){
      i=0;
      printf("--------TORRE DE CONTROLO--------\n\n");

      printf("---PRIORITY FLIGHT---\n\n");

      //adiciona o novo elemento à shm memory e envia o id para a thread
       while (strcmp(shm_chegada[i].arr.nome,"\0") != 0)
      {
        i++;
      }
      strcpy(shm_chegada[i].arr.nome,msg.nome);
      shm_chegada[i].arr.inicial = msg.init;
      shm_chegada[i].eta = msg.eta;
      shm_chegada[i].combustivel = msg.combustivel;

      index_number.msgtype = msg.id_thread;
      index_number.id_sh = i;
      insere_fila_chegada(fila_espera_chegada,msg.nome,msg.init, msg.eta,msg.combustivel);
      //falta o id
      imprime_lista_chegada(fila_espera_chegada);
      msgsnd(mq_id, &index_number, sizeof(index_number)-sizeof(long), 0);
      //adiciona o novo elemento a lista de espera  e ordena-o
      //signal(SIGINT,termina_programa);

    }
  }

}
}
  /*if(pthread_create(&thread_mq_id,NULL,thread_msq,NULL)!=0){
      perror("ERROR creating the thread pipe!\n");
    }
    printf("TORRE PASSOU\n");
    */
//inicializa as filas de espera  a

void termina_programa(int signum){

  signal(SIGINT, termina_programa);
	signal(SIGUSR1,SIG_IGN);

  int  i;
  i = 0;
  kill(pid_torre,0);	//vai esperar pelo Torre de controlo acabar

  escreve_log("Torre de Controlo eliminada\n");
	while (i < max_chegadas){	//Vai enviar sinal aos armazens para morrerem
		shmdt(shm_chegada);

	}
  shmctl(shm_chegad_id,IPC_RMID,NULL);

  i = 0;
  while (i < max_partidas){	//Vai enviar sinal aos armazens para morrerem
    shmdt(shm_partida);

	}
  shmctl(shm_partida_id,IPC_RMID,NULL);
 lista_voo_chegada temp_c;
 lista_voo_partida temp_p;
 lista_voos temp_a;
 while(lista_chegada->next!=NULL){
		temp_c=lista_chegada;
		lista_chegada=lista_chegada->next;
		free(temp_c);
	}
  while(lista_partida->next!=NULL){
		temp_p=lista_partida;
		lista_partida=lista_partida->next;
		free(temp_p);
	}

  while(lista_voo_aux->next!=NULL){
		temp_a=lista_voo_aux;
		lista_voo_aux=lista_voo_aux->next;
		free(temp_a);
	}

  msgctl(mq_id, IPC_RMID, 0);
  escreve_log("Message queue eliminada\n");
  pthread_join(thread_voo,NULL);
  pthread_join(thread_pipe,NULL);
  close(pipe_id);
	unlink(PIPE_NAME);

  pthread_mutex_destroy(&mutex_thread);
  pthread_cond_destroy(&cond);

  exit(0);

}

//funcao que calcula hora do sistema e returna string no formato 19:35:01
char * horas(){
	char * aux;
	aux = malloc(sizeof(char*));
	time_t atual;
    time(&atual);
    struct tm *hora_local = localtime(&atual);
    sprintf(aux, "%02d:%02d:%02d", hora_local->tm_hour, hora_local->tm_min, hora_local->tm_sec);
    return aux;
}

//funcao que guarda hora de inicio do programa, em segundos
void hora_inicio(){
  int hora_incial,minutos_inicial,segundos_inicial;
  time_t atual;
  time(&atual);
  struct tm *hora_local = localtime(&atual);
  hora_incial= hora_local->tm_hour * 60 * 60;
  minutos_inicial= hora_local->tm_min * 60;
  segundos_inicial= hora_local->tm_sec;
  ut_inicial = hora_incial + minutos_inicial + segundos_inicial;
}

//funcao que devolve hora atual do programa em ut
int hora_ut(){
  double aux,aux2;
  time_t atual;
  time(&atual);
  struct tm *hora_local = localtime(&atual);
  aux = (((hora_local->tm_hour * 60 * 60) + (hora_local->tm_min * 60) + hora_local->tm_sec)-ut_inicial);
  aux2 = (int) aux*ut/1000;
  return(aux2);
}

double calcula_init(int init){
  double final,aux;
  int var;
  var = init;
  aux = (double) ut;
  var = init-hora_ut();
  final = (aux/1000) * var;
  return final;
}



void imprime_lista_partida(lista_voo_partida head){
    lista_voo_partida atual = head->next;
    printf("LISTA DE ESPERA - VOOS PARTIDA\n");
      while (atual != NULL) {
        printf("----------------\n");
        printf("NOME: %s \n", atual->dep.nome);
        printf("Takeoff : %d\n ", atual->descolagem);
        printf("----------------\n");
        atual = atual->next;

      }
}

void imprime_lista_voos(lista_voos head){
    lista_voos atual = head->next;
      printf("LISTA DE VOOS\n");
      while (atual != NULL) {
        printf("----------------\n");
        printf("NAME: %s \n",atual->nome);
        printf("INIT: %d \n",atual->inicial);
        printf("----------------\n");
        printf("\n\n");
        atual = atual->next;
      }
}


void imprime_lista_chegada(lista_voo_chegada head){
    lista_voo_chegada atual = head->next;
    printf("LISTA DE ESPERA - VOOS CHEGADA\n");
    while (atual != NULL) {
      printf("----------------\n");
      printf("NOME:%s\n", atual->arr.nome);
      printf("INIT :%d\n", atual->arr.inicial);
      printf("FUEL: %d \n",atual->combustivel);
      printf("ETA: %d\n",atual->eta);
      printf("----------------\n");
      atual = atual->next;
    }
}


lista_voos cria_lista_voos(){
  lista_voos head = NULL;
  head = (lista_voos)malloc(sizeof(voo_aux));
  if(head != NULL){
    strcpy(head->nome," ");
    head->inicial = 0;
    head->next = NULL;
  }
  return(head);
}


lista_voo_partida cria_lista_partida(){
  lista_voo_partida head = NULL;
  head = (lista_voo_partida) malloc(sizeof(voo_partida));
  if(head != NULL){
    strcpy(head->dep.nome," ");
    head->dep.inicial = 0;
    head->descolagem = 0;
    head->next = NULL;
  }
  return(head);
}

lista_voo_chegada cria_lista_chegada(){
  lista_voo_chegada head = NULL;
  head = (lista_voo_chegada) malloc(sizeof(voo_chegada));
  if(head != NULL){
    strcpy(head->arr.nome," ");
    head->arr.inicial = 0;
    head->eta = 0;
    head->combustivel = 0;
    head->next = NULL;
  }
  return (head);
}


void insere_lista_voos(lista_voos head, char * n, int init){
    lista_voos atual;
    lista_voos ant, inutil;
    atual = (lista_voos) malloc (sizeof (voo_aux));
    if (atual != NULL)
    {
      strcpy(atual->nome,n);
    	atual->inicial = init;

	    procura_lista_voos(head, init, &ant, &inutil);
      atual->next = ant->next;
      ant->next = atual;
    }
}

void insere_lista_partida(lista_voo_partida head, char * n, int init, int desc){
    lista_voo_partida atual;
    lista_voo_partida ant, inutil;
    atual = (lista_voo_partida) malloc (sizeof (voo_partida));
    if (atual != NULL)
    {
      strcpy(atual->dep.nome,n);
    	atual->dep.inicial = init;
    	atual->descolagem = desc;

	    procura_lista_partida(head, init, &ant, &inutil);
      atual->next = ant->next;
      ant->next = atual;
    }
}



void insere_fila_partida(lista_voo_partida head, char * n, int init, int desc){
   lista_voo_partida atual;
    lista_voo_partida ant, inutil;
    atual = (lista_voo_partida) malloc (sizeof (voo_partida));
    if (atual != NULL)
    {
      strcpy(atual->dep.nome,n);
    	atual->dep.inicial = init;
    	atual->descolagem = desc;

	    procura_fila_partida(head, desc, &ant, &inutil);
      atual->next = ant->next;
      ant->next = atual;
    }
}


int checkNome(lista_voos lista,char *nome){
  lista_voos atual;
  atual = lista->next;
  if(atual == NULL){
    return 0;
  }
  else{
    while(atual->next != NULL){
      if(strcmp(atual->nome,nome) == 0){
        return 1;
      }
      atual = atual->next;
    }
    return 0;
    }
}


void procura_lista_voos(lista_voos lista, int chave, lista_voos *ant, lista_voos *atual)
{
    *ant = lista;
    *atual = lista->next;
    while ((*atual) != NULL &&( ((*atual)->inicial) < chave))
    {
        *ant = *atual;
        *atual = (*atual) -> next;
    }
}


void procura_lista_partida(lista_voo_partida lista, int chave, lista_voo_partida *ant, lista_voo_partida *atual)
{
    *ant = lista;
    *atual = lista->next;
    while ((*atual) != NULL &&( ((*atual)->dep.inicial) < chave))
    {
        *ant = *atual;
        *atual = (*atual) -> next;
    }
}

void procura_fila_partida(lista_voo_partida lista, int chave, lista_voo_partida *ant, lista_voo_partida *atual)
{
    *ant = lista;
    *atual = lista->next;
    while ((*atual) != NULL &&( ((*atual)->descolagem) < chave))
    {
        *ant = *atual;
        *atual = (*atual) -> next;
    }
}


void insere_lista_chegada(lista_voo_chegada head, char * n, int init, int eta, int fuel){
    lista_voo_chegada atual;
    lista_voo_chegada ant, inutil;
    atual = (lista_voo_chegada) malloc (sizeof (voo_chegada));
    if (atual != NULL)
    {
      strcpy(atual->arr.nome,n);
      atual->arr.inicial = init;
      atual->eta = eta;
      atual->combustivel = fuel;
    }

	  procura_lista_chegada(head, init, &ant, &inutil);
    atual->next = ant->next;
    ant->next = atual;
}


void insere_fila_chegada(lista_voo_chegada head, char * n, int init, int eta, int fuel){
    lista_voo_chegada atual;
    lista_voo_chegada ant, inutil;
    atual = (lista_voo_chegada) malloc (sizeof (voo_chegada));
    if (atual != NULL)
    {
      strcpy(atual->arr.nome,n);
      atual->arr.inicial = init;
      atual->eta = eta;
      atual->combustivel = fuel;
    }

	  procura_fila_chegada(head, eta, &ant, &inutil);
    atual->next = ant->next;
    ant->next = atual;
}

void procura_fila_chegada(lista_voo_chegada lista, int chave, lista_voo_chegada *ant, lista_voo_chegada *atual)
{
    *ant = lista;
    *atual = lista->next;
    while ((*atual) != NULL && ((*atual)->eta) < chave)
    {
        *ant = *atual;
        *atual = (*atual) -> next;
    }
}



void procura_lista_chegada(lista_voo_chegada lista, int chave, lista_voo_chegada *ant, lista_voo_chegada *atual)
{
    *ant = lista;
    *atual = lista->next;
    while ((*atual) != NULL &&( ((*atual)->arr.inicial) < chave))
    {
        *ant = *atual;
        *atual = (*atual) -> next;
    }
}


//funcao de escrita no log
void escreve_log(char *aux){
  sem_wait(log_mutex);
	fprintf(flog,"%s %s\n",horas(),aux);
  sem_post(log_mutex);
  fflush(0);
}

//Funcao de leitura da config inicial do programa
void ler_config(){
	FILE * fconfig;
	int linha=0;
	char buffer1[MAX2],buffer2[MAX2];

	if ((fconfig=fopen("config.txt", "r")) == NULL){
    perror("Erro ao abrir o ficheiro config\n");
    exit(1);
  }else{
    while (linha!=6){
      linha++;
      if(linha==1){
        fscanf(fconfig, "%s", buffer1);
        ut = atoi(buffer1);
      }else if(linha==2){
        fscanf(fconfig, "%[^,],%s", buffer1,buffer2);
        dur_descolagem = atoi(buffer1);
        int_descolagem = atoi(buffer2);
      }else if(linha==3){
        fscanf(fconfig, "%[^,],%s", buffer1,buffer2);
        dur_aterragem = atoi(buffer1);
        int_aterragem = atoi(buffer2);
      }else if(linha==4){
        fscanf(fconfig, "%[^,],%s", buffer1,buffer2);
        holding_min = atoi(buffer1);
        holding_max = atoi(buffer2);
      }else if(linha==5){
        fscanf(fconfig, "%s", buffer1);
        max_partidas = atoi(buffer1);
      }else if(linha==6){
        fscanf(fconfig, "%s", buffer1);
        max_chegadas = atoi(buffer1);
      }
    }
    fclose(fconfig);
    debug_print("Ficheiro cfg lido");
    }
}

//------------------Shared Memory Estatistica------------------------
void cria_shm_stats(){
  if((shm_stats_id = shmget(IPC_PRIVATE,(sizeof(estatistica)),IPC_CREAT | 0766)) < 0){
		perror("Erro ao criar a memoria partilhada para as estatisticas ( IPC_CREAT)");
	}else{
    if(( stats = (estatistica *) shmat(shm_stats_id,NULL,0)) == (estatistica *)-1){
      perror("Erro ao criar a memoria partilhada para as estatisticas ( IPC_CREAT)");
    }
    else{
      stats->total_voos_criados = 0;
      stats->media_manobras_aterragem = 0;
      stats->total_voos_descolaram = 0;
      stats->total_voos_aterraram = 0;
      stats->media_manobras_emergencia = 0;
      stats->voos_redirecionados = 0;
      stats->voos_rejeitados = 0;
      stats->tempo_medio_espera_aterrar = 0;
      stats->tempo_medio_espera_descolar = 0;
      debug_print("Memoria partilhada Estatistica criada");
    }
  }
}

//------------------Shared Memory Partidas------------------------

void cria_shm_partida(){
  if((shm_partida_id = shmget(IPC_PRIVATE,sizeof(voo_partida) * max_partidas,IPC_CREAT | 0766)) <0){
    perror("Erro a criar memoria partilhada para os voos de partida ");
  }
  if (( shm_partida = (voo_partida *) shmat(shm_partida_id,NULL,0)) == (voo_partida *)-1){
    perror("Erro a criar memoria partilhada para os voos de partida ");
  }
  else{
    debug_print("Memoria partilhada para os voos de partida criada com sucesso");
    int i;
    for(i = 0; i<max_partidas; i++){

      strcpy(shm_partida[i].dep.nome,"\0");
      shm_partida[i].dep.inicial = 0;
      shm_partida[i].descolagem = 0;
    }
  }

}
//------------------Shared Memory chegadas------------------------
void cria_shm_chegada(){
  if((shm_chegad_id = shmget(IPC_PRIVATE,sizeof(voo_chegada) * max_chegadas,IPC_CREAT | 0766)) <0){
    perror("Erro a criar memoria partilhada para os voos de chegada ");
  }
  if (( shm_chegada = (voo_chegada *) shmat(shm_chegad_id,NULL,0)) == (voo_chegada *)-1){
    perror("Erro a criar memoria partilhada para os voos de chegada ");
  }
  else{
    debug_print("Memoria partilhada para os voos de chegada criada com sucesso");
    int i;
    for(i = 0; i<max_chegadas; i++){

      strcpy(shm_chegada[i].arr.nome,"\0");
      shm_chegada[i].arr.inicial = 0;
      shm_chegada[i].combustivel = 0;
      shm_chegada[i].eta = 0;
    }
  }
}

//funcao que cria pipe
void cria_pipe(){
  unlink(PIPE_NAME);
  if ((mkfifo(PIPE_NAME, O_CREAT|O_EXCL|0600)<0) && (errno!= EEXIST)){ // Cria o pipe
    perror("Erro ao inicializar PIPE");
  }else{
    if ((pipe_id=open(PIPE_NAME, O_RDWR)) < 0){
      perror("Impossivel abrir Pipe para leitura");
      exit(0);
    }else{
    debug_print("Named Pipe criado");
    }
  }
}

void *abre_pipe(){
  char aux[MAX],*buffer1;
  char auxNome[MAX2];
  int a,b,c;
  char original[MAX],erro[MAX],correto[MAX];

  while (1) {

    read(pipe_id, &aux, sizeof(char[MAX]));
    strcpy(original,aux);
    sprintf(correto,"%s%s","NEW COMMAND => ",original);
    sprintf(erro,"%s%s","WRONG COMMAND => ",original);
    buffer1 = strtok(aux," ");

    if(strcmp(buffer1,"ARRIVAL") == 0){

      //echo ARRIVAL TP437 init: 100 eta: 100 fuel: 1000 >> "input_pipe"
      //guarda nome
      buffer1 = strtok(NULL, " ");
      strcpy(auxNome, buffer1);
      //init:
      buffer1 = strtok(NULL, " ");
      if(strcmp(buffer1,"init:")!=0){
        escreve_log(erro);
        continue;
      }
      //init: 100
      buffer1 = strtok(NULL, " ");
      a = atoi(buffer1);
      if(a==0){
        escreve_log(erro);
        continue;
      }
      if(a<hora_ut()){
        escreve_log(erro);
        continue;
      }
      //eta:
      buffer1 = strtok(NULL, " ");
      if(strcmp(buffer1,"eta:")!=0){
        escreve_log(erro);
        continue;
      }
      //eta: 120
      buffer1 = strtok(NULL, " ");
      b = atoi(buffer1);
      if(b==0){
        escreve_log(erro);
        continue;
      }
      if(b<hora_ut() || b<a){
        escreve_log(erro);
        continue;
      }
      //fuel
      buffer1 = strtok(NULL, " ");
      if(strcmp(buffer1,"fuel:")!=0){
        escreve_log(erro);
        continue;
      }
      //fuel: 1000
      buffer1 = strtok(NULL, " ");
      c = atoi(buffer1);
      if(c==0){
        escreve_log(erro);
        continue;
      }
      if(c<b){
        escreve_log(erro);
        continue;
      }
      //pthread_mutex_unlock(&mutex_thread);
      pthread_mutex_lock(&mutex_thread);
      if((checkNome(lista_voo_aux,auxNome)== 0)){
        printf("O voo %s não existe no sistema, pode prosseguir\n",auxNome);
        insere_lista_chegada(lista_chegada,auxNome,a,b,c);
        insere_lista_voos(lista_voo_aux,auxNome,a);
        pthread_cond_signal(&cond);
      }
      else{
        printf("O voo %s já se encontra no sistema, acesso negado\n",auxNome);
      }
      pthread_mutex_unlock(&mutex_thread);
      escreve_log(correto);

    }else if(strcmp(buffer1,"DEPARTURE") == 0 ){
      int i;
      //nome
      buffer1 = strtok(NULL, " ");
      strcpy(auxNome, buffer1);
      //init:
      buffer1 = strtok(NULL, " ");
      if(strcmp(buffer1,"init:")!=0){
        escreve_log(erro);
        continue;
      }
      //init:100
      buffer1 = strtok(NULL, " ");
      a = atoi(buffer1);
      if(a==0){
        escreve_log(erro);
        continue;
      }
      if(a<hora_ut()){
        escreve_log(erro);
        continue;
      }
      //takeoff:
      buffer1 = strtok(NULL, " ");
      if(strcmp(buffer1,"takeoff:")!=0){
        escreve_log(erro);
        continue;
      }
      //takeoff: 100
      buffer1 = strtok(NULL, " ");
      b = atoi(buffer1);
      if(b==0){
        escreve_log(erro);
        continue;
      }
      if(b<hora_ut() || b<a){
        escreve_log(erro);
        continue;
      }
      i = 0;
      pthread_mutex_unlock(&mutex_thread);
      pthread_mutex_lock(&mutex_thread);
      if((checkNome(lista_voo_aux,auxNome)== 0)){

        printf("O voo %s não existe no sistema pode prosseguir\n",auxNome);
        //se o i = max_chegadas diz logo que nao dá e sai -> FAZER
        insere_lista_partida(lista_partida,auxNome,a,b);
        insere_lista_voos(lista_voo_aux,auxNome,a);
        pthread_mutex_unlock(&mutex_thread);
        pthread_cond_signal(&cond);
        escreve_log(correto);

      }
      else{
        printf("O voo %s já se encontra no sistema, acesso negado\n",auxNome);
        pthread_mutex_unlock(&mutex_thread);
      }

    }else{
        escreve_log(erro);
    }
  }
}

//DEPARTURE TP440 init: 0 takeoff: 100 >> "input_pipe"
//echo ARRIVAL TP437 init: 100 eta: 100 fuel: 1000 >> "input_pipe"

//mutex para o ficheiro de escrita no log
void cria_semaforos(){
	sem_unlink("LOG_MUTEX");
	if((log_mutex = sem_open("LOG_MUTEX",O_CREAT|O_EXCL,0766,1))==SEM_FAILED){
		perror("Impossivel incializar o Semaforo para o Log File\n");
		sem_unlink("LOG_MUTEX");
		exit(0);
	}
  else{
    debug_print("Semaforos criados");
  }
}

//--------------Message Queue------------------
void cria_mq(){
mq_id = msgget(IPC_PRIVATE, IPC_CREAT|0777);
  if (mq_id < 0)
  {
    perror("Erro ao inicializar a message queue");
  }
  else{
    debug_print("Message queue criada");
  }
}

//thread voo
void *thread_worker(void* a){

  int id,flag,id_shared;
  mensagem msg;
  callback_id call;
  id = *((int*) a);


  pthread_mutex_lock(&mutex_thread);
  flag = checkLista(lista_chegada,lista_partida,lista_voo_aux->next->nome);

  pthread_mutex_unlock(&mutex_thread);
  //vai buscar o ultimo elemento da lista de voos para enviar pela mq a info

  //procura na lista de voos de partida

  debug_print("Thread Voo Criada");

  if(flag == 2){
    pthread_mutex_lock(&mutex_thread);
    strcpy(msg.nome,lista_partida->next->dep.nome);
    msg.eta = 0;
    msg.combustivel = 0;
    msg.msgtyp = 3;
    msg.instante_partida = lista_partida->next->descolagem;
    msg.id_thread = id;
    msg.init = lista_partida->next->dep.inicial;
    remove_lista_voo(lista_voo_aux,lista_partida->next->dep.nome);
    msgsnd(mq_id, &msg, sizeof(msg)-sizeof(long), 0);
    msgrcv(mq_id, &call, sizeof(call)-sizeof(long), id, 0);
    id_shared = call.id_sh;
    printf("ID shared memory- %d\n", id_shared);
    pthread_mutex_unlock(&mutex_thread);

  } //procura na lista de voos de chegada
  else if(flag == 1){
    if(lista_chegada->next->combustivel <= 4 * ut + lista_chegada->next->eta){
      pthread_mutex_lock(&mutex_thread);
      msg.msgtyp = 1;
      printf("PRIORITY\n");

      strcpy(msg.nome,lista_chegada->next->arr.nome);
      msg.eta = lista_chegada->next->eta;
      msg.combustivel = lista_chegada->next->combustivel;
      msg.init = lista_chegada->next->arr.inicial;
      msg.id_thread = id;
      msg.instante_partida = 0;

      msgsnd(mq_id, &msg, sizeof(msg)-sizeof(long), 0);

      msgrcv(mq_id, &call, sizeof(call)-sizeof(long), id, 0);
      id_shared = call.id_sh;
      printf("ID shared memory- %d\n", id_shared);
      remove_lista_voo(lista_voo_aux,lista_chegada->next->arr.nome);
      pthread_mutex_unlock(&mutex_thread);
    }
    else{

      pthread_mutex_lock(&mutex_thread);
      printf("NOT PRIORITY\n");
      printf("IDIDID- %d\n",id);
      msg.msgtyp = 2;
      strcpy(msg.nome,lista_chegada->next->arr.nome);
      msg.eta = lista_chegada->next->eta;
      msg.combustivel = lista_chegada->next->combustivel;
      msg.init = lista_chegada->next->arr.inicial;
      msg.id_thread = id;
      msg.instante_partida = 0;
      imprime_lista_chegada(lista_chegada);
      msgsnd(mq_id, &msg, sizeof(mensagem)-sizeof(long), 0);
      //pthread_mutex_unlock(&mutex_thread)
      msgrcv(mq_id, &call, sizeof(call)-sizeof(long), id, 0);


      id_shared = call.id_sh;
      printf("ID shared memory- %d\n", id_shared);
      remove_lista_voo(lista_voo_aux,lista_chegada->next->arr.nome);
      pthread_mutex_unlock(&mutex_thread);
    }
  }
}
//funcao que chama as funcoes todas de criar
void gestor(){
  cria_semaforos();
  ler_config();
  hora_inicio();
  cria_semaforos();
  cria_shm_stats();
  cria_shm_chegada();
  cria_shm_partida();
  pthread_mutex_init(&mutex_thread,NULL);
  pthread_cond_init(&cond, NULL);
  lista_chegada = cria_lista_chegada();
  lista_partida = cria_lista_partida();
  lista_voo_aux = cria_lista_voos();
  cria_mq();
  cria_pipe();
}

void remove_lista_chegada(lista_voo_chegada chegada, char *nome){
  lista_voo_chegada atual,ant;
  atual = chegada->next;
  ant = chegada;
  if(atual!= NULL){
    while (strcmp(atual->arr.nome,nome)!=0)
    {
      atual = atual->next;
      ant = ant->next;
    }
    ant->next = atual->next;
    free(atual);
  }
}

void remove_lista_voo(lista_voos chegada, char *nome){
  lista_voos atual,ant;
  atual = chegada->next;
  ant = chegada;
  if(atual!= NULL){
    while (strcmp(atual->nome,nome)!=0)
    {
      atual = atual->next;
      ant = ant->next;
    }
    ant->next = atual->next;
    free(atual);
  }
}

void remove_lista_partida(lista_voo_partida partida, char *nome){
  lista_voo_partida atual,ant;
  atual = partida->next;
  ant = partida;
  if(atual!= NULL){
    while (strcmp(atual->dep.nome,nome)!=0)
    {
      atual = atual->next;
      ant = ant->next;
    }
    ant->next = atual->next;
    free(atual);
  }
}

int checkLista(lista_voo_chegada chegadas, lista_voo_partida partidas,char *nome){
  lista_voo_partida atual_partida;
  lista_voo_chegada atual_chegada;
  atual_chegada = chegadas;
  atual_partida = partidas;
  if(chegadas->next == NULL){
    while(partidas->next != NULL){
      if(strcmp(partidas->next->dep.nome,nome) == 0){
        return 2;
      }
      else{
        partidas = partidas->next;
      }
    }
  }
  else if(partidas->next == NULL){
    while(chegadas->next != NULL){
      if(strcmp(chegadas->next->arr.nome,nome) == 0){
        return 1;
      }
      else{
        chegadas = chegadas->next;
      }
    }
  }
  else if(partidas->next != NULL && chegadas->next != NULL){
    while(chegadas->next != NULL){
      if(strcmp(chegadas->next->arr.nome,nome) == 0){
        return 1;
      }
      else{
        chegadas = chegadas->next;
      }
    }
    while(partidas->next != NULL){
      if(strcmp(partidas->dep.nome,nome) == 0){
        return 2;
      }
      else{
        partidas = partidas->next;
      }
    }
  }
}

int condition(){

  double var;
  var = (hora_ut());
  if(lista_voo_aux->next != NULL){
    if(lista_voo_aux->next->inicial <= hora_ut()){
      return 1;
    }
    else{
      return 0;
    }
  }
  else{
    return 0;
  }
}

void *thread_manage(){

int k;
k=3;

while(1){
      pthread_mutex_lock(&mutex_thread);
      while(condition() == 0){
        if(lista_voo_aux->next != NULL){
          clock_gettime(CLOCK_REALTIME, &ts);
          double var;
          var = calcula_init(lista_voo_aux->next->inicial);
          ts.tv_sec += var;
          pthread_cond_timedwait(&cond,&mutex_thread,&ts);
        }
        else{
          clock_gettime(CLOCK_REALTIME, &ts);
          ts.tv_sec += 5;
          printf("ESPEROU + 5seg\n");
          pthread_cond_wait(&cond,&mutex_thread);
        }
      }

      pthread_mutex_unlock(&mutex_thread);
      k++;

      if(pthread_create(&thread_voo[k],NULL,thread_worker,(void *) &k) !=0){
          perror("ERROR creating the thread pipe!\n");
        }
        printf("Asnbasv\n");
    }

}

int main(){

  lista_voo_chegada aux_lista_chegada;
  lista_voo_partida aux_lista_partida;
  lista_voos aux_lista_voos;

  aux_lista_partida = lista_partida;
  aux_lista_chegada = lista_chegada;
  aux_lista_voos = lista_voo_aux;
  int k;
  k=-1;

  pthread_mutex_init(&mutex_thread,NULL);
  pthread_cond_init(&cond, NULL);

  debug_print("Programa iniciado");

  flog=fopen("log.txt","w");

  gestor();

 if(pthread_create(&thread_pipe,NULL,abre_pipe,NULL)!=0){
   perror("ERROR creating the thread pipe!\n");
 }

  if ((pid_torre = fork()) == 0) {
    criar_processo_torre();
  }
  else if (pid_torre == -1) {
    perror("Erro a criar o processo torre de controlo");
  }
  else{

    if(pthread_create(&thread_manage_id,NULL,thread_manage,NULL)!=0){
      perror("ERROR creating the thread pipe!\n");
    }
    while(1){
      sleep(10);
    }
  }
  fclose(flog);
  return 0;
}