From dd794212390f3dfd9852bcf6602d88c918dfd26a Mon Sep 17 00:00:00 2001 From: Kirill Zhumarin Date: Sun, 13 Jan 2019 23:28:02 +0200 Subject: [PATCH] fix infinitie loop (revert my previous broken PR) --- source/mycore/thread_queue.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/source/mycore/thread_queue.c b/source/mycore/thread_queue.c index bca2470..862a2a3 100644 --- a/source/mycore/thread_queue.c +++ b/source/mycore/thread_queue.c @@ -458,7 +458,7 @@ void mythread_queue_list_entry_make_batch(mythread_t* mythread, mythread_queue_l return; size_t i = 0; - for(size_t from = mythread->id_increase; from < mythread->entries_length; from++) { + for(size_t from = mythread->id_increase; from <= mythread->entries_length; from++) { entry->thread_param[from].use = i; i++; } @@ -469,8 +469,9 @@ void mythread_queue_list_entry_make_stream(mythread_t* mythread, mythread_queue_ if(entry == NULL || mythread == NULL) return; - for(size_t from = mythread->id_increase; from < mythread->entries_length; from++) { - entry->thread_param[from].use = 0; + for(size_t from = mythread->id_increase; from <= mythread->entries_length; from++) { + if (from < entry->thread_param_size) + entry->thread_param[from].use = 0; } }