VLC  2.1.0-git
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
Data Structures | Macros | Enumerations | Functions | Variables
thread.c File Reference
Include dependency graph for thread.c:

Data Structures

struct  vlc_threadvar
struct  vlc_thread
 Per-thread data. More...
struct  vlc_timer

Macros

#define xstrdup(str)   (strdup(str) ?: (abort(), NULL))

Enumerations

enum  { CLOCK_STATIC = 0, CLOCK_MONOTONIC, CLOCK_REALTIME }

Functions

static DWORD vlc_WaitForMultipleObjects (DWORD count, const HANDLE *handles, DWORD delay)
static DWORD vlc_WaitForSingleObject (HANDLE handle, DWORD delay)
static DWORD vlc_Sleep (DWORD delay)
void vlc_mutex_init (vlc_mutex_t *p_mutex)
 Initializes a fast mutex.
void vlc_mutex_init_recursive (vlc_mutex_t *p_mutex)
 Initializes a recursive mutex.
void vlc_mutex_destroy (vlc_mutex_t *p_mutex)
 Destroys a mutex.
void vlc_mutex_lock (vlc_mutex_t *p_mutex)
 Acquires a mutex.
int vlc_mutex_trylock (vlc_mutex_t *p_mutex)
 Acquires a mutex if and only if it is not currently held by another thread.
void vlc_mutex_unlock (vlc_mutex_t *p_mutex)
 Releases a mutex (or crashes if the mutex is not locked by the caller).
static void vlc_cond_init_common (vlc_cond_t *p_condvar, unsigned clock)
void vlc_cond_init (vlc_cond_t *p_condvar)
 Initializes a condition variable.
void vlc_cond_init_daytime (vlc_cond_t *p_condvar)
 Initializes a condition variable.
void vlc_cond_destroy (vlc_cond_t *p_condvar)
 Destroys a condition variable.
void vlc_cond_signal (vlc_cond_t *p_condvar)
 Wakes up one thread waiting on a condition variable, if any.
void vlc_cond_broadcast (vlc_cond_t *p_condvar)
 Wakes up all threads (if any) waiting on a condition variable.
void vlc_cond_wait (vlc_cond_t *p_condvar, vlc_mutex_t *p_mutex)
 Waits for a condition variable.
int vlc_cond_timedwait (vlc_cond_t *p_condvar, vlc_mutex_t *p_mutex, mtime_t deadline)
 Waits for a condition variable up to a certain date.
void vlc_sem_init (vlc_sem_t *sem, unsigned value)
 Initializes a semaphore.
void vlc_sem_destroy (vlc_sem_t *sem)
 Destroys a semaphore.
int vlc_sem_post (vlc_sem_t *sem)
 Increments the value of a semaphore.
void vlc_sem_wait (vlc_sem_t *sem)
 Atomically wait for the semaphore to become non-zero (if needed), then decrements it.
int vlc_threadvar_create (vlc_threadvar_t *p_tls, void(*destr)(void *))
 Allocates a thread-specific variable.
void vlc_threadvar_delete (vlc_threadvar_t *p_tls)
int vlc_threadvar_set (vlc_threadvar_t key, void *value)
 Sets a thread-specific variable.
void * vlc_threadvar_get (vlc_threadvar_t key)
 Gets the value of a thread-local variable for the calling thread.
static void vlc_thread_cleanup (struct vlc_thread *th)
static unsigned __stdcall vlc_entry (void *p)
static int vlc_clone_attr (vlc_thread_t *p_handle, bool detached, void *(*entry)(void *), void *data, int priority)
int vlc_clone (vlc_thread_t *p_handle, void *(*entry)(void *), void *data, int priority)
void vlc_join (vlc_thread_t th, void **result)
 Waits for a thread to complete (if needed), then destroys it.
int vlc_clone_detach (vlc_thread_t *p_handle, void *(*entry)(void *), void *data, int priority)
int vlc_set_priority (vlc_thread_t th, int priority)
static void CALLBACK vlc_cancel_self (ULONG_PTR self)
void vlc_cancel (vlc_thread_t th)
 Marks a thread as cancelled.
int vlc_savecancel (void)
 Save the current cancellation state (enabled or disabled), then disable cancellation for the calling thread.
void vlc_restorecancel (int state)
 Restore the cancellation state for the calling thread.
void vlc_testcancel (void)
 Issues an explicit deferred cancellation point.
void vlc_control_cancel (int cmd,...)
static mtime_t mdate_giveup (void)
mtime_t mdate (void)
 Precision monotonic clock.
static mtime_t mdate_interrupt (void)
static mtime_t mdate_tick (void)
static mtime_t mdate_multimedia (void)
static mtime_t mdate_perf (void)
static mtime_t mdate_wall (void)
void mwait ((mtime_t deadline))
 Waits until a deadline (possibly later due to OS scheduling).
void msleep ((mtime_t delay))
 Waits for an interval of time.
static void SelectClockSource (vlc_object_t *obj)
size_t EnumClockSource (vlc_object_t *obj, const char *var, char ***vp, char ***np)
static void CALLBACK vlc_timer_do (void *val, BOOLEAN timeout)
int vlc_timer_create (vlc_timer_t *id, void(*func)(void *), void *data)
 Initializes an asynchronous timer.
void vlc_timer_destroy (vlc_timer_t timer)
 Destroys an initialized timer.
void vlc_timer_schedule (vlc_timer_t timer, bool absolute, mtime_t value, mtime_t interval)
 Arm or disarm an initialized timer.
unsigned vlc_timer_getoverrun (vlc_timer_t timer)
 Fetch and reset the overrun counter for a timer.
unsigned vlc_GetCPUCount (void)
 Count CPUs.
void vlc_threads_setup (libvlc_int_t *p_libvlc)
BOOL WINAPI DllMain (HINSTANCE, DWORD, LPVOID)

Variables

static vlc_mutex_t super_mutex
static vlc_cond_t super_variable
struct vlc_threadvarvlc_threadvar_last
static vlc_threadvar_t thread_key
static CRITICAL_SECTION clock_lock
static mtime_t(* mdate_selected )(void) = mdate_giveup
union {
   struct {
      BOOL(*   query )(PULONGLONG)
   }   interrupt
   struct {
      ULONGLONG(*   get )(void)
   }   tick
   struct {
      LARGE_INTEGER   freq
   }   perf
clk
vlc_rwlock_t config_lock
vlc_rwlock_t msg_lock
 Store all data required by messages interfaces.

Macro Definition Documentation

#define xstrdup (   str)    (strdup(str) ?: (abort(), NULL))

Enumeration Type Documentation

anonymous enum
Enumerator:
CLOCK_STATIC 
CLOCK_MONOTONIC 
CLOCK_REALTIME 

Function Documentation

BOOL WINAPI DllMain ( HINSTANCE  hinstDll,
DWORD  fdwReason,
LPVOID  lpvReserved 
)
size_t EnumClockSource ( vlc_object_t obj,
const char *  var,
char ***  vp,
char ***  np 
)

References _, xmalloc(), and xstrdup.

mtime_t mdate ( void  )

Precision monotonic clock.

In principles, the clock has a precision of 1 MHz. But the actual resolution may be much lower, especially when it comes to sleeping with mwait() or msleep(). Most general-purpose operating systems provide a resolution of only 100 to 1000 Hz.

Warning
The origin date (time value "zero") is not specified. It is typically the time the kernel started, but this is platform-dependent. If you need wall clock time, use gettimeofday() instead.
Returns
a timestamp in microseconds.

References CLOCK_MONOTONIC, mdate_selected, and unlikely.

static mtime_t mdate_giveup ( void  )
static

Referenced by SelectClockSource().

static mtime_t mdate_interrupt ( void  )
static

References clk, CLOCK_FREQ, static_assert, and unlikely.

Referenced by SelectClockSource().

static mtime_t mdate_multimedia ( void  )
static

References CLOCK_FREQ, and static_assert.

Referenced by SelectClockSource().

static mtime_t mdate_perf ( void  )
static

References clk, lldiv(), lldiv_t::quot, and lldiv_t::rem.

Referenced by SelectClockSource().

static mtime_t mdate_tick ( void  )
static

References clk, CLOCK_FREQ, and static_assert.

Referenced by SelectClockSource().

static mtime_t mdate_wall ( void  )
static

References CLOCK_FREQ, and static_assert.

Referenced by SelectClockSource().

void msleep ( (mtime_t delay)  )

Waits for an interval of time.

Parameters
delayhow long to wait (in microseconds)

References mdate(), and mwait.

void mwait ( (mtime_t deadline)  )

Waits until a deadline (possibly later due to OS scheduling).

Parameters
deadlinetimestamp to wait for (see mdate())

References lock, mdate(), mutex_cleanup_push, unlikely, vlc_cleanup_run, vlc_cond_destroy(), vlc_cond_init(), vlc_cond_timedwait(), vlc_mutex_destroy(), vlc_mutex_init(), vlc_mutex_lock(), vlc_Sleep(), and vlc_testcancel().

static void SelectClockSource ( vlc_object_t obj)
static
void vlc_cancel ( vlc_thread_t  th)

Marks a thread as cancelled.

Next time the target thread reaches a cancellation point (while not having disabled cancellation), it will run its cancellation cleanup handler, the thread variable destructors, and terminate. vlc_join() must be used afterward regardless of a thread being cancelled or not.

References vlc_thread::cond, vlc_atomic_set(), vlc_cancel_self(), vlc_mutex_lock(), and vlc_mutex_unlock().

static void CALLBACK vlc_cancel_self ( ULONG_PTR  self)
static

References vlc_thread::killed, and likely.

Referenced by vlc_cancel().

int vlc_clone ( vlc_thread_t p_handle,
void *(*)(void *)  entry,
void *  data,
int  priority 
)

References vlc_clone_attr().

static int vlc_clone_attr ( vlc_thread_t p_handle,
bool  detached,
void *(*)(void *)  entry,
void *  data,
int  priority 
)
static
int vlc_clone_detach ( vlc_thread_t p_handle,
void *(*)(void *)  entry,
void *  data,
int  priority 
)

References vlc_clone_attr().

void vlc_cond_broadcast ( vlc_cond_t p_condvar)

Wakes up all threads (if any) waiting on a condition variable.

Parameters
p_condcondition variable
void vlc_cond_destroy ( vlc_cond_t p_condvar)

Destroys a condition variable.

No threads shall be waiting or signaling the condition.

Parameters
p_condvarcondition variable to destroy

References VLC_THREAD_ASSERT.

void vlc_cond_init ( vlc_cond_t p_condvar)

Initializes a condition variable.

References CLOCK_MONOTONIC, unlikely, and vlc_cond_init_common().

static void vlc_cond_init_common ( vlc_cond_t p_condvar,
unsigned  clock 
)
static
void vlc_cond_init_daytime ( vlc_cond_t p_condvar)

Initializes a condition variable.

Contrary to vlc_cond_init(), the wall clock will be used as a reference for the vlc_cond_timedwait() time-out parameter.

References CLOCK_REALTIME, unlikely, and vlc_cond_init_common().

void vlc_cond_signal ( vlc_cond_t p_condvar)

Wakes up one thread waiting on a condition variable, if any.

Parameters
p_condvarcondition variable

References vlc_cond_broadcast(), and VLC_THREAD_ASSERT.

int vlc_cond_timedwait ( vlc_cond_t p_condvar,
vlc_mutex_t p_mutex,
mtime_t  deadline 
)

Waits for a condition variable up to a certain date.

This works like vlc_cond_wait(), except for the additional time-out.

If the variable was initialized with vlc_cond_init(), the timeout has the same arbitrary origin as mdate(). If the variable was initialized with vlc_cond_init_daytime(), the timeout is expressed from the Unix epoch.

Parameters
p_condvarcondition variable to wait on
p_mutexmutex which is unlocked while waiting, then locked again when waking up.
deadlineabsolute timeout
Returns
0 if the condition was signaled, an error code in case of timeout.

References CLOCK_FREQ, CLOCK_MONOTONIC, CLOCK_REALTIME, vlc_thread::cond, mdate(), msleep, mtime_to_ts(), thread, vlc_mutex_lock(), vlc_mutex_trylock(), vlc_mutex_unlock(), vlc_testcancel(), VLC_THREAD_ASSERT, and vlc_WaitForSingleObject().

void vlc_cond_wait ( vlc_cond_t p_condvar,
vlc_mutex_t p_mutex 
)

Waits for a condition variable.

The calling thread will be suspended until another thread calls vlc_cond_signal() or vlc_cond_broadcast() on the same condition variable, the thread is cancelled with vlc_cancel(), or the system causes a "spurious" unsolicited wake-up.

A mutex is needed to wait on a condition variable. It must not be a recursive mutex. Although it is possible to use the same mutex for multiple condition, it is not valid to use different mutexes for the same condition variable at the same time from different threads.

In case of thread cancellation, the mutex is always locked before cancellation proceeds.

The canonical way to use a condition variable to wait for event foobar is:

mutex_cleanup_push (&lock); // release the mutex in case of cancellation
while (!foobar)
vlc_cond_wait (&wait, &lock);
--- foobar is now true, do something about it here --
vlc_cleanup_run (); // release the mutex
Parameters
p_condvarcondition variable to wait on
p_mutexmutex which is unlocked while waiting, then locked again when waking up.
deadlineabsolute timeout

References vlc_thread::cond, msleep, thread, vlc_mutex_lock(), vlc_mutex_trylock(), vlc_mutex_unlock(), vlc_testcancel(), VLC_THREAD_ASSERT, and vlc_WaitForSingleObject().

void vlc_control_cancel ( int  cmd,
  ... 
)
static unsigned __stdcall vlc_entry ( void *  p)
static
unsigned vlc_GetCPUCount ( void  )

Count CPUs.

Returns
number of available (logical) CPUs.
void vlc_join ( vlc_thread_t  th,
void **  result 
)

Waits for a thread to complete (if needed), then destroys it.

This is a cancellation point; in case of cancellation, the join does not occur.

Warning
A thread cannot join itself (normally VLC will abort if this is attempted). Also, a detached thread cannot be joined.
Parameters
handlethread handle
p_result[OUT] pointer to write the thread return value or NULL

References vlc_mutex_destroy(), vlc_sem_destroy(), vlc_sem_wait(), vlc_testcancel(), VLC_THREAD_ASSERT, and vlc_WaitForSingleObject().

void vlc_mutex_destroy ( vlc_mutex_t p_mutex)

Destroys a mutex.

The mutex must not be locked.

Parameters
p_mutexmutex to destroy
Returns
always succeeds

References VLC_THREAD_ASSERT.

void vlc_mutex_init ( vlc_mutex_t p_mutex)

Initializes a fast mutex.

void vlc_mutex_init_recursive ( vlc_mutex_t p_mutex)

Initializes a recursive mutex.

Warning
This is strongly discouraged. Please use normal mutexes.
void vlc_mutex_lock ( vlc_mutex_t p_mutex)

Acquires a mutex.

If needed, waits for any other thread to release it. Beware of deadlocks when locking multiple mutexes at the same time, or when using mutexes from callbacks. This function is not a cancellation-point.

Parameters
p_mutexmutex initialized with vlc_mutex_init() or vlc_mutex_init_recursive()

References super_mutex, super_variable, vlc_cond_wait(), vlc_mutex_lock(), vlc_mutex_unlock(), vlc_restorecancel(), vlc_savecancel(), and VLC_THREAD_ASSERT.

int vlc_mutex_trylock ( vlc_mutex_t p_mutex)

Acquires a mutex if and only if it is not currently held by another thread.

This function never sleeps and can be used in delay-critical code paths. This function is not a cancellation-point.

Beware: If this function fails, then the mutex is held... by another thread. The calling thread must deal with the error appropriately. That typically implies postponing the operations that would have required the mutex. If the thread cannot defer those operations, then it must use vlc_mutex_lock(). If in doubt, use vlc_mutex_lock() instead.

Parameters
p_mutexmutex initialized with vlc_mutex_init() or vlc_mutex_init_recursive()
Returns
0 if the mutex could be acquired, an error code otherwise.

References super_mutex, vlc_mutex_lock(), vlc_mutex_unlock(), and VLC_THREAD_ASSERT.

void vlc_mutex_unlock ( vlc_mutex_t p_mutex)

Releases a mutex (or crashes if the mutex is not locked by the caller).

Parameters
p_mutexmutex locked with vlc_mutex_lock().

References super_mutex, super_variable, vlc_cond_broadcast(), vlc_mutex_lock(), vlc_mutex_unlock(), and VLC_THREAD_ASSERT.

void vlc_restorecancel ( int  state)

Restore the cancellation state for the calling thread.

Parameters
stateprevious state as returned by vlc_savecancel().
Returns
Nothing, always succeeds.

References vlc_thread::killable, thread, and vlc_threadvar_get().

int vlc_savecancel ( void  )

Save the current cancellation state (enabled or disabled), then disable cancellation for the calling thread.

This function must be called before entering a piece of code that is not cancellation-safe, unless it can be proven that the calling thread will not be cancelled.

Returns
Previous cancellation state (opaque value for vlc_restorecancel()).

References vlc_thread::killable, thread, and vlc_threadvar_get().

void vlc_sem_destroy ( vlc_sem_t sem)

Destroys a semaphore.

References likely, and VLC_THREAD_ASSERT.

void vlc_sem_init ( vlc_sem_t sem,
unsigned  value 
)

Initializes a semaphore.

References unlikely.

int vlc_sem_post ( vlc_sem_t sem)

Increments the value of a semaphore.

Returns
0 on success, EOVERFLOW in case of integer overflow

References likely, unlikely, and VLC_THREAD_ASSERT.

void vlc_sem_wait ( vlc_sem_t sem)

Atomically wait for the semaphore to become non-zero (if needed), then decrements it.

References likely, vlc_testcancel(), VLC_THREAD_ASSERT, and vlc_WaitForSingleObject().

int vlc_set_priority ( vlc_thread_t  th,
int  priority 
)

< Unspecified error

< No error

References VLC_EGENERIC, and VLC_SUCCESS.

static DWORD vlc_Sleep ( DWORD  delay)
static

References vlc_WaitForMultipleObjects().

Referenced by mwait().

void vlc_testcancel ( void  )

Issues an explicit deferred cancellation point.

This has no effect if thread cancellation is disabled. This can be called when there is a rather slow non-sleeping operation. This is also used to force a cancellation point in a function that would otherwise "not always" be a one (block_FifoGet() is an example).

References vlc_thread::cleaners, vlc_thread::data, vlc_thread::killable, vlc_thread::killed, thread, vlc_atomic_get(), vlc_thread_cleanup(), and vlc_threadvar_get().

static void vlc_thread_cleanup ( struct vlc_thread th)
static
void vlc_threads_setup ( libvlc_int_t p_libvlc)

References SelectClockSource(), and VLC_OBJECT.

int vlc_threadvar_create ( vlc_threadvar_t p_tls,
void(*)(void *)  destr 
)

Allocates a thread-specific variable.

Parameters
keywhere to store the thread-specific variable handle
destra destruction callback. It is called whenever a thread exits and the thread-specific variable has a non-NULL value.
Returns
0 on success, a system error code otherwise. This function can actually fail because there is a fixed limit on the number of thread-specific variable in a process on most systems.

References vlc_threadvar::destroy, vlc_threadvar::id, vlc_threadvar::next, vlc_threadvar::prev, super_mutex, unlikely, vlc_mutex_lock(), vlc_mutex_unlock(), and vlc_threadvar_last.

void vlc_threadvar_delete ( vlc_threadvar_t p_tls)
void* vlc_threadvar_get ( vlc_threadvar_t  key)

Gets the value of a thread-local variable for the calling thread.

This function cannot fail.

Returns
the value associated with the given variable for the calling or NULL if there is no value.
int vlc_threadvar_set ( vlc_threadvar_t  key,
void *  value 
)

Sets a thread-specific variable.

Parameters
keythread-local variable key (created with vlc_threadvar_create())
valuenew value for the variable for the calling thread
Returns
0 on success, a system error code otherwise.
int vlc_timer_create ( vlc_timer_t id,
void(*)(void *)  func,
void *  data 
)

Initializes an asynchronous timer.

Warning
Asynchronous timers are processed from an unspecified thread. Multiple occurences of a single interval timer are serialized; they cannot run concurrently.
Parameters
idpointer to timer to be initialized
funcfunction that the timer will call
dataparameter for the timer function
Returns
0 on success, a system error code otherwise.

References vlc_timer::data, vlc_timer::func, vlc_timer::handle, vlc_timer::hev, vlc_timer::htimer, vlc_timer::interval, vlc_timer::quit, vlc_timer::tid, and vlc_timer_do().

void vlc_timer_destroy ( vlc_timer_t  timer)

Destroys an initialized timer.

If needed, the timer is first disarmed. This function is undefined if the specified timer is not initialized.

Warning
This function must be called before the timer data can be freed and before the timer callback function can be unloaded.
Parameters
timertimer to destroy

References vlc_timer::handle, vlc_timer::hev, vlc_timer::htimer, vlc_timer::quit, and vlc_timer::tid.

static void CALLBACK vlc_timer_do ( void *  val,
BOOLEAN  timeout 
)
static

References vlc_timer::data, and vlc_timer::func.

Referenced by vlc_timer_schedule().

unsigned vlc_timer_getoverrun ( vlc_timer_t  timer)

Fetch and reset the overrun counter for a timer.

Parameters
timerinitialized timer
Returns
the timer overrun counter, i.e. the number of times that the timer should have run but did not since the last actual run. If all is well, this is zero.
void vlc_timer_schedule ( vlc_timer_t  timer,
bool  absolute,
mtime_t  value,
mtime_t  interval 
)

Arm or disarm an initialized timer.

This functions overrides any previous call to itself.

Note
A timer can fire later than requested due to system scheduling limitations. An interval timer can fail to trigger sometimes, either because the system is busy or suspended, or because a previous iteration of the timer is still running. See also vlc_timer_getoverrun().
Parameters
timerinitialized timer
absolutethe timer value origin is the same as mdate() if true, the timer value is relative to now if false.
valuezero to disarm the timer, otherwise the initial time to wait before firing the timer.
intervalzero to fire the timer just once, otherwise the timer repetition interval.

References vlc_timer::handle, vlc_timer::hev, vlc_timer::htimer, vlc_timer::interval, mdate(), and vlc_timer_do().

static DWORD vlc_WaitForMultipleObjects ( DWORD  count,
const HANDLE *  handles,
DWORD  delay 
)
static

References unlikely.

Referenced by vlc_Sleep(), and vlc_WaitForSingleObject().

static DWORD vlc_WaitForSingleObject ( HANDLE  handle,
DWORD  delay 
)
static

Variable Documentation

union { ... } clk
CRITICAL_SECTION clock_lock
static
vlc_rwlock_t config_lock
LARGE_INTEGER freq

Referenced by mdate().

ULONGLONG(* get)(void)
struct { ... } interrupt
mtime_t(* mdate_selected)(void) = mdate_giveup
static

Referenced by mdate(), and SelectClockSource().

vlc_rwlock_t msg_lock

Store all data required by messages interfaces.

Referenced by _DLL_InitTerm(), vlc_Subscribe(), vlc_Unsubscribe(), and vlc_vaLog().

struct { ... } perf
BOOL(* query)(PULONGLONG)

Referenced by httpd_HostThread().

vlc_mutex_t super_mutex
static
vlc_cond_t super_variable
static
vlc_threadvar_t thread_key
static
struct { ... } tick
struct vlc_threadvar * vlc_threadvar_last