X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fsel_thread.c;h=7d1d6e20ee8263ca841269b074bdd7b2c934b58e;hb=817e3ec506c4095bc4fcc1923cee36153ef4ee43;hp=1aca81a2f3a01b9d8b5b7a1d19be347e2feb9bd8;hpb=c7ce18b91b4b542af4f02ad9fa3f86f12b92f3d1;p=pazpar2-moved-to-github.git diff --git a/src/sel_thread.c b/src/sel_thread.c index 1aca81a..7d1d6e2 100644 --- a/src/sel_thread.c +++ b/src/sel_thread.c @@ -1,5 +1,5 @@ /* This file is part of Pazpar2. - Copyright (C) 2006-2012 Index Data + Copyright (C) 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 @@ -108,7 +108,7 @@ static void *sel_thread_handler(void *vp) /* work on this item */ p->work_handler(work_this->data); - + /* put it back into output queue */ yaz_mutex_enter(p->mutex); work_this->next = p->output_queue; @@ -121,7 +121,7 @@ static void *sel_thread_handler(void *vp) #else (void) write(p->write_fd, "", 1); #endif - } + } yaz_mutex_leave(p->mutex); return 0; } @@ -151,7 +151,7 @@ sel_thread_t sel_thread_create(void (*work_handler)(void *work_data), { nmem_destroy(nmem); return 0; - } + } *read_fd = p->read_fd = yaz_spipe_get_read_fd(p->spipe); p->write_fd = yaz_spipe_get_write_fd(p->spipe); @@ -186,7 +186,7 @@ void sel_thread_destroy(sel_thread_t p) p->stop_flag = 1; yaz_cond_broadcast(p->input_data); yaz_mutex_leave(p->mutex); - + for (i = 0; i< p->no_threads; i++) yaz_thread_join(&p->thread_id[i], 0); @@ -242,7 +242,7 @@ void *sel_thread_result(sel_thread_t p) /* put freed item in free list */ work_this->next = p->free_queue; p->free_queue = work_this; - + data = work_this->data; #ifdef WIN32 (void) recv(p->read_fd, read_buf, 1, 0);