1 /**
2 * Copyright (c) 2016 Tino Reichardt
3 * All rights reserved.
4 *
5 * You can contact the author at:
6 * - zstdmt source repository: https://github.com/mcmilk/zstdmt
7 *
8 * This source code is licensed under both the BSD-style license (found in the
9 * LICENSE file in the root directory of this source tree) and the GPLv2 (found
10 * in the COPYING file in the root directory of this source tree).
11 * You may select, at your option, one of the above-listed licenses.
12 */
13
14 /**
15 * This file will hold wrapper for systems, which do not support pthreads
16 */
17
18 #include "threading.h"
19
20 /* create fake symbol to avoid empty translation unit warning */
21 int g_ZSTD_threading_useless_symbol;
22
23 #if defined(ZSTD_MULTITHREAD) && defined(_WIN32)
24
25 /**
26 * Windows minimalist Pthread Wrapper, based on :
27 * http://www.cse.wustl.edu/~schmidt/win32-cv-1.html
28 */
29
30
31 /* === Dependencies === */
32 #include <process.h>
33 #include <errno.h>
34
35
36 /* === Implementation === */
37
worker(void * arg)38 static unsigned __stdcall worker(void *arg)
39 {
40 ZSTD_pthread_t* const thread = (ZSTD_pthread_t*) arg;
41 thread->arg = thread->start_routine(thread->arg);
42 return 0;
43 }
44
ZSTD_pthread_create(ZSTD_pthread_t * thread,const void * unused,void * (* start_routine)(void *),void * arg)45 int ZSTD_pthread_create(ZSTD_pthread_t* thread, const void* unused,
46 void* (*start_routine) (void*), void* arg)
47 {
48 (void)unused;
49 thread->arg = arg;
50 thread->start_routine = start_routine;
51 thread->handle = (HANDLE) _beginthreadex(NULL, 0, worker, thread, 0, NULL);
52
53 if (!thread->handle)
54 return errno;
55 else
56 return 0;
57 }
58
ZSTD_pthread_join(ZSTD_pthread_t thread,void ** value_ptr)59 int ZSTD_pthread_join(ZSTD_pthread_t thread, void **value_ptr)
60 {
61 DWORD result;
62
63 if (!thread.handle) return 0;
64
65 result = WaitForSingleObject(thread.handle, INFINITE);
66 switch (result) {
67 case WAIT_OBJECT_0:
68 if (value_ptr) *value_ptr = thread.arg;
69 return 0;
70 case WAIT_ABANDONED:
71 return EINVAL;
72 default:
73 return GetLastError();
74 }
75 }
76
77 #endif /* ZSTD_MULTITHREAD */
78
79 #if defined(ZSTD_MULTITHREAD) && DEBUGLEVEL >= 1 && !defined(_WIN32)
80
81 #define ZSTD_DEPS_NEED_MALLOC
82 #include "zstd_deps.h"
83
ZSTD_pthread_mutex_init(ZSTD_pthread_mutex_t * mutex,pthread_mutexattr_t const * attr)84 int ZSTD_pthread_mutex_init(ZSTD_pthread_mutex_t* mutex, pthread_mutexattr_t const* attr)
85 {
86 *mutex = (pthread_mutex_t*)ZSTD_malloc(sizeof(pthread_mutex_t));
87 if (!*mutex)
88 return 1;
89 return pthread_mutex_init(*mutex, attr);
90 }
91
ZSTD_pthread_mutex_destroy(ZSTD_pthread_mutex_t * mutex)92 int ZSTD_pthread_mutex_destroy(ZSTD_pthread_mutex_t* mutex)
93 {
94 if (!*mutex)
95 return 0;
96 {
97 int const ret = pthread_mutex_destroy(*mutex);
98 ZSTD_free(*mutex);
99 return ret;
100 }
101 }
102
ZSTD_pthread_cond_init(ZSTD_pthread_cond_t * cond,pthread_condattr_t const * attr)103 int ZSTD_pthread_cond_init(ZSTD_pthread_cond_t* cond, pthread_condattr_t const* attr)
104 {
105 *cond = (pthread_cond_t*)ZSTD_malloc(sizeof(pthread_cond_t));
106 if (!*cond)
107 return 1;
108 return pthread_cond_init(*cond, attr);
109 }
110
ZSTD_pthread_cond_destroy(ZSTD_pthread_cond_t * cond)111 int ZSTD_pthread_cond_destroy(ZSTD_pthread_cond_t* cond)
112 {
113 if (!*cond)
114 return 0;
115 {
116 int const ret = pthread_cond_destroy(*cond);
117 ZSTD_free(*cond);
118 return ret;
119 }
120 }
121
122 #endif
123