/* * Copyright (c) 2011 KO Myung-Hun <komh@chollian.net> * * This file is part of FFmpeg. * * FFmpeg is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * FFmpeg is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with FFmpeg; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ /** * @file * os2threads to pthreads wrapper */ #ifndef AVCODEC_OS2PTHREADS_H #define AVCODEC_OS2PTHREADS_H #define INCL_DOS #include <os2.h> #undef __STRICT_ANSI__ /* for _beginthread() */ #include <stdlib.h> typedef TID pthread_t; typedef void pthread_attr_t; typedef HMTX pthread_mutex_t; typedef void pthread_mutexattr_t; typedef struct { HEV event_sem; int wait_count; } pthread_cond_t; typedef void pthread_condattr_t; struct thread_arg { void *(*start_routine)(void *); void *arg; }; static void thread_entry(void *arg) { struct thread_arg *thread_arg = arg; thread_arg->start_routine(thread_arg->arg); av_free(thread_arg); } static av_always_inline int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void*), void *arg) { struct thread_arg *thread_arg; thread_arg = av_mallocz(sizeof(struct thread_arg)); thread_arg->start_routine = start_routine; thread_arg->arg = arg; *thread = _beginthread(thread_entry, NULL, 256 * 1024, thread_arg); return 0; } static av_always_inline int pthread_join(pthread_t thread, void **value_ptr) { DosWaitThread((PTID)&thread, DCWW_WAIT); return 0; } static av_always_inline int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr) { DosCreateMutexSem(NULL, (PHMTX)mutex, 0, FALSE); return 0; } static av_always_inline int pthread_mutex_destroy(pthread_mutex_t *mutex) { DosCloseMutexSem(*(PHMTX)mutex); return 0; } static av_always_inline int pthread_mutex_lock(pthread_mutex_t *mutex) { DosRequestMutexSem(*(PHMTX)mutex, SEM_INDEFINITE_WAIT); return 0; } static av_always_inline int pthread_mutex_unlock(pthread_mutex_t *mutex) { DosReleaseMutexSem(*(PHMTX)mutex); return 0; } static av_always_inline int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr) { DosCreateEventSem(NULL, &cond->event_sem, DCE_POSTONE, FALSE); cond->wait_count = 0; return 0; } static av_always_inline int pthread_cond_destroy(pthread_cond_t *cond) { DosCloseEventSem(cond->event_sem); return 0; } static av_always_inline int pthread_cond_signal(pthread_cond_t *cond) { if (cond->wait_count > 0) { DosPostEventSem(cond->event_sem); cond->wait_count--; } return 0; } static av_always_inline int pthread_cond_broadcast(pthread_cond_t *cond) { while (cond->wait_count > 0) { DosPostEventSem(cond->event_sem); cond->wait_count--; } return 0; } static av_always_inline int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) { cond->wait_count++; pthread_mutex_unlock(mutex); DosWaitEventSem(cond->event_sem, SEM_INDEFINITE_WAIT); pthread_mutex_lock(mutex); return 0; } #endif /* AVCODEC_OS2PTHREADS_H */