[sr-dev] git:master:f8909163: core: add infrastructure to run functions in threads

Module: kamailio Branch: master Commit: f8909163c47c8776d23373fad688586f02d31e67 URL: https://github.com/kamailio/kamailio/commit/f8909163c47c8776d23373fad688586… Author: S-P Chan &lt;shihping.chan(a)gmail.com&gt; Committer: S-P Chan &lt;shihping.chan(a)gmail.com&gt; Date: 2024-01-31T16:47:09+08:00 core: add infrastructure to run functions in threads --- Added: src/core/rthreads.h --- Diff: https://github.com/kamailio/kamailio/commit/f8909163c47c8776d23373fad688586… Patch: https://github.com/kamailio/kamailio/commit/f8909163c47c8776d23373fad688586… --- diff --git a/src/core/rthreads.h b/src/core/rthreads.h new file mode 100644 index 00000000000..a5ad7670dae --- /dev/null +++ b/src/core/rthreads.h @@ -0,0 +1,100 @@ +/* + * Copyright (C) 2024 Chan Shih-Ping + * + * This file is part of Kamailio, a free SIP server. + * + * Permission to use, copy, modify, and distribute this software for any + * purpose with or without fee is hereby granted, provided that the above + * copyright notice and this permission notice appear in all copies. + * + * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES + * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR + * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES + * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN + * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF + * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + */ + +/* + * A set of helpers to run functions in threads. + * + * This is not a thread pool implementation - + * - it runs functions in a run-once thread to avoid + * creating thread-locals in the calling thread. + * + * Primary use case: to init libssl in a separate thread + */ +#include <pthread.h> + +/* + * prototype: void *fn(void *arg) { ... } + */ +typedef void *(*_thread_proto)(void *); + +#ifndef KSR_RTHREAD_SKIP_P +static void *run_threadP(_thread_proto fn, void *arg) +{ + pthread_t tid; + void *ret; + + pthread_create(&tid, NULL, fn, arg); + pthread_join(tid, &ret); + + return ret; +} +#endif + +/* + * prototype: void *fn(void *arg1, int arg2) { ... } + */ +#ifdef KSR_RTHREAD_NEED_PI +typedef void *(*_thread_protoPI)(void *, int); +struct _thread_argsPI +{ + _thread_protoPI fn; + void *tptr; + int tint; +}; +static void *run_thread_wrapPI(struct _thread_argsPI *args) +{ + return (*args->fn)(args->tptr, args->tint); +} + +static void *run_threadPI(_thread_protoPI fn, void *arg1, int arg2) +{ + pthread_t tid; + void *ret; + + pthread_create(&tid, NULL, (_thread_proto)&run_thread_wrapPI, + &(struct _thread_argsPI){fn, arg1, arg2}); + pthread_join(tid, &ret); + + return ret; +} +#endif + +/* + * prototype: void fn(void) { ... } + */ +#ifdef KSR_RTHREAD_NEED_V +typedef void (*_thread_protoV)(void); +struct _thread_argsV +{ + _thread_protoV fn; +}; +static void *run_thread_wrapV(struct _thread_argsV *args) +{ + (*args->fn)(); + return NULL; +} + +static void run_threadV(_thread_protoV fn) +{ + pthread_t tid; + + pthread_create(&tid, NULL, (_thread_proto)run_thread_wrapV, + &(struct _thread_argsV){fn}); + pthread_join(tid, NULL); +} +#endif