1118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati/****************************************************************************** 2118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * 3118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * Copyright (C) 2014 Google, Inc. 4118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * 5118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * Licensed under the Apache License, Version 2.0 (the "License"); 6118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * you may not use this file except in compliance with the License. 7118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * You may obtain a copy of the License at: 8118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * 9118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * http://www.apache.org/licenses/LICENSE-2.0 10118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * 11118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * Unless required by applicable law or agreed to in writing, software 12118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * distributed under the License is distributed on an "AS IS" BASIS, 13118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * See the License for the specific language governing permissions and 15118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * limitations under the License. 16118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati * 17118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati ******************************************************************************/ 18118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 19f8027005333c88a2f097cfd70d15c3d54c7764aeChris Manton#define LOG_TAG "bt_osi_thread" 20118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 2149a86709488e5cfd5e23759da18bf9613e15b04dMarie Janssen#include "osi/include/thread.h" 2249a86709488e5cfd5e23759da18bf9613e15b04dMarie Janssen 23118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <assert.h> 2494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati#include <errno.h> 25b9164f414b4d8d414358d0146a8f911207af3122Elliott Hughes#include <malloc.h> 26118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <pthread.h> 27118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <string.h> 28118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/prctl.h> 296c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach#include <sys/resource.h> 30118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/types.h> 31118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 320f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/allocator.h" 3347d68ee6229ccec3deeaaf694fa86438d97333a4Scott James Remnant#include "osi/include/compat.h" 340f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/fixed_queue.h" 350f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/log.h" 360f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/reactor.h" 370f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/semaphore.h" 38118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 3994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistruct thread_t { 4040fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson bool is_joined; 41118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_t pthread; 42118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pid_t tid; 4394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati char name[THREAD_NAME_MAX + 1]; 4494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_t *reactor; 4594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *work_queue; 4694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati}; 47118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 48118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatistruct start_arg { 49118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati thread_t *thread; 50118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_t *start_sem; 51118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati int error; 52118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati}; 53118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatitypedef struct { 5594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_fn func; 5694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati void *context; 5794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} work_item_t; 58118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg); 6094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context); 61118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 627307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonstatic const size_t DEFAULT_WORK_QUEUE_CAPACITY = 128; 63118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 647307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new_sized(const char *name, size_t work_queue_capacity) { 65118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati assert(name != NULL); 667307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton assert(work_queue_capacity != 0); 67118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 68384f8a948e9837475c4f504a626205334522df2aZach Johnson thread_t *ret = osi_calloc(sizeof(thread_t)); 6994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 7094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ret->reactor = reactor_new(); 7194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->reactor) 7294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 747307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton ret->work_queue = fixed_queue_new(work_queue_capacity); 7594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->work_queue) 7694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 78cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson // Start is on the stack, but we use a semaphore, so it's safe 7994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg start; 80118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.start_sem = semaphore_new(0); 81118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (!start.start_sem) 82118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 83118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 84118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati strncpy(ret->name, name, THREAD_NAME_MAX); 85118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.thread = ret; 86118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.error = 0; 87118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_create(&ret->pthread, NULL, run_thread, &start); 88118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_wait(start.start_sem); 8994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_free(start.start_sem); 90cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 91118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (start.error) 92118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 93cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 94118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return ret; 95118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 96118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatierror:; 9794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (ret) { 98c0745da4fb23eea23abac3c3cfd51cc7f1d38f6dSharvil Nanavati fixed_queue_free(ret->work_queue, osi_free); 9994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(ret->reactor); 10094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 101384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(ret); 102118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return NULL; 103118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 104118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 1057307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new(const char *name) { 1067307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton return thread_new_sized(name, DEFAULT_WORK_QUEUE_CAPACITY); 1077307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton} 1087307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton 10994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_free(thread_t *thread) { 11094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!thread) 11194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return; 11294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 11394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_stop(thread); 11440fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread_join(thread); 11540fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 116c0745da4fb23eea23abac3c3cfd51cc7f1d38f6dSharvil Nanavati fixed_queue_free(thread->work_queue, osi_free); 11794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(thread->reactor); 118384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(thread); 11994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 12094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 12140fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnsonvoid thread_join(thread_t *thread) { 12240fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson assert(thread != NULL); 12340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 12440fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson // TODO(zachoverflow): use a compare and swap when ready 12540fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson if (!thread->is_joined) { 12640fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread->is_joined = true; 12740fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson pthread_join(thread->pthread, NULL); 12840fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson } 12994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 13094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatibool thread_post(thread_t *thread, thread_fn func, void *context) { 13294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 13394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(func != NULL); 13494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // TODO(sharvil): if the current thread == |thread| and we've run out 13694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // of queue space, we should abort this operation, otherwise we'll 13794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // deadlock. 13894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Queue item is freed either when the queue itself is destroyed 14094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // or when the item is removed from the queue for dispatch. 141384f8a948e9837475c4f504a626205334522df2aZach Johnson work_item_t *item = (work_item_t *)osi_malloc(sizeof(work_item_t)); 14294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func = func; 14394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->context = context; 14494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_enqueue(thread->work_queue, item); 14594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return true; 14694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 14794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 14894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_stop(thread_t *thread) { 14994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 15094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_stop(thread->reactor); 15194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 15294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 1536c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbachbool thread_set_priority(thread_t *thread, int priority) { 1546c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach if (!thread) 1556c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach return false; 1566c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1576c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach const int rc = setpriority(PRIO_PROCESS, thread->tid, priority); 1586c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach if (rc < 0) { 159a2717afd580569d67fdaa7131255e405ac18e0ecPavlin Radoslavov LOG_ERROR(LOG_TAG, "%s unable to set thread priority %d for tid %d, error %d", 1606c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach __func__, priority, thread->tid, rc); 1616c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach return false; 1626c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach } 1636c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1646c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach return true; 1656c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach} 1666c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1677c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavatibool thread_is_self(const thread_t *thread) { 1687c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati assert(thread != NULL); 1697c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati return !!pthread_equal(pthread_self(), thread->pthread); 1707c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati} 1717c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati 1729d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavatireactor_t *thread_get_reactor(const thread_t *thread) { 1739d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati assert(thread != NULL); 1749d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati return thread->reactor; 1759d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati} 1769d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati 17794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavaticonst char *thread_name(const thread_t *thread) { 17894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 17994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return thread->name; 18094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 18194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 18294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg) { 18394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(start_arg != NULL); 18494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 18594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg *start = start_arg; 18694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_t *thread = start->thread; 18794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 18894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 18994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 19094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (prctl(PR_SET_NAME, (unsigned long)thread->name) == -1) { 191db554581079863974af8e1289646f5deea6fc044Marie Janssen LOG_ERROR(LOG_TAG, "%s unable to set thread name: %s", __func__, strerror(errno)); 19294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati start->error = errno; 19394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 19494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 19594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 19694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread->tid = gettid(); 19794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 198b5754d2fdfce8acba35ac8a03aae2ab88152dc6bSrinu Jella LOG_WARN(LOG_TAG, "%s: thread id %d, thread name %s started", __func__, thread->tid, thread->name); 199b5754d2fdfce8acba35ac8a03aae2ab88152dc6bSrinu Jella 20094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 20194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 202fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd = fixed_queue_get_dequeue_fd(thread->work_queue); 203fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void *context = thread->work_queue; 20494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 205fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_object_t *work_queue_object = reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); 20694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_start(thread->reactor); 207fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_unregister(work_queue_object); 20894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 20994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Make sure we dispatch all queued work items before exiting the thread. 21094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // This allows a caller to safely tear down by enqueuing a teardown 21194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // work item and then joining the thread. 21294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati size_t count = 0; 21394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_try_dequeue(thread->work_queue); 2147307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton while (item && count <= fixed_queue_capacity(thread->work_queue)) { 21594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 216384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 21794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item = fixed_queue_try_dequeue(thread->work_queue); 21894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ++count; 21994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 22094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 2217307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton if (count > fixed_queue_capacity(thread->work_queue)) 222db554581079863974af8e1289646f5deea6fc044Marie Janssen LOG_DEBUG(LOG_TAG, "%s growing event queue on shutdown.", __func__); 22394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 224b5754d2fdfce8acba35ac8a03aae2ab88152dc6bSrinu Jella LOG_WARN(LOG_TAG, "%s: thread id %d, thread name %s exited", __func__, thread->tid, thread->name); 22594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 22694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 22794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 22894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context) { 22994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(context != NULL); 23094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 23194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *queue = (fixed_queue_t *)context; 23294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_dequeue(queue); 23394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 234384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 235118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 236