sergiotarxz/nuttx-apps
sergiotarxz/nuttx-apps
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

system/libuv: Support specify stack size for worker thread

Browse Source 
Signed-off-by: Huang Qi <huangqi3@xiaomi.com>
This commit is contained in:
Huang Qi 2022-03-28 17:12:42 +08:00 committed by Petro Karashchenko
parent cd1bc19bf9
commit ec15dc0344
3 changed files with 34 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
system/libuv/0001-libuv-port-for-nuttx.patch
View File

@ -59,7 +59,7 @@ index e75f77de..feef5a44 100644
#elif defined(_AIX) || defined(__QNX__) #elif defined(_AIX) || defined(__QNX__)
rc = uv__random_readpath("/dev/random", buf, buflen); rc = uv__random_readpath("/dev/random", buf, buflen);
diff --git a/src/threadpool.c b/src/threadpool.c diff --git a/src/threadpool.c b/src/threadpool.c
index 869ae95f..8fabeba5 100644 index 869ae95f..73077ec6 100644
--- a/src/threadpool.c --- a/src/threadpool.c
+++ b/src/threadpool.c +++ b/src/threadpool.c
@@ -20,6 +20,7 @@ @@ -20,6 +20,7 @@
@ -169,7 +169,24 @@ index 869ae95f..8fabeba5 100644
} }
@@ -212,7 +217,7 @@ static void init_threads(void) { @@ -188,6 +193,16 @@ static void init_threads(void) {
const char* val;
uv_sem_t sem;
+ const uv_thread_options_t params = {
+#ifdef DEF_THREADPOOL_STACKSIZE
+ UV_THREAD_HAS_STACK_SIZE,
+ DEF_THREADPOOL_STACKSIZE
+#else
+ UV_THREAD_NO_FLAGS,
+ 0
+#endif
+ };
+
nthreads = ARRAY_SIZE(default_threads);
val = getenv("UV_THREADPOOL_SIZE");
if (val != NULL)
@@ -212,7 +227,7 @@ static void init_threads(void) {
if (uv_mutex_init(&mutex)) if (uv_mutex_init(&mutex))
abort(); abort();
@ -178,7 +195,16 @@ index 869ae95f..8fabeba5 100644
QUEUE_INIT(&slow_io_pending_wq); QUEUE_INIT(&slow_io_pending_wq);
QUEUE_INIT(&run_slow_work_message); QUEUE_INIT(&run_slow_work_message);
@@ -230,14 +235,6 @@ static void init_threads(void) { @@ -220,7 +235,7 @@ static void init_threads(void) {
abort();
for (i = 0; i < nthreads; i++)
- if (uv_thread_create(threads + i, worker, &sem))
+ if (uv_thread_create_ex(threads + i, &params, worker, &sem))
abort();
for (i = 0; i < nthreads; i++)
@@ -230,14 +245,6 @@ static void init_threads(void) {
} }

4
system/libuv/Kconfig
View File

@ -16,6 +16,10 @@ config LIBUV_THREADPOOL_SIZE
int "libuv default thread pool size" int "libuv default thread pool size"
default 1 default 1
config LIBUV_THREAD_STACKSIZE
int "libuv worker thread stack size"
default PTHREAD_STACK_DEFAULT
choice choice
prompt "libuv utils" prompt "libuv utils"
default LIBUV_UTILS_NONE default LIBUV_UTILS_NONE

1
system/libuv/Makefile
View File

@ -51,6 +51,7 @@ CFLAGS += -I$(LIBUV_UNPACK)/src/unix
CFLAGS += -I$(LIBUV_UNPACK)/test CFLAGS += -I$(LIBUV_UNPACK)/test
CFLAGS += -Wno-shadow CFLAGS += -Wno-shadow
CFLAGS += -DDEF_THREADPOOL_SIZE=CONFIG_LIBUV_THREADPOOL_SIZE CFLAGS += -DDEF_THREADPOOL_SIZE=CONFIG_LIBUV_THREADPOOL_SIZE
CFLAGS += -DDEF_THREADPOOL_STACKSIZE=CONFIG_LIBUV_THREAD_STACKSIZE
VPATH += $(LIBUV_UNPACK)/src VPATH += $(LIBUV_UNPACK)/src
VPATH += $(LIBUV_UNPACK)/src/unix VPATH += $(LIBUV_UNPACK)/src/unix