X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fsel_thread.c;h=8a14e55121101c36921d78d1c63829ecc9aa1429;hb=01f19b8c3664fa1c78d1fb9efb8e358d50f85c39;hp=6ce0f2abb55f65b550cd42935786ef9db9ecf3e9;hpb=8351b07cbbd0deab140944ce7ededa3d52ddb41c;p=pazpar2-moved-to-github.git diff --git a/src/sel_thread.c b/src/sel_thread.c index 6ce0f2a..8a14e55 100644 --- a/src/sel_thread.c +++ b/src/sel_thread.c @@ -1,5 +1,5 @@ /* This file is part of Pazpar2. - Copyright (C) 2006-2010 Index Data + Copyright (C) 2006-2011 Index Data Pazpar2 is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -24,7 +24,12 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #include "sel_thread.h" #include #include +#if HAVE_UNISTD_H #include +#endif +#ifdef WIN32 +#include +#endif #include #include #include @@ -94,7 +99,9 @@ static void *sel_thread_handler(void *vp) assert(p->input_queue); work_this = queue_remove_last(&p->input_queue); input_queue_length--; +#if 0 yaz_log(YLOG_DEBUG, "input queue length after pop: %d", input_queue_length); +#endif assert(work_this); yaz_mutex_leave(p->mutex); @@ -213,7 +220,9 @@ void sel_thread_add(sel_thread_t p, void *data) work_p->next = p->input_queue; p->input_queue = work_p; input_queue_length++; +#if 0 yaz_log(YLOG_DEBUG, "sel_thread_add: Input queue length after push: %d", input_queue_length); +#endif yaz_cond_signal(p->input_data); yaz_mutex_leave(p->mutex); }