Mercurial > hg > nginx-vendor-0-6

comparison src/os/unix/ngx_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 4b2dafa26fe2
comparison
equal deleted inserted replaced
-1:000000000000 0:f0b350454894
1
2 /*
3 * Copyright (C) Igor Sysoev
4 */
5
6
7 #ifndef _NGX_THREAD_H_INCLUDED_
8 #define _NGX_THREAD_H_INCLUDED_
9
10
11 #include <ngx_config.h>
12 #include <ngx_core.h>
13
14 #if (NGX_THREADS)
15
16 #define NGX_MAX_THREADS 128
17
18 #if (NGX_USE_RFORK)
19 #include <ngx_freebsd_rfork_thread.h>
20
21
22 #else /* use pthreads */
23
24 #include <pthread.h>
25
26 typedef pthread_t ngx_tid_t;
27
28 #define ngx_thread_self() pthread_self()
29 #define ngx_log_tid (int) ngx_thread_self()
30
31 #if defined(__FreeBSD__) && !defined(NGX_LINUXTHREADS)
32 #define TID_T_FMT PTR_FMT
33 #else
34 #define TID_T_FMT "%d"
35 #endif
36
37
38 typedef pthread_key_t ngx_tls_key_t;
39
40 #define ngx_thread_key_create(key) pthread_key_create(key, NULL)
41 #define ngx_thread_key_create_n "pthread_key_create()"
42 #define ngx_thread_set_tls pthread_setspecific
43 #define ngx_thread_set_tls_n "pthread_setspecific()"
44 #define ngx_thread_get_tls pthread_getspecific
45
46
47 #define NGX_MUTEX_LIGHT 0
48
49 typedef struct {
50 pthread_mutex_t mutex;
51 ngx_log_t *log;
52 } ngx_mutex_t;
53
54 typedef struct {
55 pthread_cond_t cond;
56 ngx_tid_t tid;
57 ngx_log_t *log;
58 } ngx_cond_t;
59
60 #define ngx_thread_sigmask pthread_sigmask
61 #define ngx_thread_sigmask_n "pthread_sigmask()"
62
63 #define ngx_thread_join(t, p) pthread_join(t, p)
64
65 #define ngx_setthrtitle(n)
66
67
68
69 ngx_int_t ngx_mutex_trylock(ngx_mutex_t *m);
70 ngx_int_t ngx_mutex_lock(ngx_mutex_t *m);
71 ngx_int_t ngx_mutex_unlock(ngx_mutex_t *m);
72
73 #endif
74
75
76 #define ngx_thread_volatile volatile
77
78
79 typedef struct {
80 ngx_tid_t tid;
81 ngx_cond_t *cv;
82 ngx_uint_t state;
83 } ngx_thread_t;
84
85 #define NGX_THREAD_FREE 1
86 #define NGX_THREAD_BUSY 2
87 #define NGX_THREAD_EXIT 3
88 #define NGX_THREAD_DONE 4
89
90 extern ngx_int_t ngx_threads_n;
91 extern volatile ngx_thread_t ngx_threads[NGX_MAX_THREADS];
92
93
94 ngx_int_t ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle);
95 int ngx_create_thread(ngx_tid_t *tid, void* (*func)(void *arg), void *arg,
96 ngx_log_t *log);
97
98
99 ngx_mutex_t *ngx_mutex_init(ngx_log_t *log, uint flags);
100 void ngx_mutex_destroy(ngx_mutex_t *m);
101
102
103 ngx_cond_t *ngx_cond_init(ngx_log_t *log);
104 void ngx_cond_destroy(ngx_cond_t *cv);
105 ngx_int_t ngx_cond_wait(ngx_cond_t *cv, ngx_mutex_t *m);
106 ngx_int_t ngx_cond_signal(ngx_cond_t *cv);
107
108
109 #else /* !NGX_THREADS */
110
111 #define ngx_thread_volatile
112
113 #define ngx_log_tid 0
114 #define TID_T_FMT "%d"
115
116 #define ngx_mutex_trylock(m) NGX_OK
117 #define ngx_mutex_lock(m) NGX_OK
118 #define ngx_mutex_unlock(m)
119
120 #define ngx_cond_signal(cv)
121
122 #define ngx_thread_main() 1
123
124 #endif
125
126
127
128 #endif /* _NGX_THREAD_H_INCLUDED_ */