|
0
|
1
|
|
|
2 /*
|
|
|
3 * Copyright (C) Igor Sysoev
|
|
660
|
4 * Copyright (C) Nginx, Inc.
|
|
0
|
5 */
|
|
|
6
|
|
|
7
|
|
|
8 #ifndef _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_
|
|
|
9 #define _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_
|
|
|
10
|
|
|
11
|
|
|
12 #include <sys/ipc.h>
|
|
|
13 #include <sys/sem.h>
|
|
|
14 #include <sched.h>
|
|
|
15
|
|
|
16 typedef pid_t ngx_tid_t;
|
|
|
17
|
|
|
18 #define ngx_log_pid ngx_thread_self()
|
|
|
19 #define ngx_log_tid 0
|
|
|
20
|
|
10
|
21 #define NGX_TID_T_FMT "%P"
|
|
0
|
22
|
|
|
23
|
|
|
24 #define NGX_MUTEX_LIGHT 1
|
|
|
25
|
|
|
26 #define NGX_MUTEX_LOCK_BUSY 0x80000000
|
|
|
27
|
|
|
28 typedef volatile struct {
|
|
|
29 ngx_atomic_t lock;
|
|
|
30 ngx_log_t *log;
|
|
|
31 int semid;
|
|
|
32 } ngx_mutex_t;
|
|
|
33
|
|
|
34
|
|
|
35 #define NGX_CV_SIGNAL 64
|
|
|
36
|
|
|
37 typedef struct {
|
|
|
38 int signo;
|
|
|
39 int kq;
|
|
|
40 ngx_tid_t tid;
|
|
|
41 ngx_log_t *log;
|
|
|
42 } ngx_cond_t;
|
|
|
43
|
|
|
44
|
|
|
45 #define ngx_thread_sigmask(how, set, oset) \
|
|
|
46 (sigprocmask(how, set, oset) == -1) ? ngx_errno : 0
|
|
|
47
|
|
|
48 #define ngx_thread_sigmask_n "sigprocmask()"
|
|
|
49
|
|
|
50 #define ngx_thread_join(t, p)
|
|
|
51
|
|
|
52 #define ngx_setthrtitle(n) setproctitle(n)
|
|
|
53
|
|
|
54
|
|
|
55 extern char *ngx_freebsd_kern_usrstack;
|
|
|
56 extern size_t ngx_thread_stack_size;
|
|
|
57
|
|
|
58
|
|
112
|
59 static ngx_inline ngx_int_t
|
|
|
60 ngx_gettid()
|
|
0
|
61 {
|
|
|
62 char *sp;
|
|
|
63
|
|
|
64 if (ngx_thread_stack_size == 0) {
|
|
|
65 return 0;
|
|
|
66 }
|
|
|
67
|
|
|
68 #if ( __i386__ )
|
|
|
69
|
|
|
70 __asm__ volatile ("mov %%esp, %0" : "=q" (sp));
|
|
|
71
|
|
|
72 #elif ( __amd64__ )
|
|
|
73
|
|
|
74 __asm__ volatile ("mov %%rsp, %0" : "=q" (sp));
|
|
|
75
|
|
|
76 #else
|
|
|
77
|
|
|
78 #error "rfork()ed threads are not supported on this platform"
|
|
|
79
|
|
|
80 #endif
|
|
|
81
|
|
|
82 return (ngx_freebsd_kern_usrstack - sp) / ngx_thread_stack_size;
|
|
|
83 }
|
|
|
84
|
|
|
85
|
|
|
86 ngx_tid_t ngx_thread_self();
|
|
|
87
|
|
|
88
|
|
|
89 typedef ngx_uint_t ngx_tls_key_t;
|
|
|
90
|
|
|
91 #define NGX_THREAD_KEYS_MAX 16
|
|
|
92
|
|
|
93 extern void **ngx_tls;
|
|
|
94
|
|
10
|
95 ngx_err_t ngx_thread_key_create(ngx_tls_key_t *key);
|
|
0
|
96 #define ngx_thread_key_create_n "the tls key creation"
|
|
|
97
|
|
10
|
98 ngx_err_t ngx_thread_set_tls(ngx_tls_key_t key, void *value);
|
|
0
|
99 #define ngx_thread_set_tls_n "the tls key setting"
|
|
|
100
|
|
|
101
|
|
112
|
102 static void *
|
|
|
103 ngx_thread_get_tls(ngx_tls_key_t key)
|
|
126
|
104 {
|
|
0
|
105 if (key >= NGX_THREAD_KEYS_MAX) {
|
|
|
106 return NULL;
|
|
|
107 }
|
|
|
108
|
|
|
109 return ngx_tls[key * NGX_THREAD_KEYS_MAX + ngx_gettid()];
|
|
|
110 }
|
|
|
111
|
|
|
112
|
|
|
113 #define ngx_mutex_trylock(m) ngx_mutex_dolock(m, 1)
|
|
112
|
114 #define ngx_mutex_lock(m) (void) ngx_mutex_dolock(m, 0)
|
|
0
|
115 ngx_int_t ngx_mutex_dolock(ngx_mutex_t *m, ngx_int_t try);
|
|
112
|
116 void ngx_mutex_unlock(ngx_mutex_t *m);
|
|
0
|
117
|
|
|
118
|
|
|
119 typedef int (*ngx_rfork_thread_func_pt)(void *arg);
|
|
|
120
|
|
|
121
|
|
|
122 #endif /* _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_ */
|
