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 23de3135d1a6adbe5d5f4c1eec6f610009f72f317dMyles Watson#include <atomic> 24de3135d1a6adbe5d5f4c1eec6f610009f72f317dMyles Watson 25f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He#include <base/logging.h> 2694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati#include <errno.h> 27b9164f414b4d8d414358d0146a8f911207af3122Elliott Hughes#include <malloc.h> 28118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <pthread.h> 29118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <string.h> 30118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/prctl.h> 316c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach#include <sys/resource.h> 32118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/types.h> 336aee1e82aa0bf44d7e382f1b01448fe31c490763Mark Salyzyn#include <unistd.h> 34118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 350f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/allocator.h" 3647d68ee6229ccec3deeaaf694fa86438d97333a4Scott James Remnant#include "osi/include/compat.h" 370f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/fixed_queue.h" 380f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/log.h" 390f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/reactor.h" 400f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/semaphore.h" 41118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 4294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistruct thread_t { 43de3135d1a6adbe5d5f4c1eec6f610009f72f317dMyles Watson std::atomic_bool is_joined{false}; 44118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_t pthread; 45118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pid_t tid; 4694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati char name[THREAD_NAME_MAX + 1]; 47b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson reactor_t* reactor; 48b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson fixed_queue_t* work_queue; 4994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati}; 50118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 51118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatistruct start_arg { 52b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson thread_t* thread; 53b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson semaphore_t* start_sem; 54118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati int error; 55118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati}; 56118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatitypedef struct { 5894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_fn func; 59b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson void* context; 6094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} work_item_t; 61118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 62b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonstatic void* run_thread(void* start_arg); 63b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonstatic void work_queue_read_cb(void* context); 64118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 657307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonstatic const size_t DEFAULT_WORK_QUEUE_CAPACITY = 128; 66118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 67b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonthread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { 68f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(name != NULL); 69f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(work_queue_capacity != 0); 70118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 71b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson thread_t* ret = static_cast<thread_t*>(osi_calloc(sizeof(thread_t))); 7294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 7394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ret->reactor = reactor_new(); 74b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (!ret->reactor) goto error; 7594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 767307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton ret->work_queue = fixed_queue_new(work_queue_capacity); 77b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (!ret->work_queue) goto error; 7894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 79cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson // Start is on the stack, but we use a semaphore, so it's safe 8094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg start; 81118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.start_sem = semaphore_new(0); 82b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (!start.start_sem) 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 91b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (start.error) goto error; 92cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 93118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return ret; 94118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 95118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatierror:; 9694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (ret) { 97c0745da4fb23eea23abac3c3cfd51cc7f1d38f6dSharvil Nanavati fixed_queue_free(ret->work_queue, osi_free); 9894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(ret->reactor); 9994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 100384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(ret); 101118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return NULL; 102118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 103118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 104b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonthread_t* thread_new(const char* name) { 1057307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton return thread_new_sized(name, DEFAULT_WORK_QUEUE_CAPACITY); 1067307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton} 1077307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton 108b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonvoid thread_free(thread_t* thread) { 109b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (!thread) return; 11094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 11194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_stop(thread); 11240fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread_join(thread); 11340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 114c0745da4fb23eea23abac3c3cfd51cc7f1d38f6dSharvil Nanavati fixed_queue_free(thread->work_queue, osi_free); 11594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(thread->reactor); 116384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(thread); 11794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 11894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 119b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonvoid thread_join(thread_t* thread) { 120f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 12140fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 122de3135d1a6adbe5d5f4c1eec6f610009f72f317dMyles Watson if (!std::atomic_exchange(&thread->is_joined, true)) 12340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson pthread_join(thread->pthread, NULL); 12494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 12594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 126b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonbool thread_post(thread_t* thread, thread_fn func, void* context) { 127f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 128f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(func != NULL); 12994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // TODO(sharvil): if the current thread == |thread| and we've run out 13194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // of queue space, we should abort this operation, otherwise we'll 13294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // deadlock. 13394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Queue item is freed either when the queue itself is destroyed 13594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // or when the item is removed from the queue for dispatch. 136b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson work_item_t* item = (work_item_t*)osi_malloc(sizeof(work_item_t)); 13794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func = func; 13894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->context = context; 13994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_enqueue(thread->work_queue, item); 14094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return true; 14194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 14294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 143b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonvoid thread_stop(thread_t* thread) { 144f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 14594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_stop(thread->reactor); 14694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 14794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 148b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonbool thread_set_priority(thread_t* thread, int priority) { 149b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson if (!thread) return false; 1506c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1516c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach const int rc = setpriority(PRIO_PROCESS, thread->tid, priority); 1526c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach if (rc < 0) { 153b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson LOG_ERROR(LOG_TAG, 154b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson "%s unable to set thread priority %d for tid %d, error %d", 155b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson __func__, priority, thread->tid, rc); 1566c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach return false; 1576c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach } 1586c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1596c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach return true; 1606c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach} 1616c25b3c02c863cbb047e4cf8b4ec88d8335dac30Andre Eisenbach 1620035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadrabool thread_set_rt_priority(thread_t* thread, int priority) { 1630035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra if (!thread) return false; 1640035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra 1650035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra struct sched_param rt_params; 1660035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra rt_params.sched_priority = priority; 1670035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra 1680035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra const int rc = sched_setscheduler(thread->tid, SCHED_FIFO, &rt_params); 1690035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra if (rc != 0) { 1700035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra LOG_ERROR(LOG_TAG, 1710035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra "%s unable to set SCHED_FIFO priority %d for tid %d, error %s", 1720035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra __func__, priority, thread->tid, strerror(errno)); 1730035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra return false; 1740035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra } 1750035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra 1760035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra return true; 1770035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra} 1780035d8c9a8b50456f72874174857950df0ecfc67Philip Cuadra 179b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonbool thread_is_self(const thread_t* thread) { 180f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 1817c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati return !!pthread_equal(pthread_self(), thread->pthread); 1827c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati} 1837c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati 184b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonreactor_t* thread_get_reactor(const thread_t* thread) { 185f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 1869d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati return thread->reactor; 1879d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati} 1889d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati 189b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonconst char* thread_name(const thread_t* thread) { 190f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 19194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return thread->name; 19294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 19394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 194b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonstatic void* run_thread(void* start_arg) { 195f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(start_arg != NULL); 19694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 197b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson struct start_arg* start = static_cast<struct start_arg*>(start_arg); 198b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson thread_t* thread = start->thread; 19994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 200f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(thread != NULL); 20194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 20294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (prctl(PR_SET_NAME, (unsigned long)thread->name) == -1) { 203b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson LOG_ERROR(LOG_TAG, "%s unable to set thread name: %s", __func__, 204b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson strerror(errno)); 20594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati start->error = errno; 20694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 20794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 20894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 20994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread->tid = gettid(); 21094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 211b7baea62386552af553ee1976111cdcb212e6e40Myles Watson LOG_INFO(LOG_TAG, "%s: thread id %d, thread name %s started", __func__, 212b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson thread->tid, thread->name); 2130fa35546304901c62bafcb54420d23ace56a69c1Srinu Jella 21494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 21594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 216fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd = fixed_queue_get_dequeue_fd(thread->work_queue); 217b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson void* context = thread->work_queue; 21894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 219b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson reactor_object_t* work_queue_object = 220b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); 22194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_start(thread->reactor); 222fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_unregister(work_queue_object); 22394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 22494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Make sure we dispatch all queued work items before exiting the thread. 22594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // This allows a caller to safely tear down by enqueuing a teardown 22694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // work item and then joining the thread. 22794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati size_t count = 0; 228b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson work_item_t* item = 229b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue)); 2307307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton while (item && count <= fixed_queue_capacity(thread->work_queue)) { 23194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 232384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 233b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson item = 234b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue)); 23594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ++count; 23694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 23794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 2387307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton if (count > fixed_queue_capacity(thread->work_queue)) 239db554581079863974af8e1289646f5deea6fc044Marie Janssen LOG_DEBUG(LOG_TAG, "%s growing event queue on shutdown.", __func__); 24094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 241b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson LOG_WARN(LOG_TAG, "%s: thread id %d, thread name %s exited", __func__, 242b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson thread->tid, thread->name); 24394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 24494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 24594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 246b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watsonstatic void work_queue_read_cb(void* context) { 247f2af1c42ccb2f642b241c2261b42d0be61d45438Jack He CHECK(context != NULL); 24894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 249b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson fixed_queue_t* queue = (fixed_queue_t*)context; 250b55040cc6448a8847490da807d2b6362aa8cb8d9Myles Watson work_item_t* item = static_cast<work_item_t*>(fixed_queue_dequeue(queue)); 25194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 252384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 253118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 254