From 98b1434a721ab94907a99698526679f9107cb87f Mon Sep 17 00:00:00 2001 From: Heng Li Date: Tue, 8 Oct 2013 23:01:44 -0400 Subject: [PATCH] fixed a typo --- kthread.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kthread.c b/kthread.c index e4b6568..57c8fed 100644 --- a/kthread.c +++ b/kthread.c @@ -58,7 +58,7 @@ int dq_deq(deque_t *q, int is_back, dqval_t *v) --q->count; } else ret = -1; __sync_lock_release(&q->lock); - return 0; + return ret; } /********************************** @@ -93,6 +93,7 @@ static void *ktf_worker(void *data) if (max < dq_size(w->f->w[i].q)) max = dq_size(w->f->w[i].q), max_i = i; if (dq_deq(w->f->w[max_i].q, 0, &k) < 0) k = -1; + k = -1; } if (k >= 0) w->f->func(w->f->global, (uint8_t*)w->f->local + w->f->size * k); else if (w->f->finished) break; -- 2.47.3