|
0
|
1
|
|
|
2 /*
|
|
|
3 * Copyright (C) Igor Sysoev
|
|
|
4 */
|
|
|
5
|
|
|
6
|
|
|
7 #ifndef _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_
|
|
|
8 #define _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_
|
|
|
9
|
|
|
10
|
|
|
11 #include <sys/ipc.h>
|
|
|
12 #include <sys/sem.h>
|
|
|
13 #include <sched.h>
|
|
|
14
|
|
|
15 typedef pid_t ngx_tid_t;
|
|
|
16
|
|
|
17 #undef ngx_log_pid
|
|
|
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
|
|
|
59 static inline int ngx_gettid()
|
|
|
60 {
|
|
|
61 char *sp;
|
|
|
62
|
|
|
63 if (ngx_thread_stack_size == 0) {
|
|
|
64 return 0;
|
|
|
65 }
|
|
|
66
|
|
|
67 #if ( __i386__ )
|
|
|
68
|
|
|
69 __asm__ volatile ("mov %%esp, %0" : "=q" (sp));
|
|
|
70
|
|
|
71 #elif ( __amd64__ )
|
|
|
72
|
|
|
73 __asm__ volatile ("mov %%rsp, %0" : "=q" (sp));
|
|
|
74
|
|
|
75 #else
|
|
|
76
|
|
|
77 #error "rfork()ed threads are not supported on this platform"
|
|
|
78
|
|
|
79 #endif
|
|
|
80
|
|
|
81 return (ngx_freebsd_kern_usrstack - sp) / ngx_thread_stack_size;
|
|
|
82 }
|
|
|
83
|
|
|
84
|
|
|
85 ngx_tid_t ngx_thread_self();
|
|
|
86
|
|
|
87
|
|
|
88 typedef ngx_uint_t ngx_tls_key_t;
|
|
|
89
|
|
|
90 #define NGX_THREAD_KEYS_MAX 16
|
|
|
91
|
|
|
92 extern void **ngx_tls;
|
|
|
93
|
|
10
|
94 ngx_err_t ngx_thread_key_create(ngx_tls_key_t *key);
|
|
0
|
95 #define ngx_thread_key_create_n "the tls key creation"
|
|
|
96
|
|
10
|
97 ngx_err_t ngx_thread_set_tls(ngx_tls_key_t key, void *value);
|
|
0
|
98 #define ngx_thread_set_tls_n "the tls key setting"
|
|
|
99
|
|
|
100
|
|
|
101 static void *ngx_thread_get_tls(ngx_tls_key_t key)
|
|
|
102 {
|
|
|
103 if (key >= NGX_THREAD_KEYS_MAX) {
|
|
|
104 return NULL;
|
|
|
105 }
|
|
|
106
|
|
|
107 return ngx_tls[key * NGX_THREAD_KEYS_MAX + ngx_gettid()];
|
|
|
108 }
|
|
|
109
|
|
|
110
|
|
|
111 #define ngx_mutex_trylock(m) ngx_mutex_dolock(m, 1)
|
|
|
112 #define ngx_mutex_lock(m) ngx_mutex_dolock(m, 0)
|
|
|
113 ngx_int_t ngx_mutex_dolock(ngx_mutex_t *m, ngx_int_t try);
|
|
|
114 ngx_int_t ngx_mutex_unlock(ngx_mutex_t *m);
|
|
|
115
|
|
|
116
|
|
|
117 typedef int (*ngx_rfork_thread_func_pt)(void *arg);
|
|
|
118
|
|
|
119
|
|
|
120
|
|
|
121 #endif /* _NGX_FREEBSD_RFORK_THREAD_H_INCLUDED_ */
|
