[331] | 1 | /***************************************************************************
|
---|
| 2 | * _ _ ____ _
|
---|
| 3 | * Project ___| | | | _ \| |
|
---|
| 4 | * / __| | | | |_) | |
|
---|
| 5 | * | (__| |_| | _ <| |___
|
---|
| 6 | * \___|\___/|_| \_\_____|
|
---|
| 7 | *
|
---|
| 8 | * Copyright (C) 1998 - 2016, Daniel Stenberg, <daniel@haxx.se>, 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.haxx.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 | ***************************************************************************/
|
---|
| 22 |
|
---|
| 23 | #include "curl_setup.h"
|
---|
| 24 |
|
---|
| 25 | #include <curl/curl.h>
|
---|
| 26 |
|
---|
| 27 | #if defined(USE_THREADS_POSIX)
|
---|
| 28 | # ifdef HAVE_PTHREAD_H
|
---|
| 29 | # include <pthread.h>
|
---|
| 30 | # endif
|
---|
| 31 | #elif defined(USE_THREADS_WIN32)
|
---|
| 32 | # ifdef HAVE_PROCESS_H
|
---|
| 33 | # include <process.h>
|
---|
| 34 | # endif
|
---|
| 35 | #endif
|
---|
| 36 |
|
---|
| 37 | #include "curl_threads.h"
|
---|
| 38 | #include "curl_memory.h"
|
---|
| 39 | /* The last #include file should be: */
|
---|
| 40 | #include "memdebug.h"
|
---|
| 41 |
|
---|
| 42 | #if defined(USE_THREADS_POSIX)
|
---|
| 43 |
|
---|
| 44 | struct curl_actual_call {
|
---|
| 45 | unsigned int (*func)(void *);
|
---|
| 46 | void *arg;
|
---|
| 47 | };
|
---|
| 48 |
|
---|
| 49 | static void *curl_thread_create_thunk(void *arg)
|
---|
| 50 | {
|
---|
| 51 | struct curl_actual_call * ac = arg;
|
---|
| 52 | unsigned int (*func)(void *) = ac->func;
|
---|
| 53 | void *real_arg = ac->arg;
|
---|
| 54 |
|
---|
| 55 | free(ac);
|
---|
| 56 |
|
---|
| 57 | (*func)(real_arg);
|
---|
| 58 |
|
---|
| 59 | return 0;
|
---|
| 60 | }
|
---|
| 61 |
|
---|
| 62 | curl_thread_t Curl_thread_create(unsigned int (*func) (void *), void *arg)
|
---|
| 63 | {
|
---|
| 64 | curl_thread_t t = malloc(sizeof(pthread_t));
|
---|
| 65 | struct curl_actual_call *ac = malloc(sizeof(struct curl_actual_call));
|
---|
| 66 | if(!(ac && t))
|
---|
| 67 | goto err;
|
---|
| 68 |
|
---|
| 69 | ac->func = func;
|
---|
| 70 | ac->arg = arg;
|
---|
| 71 |
|
---|
| 72 | if(pthread_create(t, NULL, curl_thread_create_thunk, ac) != 0)
|
---|
| 73 | goto err;
|
---|
| 74 |
|
---|
| 75 | return t;
|
---|
| 76 |
|
---|
| 77 | err:
|
---|
| 78 | free(t);
|
---|
| 79 | free(ac);
|
---|
| 80 | return curl_thread_t_null;
|
---|
| 81 | }
|
---|
| 82 |
|
---|
| 83 | void Curl_thread_destroy(curl_thread_t hnd)
|
---|
| 84 | {
|
---|
| 85 | if(hnd != curl_thread_t_null) {
|
---|
| 86 | pthread_detach(*hnd);
|
---|
| 87 | free(hnd);
|
---|
| 88 | }
|
---|
| 89 | }
|
---|
| 90 |
|
---|
| 91 | int Curl_thread_join(curl_thread_t *hnd)
|
---|
| 92 | {
|
---|
| 93 | int ret = (pthread_join(**hnd, NULL) == 0);
|
---|
| 94 |
|
---|
| 95 | free(*hnd);
|
---|
| 96 | *hnd = curl_thread_t_null;
|
---|
| 97 |
|
---|
| 98 | return ret;
|
---|
| 99 | }
|
---|
| 100 |
|
---|
| 101 | #elif defined(USE_THREADS_WIN32)
|
---|
| 102 |
|
---|
| 103 | /* !checksrc! disable SPACEBEFOREPAREN 1 */
|
---|
| 104 | curl_thread_t Curl_thread_create(unsigned int (CURL_STDCALL *func) (void *),
|
---|
| 105 | void *arg)
|
---|
| 106 | {
|
---|
| 107 | curl_thread_t t;
|
---|
| 108 | #ifdef _WIN32_WCE
|
---|
| 109 | t = CreateThread(NULL, 0, func, arg, 0, NULL);
|
---|
| 110 | #else
|
---|
| 111 | t = (curl_thread_t)_beginthreadex(NULL, 0, func, arg, 0, NULL);
|
---|
| 112 | #endif
|
---|
| 113 | if((t == 0) || (t == LongToHandle(-1L))) {
|
---|
| 114 | #ifdef _WIN32_WCE
|
---|
| 115 | DWORD gle = GetLastError();
|
---|
| 116 | errno = ((gle == ERROR_ACCESS_DENIED ||
|
---|
| 117 | gle == ERROR_NOT_ENOUGH_MEMORY) ?
|
---|
| 118 | EACCES : EINVAL);
|
---|
| 119 | #endif
|
---|
| 120 | return curl_thread_t_null;
|
---|
| 121 | }
|
---|
| 122 | return t;
|
---|
| 123 | }
|
---|
| 124 |
|
---|
| 125 | void Curl_thread_destroy(curl_thread_t hnd)
|
---|
| 126 | {
|
---|
| 127 | CloseHandle(hnd);
|
---|
| 128 | }
|
---|
| 129 |
|
---|
| 130 | int Curl_thread_join(curl_thread_t *hnd)
|
---|
| 131 | {
|
---|
| 132 | #if !defined(_WIN32_WINNT) || !defined(_WIN32_WINNT_VISTA) || \
|
---|
| 133 | (_WIN32_WINNT < _WIN32_WINNT_VISTA)
|
---|
| 134 | int ret = (WaitForSingleObject(*hnd, INFINITE) == WAIT_OBJECT_0);
|
---|
| 135 | #else
|
---|
| 136 | int ret = (WaitForSingleObjectEx(*hnd, INFINITE, FALSE) == WAIT_OBJECT_0);
|
---|
| 137 | #endif
|
---|
| 138 |
|
---|
| 139 | Curl_thread_destroy(*hnd);
|
---|
| 140 |
|
---|
| 141 | *hnd = curl_thread_t_null;
|
---|
| 142 |
|
---|
| 143 | return ret;
|
---|
| 144 | }
|
---|
| 145 |
|
---|
| 146 | #endif /* USE_THREADS_* */
|
---|