Mercurial > hg > nginx
annotate src/core/ngx_resolver.h @ 4225:016352c19049
Support of several servers in the "resolver" directive.
Patch by Kirill A. Korinskiy.
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Mon, 24 Oct 2011 16:09:05 +0000 |
| parents | 71193a456616 |
| 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_ */ |