src/evanix.c


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

#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);
}