comments: evanix.c

3 files changed, 8 insertions, 7 deletions

diff --git a/include/jobs.h b/include/jobs.h
index 37445c1..2e30547 100644
--- a/include/jobs.h
+++ b/include/jobs.h
@@ -36,7 +36,8 @@ typedef enum {
 } job_read_state_t;
 int job_read(FILE *stream, struct job **jobs);
 
-int jobs_init(FILE **stream, char *expr);
+/* Spawns nix-eval-jobs and connects its stdout to stream */
+int jobs_init(FILE **stream, const char *expr);
 void job_free(struct job *j);
 int job_parents_list_insert(struct job *job, struct job *parent);
 void job_deps_list_rm(struct job *job, struct job *dep);
diff --git a/src/evanix.c b/src/evanix.c
index 01279d1..27ab428 100644
--- a/src/evanix.c
+++ b/src/evanix.c
@@ -33,22 +33,22 @@ static int evanix(char *expr)
 {
 	struct queue_thread *queue_thread = NULL;
 	struct build_thread *build_thread = NULL;
-	FILE *stream = NULL;
+	FILE *jobsStream = NULL; /* nix-eval-jobs stdout */
 	int ret = 0;
 
-	ret = jobs_init(&stream, expr);
+	ret = jobs_init(&jobsStream, expr);
 	if (ret < 0)
 		goto out_free;
 
-	ret = queue_thread_new(&queue_thread, stream);
+	ret = queue_thread_new(&queue_thread, jobsStream);
 	if (ret < 0) {
-		free(stream);
+		free(jobsStream);
 		goto out_free;
 	}
 
 	ret = build_thread_new(&build_thread, queue_thread->queue);
 	if (ret < 0) {
-		free(stream);
+		free(jobsStream);
 		goto out_free;
 	}
 
diff --git a/src/jobs.c b/src/jobs.c
index 4e3926a..bda8d11 100644
--- a/src/jobs.c
+++ b/src/jobs.c
@@ -434,7 +434,7 @@ out_free_job:
 	return ret;
 }
 
-int jobs_init(FILE **stream, char *expr)
+int jobs_init(FILE **stream, const char *expr)
 {
 	size_t argindex;
 	char *args[6];