diff options
| author | guozhanxin <[email protected]> | 2021-03-31 13:59:58 +0800 |
|---|---|---|
| committer | guozhanxin <[email protected]> | 2021-03-31 14:00:09 +0800 |
| commit | d49cc6452406d70ce7a2e2acce786fbe697673b9 (patch) | |
| tree | ddb998772a7915a57ab93b8b52953c99259c3696 /components/libc/pthreads | |
| parent | f9be3c80e3631ebfc1ecc3e1f1d2df21277c0608 (diff) | |
| parent | 61be3180f57bcb58a7a62acb67e3179934d500b8 (diff) | |
Merge remote-tracking branch 'remotes/origin/master' into add_error_check
Diffstat (limited to 'components/libc/pthreads')
| -rw-r--r-- | components/libc/pthreads/pthread.c | 21 |
1 files changed, 20 insertions, 1 deletions
diff --git a/components/libc/pthreads/pthread.c b/components/libc/pthreads/pthread.c index 8a728c4e99..79104d1fd5 100644 --- a/components/libc/pthreads/pthread.c +++ b/components/libc/pthreads/pthread.c @@ -209,6 +209,8 @@ int pthread_create(pthread_t *pid, /* get pthread data */ ptd = _pthread_get_data(pth_id); + RT_ASSERT(ptd != RT_NULL); + if (attr != RT_NULL) { ptd->attr = *attr; @@ -299,6 +301,12 @@ int pthread_detach(pthread_t thread) { int ret = 0; _pthread_data_t *ptd = _pthread_get_data(thread); + if (ptd == RT_NULL) + { + /* invalid pthread id */ + ret = EINVAL; + goto __exit; + } rt_enter_critical(); if (ptd->attr.detachstate == PTHREAD_CREATE_DETACHED) @@ -360,6 +368,12 @@ int pthread_join(pthread_t thread, void **value_ptr) rt_err_t result; ptd = _pthread_get_data(thread); + + if (ptd == RT_NULL) + { + return EINVAL; /* invalid pthread id */ + } + if (ptd && ptd->tid == rt_thread_self()) { /* join self */ @@ -367,7 +381,9 @@ int pthread_join(pthread_t thread, void **value_ptr) } if (ptd->attr.detachstate == PTHREAD_CREATE_DETACHED) + { return EINVAL; /* join on a detached pthread */ + } result = rt_sem_take(ptd->joinable_sem, RT_WAITING_FOREVER); if (result == RT_EOK) @@ -662,7 +678,10 @@ int pthread_cancel(pthread_t thread) /* get posix thread data */ ptd = _pthread_get_data(thread); - RT_ASSERT(ptd != RT_NULL); + if (ptd == RT_NULL) + { + return EINVAL; + } /* cancel self */ if (ptd->tid == rt_thread_self()) |