os2threads.h File Reference

#include <os2.h>
#include <stdlib.h>
#include <time.h>
#include <sys/builtin.h>
#include <sys/fmutex.h>
#include "libavutil/attributes.h"
#include "libavutil/common.h"

Go to the source code of this file.

Data Structures
struct	pthread_t
struct	pthread_cond_t
struct	pthread_once_t

Macros
#define	INCL_DOS
#define	INCL_DOSERRORS
#define	PTHREAD_MUTEX_INITIALIZER   _FMUTEX_INITIALIZER
#define	PTHREAD_ONCE_INIT   {0, _FMUTEX_INITIALIZER}

Typedefs
typedef void	pthread_attr_t
typedef _fmutex	pthread_mutex_t
typedef void	pthread_mutexattr_t
typedef void	pthread_condattr_t

Functions
static void	thread_entry (void *arg)
static av_always_inline int	pthread_create (pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
static av_always_inline int	pthread_join (pthread_t thread, void **value_ptr)
static av_always_inline int	pthread_mutex_init (pthread_mutex_t *mutex, const pthread_mutexattr_t *attr)
static av_always_inline int	pthread_mutex_destroy (pthread_mutex_t *mutex)
static av_always_inline int	pthread_mutex_lock (pthread_mutex_t *mutex)
static av_always_inline int	pthread_mutex_unlock (pthread_mutex_t *mutex)
static av_always_inline int	pthread_cond_init (pthread_cond_t *cond, const pthread_condattr_t *attr)
static av_always_inline int	pthread_cond_destroy (pthread_cond_t *cond)
static av_always_inline int	pthread_cond_signal (pthread_cond_t *cond)
static av_always_inline int	pthread_cond_broadcast (pthread_cond_t *cond)
static av_always_inline int	pthread_cond_timedwait (pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime)
static av_always_inline int	pthread_cond_wait (pthread_cond_t *cond, pthread_mutex_t *mutex)
static av_always_inline int	pthread_once (pthread_once_t *once_control, void(*init_routine)(void))

Detailed Description

os2threads to pthreads wrapper

Definition in file os2threads.h.

Macro Definition Documentation

INCL_DOS

#define INCL_DOS

Definition at line 29 of file os2threads.h.

INCL_DOSERRORS

#define INCL_DOSERRORS

Definition at line 30 of file os2threads.h.

PTHREAD_MUTEX_INITIALIZER

#define PTHREAD_MUTEX_INITIALIZER   _FMUTEX_INITIALIZER

Definition at line 56 of file os2threads.h.

PTHREAD_ONCE_INIT

#define PTHREAD_ONCE_INIT   {0, _FMUTEX_INITIALIZER}

Definition at line 71 of file os2threads.h.

Typedef Documentation

pthread_attr_t

typedef void pthread_attr_t

Definition at line 51 of file os2threads.h.

pthread_mutex_t

typedef _fmutex pthread_mutex_t

Definition at line 53 of file os2threads.h.

pthread_mutexattr_t

typedef void pthread_mutexattr_t

Definition at line 54 of file os2threads.h.

pthread_condattr_t

typedef void pthread_condattr_t

Definition at line 64 of file os2threads.h.

Function Documentation

thread_entry()

static void thread_entry ( void *  arg )

static

Definition at line 73 of file os2threads.h.

Referenced by pthread_create().

pthread_create()

static av_always_inline int pthread_create ( pthread_t *  thread, const pthread_attr_t *  attr, void *(*)(void *)  start_routine, void *  arg  )

static

Definition at line 80 of file os2threads.h.

Referenced by async_open(), ff_dnn_start_inference_async(), ff_frame_thread_encoder_init(), fifo_write_header(), iec61883_read_header(), init_thread(), main(), task_start(), and udp_open().

pthread_join()

static av_always_inline int pthread_join ( pthread_t  thread, void **  value_ptr  )

static

Definition at line 94 of file os2threads.h.

Referenced by async_close(), ff_dnn_async_module_cleanup(), ff_dnn_start_inference_async(), ff_frame_thread_encoder_free(), ff_frame_thread_free(), fifo_write_trailer(), iec61883_close(), main(), task_stop(), and udp_close().

pthread_mutex_init()

static av_always_inline int pthread_mutex_init ( pthread_mutex_t *  mutex, const pthread_mutexattr_t *  attr  )

static

Definition at line 104 of file os2threads.h.

Referenced by async_open(), at_write_header(), av_thread_message_queue_alloc(), av_vk_frame_alloc(), avf_read_header(), decklink_setup_video(), enc_stats_init(), ff_decklink_packet_queue_init(), ff_openssl_init(), fifo_init(), iec61883_read_header(), qsv_frames_init(), sch_add_sq_enc(), sch_alloc(), tq_alloc(), udp_open(), update_dimensions(), vtenc_init(), vulkan_device_init(), and waiter_init().

pthread_mutex_destroy()

static av_always_inline int pthread_mutex_destroy ( pthread_mutex_t *  mutex )

static

Definition at line 112 of file os2threads.h.

Referenced by async_close(), async_open(), at_write_trailer(), av_thread_message_queue_alloc(), av_thread_message_queue_free(), destroy_context(), enc_stats_uninit(), ff_decklink_packet_queue_end(), ff_decklink_write_trailer(), ff_openssl_deinit(), ff_pthread_free(), fifo_deinit(), free_buffers(), iec61883_close(), qsv_frames_uninit(), sch_free(), tq_free(), udp_close(), udp_open(), vtenc_close(), vulkan_device_uninit(), vulkan_free_internal(), and waiter_uninit().

pthread_mutex_lock()

static av_always_inline int pthread_mutex_lock ( pthread_mutex_t *  mutex )

static

Definition at line 119 of file os2threads.h.

Referenced by append_buffer(), async_buffer_task(), async_close(), async_lock(), async_read_internal(), async_seek(), async_unlock(), at_write_packet(), av_thread_message_flush(), av_thread_message_queue_nb_elems(), av_thread_message_queue_recv(), av_thread_message_queue_send(), av_thread_message_queue_set_err_recv(), av_thread_message_queue_set_err_send(), cleanup(), decklink_write_video_packet(), demux_done(), enc_open(), enc_stats_write(), event_handler(), ff_decklink_packet_queue_flush(), ff_decklink_packet_queue_get(), ff_decklink_packet_queue_peekpts(), ff_decklink_packet_queue_put(), ff_decklink_packet_queue_size(), ff_frame_thread_encoder_free(), ff_frame_thread_free(), ff_jni_get_env(), ff_thread_await_progress(), ff_thread_finish_setup(), ff_thread_receive_frame(), ff_thread_report_progress(), ff_thread_video_encode_frame(), ff_vk_glslang_init(), fifo_consumer_thread(), fifo_write_packet(), filter_done(), frame_worker_thread(), get_buffer(), glslc_uninit(), iec61883_callback(), iec61883_read_packet(), iec61883_receive_task(), init(), lock_frame(), lock_frames(), lock_queue(), mux_done(), park_frame_worker_threads(), pthread_cond_timedwait(), pthread_cond_wait(), qsv_internal_session_check_init(), sch_filter_receive(), sch_mux_receive_finish(), sch_mux_stream_ready(), sch_start(), sch_wait(), decklink_output_callback::ScheduledFrameCompleted(), select_voice(), send_to_enc_sq(), send_to_mux(), set_async_error(), submit_packet(), task_wrapper(), thread_get_buffer_internal(), tq_receive(), tq_receive_finish(), tq_send(), tq_send_finish(), udp_close(), udp_read(), udp_write(), uninit(), vtenc_q_pop(), vtenc_q_push(), wait_for_state(), waiter_set(), waiter_wait(), and worker().

pthread_mutex_unlock()

static av_always_inline int pthread_mutex_unlock ( pthread_mutex_t *  mutex )

static

Definition at line 126 of file os2threads.h.

Referenced by append_buffer(), async_buffer_task(), async_close(), async_lock(), async_read_internal(), async_seek(), async_unlock(), at_write_packet(), av_thread_message_flush(), av_thread_message_queue_nb_elems(), av_thread_message_queue_recv(), av_thread_message_queue_send(), av_thread_message_queue_set_err_recv(), av_thread_message_queue_set_err_send(), cleanup(), decklink_write_video_packet(), demux_done(), enc_open(), enc_stats_write(), event_handler(), ff_decklink_packet_queue_flush(), ff_decklink_packet_queue_get(), ff_decklink_packet_queue_peekpts(), ff_decklink_packet_queue_put(), ff_decklink_packet_queue_size(), ff_frame_thread_encoder_free(), ff_frame_thread_free(), ff_jni_get_env(), ff_thread_await_progress(), ff_thread_finish_setup(), ff_thread_receive_frame(), ff_thread_report_progress(), ff_thread_video_encode_frame(), ff_vk_glslang_init(), fifo_consumer_thread(), fifo_write_packet(), filter_done(), frame_worker_thread(), get_buffer(), glslc_uninit(), iec61883_callback(), iec61883_read_packet(), iec61883_receive_task(), init(), mux_done(), park_frame_worker_threads(), pthread_cond_timedwait(), pthread_cond_wait(), qsv_internal_session_check_init(), queue_callback(), sch_filter_receive(), sch_mux_receive_finish(), sch_mux_stream_ready(), sch_start(), sch_wait(), decklink_output_callback::ScheduledFrameCompleted(), select_voice(), send_to_enc_sq(), send_to_mux(), set_async_error(), submit_packet(), task_wrapper(), thread_get_buffer_internal(), tq_receive(), tq_receive_finish(), tq_send(), tq_send_finish(), udp_close(), udp_read(), udp_write(), uninit(), unlock_frame(), unlock_frames(), unlock_queue(), vtenc_q_pop(), vtenc_q_push(), wait_for_state(), waiter_set(), waiter_wait(), and worker().

pthread_cond_init()

static av_always_inline int pthread_cond_init ( pthread_cond_t *  cond, const pthread_condattr_t *  attr  )

static

Definition at line 133 of file os2threads.h.

Referenced by async_open(), av_thread_message_queue_alloc(), decklink_setup_video(), ff_decklink_packet_queue_init(), iec61883_read_header(), sch_alloc(), tq_alloc(), udp_open(), update_dimensions(), vtenc_init(), and waiter_init().

pthread_cond_destroy()

static av_always_inline int pthread_cond_destroy ( pthread_cond_t *  cond )

static

Definition at line 144 of file os2threads.h.

Referenced by async_close(), async_open(), av_thread_message_queue_alloc(), av_thread_message_queue_free(), ff_decklink_packet_queue_end(), ff_decklink_write_trailer(), ff_pthread_free(), free_buffers(), iec61883_close(), sch_free(), tq_alloc(), tq_free(), udp_close(), udp_open(), vtenc_close(), and waiter_uninit().

pthread_cond_signal()

static av_always_inline int pthread_cond_signal ( pthread_cond_t *  cond )

static

Definition at line 152 of file os2threads.h.

Referenced by async_buffer_task(), async_close(), async_read_internal(), async_seek(), ff_decklink_packet_queue_put(), ff_frame_thread_free(), ff_thread_video_encode_frame(), frame_worker_thread(), mux_done(), pthread_cond_broadcast(), submit_packet(), task_wrapper(), udp_close(), udp_write(), vtenc_q_push(), waiter_set(), and worker().

pthread_cond_broadcast()

static av_always_inline int pthread_cond_broadcast ( pthread_cond_t *  cond )

static

Definition at line 162 of file os2threads.h.

Referenced by append_buffer(), async_unlock(), av_thread_message_flush(), av_thread_message_queue_set_err_recv(), av_thread_message_queue_set_err_send(), event_handler(), ff_frame_thread_encoder_free(), ff_thread_finish_setup(), ff_thread_report_progress(), frame_worker_thread(), iec61883_callback(), iec61883_receive_task(), decklink_output_callback::ScheduledFrameCompleted(), tq_receive(), tq_receive_finish(), tq_send(), and tq_send_finish().

pthread_cond_timedwait()

static av_always_inline int pthread_cond_timedwait ( pthread_cond_t *  cond, pthread_mutex_t *  mutex, const struct timespec *  abstime  )

static

Definition at line 170 of file os2threads.h.

Referenced by sch_wait(), and udp_read().

pthread_cond_wait()

static av_always_inline int pthread_cond_wait ( pthread_cond_t *  cond, pthread_mutex_t *  mutex  )

static

Definition at line 192 of file os2threads.h.

Referenced by async_buffer_task(), async_lock(), async_read_internal(), async_seek(), decklink_write_video_packet(), ff_decklink_packet_queue_get(), ff_thread_await_progress(), ff_thread_receive_frame(), ff_thread_video_encode_frame(), frame_worker_thread(), get_buffer(), iec61883_read_packet(), park_frame_worker_threads(), submit_packet(), tq_receive(), tq_send(), vtenc_q_pop(), wait_for_state(), waiter_wait(), and worker().

pthread_once()

static av_always_inline int pthread_once ( pthread_once_t *  once_control, void(*)(void)  init_routine  )

static

Definition at line 210 of file os2threads.h.

Referenced by ff_jni_get_env(), and vtenc_init().