From: Seija Kijin <doremylover123@xxxxxxxxx>
After joining threads, the handle to the original thread
should be closed as it no longer needs to be open.
Because this only needs to happen if the
WaitForSingleObject fails, the function was
rewritten to accommodate this change.
The function is still POSIX compliant.
Signed-off-by: Seija Kijin <doremylover123@xxxxxxxxx>
---
win32: close handles of threads that have been joined
After joining threads, the handle to the original thread should be
closed as it no longer needs to be open.
Signed-off-by: Seija Kijin doremylover123@xxxxxxxxx
Published-As: https://github.com/gitgitgadget/git/releases/tag/pr-git-1406%2FAtariDreams%2Fjoin-v5
Fetch-It-Via: git fetch https://github.com/gitgitgadget/git pr-git-1406/AtariDreams/join-v5
Pull-Request: https://github.com/git/git/pull/1406
Range-diff vs v4:
1: 526ef7cc339 < -: ----------- win32: close handles of threads that have been joined
2: 2cb4d5c7007 ! 1: 94ed068d25b prep
@@ Metadata
Author: Seija Kijin <doremylover123@xxxxxxxxx>
## Commit message ##
- prep
+ win32: close handles of threads that have been joined
+
+ After joining threads, the handle to the original thread
+ should be closed as it no longer needs to be open.
+
+ Because this only needs to happen if the
+ WaitForSingleObject fails, the function was
+ rewritten to accommodate this change.
+
+ The function is still POSIX compliant.
Signed-off-by: Seija Kijin <doremylover123@xxxxxxxxx>
## compat/win32/pthread.c ##
-@@ compat/win32/pthread.c: static unsigned __stdcall win32_start_routine(void *arg)
- }
-
- int pthread_create(pthread_t *thread, const void *unused,
-- void *(*start_routine)(void*), void *arg)
-+ void *(*start_routine)(void *), void *arg)
- {
- thread->arg = arg;
- thread->start_routine = start_routine;
-- thread->handle = (HANDLE)
-- _beginthreadex(NULL, 0, win32_start_routine, thread, 0, NULL);
-+ thread->handle = (HANDLE)_beginthreadex(NULL, 0, win32_start_routine,
-+ thread, 0, NULL);
+@@ compat/win32/pthread.c: int pthread_create(pthread_t *thread, const void *unused,
- if (!thread->handle)
- return errno;
-@@ compat/win32/pthread.c: int win32_pthread_join(pthread_t *thread, void **value_ptr)
+ int win32_pthread_join(pthread_t *thread, void **value_ptr)
{
- DWORD result = WaitForSingleObject(thread->handle, INFINITE);
- switch (result) {
+- DWORD result = WaitForSingleObject(thread->handle, INFINITE);
+- switch (result) {
- case WAIT_OBJECT_0:
- if (value_ptr)
- *value_ptr = thread->arg;
-- /* detach the thread once the join succeeds */
-- CloseHandle(thread->handle);
- return 0;
- case WAIT_ABANDONED:
-- /* either thread is not joinable or another thread is
-- * waiting on this, so do not detatch */
- return EINVAL;
- default:
-- /* the function failed, so do not detach */
- return err_win_to_posix(GetLastError());
-+ case WAIT_OBJECT_0:
-+ if (value_ptr)
-+ *value_ptr = thread->arg;
-+ /* detach the thread once the join succeeds */
-+ CloseHandle(thread->handle);
-+ return 0;
-+ case WAIT_ABANDONED:
-+ /* either thread is not joinable or another thread is
-+ * waiting on this, so do not detatch */
-+ return EINVAL;
-+ default:
-+ /* the function failed, so do not detach */
++ if (WaitForSingleObject(thread->handle, INFINITE) == WAIT_FAILED)
+ return err_win_to_posix(GetLastError());
++
++ if (value_ptr) {
++ *value_ptr = thread->arg;
}
++
++ CloseHandle(thread->handle);
++ return 0;
}
+ pthread_t pthread_self(void)
compat/win32/pthread.c | 18 ++++++++----------
1 file changed, 8 insertions(+), 10 deletions(-)
diff --git a/compat/win32/pthread.c b/compat/win32/pthread.c
index 2e7eead42cb..7f8503b4b50 100644
--- a/compat/win32/pthread.c
+++ b/compat/win32/pthread.c
@@ -37,17 +37,15 @@ int pthread_create(pthread_t *thread, const void *unused,
int win32_pthread_join(pthread_t *thread, void **value_ptr)
{
- DWORD result = WaitForSingleObject(thread->handle, INFINITE);
- switch (result) {
- case WAIT_OBJECT_0:
- if (value_ptr)
- *value_ptr = thread->arg;
- return 0;
- case WAIT_ABANDONED:
- return EINVAL;
- default:
- return err_win_to_posix(GetLastError());
+ if (WaitForSingleObject(thread->handle, INFINITE) == WAIT_FAILED)
+ return err_win_to_posix(GetLastError());
+
+ if (value_ptr) {
+ *value_ptr = thread->arg;
}
+
+ CloseHandle(thread->handle);
+ return 0;
}
pthread_t pthread_self(void)
base-commit: 7c2ef319c52c4997256f5807564523dfd4acdfc7
--
gitgitgadget
