static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
 

void *routineRead(void *val)
{
    pthread_mutex_lock(&mutex);
    int fg = 0, fd;
    void *buf = malloc(MAX_SIZE * 2);
    do
    {
        fd = open(val, O_RDONLY);
        if (fd == -1)
        {
            perror("pipe");
            printf(" Se volvera a intentar despues\n");
            sleep(5);
        }
        else
            fg = 1;
    } while (fg == 0);
    read(fd, buf, MAX_SIZE * 2);
    close(fd);
    pthread_mutex_unlock(&mutex);
    return buf;
}
void *routineWrite(void *val)
{
    pthread_mutex_lock(&mutex1);
    int fg = 0, fd;
    int *time = malloc(sizeof(int));
    *time = bh.current_time;
    do
    {
        fd = open(val, O_WRONLY);
        if (fd == -1)
        {
            perror("pipe");
            printf(" Se volvera a intentar despues\n");
            sleep(5);
        }
        else
            fg = 1;
    } while (fg == 0);
    write(fd, time, MAX_SIZE);
    close(fd);
    pthread_mutex_unlock(&mutex1);
}
 

    pthread_t p_read, p_write, p_time;
    sem_init(&sem, 0, 1);
    sem_init(&sem1, 0, 1);
    clean_fifo(pipe);
    int seconds = atoi(argv[6]);
    pthread_create(&p_time, NULL, routineTime, &seconds);
    do
    {
        int cont = 0;
        //p_read get the agent name from the pipe
        pthread_create(&p_read, NULL, routineRead, pipe);
        pthread_join(p_read, (void **)&agent_name);
        printf("Agente:%s\t", agent_name);
        clean_fifo(agent_name);
        //send current time
        pthread_create(&p_write, NULL, routineWrite, pipe);
        pthread_join(p_write, NULL);
        printf("pipe: %s\n", agent_name);
        //Read all the requests by an agent
        do
        {
            pthread_create(&p_read, NULL, routineRead, agent_name);
            pthread_join(p_read, (void **)&data[cont].re);
            if (data[cont].re->amount_people != 0)
                answer_request(&tree, data[cont].re, &bh);
            else
                break;
            write_pipe(fd, (struct Reserva *)data[cont].re, sizeof(Reserva), agent_name, O_WRONLY);
            cont++;
        } while (1);
 
    } while (1);