thread.c revision 47d68ee6229ccec3deeaaf694fa86438d97333a4
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 21118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <assert.h> 2294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati#include <errno.h> 23118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <pthread.h> 24118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <string.h> 25118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/prctl.h> 26118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include <sys/types.h> 27118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 280f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/allocator.h" 2947d68ee6229ccec3deeaaf694fa86438d97333a4Scott James Remnant#include "osi/include/compat.h" 300f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/fixed_queue.h" 310f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/log.h" 320f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/reactor.h" 330f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/semaphore.h" 340f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/thread.h" 35118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 3694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistruct thread_t { 3740fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson bool is_joined; 38118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_t pthread; 39118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pid_t tid; 4094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati char name[THREAD_NAME_MAX + 1]; 4194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_t *reactor; 4294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *work_queue; 4394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati}; 44118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 45118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatistruct start_arg { 46118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati thread_t *thread; 47118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_t *start_sem; 48118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati int error; 49118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati}; 50118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatitypedef struct { 5294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_fn func; 5394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati void *context; 5494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} work_item_t; 55118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg); 5794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context); 58118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 597307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonstatic const size_t DEFAULT_WORK_QUEUE_CAPACITY = 128; 60118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 617307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new_sized(const char *name, size_t work_queue_capacity) { 62118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati assert(name != NULL); 637307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton assert(work_queue_capacity != 0); 64118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 65384f8a948e9837475c4f504a626205334522df2aZach Johnson thread_t *ret = osi_calloc(sizeof(thread_t)); 66118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (!ret) 67118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 6894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 6994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ret->reactor = reactor_new(); 7094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->reactor) 7194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 737307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton ret->work_queue = fixed_queue_new(work_queue_capacity); 7494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->work_queue) 7594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 77cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson // Start is on the stack, but we use a semaphore, so it's safe 7894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg start; 79118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.start_sem = semaphore_new(0); 80118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (!start.start_sem) 81118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 82118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 83118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati strncpy(ret->name, name, THREAD_NAME_MAX); 84118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.thread = ret; 85118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.error = 0; 86118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_create(&ret->pthread, NULL, run_thread, &start); 87118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_wait(start.start_sem); 8894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_free(start.start_sem); 89cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 90118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (start.error) 91118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 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 1047307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new(const char *name) { 1057307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton return thread_new_sized(name, DEFAULT_WORK_QUEUE_CAPACITY); 1067307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton} 1077307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton 10894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_free(thread_t *thread) { 10994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!thread) 11094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return; 11194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 11294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_stop(thread); 11340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread_join(thread); 11440fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 115c0745da4fb23eea23abac3c3cfd51cc7f1d38f6dSharvil Nanavati fixed_queue_free(thread->work_queue, osi_free); 11694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(thread->reactor); 117384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(thread); 11894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 11994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 12040fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnsonvoid thread_join(thread_t *thread) { 12140fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson assert(thread != NULL); 12240fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 12340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson // TODO(zachoverflow): use a compare and swap when ready 12440fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson if (!thread->is_joined) { 12540fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread->is_joined = true; 12640fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson pthread_join(thread->pthread, NULL); 12740fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson } 12840fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson} 12940fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 13094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatibool thread_post(thread_t *thread, thread_fn func, void *context) { 13194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 13294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(func != NULL); 13394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // TODO(sharvil): if the current thread == |thread| and we've run out 13594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // of queue space, we should abort this operation, otherwise we'll 13694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // deadlock. 13794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Queue item is freed either when the queue itself is destroyed 13994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // or when the item is removed from the queue for dispatch. 140384f8a948e9837475c4f504a626205334522df2aZach Johnson work_item_t *item = (work_item_t *)osi_malloc(sizeof(work_item_t)); 14194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!item) { 14244802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to allocate memory: %s", __func__, strerror(errno)); 14394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return false; 14494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 14594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func = func; 14694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->context = context; 14794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_enqueue(thread->work_queue, item); 14894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return true; 14994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 15094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 15194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_stop(thread_t *thread) { 15294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 15394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_stop(thread->reactor); 15494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 15594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 1567c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavatibool thread_is_self(const thread_t *thread) { 1577c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati assert(thread != NULL); 1587c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati return !!pthread_equal(pthread_self(), thread->pthread); 1597c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati} 1607c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati 1619d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavatireactor_t *thread_get_reactor(const thread_t *thread) { 1629d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati assert(thread != NULL); 1639d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati return thread->reactor; 1649d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati} 1659d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati 16694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavaticonst char *thread_name(const thread_t *thread) { 16794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 16894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return thread->name; 16994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 17094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg) { 17294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(start_arg != NULL); 17394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg *start = start_arg; 17594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_t *thread = start->thread; 17694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 17894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (prctl(PR_SET_NAME, (unsigned long)thread->name) == -1) { 18044802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to set thread name: %s", __func__, strerror(errno)); 18194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati start->error = errno; 18294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 18394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 18494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 18594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread->tid = gettid(); 18694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 18794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 18894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 189fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd = fixed_queue_get_dequeue_fd(thread->work_queue); 190fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void *context = thread->work_queue; 19194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 192fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_object_t *work_queue_object = reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); 19394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_start(thread->reactor); 194fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_unregister(work_queue_object); 19594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 19694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Make sure we dispatch all queued work items before exiting the thread. 19794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // This allows a caller to safely tear down by enqueuing a teardown 19894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // work item and then joining the thread. 19994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati size_t count = 0; 20094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_try_dequeue(thread->work_queue); 2017307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton while (item && count <= fixed_queue_capacity(thread->work_queue)) { 20294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 203384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 20494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item = fixed_queue_try_dequeue(thread->work_queue); 20594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ++count; 20694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 20794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 2087307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton if (count > fixed_queue_capacity(thread->work_queue)) 20944802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_DEBUG("%s growing event queue on shutdown.", __func__); 21094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 21194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 21294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 21394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 21494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context) { 21594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(context != NULL); 21694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 21794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *queue = (fixed_queue_t *)context; 21894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_dequeue(queue); 21994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 220384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(item); 221118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 222