aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/evanix.c42
-rw-r--r--src/meson.build1
-rw-r--r--src/queue.c78
3 files changed, 120 insertions, 1 deletions
diff --git a/src/evanix.c b/src/evanix.c
index b552c8e..dcac070 100644
--- a/src/evanix.c
+++ b/src/evanix.c
@@ -1 +1,41 @@
-int main(void) {}
+#include <stdlib.h>
+#include <string.h>
+
+#include "queue.h"
+#include "util.h"
+
+int main(void)
+{
+ struct queue_thread *queue_thread = NULL;
+ FILE *stream = NULL;
+ int ret = 0;
+
+ ret = jobs_init(&stream);
+ if (ret < 0)
+ goto out_free;
+
+ ret = queue_thread_new(&queue_thread, stream);
+ if (ret < 0) {
+ free(stream);
+ goto out_free;
+ }
+
+ ret = pthread_create(&queue_thread->tid, NULL, queue_thread_entry,
+ queue_thread);
+ if (ret < 0) {
+ print_err("%s", strerror(ret));
+ ret = -ret;
+ goto out_free;
+ }
+
+ ret = pthread_join(queue_thread->tid, NULL);
+ if (ret < 0) {
+ print_err("%s", strerror(ret));
+ ret = -ret;
+ goto out_free;
+ }
+
+out_free:
+ queue_thread_free(queue_thread);
+ exit(ret < 0 ? EXIT_FAILURE : EXIT_SUCCESS);
+}
diff --git a/src/meson.build b/src/meson.build
index 5fe292f..bb68e18 100644
--- a/src/meson.build
+++ b/src/meson.build
@@ -4,6 +4,7 @@ e = executable(
'evanix.c',
'jobs.c',
'util.c',
+ 'queue.c',
],
include_directories: evanix_inc,
diff --git a/src/queue.c b/src/queue.c
new file mode 100644
index 0000000..5c196aa
--- /dev/null
+++ b/src/queue.c
@@ -0,0 +1,78 @@
+#include <errno.h>
+#include <pthread.h>
+#include <stdbool.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/queue.h>
+
+#include "queue.h"
+#include "util.h"
+
+void *queue_thread_entry(void *queue_thread)
+{
+ struct queue_thread *qt = queue_thread;
+ struct job *job = NULL;
+ int ret = 0;
+
+ while (true) {
+ ret = job_read(qt->stream, &job);
+ if (ret < 0) {
+ if (ret == -EOF)
+ ret = 0;
+ break;
+ }
+
+ pthread_mutex_lock(&qt->queue->mutex);
+ CIRCLEQ_INSERT_TAIL(&qt->queue->jobs, job, clist);
+ pthread_mutex_unlock(&qt->queue->mutex);
+ }
+
+ pthread_exit(NULL);
+}
+
+void queue_thread_free(struct queue_thread *queue_thread)
+{
+ struct job *job;
+
+ if (queue_thread == NULL)
+ return;
+
+ CIRCLEQ_FOREACH (job, &queue_thread->queue->jobs, clist) {
+ CIRCLEQ_REMOVE(&queue_thread->queue->jobs, job, clist);
+ free(job);
+ }
+
+ free(queue_thread->queue);
+ fclose(queue_thread->stream);
+}
+
+int queue_thread_new(struct queue_thread **queue_thread, FILE *stream)
+{
+ int ret = 0;
+ struct queue_thread *qt = NULL;
+
+ qt = malloc(sizeof(*qt));
+ if (qt == NULL) {
+ print_err("%s", strerror(errno));
+ return -errno;
+ }
+
+ qt->stream = stream;
+
+ qt->queue = malloc(sizeof(*qt->queue));
+ if (qt->queue == NULL) {
+ print_err("%s", strerror(errno));
+ ret = -errno;
+ goto out_free;
+ }
+ CIRCLEQ_INIT(&qt->queue->jobs);
+ pthread_mutex_init(&qt->queue->mutex, NULL);
+
+out_free:
+ if (ret < 0)
+ free(qt);
+ else
+ *queue_thread = qt;
+
+ return ret;
+}