#include <signal.h>
#include <errno.h>
+#include "log.h"
#include "thread.h"
Thread::~Thread() {}
should_stop = false;
int pipefd[2];
if (pipe2(pipefd, O_CLOEXEC) == -1) {
- perror("pipe");
+ log_perror("pipe");
exit(1);
}
stop_fd_read = pipefd[0];
} while (err == -1 && errno == EINTR);
if (err == -1) {
- perror("write");
+ log_perror("write");
exit(1);
}
} while (err == -1 && errno == EINTR);
if (err == -1) {
- perror("close");
+ log_perror("close");
// Can continue (we have close-on-exec).
}
pthread_kill(worker_thread, SIGHUP);
if (pthread_join(worker_thread, NULL) == -1) {
- perror("pthread_join");
+ log_perror("pthread_join");
exit(1);
}
} while (err == -1 && errno == EINTR);
if (err == -1) {
- perror("close");
+ log_perror("close");
// Can continue (we have close-on-exec).
}
}