null+****@clear*****
null+****@clear*****
2010年 10月 13日 (水) 16:50:02 JST
Daijiro MORI 2010-10-13 07:50:02 +0000 (Wed, 13 Oct 2010)
New Revision: f28007a54a83d291fa04b6820d3045b1f9534449
Log:
Fixed missing decrement of 'nfthreads' value.
Modified files:
src/groonga.c
Modified: src/groonga.c (+4 -1)
===================================================================
--- src/groonga.c 2010-10-12 16:37:26 +0000 (dd82aac)
+++ src/groonga.c 2010-10-13 07:50:02 +0000 (b2a2f39)
@@ -1637,7 +1637,10 @@ g_worker(void *arg)
nfthreads++;
while (!(edge = (grn_edge *)grn_com_queue_deque(&grn_gctx, &ctx_new))) {
COND_WAIT(q_cond, q_mutex);
- if (grn_gctx.stat == GRN_CTX_QUIT) { goto exit; }
+ if (grn_gctx.stat == GRN_CTX_QUIT) {
+ nfthreads--;
+ goto exit;
+ }
}
ctx = &edge->ctx;
nfthreads--;