/* pipe to wake the poll thread when necessary */
int consumer_poll_pipe[2];
/* to let the signal handler wake up the fd receiver thread */
int consumer_should_quit[2];
/* pipe to wake the poll thread when necessary */
int consumer_poll_pipe[2];
/* to let the signal handler wake up the fd receiver thread */
int consumer_should_quit[2];