Mercurial > hg > nginx

comparison src/core/ngx_resolver.c @ 583:4e296b7d25bf release-0.3.13

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.3.13-RELEASE import *) Feature: the IMAP/POP3 proxy supports STARTTLS and STLS. *) Bugfix: the IMAP/POP3 proxy did not work with the select, poll, and /dev/poll methods. *) Bugfix: in SSI handling. *) Bugfix: now Solaris sendfilev() is not used to transfer the client request body to FastCGI-server via the unix domain socket. *) Bugfix: the "auth_basic" directive did not disable the authorization; the bug had appeared in 0.3.11.
author Igor Sysoev <igor@sysoev.ru>
date Mon, 05 Dec 2005 13:18:09 +0000
parents
children 80901499140d
comparison
equal deleted inserted replaced
582:6646640ac20b 583:4e296b7d25bf
1
2 /*
3 * Copyright (C) Igor Sysoev
4 */
5
6
7 #include <ngx_config.h>
8 #include <ngx_core.h>
9 #include <ngx_event.h>
10
11
12 typedef struct {
13 ngx_connection_t *connection;
14
15 struct sockaddr *sockaddr;
16 socklen_t socklen;
17
18 ngx_str_r server;
19 ngx_str_r name;
20
21 ngx_event_handler_pt handler;
22
23 ngx_log_t *pool;
24 ngx_log_t *log;
25 } ngx_resolver_t;
26
27
28 ngx_int_t
29 ngx_gethostbyname(ngx_resolver_t *r)
30 {
31 ngx_socket_t s;
32
33 if (r->connection) {
34 return NGX_OK;
35 }
36
37 s = ngx_socket(AF_INET, SOCK_DGRAM, 0);
38
39 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, r->log, 0, "socket %d", s);
40
41 if (s == -1) {
42 ngx_log_error(NGX_LOG_ALERT, r->log, ngx_socket_errno,
43 ngx_socket_n " failed");
44 return NGX_ERROR;
45 }
46
47 c = ngx_get_connection(s, r->log);
48
49 if (c == NULL) {
50 if (ngx_close_socket(s) == -1) {
51 ngx_log_error(NGX_LOG_ALERT, r->log, ngx_socket_errno,
52 ngx_close_socket_n "failed");
53 }
54
55 return NGX_ERROR;
56 }
57
58 rev = c->read;
59 wev = c->write;
60
61 rev->log = pc->log;
62 wev->log = pc->log;
63
64 r->connection = c;
65
66 /*
67 * TODO: MT: - ngx_atomic_fetch_add()
68 * or protection by critical section or mutex
69 *
70 * TODO: MP: - allocated in a shared memory
71 * - ngx_atomic_fetch_add()
72 * or protection by critical section or mutex
73 */
74
75 c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);
76
77 #if (NGX_THREADS)
78 rev->lock = pc->lock;
79 wev->lock = pc->lock;
80 rev->own_lock = &c->lock;
81 wev->own_lock = &c->lock;
82 #endif
83
84 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0,
85 "connect to %V, fd:%d #%d", &r->server, s, c->number);
86
87 rc = connect(s, r->sockaddr, r->socklen);
88
89 if (rc == -1) {
90 ngx_log_error(level, r->log, ngx_socket_errno,
91 "connect() to %V failed", &r->server);
92
93 return NGX_ERROR;
94 }
95
96
97
98
99
100
101
102 if (ngx_add_conn) {
103 if (ngx_add_conn(c) == NGX_ERROR) {
104 return NGX_ERROR;
105 }
106 }
107
108
109 if (ngx_add_conn) {
110 if (rc == -1) {
111
112 /* NGX_EINPROGRESS */
113
114 return NGX_AGAIN;
115 }
116
117 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
118
119 wev->ready = 1;
120
121 return NGX_OK;
122 }
123
124 if (ngx_event_flags & NGX_USE_AIO_EVENT) {
125
126 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, ngx_socket_errno,
127 "connect(): %d", rc);
128
129 /* aio, iocp */
130
131 if (ngx_blocking(s) == -1) {
132 ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
133 ngx_blocking_n " failed");
134 return NGX_ERROR;
135 }
136
137 /*
138 * FreeBSD's aio allows to post an operation on non-connected socket.
139 * NT does not support it.
140 *
141 * TODO: check in Win32, etc. As workaround we can use NGX_ONESHOT_EVENT
142 */
143
144 rev->ready = 1;
145 wev->ready = 1;
146
147 return NGX_OK;
148 }
149
150 if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {
151
152 /* kqueue */
153
154 event = NGX_CLEAR_EVENT;
155
156 } else {
157
158 /* select, poll, /dev/poll */
159
160 event = NGX_LEVEL_EVENT;
161 }
162
163 if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
164 return NGX_ERROR;
165 }
166
167 if (rc == -1) {
168
169 /* NGX_EINPROGRESS */
170
171 if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
172 return NGX_ERROR;
173 }
174
175 return NGX_AGAIN;
176 }
177
178 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");
179
180 wev->ready = 1;
181
182 return NGX_OK;
183 }