Mercurial > hg > nginx
annotate src/core/ngx_resolver.h @ 4309:3f6040cd731e
Added shmtx interface to forcibly unlock mutexes.
It is currently used from master process on abnormal worker termination to
unlock accept mutex (unlocking of accept mutex was broken in 1.0.2). It is
expected to be used in the future to unlock other mutexes as well.
Shared mutex code was rewritten to make this possible in a safe way, i.e.
with a check if lock was actually held by the exited process. We again use
pid to lock mutex, and use separate atomic variable for a count of processes
waiting in sem_wait().
| author | Maxim Dounin <mdounin@mdounin.ru> |
|---|---|
| date | Wed, 23 Nov 2011 13:55:38 +0000 |
| parents | 016352c19049 |
| children | d620f497c50f |
| rev | line source |
|---|---|
| 1649 | 1 |
| 2 /* | |
| 3 * Copyright (C) Igor Sysoev | |
| 4 */ | |
| 5 | |
| 6 | |
| 7 #include <ngx_config.h> | |
| 8 #include <ngx_core.h> | |
| 9 | |
| 10 | |
| 11 #ifndef _NGX_RESOLVER_H_INCLUDED_ | |
| 12 #define _NGX_RESOLVER_H_INCLUDED_ | |
| 13 | |
| 14 | |
| 15 #define NGX_RESOLVE_A 1 | |
| 16 #define NGX_RESOLVE_CNAME 5 | |
| 17 #define NGX_RESOLVE_PTR 12 | |
| 18 #define NGX_RESOLVE_MX 15 | |
| 19 #define NGX_RESOLVE_TXT 16 | |
| 1965 | 20 #define NGX_RESOLVE_DNAME 39 |
| 1649 | 21 |
| 22 #define NGX_RESOLVE_FORMERR 1 | |
| 23 #define NGX_RESOLVE_SERVFAIL 2 | |
| 24 #define NGX_RESOLVE_NXDOMAIN 3 | |
| 25 #define NGX_RESOLVE_NOTIMP 4 | |
| 26 #define NGX_RESOLVE_REFUSED 5 | |
| 27 #define NGX_RESOLVE_TIMEDOUT NGX_ETIMEDOUT | |
| 28 | |
| 29 | |
|
1683
1e0b028055ec
allow to use IP addresses without defined resolver
Igor Sysoev <igor@sysoev.ru>
parents:
1649
diff
changeset
|
30 #define NGX_NO_RESOLVER (void *) -1 |
|
1e0b028055ec
allow to use IP addresses without defined resolver
Igor Sysoev <igor@sysoev.ru>
parents:
1649
diff
changeset
|
31 |
| 1969 | 32 #define NGX_RESOLVER_MAX_RECURSION 50 |
| 33 | |
|
1683
1e0b028055ec
allow to use IP addresses without defined resolver
Igor Sysoev <igor@sysoev.ru>
parents:
1649
diff
changeset
|
34 |
| 1649 | 35 typedef struct { |
| 36 ngx_connection_t *connection; | |
| 37 struct sockaddr *sockaddr; | |
| 38 socklen_t socklen; | |
| 39 ngx_str_t server; | |
|
3408
71193a456616
add context to a resolver log
Igor Sysoev <igor@sysoev.ru>
parents:
3269
diff
changeset
|
40 ngx_log_t log; |
| 1649 | 41 } ngx_udp_connection_t; |
| 42 | |
| 43 | |
| 44 typedef struct ngx_resolver_ctx_s ngx_resolver_ctx_t; | |
| 45 | |
| 46 typedef void (*ngx_resolver_handler_pt)(ngx_resolver_ctx_t *ctx); | |
| 47 | |
| 48 | |
| 49 typedef struct { | |
| 50 ngx_rbtree_node_t node; | |
| 51 ngx_queue_t queue; | |
| 52 | |
| 53 /* PTR: resolved name, A: name to resolve */ | |
| 54 u_char *name; | |
| 55 | |
| 56 u_short nlen; | |
| 57 u_short qlen; | |
| 58 | |
| 59 u_char *query; | |
| 60 | |
| 61 union { | |
| 62 in_addr_t addr; | |
| 63 in_addr_t *addrs; | |
| 64 u_char *cname; | |
| 65 } u; | |
| 66 | |
| 67 u_short naddrs; | |
| 68 u_short cnlen; | |
| 69 | |
| 70 time_t expire; | |
| 71 time_t valid; | |
| 72 | |
| 73 ngx_resolver_ctx_t *waiting; | |
| 74 } ngx_resolver_node_t; | |
| 75 | |
| 76 | |
| 77 typedef struct { | |
| 78 /* has to be pointer because of "incomplete type" */ | |
| 79 ngx_event_t *event; | |
|
4225
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
80 void *dummy; |
| 1649 | 81 ngx_log_t *log; |
| 82 | |
| 83 /* ident must be after 3 pointers */ | |
| 84 ngx_int_t ident; | |
| 85 | |
|
4225
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
86 /* simple round robin DNS peers balancer */ |
|
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
87 ngx_array_t udp_connections; |
|
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
88 ngx_uint_t last_connection; |
|
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
89 |
| 1649 | 90 ngx_rbtree_t name_rbtree; |
| 91 ngx_rbtree_node_t name_sentinel; | |
| 92 | |
| 93 ngx_rbtree_t addr_rbtree; | |
| 94 ngx_rbtree_node_t addr_sentinel; | |
| 95 | |
| 96 ngx_queue_t name_resend_queue; | |
| 97 ngx_queue_t addr_resend_queue; | |
| 98 | |
| 99 ngx_queue_t name_expire_queue; | |
| 100 ngx_queue_t addr_expire_queue; | |
| 101 | |
| 102 time_t resend_timeout; | |
| 103 time_t expire; | |
| 104 time_t valid; | |
| 105 | |
| 106 ngx_uint_t log_level; | |
| 107 } ngx_resolver_t; | |
| 108 | |
| 109 | |
| 110 struct ngx_resolver_ctx_s { | |
| 111 ngx_resolver_ctx_t *next; | |
| 112 ngx_resolver_t *resolver; | |
| 113 ngx_udp_connection_t *udp_connection; | |
| 114 | |
| 115 /* ident must be after 3 pointers */ | |
| 116 ngx_int_t ident; | |
| 117 | |
| 118 ngx_int_t state; | |
| 119 ngx_int_t type; | |
| 120 ngx_str_t name; | |
| 121 | |
| 122 ngx_uint_t naddrs; | |
| 123 in_addr_t *addrs; | |
| 124 in_addr_t addr; | |
| 125 | |
| 126 ngx_resolver_handler_pt handler; | |
| 127 void *data; | |
| 128 ngx_msec_t timeout; | |
| 129 | |
| 130 ngx_uint_t quick; /* unsigned quick:1; */ | |
| 1969 | 131 ngx_uint_t recursion; |
| 1649 | 132 ngx_event_t *event; |
| 133 }; | |
| 134 | |
| 135 | |
|
4225
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
136 ngx_resolver_t *ngx_resolver_create(ngx_conf_t *cf, ngx_str_t *names, |
|
016352c19049
Support of several servers in the "resolver" directive.
Igor Sysoev <igor@sysoev.ru>
parents:
3408
diff
changeset
|
137 ngx_uint_t n); |
| 1649 | 138 ngx_resolver_ctx_t *ngx_resolve_start(ngx_resolver_t *r, |
| 139 ngx_resolver_ctx_t *temp); | |
| 140 ngx_int_t ngx_resolve_name(ngx_resolver_ctx_t *ctx); | |
| 141 void ngx_resolve_name_done(ngx_resolver_ctx_t *ctx); | |
| 142 ngx_int_t ngx_resolve_addr(ngx_resolver_ctx_t *ctx); | |
| 143 void ngx_resolve_addr_done(ngx_resolver_ctx_t *ctx); | |
| 144 char *ngx_resolver_strerror(ngx_int_t err); | |
| 145 | |
| 146 | |
| 147 #endif /* _NGX_RESOLVER_H_INCLUDED_ */ |