One Level Up Top Level

src/os/unix/ngx_freebsd_rfork_thread.h - nginx-1.7.10

Data types defined

Functions defined

Macros defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #ifndef _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_
  9. ‌#define _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_


  12. #include <sys/ipc.h>
  13. #include <sys/sem.h>
  14. #include <sched.h>

  16. ‌typedef pid_t  ngx_tid_t;

  18. ‌#define ngx_log_pid    ngx_thread_self()
  19. ‌#define ngx_log_tid    0

  21. ‌#define NGX_TID_T_FMT  "%P"


  24. ‌#define NGX_MUTEX_LIGHT      1

  26. ‌#define NGX_MUTEX_LOCK_BUSY  0x80000000

  28. typedef volatile struct {
  29.     ngx_atomic_t  lock;
  30.     ngx_log_t    *log;
  31.     int           semid;
  32. ‌} ngx_mutex_t;


  35. ‌#define NGX_CV_SIGNAL        64

  37. typedef struct {
  38.     int           signo;
  39.     int           kq;
  40.     ngx_tid_t     tid;
  41.     ngx_log_t    *log;
  42. ‌} ngx_cond_t;


  45. ‌#define ngx_thread_sigmask(how, set, oset)                         \
  46.             (sigprocmask(how, set, oset) == -1) ? ngx_errno : 0

  48. ‌#define ngx_thread_sigmask_n   "sigprocmask()"

  50. ‌#define ngx_thread_join(t, p)

  52. ‌#define ngx_setthrtitle(n)     setproctitle(n)


  55. extern char    *ngx_freebsd_kern_usrstack;
  56. extern size_t   ngx_thread_stack_size;


  59. static ngx_inline ngx_int_t
  60. ‌ngx_gettid(void)
  61. {
  62.     char  *sp;

  64.     if (ngx_thread_stack_size == 0) {
  65.         return 0;
  66.     }

  68. #if ( __i386__ )

  70.     __asm__ volatile ("mov %%esp, %0" : "=q" (sp));

  72. #elif ( __amd64__ )

  74.     __asm__ volatile ("mov %%rsp, %0" : "=q" (sp));

  76. #else

  78. #error "rfork()ed threads are not supported on this platform"

  80. #endif

  82.     return (ngx_freebsd_kern_usrstack - sp) / ngx_thread_stack_size;
  83. }


  86. ngx_tid_t ngx_thread_self(void);


  89. ‌typedef ngx_uint_t               ngx_tls_key_t;

  91. ‌#define NGX_THREAD_KEYS_MAX      16

  93. extern void    **ngx_tls;

  95. ngx_err_t ngx_thread_key_create(ngx_tls_key_t *key);
  96. ‌#define ngx_thread_key_create_n  "the tls key creation"

  98. ngx_err_t ngx_thread_set_tls(ngx_tls_key_t key, void *value);
  99. ‌#define ngx_thread_set_tls_n     "the tls key setting"


  102. static void *
  103. ‌ngx_thread_get_tls(ngx_tls_key_t key)
  104. {
  105.     if (key >= NGX_THREAD_KEYS_MAX) {
  106.         return NULL;
  107.     }

  109.     return ngx_tls[key * NGX_THREAD_KEYS_MAX + ngx_gettid()];
  110. }


  113. ‌#define ngx_mutex_trylock(m)  ngx_mutex_dolock(m, 1)
  114. ‌#define ngx_mutex_lock(m)     (void) ngx_mutex_dolock(m, 0)
  115. ngx_int_t ngx_mutex_dolock(ngx_mutex_t *m, ngx_int_t try);
  116. void ngx_mutex_unlock(ngx_mutex_t *m);


  119. ‌typedef int (*ngx_rfork_thread_func_pt)(void *arg);


  122. #endif /* _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_ */

One Level Up Top Level