pthread_cleanup_pop(1);
}
-volatile sig_atomic_t have_listener = 0;
/* These should only be accessed in the parent thread,
* not the listener.
*/
+static volatile sig_atomic_t have_listener = 0;
static pthread_t listener_thread;
void create_listener(void)
/* Delete all blocked consumers */
list_for_each_entry(bc, &blocked_consumers, list) {
- close(bc->fd_producer);
- close(bc->fd_consumer);
+ result = close(bc->fd_producer);
+ if(result == -1) {
+ PERROR("close");
+ }
free(deletable_bc);
deletable_bc = bc;
list_del(&bc->list);