Mercurial > hg > nginx-ranges

comparison src/os/unix/ngx_freebsd_rfork_thread.h @ 0:f0b350454894 NGINX_0_1_0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx 0.1.0 *) The first public version.
author Igor Sysoev <http://sysoev.ru>
date Mon, 04 Oct 2004 00:00:00 +0400
parents
children 46833bd150cb
comparison
equal deleted inserted replaced
-1:000000000000 0:f0b350454894
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
21 #define TID_T_FMT PID_T_FMT
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
94 ngx_int_t ngx_thread_key_create(ngx_tls_key_t *key);
95 #define ngx_thread_key_create_n "the tls key creation"
96
97 ngx_int_t ngx_thread_set_tls(ngx_tls_key_t key, void *value);
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_ */