Mercurial > hg > nginx
annotate src/core/ngx_shmtx.h @ 3872:83cd1910329c
allow regex as "map" parameter
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 16 Mar 2011 15:32:31 +0000 |
parents | e345fcf61a12 |
children | 0daede16d68b |
rev | line source |
---|---|
611 | 1 |
2 /* | |
3 * Copyright (C) Igor Sysoev | |
4 */ | |
5 | |
6 | |
7 #ifndef _NGX_SHMTX_H_INCLUDED_ | |
8 #define _NGX_SHMTX_H_INCLUDED_ | |
9 | |
10 | |
11 #include <ngx_config.h> | |
12 #include <ngx_core.h> | |
13 | |
14 | |
15 typedef struct { | |
16 #if (NGX_HAVE_ATOMIC_OPS) | |
17 ngx_atomic_t *lock; | |
18 #else | |
19 ngx_fd_t fd; | |
20 u_char *name; | |
21 #endif | |
22 } ngx_shmtx_t; | |
23 | |
24 | |
860
201d017ea470
slab allocator in shared memory
Igor Sysoev <igor@sysoev.ru>
parents:
611
diff
changeset
|
25 ngx_int_t ngx_shmtx_create(ngx_shmtx_t *mtx, void *addr, u_char *name); |
611 | 26 |
27 | |
28 #if (NGX_HAVE_ATOMIC_OPS) | |
29 | |
30 static ngx_inline ngx_uint_t | |
31 ngx_shmtx_trylock(ngx_shmtx_t *mtx) | |
32 { | |
1008 | 33 return (*mtx->lock == 0 && ngx_atomic_cmp_set(mtx->lock, 0, ngx_pid)); |
611 | 34 } |
35 | |
36 #define ngx_shmtx_lock(mtx) ngx_spinlock((mtx)->lock, ngx_pid, 1024) | |
37 | |
38 #define ngx_shmtx_unlock(mtx) (void) ngx_atomic_cmp_set((mtx)->lock, ngx_pid, 0) | |
39 | |
40 #define ngx_shmtx_destory(mtx) | |
41 | |
42 | |
43 #else | |
44 | |
45 static ngx_inline ngx_uint_t | |
46 ngx_shmtx_trylock(ngx_shmtx_t *mtx) | |
47 { | |
48 ngx_err_t err; | |
49 | |
50 err = ngx_trylock_fd(mtx->fd); | |
51 | |
52 if (err == 0) { | |
53 return 1; | |
54 } | |
55 | |
56 if (err == NGX_EAGAIN) { | |
57 return 0; | |
58 } | |
59 | |
2563
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
60 #if __osf__ /* Tru64 UNIX */ |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
61 |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
62 if (err == NGX_EACCESS) { |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
63 return 0; |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
64 } |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
65 |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
66 #endif |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
67 |
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
68 ngx_log_abort(err, ngx_trylock_fd_n " %s failed", mtx->name); |
1106
2c7fed12fab7
fix building on platforms with non-supported atomic operations
Igor Sysoev <igor@sysoev.ru>
parents:
1008
diff
changeset
|
69 |
2c7fed12fab7
fix building on platforms with non-supported atomic operations
Igor Sysoev <igor@sysoev.ru>
parents:
1008
diff
changeset
|
70 return 0; |
611 | 71 } |
72 | |
73 | |
74 static ngx_inline void | |
75 ngx_shmtx_lock(ngx_shmtx_t *mtx) | |
76 { | |
77 ngx_err_t err; | |
78 | |
79 err = ngx_lock_fd(mtx->fd); | |
80 | |
81 if (err == 0) { | |
82 return; | |
83 } | |
84 | |
2563
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
85 ngx_log_abort(err, ngx_lock_fd_n " %s failed", mtx->name); |
611 | 86 } |
87 | |
88 | |
89 static ngx_inline void | |
90 ngx_shmtx_unlock(ngx_shmtx_t *mtx) | |
91 { | |
92 ngx_err_t err; | |
93 | |
94 err = ngx_unlock_fd(mtx->fd); | |
95 | |
96 if (err == 0) { | |
97 return; | |
98 } | |
99 | |
2563
e345fcf61a12
compatibility with Tru64 UNIX: fcntl(F_SETLK, F_WRLCK) returns EINVAL if busy
Igor Sysoev <igor@sysoev.ru>
parents:
1106
diff
changeset
|
100 ngx_log_abort(err, ngx_unlock_fd_n " %s failed", mtx->name); |
611 | 101 } |
102 | |
103 | |
104 void ngx_shmtx_destory(ngx_shmtx_t *mtx); | |
105 | |
106 #endif | |
107 | |
108 | |
109 #endif /* _NGX_SHMTX_H_INCLUDED_ */ |