Código (c) [Seleccionar]
static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
Routinas
Código (c) [Seleccionar]
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);
}
Mi proyecto consiste en conectar dos procesos mediante pipes, un proceso es el controlador y el otro es agente. El controlador basicamente se encarga de leer del pipe y enviar una respuesta, el punto es que estoy leyendo del pipe a través de un hilo, sin embargo,cada vez que se conecta un agente, el controlador lee el nombre del agente enviado por el agente y luego se crea un fifo que es el fd por donde se comunicaran ellos dos. Vale, el punto es que si llegan el agente1 y el agente2 al mismo tiempo no estoy seguro de lo que pasa pero creo que ambos entra a la sección critica y no me crea el fifo para cada agente sino que la variable se concatena.
No supe montar la imagen aqui pero en el link pueden ver que es lo que pasa
https://ibb.co/JsgfTp5
Entonces no se si me puedan ayudar a garantizar que si dos agente o mas se conectan a la vez atienda primero a uno y luego si siga con el otro.
Código (c) [Seleccionar]
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);
.