From: Heng Li <lh3@me.com>
Date: Wed, 9 Oct 2013 03:01:44 +0000 (-0400)
Subject: fixed a typo
X-Git-Tag: spawn-final~11
X-Git-Url: http://www.kaiwu.me/postgresql/commit/?a=commitdiff_plain;h=98b1434a721ab94907a99698526679f9107cb87f;p=klib.git

fixed a typo
---

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;