aboutsummaryrefslogtreecommitdiff
path: root/src/queue.c
diff options
context:
space:
mode:
authorSinan Mohd <sinan@sinanmohd.com>2024-06-28 18:17:52 +0530
committerGitHub <noreply@github.com>2024-06-28 18:17:52 +0530
commitaca945d03814af570a03f1f376c8ece092c6eba8 (patch)
tree2296af3fe875c525fdf70575338c148e0bf0940c /src/queue.c
parentf93d74d857bdb006fbd4d6691b058985dd2e6e51 (diff)
parent4b43a81d6082b7c6fe70234a5df912b3218bee05 (diff)
Merge pull request #2 from SomeoneSerge/review/round1
review: round 1
Diffstat (limited to 'src/queue.c')
-rw-r--r--src/queue.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/queue.c b/src/queue.c
index 09eebb6..3a7ca52 100644
--- a/src/queue.c
+++ b/src/queue.c
@@ -41,7 +41,7 @@ static int queue_dag_isolate(struct job *job, struct job *keep_parent,
job->parents_filled = 0;
}
- if (!job->transitive)
+ if (job->scheduled)
CIRCLEQ_REMOVE(jobs, job, clist);
ret = htab_delete(htab, job->drv_path);
@@ -169,8 +169,8 @@ static int queue_push(struct queue *queue, struct job *job)
}
/* no duplicate entries in queue */
- if (job->transitive) {
- job->transitive = false;
+ if (!job->scheduled) {
+ job->scheduled = true;
CIRCLEQ_INSERT_TAIL(&queue->jobs, job, clist);
}
pthread_mutex_unlock(&queue->mutex);