FFmpeg: compat/os2threads.h Source File

FFmpeg
os2threads.h
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2011-2017 KO Myung-Hun <komh@chollian.net>
3  *
4  * This file is part of FFmpeg.
5  *
6  * FFmpeg is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU Lesser General Public
8  * License as published by the Free Software Foundation; either
9  * version 2.1 of the License, or (at your option) any later version.
10  *
11  * FFmpeg is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14  * Lesser General Public License for more details.
15  *
16  * You should have received a copy of the GNU Lesser General Public
17  * License along with FFmpeg; if not, write to the Free Software
18  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
19  */
20 
21 /**
22  * @file
23  * os2threads to pthreads wrapper
24  */
25 
26 #ifndef COMPAT_OS2THREADS_H
27 #define COMPAT_OS2THREADS_H
28 
29  #define INCL_DOS
30  #define INCL_DOSERRORS
31 #include <os2.h>
32 
33 #undef __STRICT_ANSI__ /* for _beginthread() */
34 #include <stdlib.h>
35 #include <time.h>
36 
37 #include <sys/builtin.h>
38 #include <sys/fmutex.h>
39 
40 #include "libavutil/attributes.h"
41 #include "libavutil/common.h"
42 #include "libavutil/time.h"
43 
44  typedef struct {
45   TID tid;
46   void *(*start_routine)(void *);
47   void *arg;
48   void *result;
49 } pthread_t;
50 
51  typedef void pthread_attr_t;
52 
53  typedef _fmutex pthread_mutex_t;
54  typedef void pthread_mutexattr_t;
55 
56  #define PTHREAD_MUTEX_INITIALIZER _FMUTEX_INITIALIZER
57 
58  typedef struct {
59   HEV event_sem;
60   HEV ack_sem;
61   volatile unsigned wait_count;
62 } pthread_cond_t;
63 
64  typedef void pthread_condattr_t;
65 
66  typedef struct {
67   volatile int done;
68   _fmutex mtx;
69 } pthread_once_t;
70 
71  #define PTHREAD_ONCE_INIT {0, _FMUTEX_INITIALIZER}
72 
73  static void thread_entry(void *arg)
74 {
75  pthread_t *thread = arg;
76 
77  thread->result = thread->start_routine(thread->arg);
78 }
79 
80  static av_always_inline int pthread_create(pthread_t *thread,
81  const pthread_attr_t *attr,
82  void *(*start_routine)(void*),
83  void *arg)
84 {
85  thread->start_routine = start_routine;
86  thread->arg = arg;
87  thread->result = NULL;
88 
89  thread->tid = _beginthread(thread_entry, NULL, 1024 * 1024, thread);
90 
91  return 0;
92 }
93 
94  static av_always_inline int pthread_join(pthread_t thread, void **value_ptr)
95 {
96  DosWaitThread(&thread.tid, DCWW_WAIT);
97 
98  if (value_ptr)
99  *value_ptr = thread.result;
100 
101  return 0;
102 }
103 
104  static av_always_inline int pthread_mutex_init(pthread_mutex_t *mutex,
105  const pthread_mutexattr_t *attr)
106 {
107  _fmutex_create(mutex, 0);
108 
109  return 0;
110 }
111 
112  static av_always_inline int pthread_mutex_destroy(pthread_mutex_t *mutex)
113 {
114  _fmutex_close(mutex);
115 
116  return 0;
117 }
118 
119  static av_always_inline int pthread_mutex_lock(pthread_mutex_t *mutex)
120 {
121  _fmutex_request(mutex, 0);
122 
123  return 0;
124 }
125 
126  static av_always_inline int pthread_mutex_unlock(pthread_mutex_t *mutex)
127 {
128  _fmutex_release(mutex);
129 
130  return 0;
131 }
132 
133  static av_always_inline int pthread_cond_init(pthread_cond_t *cond,
134  const pthread_condattr_t *attr)
135 {
136  DosCreateEventSem(NULL, &cond->event_sem, DCE_POSTONE, FALSE);
137  DosCreateEventSem(NULL, &cond->ack_sem, DCE_POSTONE, FALSE);
138 
139  cond->wait_count = 0;
140 
141  return 0;
142 }
143 
144  static av_always_inline int pthread_cond_destroy(pthread_cond_t *cond)
145 {
146  DosCloseEventSem(cond->event_sem);
147  DosCloseEventSem(cond->ack_sem);
148 
149  return 0;
150 }
151 
152  static av_always_inline int pthread_cond_signal(pthread_cond_t *cond)
153 {
154  if (!__atomic_cmpxchg32(&cond->wait_count, 0, 0)) {
155  DosPostEventSem(cond->event_sem);
156  DosWaitEventSem(cond->ack_sem, SEM_INDEFINITE_WAIT);
157  }
158 
159  return 0;
160 }
161 
162  static av_always_inline int pthread_cond_broadcast(pthread_cond_t *cond)
163 {
164  while (!__atomic_cmpxchg32(&cond->wait_count, 0, 0))
165  pthread_cond_signal(cond);
166 
167  return 0;
168 }
169 
170  static av_always_inline int pthread_cond_timedwait(pthread_cond_t *cond,
171  pthread_mutex_t *mutex,
172  const struct timespec *abstime)
173 {
174  int64_t abs_milli = abstime->tv_sec * 1000LL + abstime->tv_nsec / 1000000;
175  ULONG t = av_clip64(abs_milli - av_gettime() / 1000, 0, ULONG_MAX);
176 
177  __atomic_increment(&cond->wait_count);
178 
179  pthread_mutex_unlock(mutex);
180 
181  APIRET ret = DosWaitEventSem(cond->event_sem, t);
182 
183  __atomic_decrement(&cond->wait_count);
184 
185  DosPostEventSem(cond->ack_sem);
186 
187  pthread_mutex_lock(mutex);
188 
189  return (ret == ERROR_TIMEOUT) ? ETIMEDOUT : 0;
190 }
191 
192  static av_always_inline int pthread_cond_wait(pthread_cond_t *cond,
193  pthread_mutex_t *mutex)
194 {
195  __atomic_increment(&cond->wait_count);
196 
197  pthread_mutex_unlock(mutex);
198 
199  DosWaitEventSem(cond->event_sem, SEM_INDEFINITE_WAIT);
200 
201  __atomic_decrement(&cond->wait_count);
202 
203  DosPostEventSem(cond->ack_sem);
204 
205  pthread_mutex_lock(mutex);
206 
207  return 0;
208 }
209 
210  static av_always_inline int pthread_once(pthread_once_t *once_control,
211  void (*init_routine)(void))
212 {
213  if (!once_control->done)
214  {
215  _fmutex_request(&once_control->mtx, 0);
216 
217  if (!once_control->done)
218  {
219  init_routine();
220 
221  once_control->done = 1;
222  }
223 
224  _fmutex_release(&once_control->mtx);
225  }
226 
227  return 0;
228 }
229 #endif /* COMPAT_OS2THREADS_H */
pthread_mutex_t
_fmutex pthread_mutex_t
Definition: os2threads.h:53
pthread_join
static av_always_inline int pthread_join(pthread_t thread, void **value_ptr)
Definition: os2threads.h:94
pthread_mutex_init
static av_always_inline int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr)
Definition: os2threads.h:104
pthread_cond_t::ack_sem
HEV ack_sem
Definition: os2threads.h:60
pthread_cond_t::wait_count
volatile unsigned wait_count
Definition: os2threads.h:61
pthread_mutexattr_t
void pthread_mutexattr_t
Definition: os2threads.h:54
pthread_mutex_lock
static av_always_inline int pthread_mutex_lock(pthread_mutex_t *mutex)
Definition: os2threads.h:119
pthread_cond_t::event_sem
HEV event_sem
Definition: os2threads.h:59
pthread_once_t::mtx
_fmutex mtx
Definition: os2threads.h:68
av_clip64
#define av_clip64
Definition: common.h:98
pthread_once_t::done
volatile int done
Definition: os2threads.h:67
pthread_mutex_unlock
static av_always_inline int pthread_mutex_unlock(pthread_mutex_t *mutex)
Definition: os2threads.h:126
pthread_t::tid
TID tid
Definition: os2threads.h:45
pthread_attr_t
void pthread_attr_t
Definition: os2threads.h:51
pthread_t::arg
void * arg
Definition: os2threads.h:47
pthread_cond_broadcast
static av_always_inline int pthread_cond_broadcast(pthread_cond_t *cond)
Definition: os2threads.h:162
thread_entry
static void thread_entry(void *arg)
Definition: os2threads.h:73
arg
const char * arg
Definition: jacosubdec.c:67
pthread_create
static av_always_inline int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
Definition: os2threads.h:80
NULL
#define NULL
Definition: coverity.c:32
pthread_once
static av_always_inline int pthread_once(pthread_once_t *once_control, void(*init_routine)(void))
Definition: os2threads.h:210
time.h
pthread_cond_t
CONDITION_VARIABLE pthread_cond_t
Definition: w32pthreads.h:58
pthread_t::result
void * result
Definition: os2threads.h:48
attributes.h
pthread_t
Definition: os2threads.h:44
pthread_cond_destroy
static av_always_inline int pthread_cond_destroy(pthread_cond_t *cond)
Definition: os2threads.h:144
pthread_mutex_destroy
static av_always_inline int pthread_mutex_destroy(pthread_mutex_t *mutex)
Definition: os2threads.h:112
common.h
av_always_inline
#define av_always_inline
Definition: attributes.h:49
pthread_cond_t
Definition: os2threads.h:58
pthread_t::start_routine
void *(* start_routine)(void *)
Definition: os2threads.h:46
ret
ret
Definition: filter_design.txt:187
pthread_cond_signal
static av_always_inline int pthread_cond_signal(pthread_cond_t *cond)
Definition: os2threads.h:152
pthread_once_t
INIT_ONCE pthread_once_t
Definition: w32pthreads.h:127
pthread_once_t
Definition: os2threads.h:66
pthread_cond_wait
static av_always_inline int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
Definition: os2threads.h:192
av_gettime
int64_t av_gettime(void)
Get the current time in microseconds.
Definition: time.c:39
pthread_cond_timedwait
static av_always_inline int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime)
Definition: os2threads.h:170
pthread_cond_init
static av_always_inline int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr)
Definition: os2threads.h:133
pthread_condattr_t
void pthread_condattr_t
Definition: os2threads.h:64
cond
int(* cond)(enum AVPixelFormat pix_fmt)
Definition: pixdesc_query.c:28
mutex
static AVMutex mutex
Definition: log.c:46
Generated on Wed Aug 24 2022 21:41:12 for FFmpeg by   doxygen 1.8.17

AltStyle によって変換されたページ (->オリジナル) /