code.delx.au - pulseaudio/blob - src/pulsecore/thread.h

   1 #ifndef foopulsethreadhfoo
   2 #define foopulsethreadhfoo
   3
   4 /***
   5   This file is part of PulseAudio.
   6
   7   Copyright 2006 Lennart Poettering
   8   Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
   9
  10   PulseAudio is free software; you can redistribute it and/or modify
  11   it under the terms of the GNU Lesser General Public License as
  12   published by the Free Software Foundation; either version 2.1 of the
  13   License, or (at your option) any later version.
  14
  15   PulseAudio is distributed in the hope that it will be useful, but
  16   WITHOUT ANY WARRANTY; without even the implied warranty of
  17   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  18   General Public License for more details.
  19
  20   You should have received a copy of the GNU Lesser General Public
  21   License along with PulseAudio; if not, write to the Free Software
  22   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
  23   USA.
  24 ***/
  25
  26 #include <pulse/def.h>
  27 #include <pulsecore/once.h>
  28 #include <pulsecore/core-util.h>
  29
  30 #ifndef PACKAGE
  31 #error "Please include config.h before including this file!"
  32 #endif
  33
  34 typedef struct pa_thread pa_thread;
  35
  36 typedef void (*pa_thread_func_t) (void *userdata);
  37
  38 pa_thread* pa_thread_new(pa_thread_func_t thread_func, void *userdata);
  39 void pa_thread_free(pa_thread *t);
  40 int pa_thread_join(pa_thread *t);
  41 int pa_thread_is_running(pa_thread *t);
  42 pa_thread *pa_thread_self(void);
  43 void pa_thread_yield(void);
  44
  45 void* pa_thread_get_data(pa_thread *t);
  46 void pa_thread_set_data(pa_thread *t, void *userdata);
  47
  48 typedef struct pa_tls pa_tls;
  49
  50 pa_tls* pa_tls_new(pa_free_cb_t free_cb);
  51 void pa_tls_free(pa_tls *t);
  52 void * pa_tls_get(pa_tls *t);
  53 void *pa_tls_set(pa_tls *t, void *userdata);
  54
  55 #define PA_STATIC_TLS_DECLARE(name, free_cb)                            \
  56     static struct {                                                     \
  57         pa_once once;                                                   \
  58         pa_tls *tls;                                                    \
  59     } name##_tls = {                                                    \
  60         .once = PA_ONCE_INIT,                                           \
  61         .tls = NULL                                                     \
  62     };                                                                  \
  63     static void name##_tls_init(void) {                                 \
  64         name##_tls.tls = pa_tls_new(free_cb);                           \
  65     }                                                                   \
  66     static inline pa_tls* name##_tls_obj(void) {                        \
  67         pa_run_once(&name##_tls.once, name##_tls_init);                 \
  68         return name##_tls.tls;                                          \
  69     }                                                                   \
  70     static void name##_tls_destructor(void) PA_GCC_DESTRUCTOR;          \
  71     static void name##_tls_destructor(void) {                           \
  72         static void (*_free_cb)(void*) = free_cb;                       \
  73         if (!pa_in_valgrind())                                          \
  74             return;                                                     \
  75         if (!name##_tls.tls)                                            \
  76             return;                                                     \
  77         if (_free_cb) {                                                 \
  78             void *p;                                                    \
  79             if ((p = pa_tls_get(name##_tls.tls)))                       \
  80                 _free_cb(p);                                            \
  81         }                                                               \
  82         pa_tls_free(name##_tls.tls);                                    \
  83     }                                                                   \
  84     static inline void* name##_tls_get(void) {                          \
  85         return pa_tls_get(name##_tls_obj());                            \
  86     }                                                                   \
  87     static inline void* name##_tls_set(void *p) {                       \
  88         return pa_tls_set(name##_tls_obj(), p);                         \
  89     }                                                                   \
  90     struct __stupid_useless_struct_to_allow_trailing_semicolon
  91
  92 #ifdef SUPPORT_TLS___THREAD
  93 /* An optimized version of the above that requires no dynamic
  94  * allocation if the compiler supports __thread */
  95 #define PA_STATIC_TLS_DECLARE_NO_FREE(name)                             \
  96     static __thread void *name##_tls = NULL;                            \
  97     static inline void* name##_tls_get(void) {                          \
  98         return name##_tls;                                              \
  99     }                                                                   \
 100     static inline void* name##_tls_set(void *p) {                       \
 101         void *r = name##_tls;                                           \
 102         name##_tls = p;                                                 \
 103         return r;                                                       \
 104     }                                                                   \
 105     struct __stupid_useless_struct_to_allow_trailing_semicolon
 106 #else
 107 #define PA_STATIC_TLS_DECLARE_NO_FREE(name) PA_STATIC_TLS_DECLARE(name, NULL)
 108 #endif
 109
 110 #define PA_STATIC_TLS_GET(name) (name##_tls_get())
 111 #define PA_STATIC_TLS_SET(name, p) (name##_tls_set(p))
 112
 113 #endif