1/***************************************************************************
2 * _ _ ____ _
3 * Project ___| | | | _ \| |
4 * / __| | | | |_) | |
5 * | (__| |_| | _ <| |___
6 * \___|\___/|_| \_\_____|
7 *
8 * Copyright (C) 1998 - 2022, Daniel Stenberg, <[email protected]>, et al.
9 *
10 * This software is licensed as described in the file COPYING, which
11 * you should have received as part of this distribution. The terms
12 * are also available at https://curl.se/docs/copyright.html.
13 *
14 * You may opt to use, copy, modify, merge, publish, distribute and/or sell
15 * copies of the Software, and permit persons to whom the Software is
16 * furnished to do so, under the terms of the COPYING file.
17 *
18 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
19 * KIND, either express or implied.
20 *
21 * SPDX-License-Identifier: curl
22 *
23 ***************************************************************************/
24
25#include "curl_setup.h"
26
27#include <curl/curl.h>
28
29#if defined(USE_THREADS_POSIX)
30# ifdef HAVE_PTHREAD_H
31# include <pthread.h>
32# endif
33#elif defined(USE_THREADS_WIN32)
34# ifdef HAVE_PROCESS_H
35# include <process.h>
36# endif
37#endif
38
39#include "curl_threads.h"
40#include "curl_memory.h"
41/* The last #include file should be: */
42#include "memdebug.h"
43
44#if defined(USE_THREADS_POSIX)
45
46struct Curl_actual_call {
47 unsigned int (*func)(void *);
48 void *arg;
49};
50
51static void *curl_thread_create_thunk(void *arg)
52{
53 struct Curl_actual_call *ac = arg;
54 unsigned int (*func)(void *) = ac->func;
55 void *real_arg = ac->arg;
56
57 free(ac);
58
59 (*func)(real_arg);
60
61 return 0;
62}
63
64curl_thread_t Curl_thread_create(unsigned int (*func) (void *), void *arg)
65{
66 curl_thread_t t = malloc(sizeof(pthread_t));
67 struct Curl_actual_call *ac = malloc(sizeof(struct Curl_actual_call));
68 if(!(ac && t))
69 goto err;
70
71 ac->func = func;
72 ac->arg = arg;
73
74 if(pthread_create(t, NULL, curl_thread_create_thunk, ac) != 0)
75 goto err;
76
77 return t;
78
79err:
80 free(t);
81 free(ac);
82 return curl_thread_t_null;
83}
84
85void Curl_thread_destroy(curl_thread_t hnd)
86{
87 if(hnd != curl_thread_t_null) {
88 pthread_detach(*hnd);
89 free(hnd);
90 }
91}
92
93int Curl_thread_join(curl_thread_t *hnd)
94{
95 int ret = (pthread_join(**hnd, NULL) == 0);
96
97 free(*hnd);
98 *hnd = curl_thread_t_null;
99
100 return ret;
101}
102
103#elif defined(USE_THREADS_WIN32)
104
105/* !checksrc! disable SPACEBEFOREPAREN 1 */
106curl_thread_t Curl_thread_create(unsigned int (CURL_STDCALL *func) (void *),
107 void *arg)
108{
109#ifdef _WIN32_WCE
110 typedef HANDLE curl_win_thread_handle_t;
111#elif defined(__MINGW32__) && !defined(__MINGW64_VERSION_MAJOR)
112 typedef unsigned long curl_win_thread_handle_t;
113#else
114 typedef uintptr_t curl_win_thread_handle_t;
115#endif
116 curl_thread_t t;
117 curl_win_thread_handle_t thread_handle;
118#ifdef _WIN32_WCE
119 thread_handle = CreateThread(NULL, 0, func, arg, 0, NULL);
120#else
121 thread_handle = _beginthreadex(NULL, 0, func, arg, 0, NULL);
122#endif
123 t = (curl_thread_t)thread_handle;
124 if((t == 0) || (t == LongToHandle(-1L))) {
125#ifdef _WIN32_WCE
126 DWORD gle = GetLastError();
127 errno = ((gle == ERROR_ACCESS_DENIED ||
128 gle == ERROR_NOT_ENOUGH_MEMORY) ?
129 EACCES : EINVAL);
130#endif
131 return curl_thread_t_null;
132 }
133 return t;
134}
135
136void Curl_thread_destroy(curl_thread_t hnd)
137{
138 CloseHandle(hnd);
139}
140
141int Curl_thread_join(curl_thread_t *hnd)
142{
143#if !defined(_WIN32_WINNT) || !defined(_WIN32_WINNT_VISTA) || \
144 (_WIN32_WINNT < _WIN32_WINNT_VISTA)
145 int ret = (WaitForSingleObject(*hnd, INFINITE) == WAIT_OBJECT_0);
146#else
147 int ret = (WaitForSingleObjectEx(*hnd, INFINITE, FALSE) == WAIT_OBJECT_0);
148#endif
149
150 Curl_thread_destroy(*hnd);
151
152 *hnd = curl_thread_t_null;
153
154 return ret;
155}
156
157#endif /* USE_THREADS_* */
158