thread.c revision 40fbe5de2fbbbd08e2dad4f1458cef291500fb20
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 19118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#define LOG_TAG "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#include <utils/Log.h> 28118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 2994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati#include "fixed_queue.h" 3094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati#include "reactor.h" 31118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include "semaphore.h" 32118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati#include "thread.h" 33118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 3494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistruct thread_t { 3540fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson bool is_joined; 36118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_t pthread; 37118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pid_t tid; 3894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati char name[THREAD_NAME_MAX + 1]; 3994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_t *reactor; 4094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *work_queue; 4194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati}; 42118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 43118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatistruct start_arg { 44118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati thread_t *thread; 45118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_t *start_sem; 46118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati int error; 47118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati}; 48118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 4994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatitypedef struct { 5094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_fn func; 5194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati void *context; 5294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} work_item_t; 53118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 5494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg); 5594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context); 56118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 577307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonstatic const size_t DEFAULT_WORK_QUEUE_CAPACITY = 128; 58118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 597307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new_sized(const char *name, size_t work_queue_capacity) { 60118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati assert(name != NULL); 617307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton assert(work_queue_capacity != 0); 62118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 6394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_t *ret = calloc(1, sizeof(thread_t)); 64118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (!ret) 65118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 6694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 6794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ret->reactor = reactor_new(); 6894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->reactor) 6994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 717307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton ret->work_queue = fixed_queue_new(work_queue_capacity); 7294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!ret->work_queue) 7394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati goto error; 7494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 75cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson // Start is on the stack, but we use a semaphore, so it's safe 7694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg start; 77118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.start_sem = semaphore_new(0); 78118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (!start.start_sem) 79118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 80118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 81118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati strncpy(ret->name, name, THREAD_NAME_MAX); 82118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.thread = ret; 83118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati start.error = 0; 84118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati pthread_create(&ret->pthread, NULL, run_thread, &start); 85118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati semaphore_wait(start.start_sem); 8694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_free(start.start_sem); 87cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 88118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati if (start.error) 89118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati goto error; 90cc3306f36fc9b0fe6f93bf9003ee8759f78d1a1eZach Johnson 91118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return ret; 92118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 93118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavatierror:; 9494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (ret) { 9594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_free(ret->work_queue, free); 9694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(ret->reactor); 9794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 98118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati free(ret); 99118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati return NULL; 100118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 101118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati 1027307d70bb66c451ed5a02f26d3add98eefd541a1Chris Mantonthread_t *thread_new(const char *name) { 1037307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton return thread_new_sized(name, DEFAULT_WORK_QUEUE_CAPACITY); 1047307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton} 1057307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton 10694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_free(thread_t *thread) { 10794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!thread) 10894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return; 10994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 11094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_stop(thread); 11140fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread_join(thread); 11240fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 11394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_free(thread->work_queue, free); 11494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_free(thread->reactor); 11594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati free(thread); 11694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 11794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 11840fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnsonvoid thread_join(thread_t *thread) { 11940fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson assert(thread != NULL); 12040fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 12140fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson // TODO(zachoverflow): use a compare and swap when ready 12240fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson if (!thread->is_joined) { 12340fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson thread->is_joined = true; 12440fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson pthread_join(thread->pthread, NULL); 12540fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson } 12640fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson} 12740fbe5de2fbbbd08e2dad4f1458cef291500fb20Zach Johnson 12894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatibool thread_post(thread_t *thread, thread_fn func, void *context) { 12994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 13094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(func != NULL); 13194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // TODO(sharvil): if the current thread == |thread| and we've run out 13394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // of queue space, we should abort this operation, otherwise we'll 13494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // deadlock. 13594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 13694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Queue item is freed either when the queue itself is destroyed 13794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // or when the item is removed from the queue for dispatch. 13894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = (work_item_t *)malloc(sizeof(work_item_t)); 13994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (!item) { 14094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ALOGE("%s unable to allocate memory: %s", __func__, strerror(errno)); 14194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return false; 14294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 14394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func = func; 14494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->context = context; 14594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_enqueue(thread->work_queue, item); 14694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return true; 14794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 14894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 14994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavativoid thread_stop(thread_t *thread) { 15094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 15194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_stop(thread->reactor); 15294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 15394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 1547c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavatibool thread_is_self(const thread_t *thread) { 1557c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati assert(thread != NULL); 1567c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati return !!pthread_equal(pthread_self(), thread->pthread); 1577c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati} 1587c19f013b81edd43466ac88bf078cfdcf4ba534aSharvil Nanavati 1599d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavatireactor_t *thread_get_reactor(const thread_t *thread) { 1609d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati assert(thread != NULL); 1619d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati return thread->reactor; 1629d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati} 1639d461af487359872d8abcfa23a0f8747f401a88fSharvil Nanavati 16494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavaticonst char *thread_name(const thread_t *thread) { 16594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 16694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return thread->name; 16794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 16894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 16994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void *run_thread(void *start_arg) { 17094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(start_arg != NULL); 17194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati struct start_arg *start = start_arg; 17394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread_t *thread = start->thread; 17494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(thread != NULL); 17694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 17794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati if (prctl(PR_SET_NAME, (unsigned long)thread->name) == -1) { 17894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ALOGE("%s unable to set thread name: %s", __func__, strerror(errno)); 17994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati start->error = errno; 18094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 18194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 18294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 18394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati thread->tid = gettid(); 18494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 18594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati semaphore_post(start->start_sem); 18694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 187fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd = fixed_queue_get_dequeue_fd(thread->work_queue); 188fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void *context = thread->work_queue; 18994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 190fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_object_t *work_queue_object = reactor_register(thread->reactor, fd, context, work_queue_read_cb, NULL); 19194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati reactor_start(thread->reactor); 192fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_unregister(work_queue_object); 19394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 19494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // Make sure we dispatch all queued work items before exiting the thread. 19594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // This allows a caller to safely tear down by enqueuing a teardown 19694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati // work item and then joining the thread. 19794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati size_t count = 0; 19894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_try_dequeue(thread->work_queue); 1997307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton while (item && count <= fixed_queue_capacity(thread->work_queue)) { 20094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 20194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati free(item); 20294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item = fixed_queue_try_dequeue(thread->work_queue); 20394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ++count; 20494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati } 20594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 2067307d70bb66c451ed5a02f26d3add98eefd541a1Chris Manton if (count > fixed_queue_capacity(thread->work_queue)) 20794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati ALOGD("%s growing event queue on shutdown.", __func__); 20894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 20994347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati return NULL; 21094347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati} 21194347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 21294347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavatistatic void work_queue_read_cb(void *context) { 21394347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati assert(context != NULL); 21494347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati 21594347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati fixed_queue_t *queue = (fixed_queue_t *)context; 21694347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati work_item_t *item = fixed_queue_dequeue(queue); 21794347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati item->func(item->context); 21894347a59972868cf6d74f92cf793eb0b4b97c45aSharvil Nanavati free(item); 219118bdd58389c77dd69b37e377b4e98ea89d2b14eSharvil Nanavati} 220