From e24060925d23f025dfd6b0618641522ce85ff943 Mon Sep 17 00:00:00 2001
From: Pedro Gonnet <pedro.gonnet@durham.ac.uk>
Date: Thu, 20 Nov 2014 21:47:10 +0000
Subject: [PATCH] destroy threads on free.
---
src/queue.c | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/queue.c b/src/queue.c
index e648d8e..2b98592 100644
--- a/src/queue.c
+++ b/src/queue.c
@@ -47,7 +47,7 @@
int queue_get ( struct queue *q , struct qsched *s , int insist ) {
- int k, j, temp, tid, *inds, w, count;
+ int k, j, temp, tid, *inds, count;
struct task *tasks = s->tasks;
/* Should we even try? */
@@ -88,7 +88,7 @@ int queue_get ( struct queue *q , struct qsched *s , int insist ) {
inds[k] = inds[ count ];
/* Fix the heap. */
- w = tasks[ inds[k] ].weight;
+ long long int w = tasks[ inds[k] ].weight;
if ( k > 0 && w > tasks[ inds[(k-1)/2] ].weight )
while ( k > 0 ) {
j = (k - 1) / 2;
@@ -144,7 +144,7 @@ void queue_put ( struct queue *q , struct qsched *s , int tid ) {
int ind, j, temp;
struct task *tasks = s->tasks;
- int *inds, *inds_new, w;
+ int *inds, *inds_new;
/* Lock this queue. */
if ( lock_lock( &q->lock ) != 0 )
@@ -180,7 +180,7 @@ void queue_put ( struct queue *q , struct qsched *s , int tid ) {
inds[ind] = tid;
/* Bubble up the new entry. */
- w = tasks[ inds[ind] ].weight;
+ long long int w = tasks[ inds[ind] ].weight;
while ( ind > 0 ) {
j = (ind - 1)/2;
if ( tasks[ inds[j] ].weight < w ) {
--
GitLab