#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h> /* Definition of AT_* constants */
#include <errno.h>
#include <sys/epoll.h>
int main(void) {
int fds[2];
if (mkfifo("./fifo1", 0644) < 0) {
perror("mkfifo()");
};
if (mkfifo("./fifo2", 0644) < 0) {
perror("mkfifo()");
};
if ((fds[0] = open("./fifo1", O_RDONLY|O_NONBLOCK, 0644)) < 0)
perror("open()");
if ((fds[1] = open("./fifo2", O_RDONLY|O_NONBLOCK, 0644)) < 0)
perror("open()");
int epfd;
struct epoll_event ev[2] = {0};
struct epoll_event evlist[2];
epfd = epoll_create(2);
if (epfd == -1) {
perror("epoll_create");
exit(EXIT_FAILURE);
}
ev[0].data.fd = fds[0];
ev[0].events = EPOLLIN;
if (epoll_ctl(epfd, EPOLL_CTL_ADD, fds[0], &ev[0]) == -1) {
perror("epoll_ctl");
exit(EXIT_FAILURE);
}
ev[1].data.fd = fds[1];
ev[1].events = EPOLLIN;
if (epoll_ctl(epfd, EPOLL_CTL_ADD, fds[1], &ev[1]) == -1) {
perror("epoll_ctl");
exit(EXIT_FAILURE);
}
while (1) {
int ready = epoll_wait(epfd, evlist, 2, -1);
if (ready == -1) {
if (errno == EINTR)
continue;
else {
perror("epoll_wait()");
exit(EXIT_FAILURE);
}
}
printf("ready: %d\n", ready);
}
// char buf[4096] = {0};
// ssize_t n;
// ssize_t result;
// size_t remains;
// for (;;) {
// char *p = buf;
// n = 0;
// remains = 4096;
// while (remains > 0) {
// if ((result = read(fds[0], p, remains)) == -1) {
// if (errno == EAGAIN || errno == ETIMEDOUT) {
// sleep(1);
// continue;
// } else {
// perror("read()");
// exit(EXIT_FAILURE);
// }
// }
// n += result;
// remains -= result;
// printf("%s", p);
// p += n;
// }
// }
}