fixed a typo

diff --git a/kthread.c b/kthread.c
index e4b65687e04d8351c87209a7f3114288c43563ff..57c8fedc1204268d548de6f7854ed2f8a2165841 100644 (file)
--- 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;