git:5.7:5132dcef: core: add infrastructure to run functions in threads - sr-dev

4 Feb 2024

Module: kamailio
Branch: 5.7
Commit: 5132dcef7a067c1337256c93f8469cb07542d9c5
URL: https://github.com/kamailio/kamailio/commit/5132dcef7a067c1337256c93f8469cb0...
Author: S-P Chan shihping.chan@gmail.com
Committer: S-P Chan shihping.chan@gmail.com
Date: 2024-02-03T10:39:51+08:00
core: add infrastructure to run functions in threads
(cherry-pick from f8909163c47c8776d23373fad688586f02d31e67)
---
Added: src/core/rthreads.h
---
Diff:  https://github.com/kamailio/kamailio/commit/5132dcef7a067c1337256c93f8469cb0...
Patch: https://github.com/kamailio/kamailio/commit/5132dcef7a067c1337256c93f8469cb0...
---

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

    