IntenseWebs/nginx
3
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-12-20 06:03:31 -06:00
Code Issues Packages Projects Releases Wiki Activity

nginx-0.0.1-2003-03-25-18:40:51 import

Browse Source
This commit is contained in:
Igor Sysoev 2003-03-25 15:40:51 +00:00
parent dc479b4d98
commit 3f76ec190a
1 changed files with 75 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
src/http/modules/ngx_http_event_proxy_handler.c
View File

@ -1157,6 +1157,7 @@ static char *ngx_http_proxy_set_pass(ngx_conf_t *cf, ngx_command_t *cmd,
{ {
ngx_http_proxy_conf_t *lcf = (ngx_http_proxy_conf_t *) conf; ngx_http_proxy_conf_t *lcf = (ngx_http_proxy_conf_t *) conf;
char *url; char *url;
struct hostent *h;
ngx_str_t *value; ngx_str_t *value;
ngx_http_proxy_pass_t *pass; ngx_http_proxy_pass_t *pass;
@ -1166,16 +1167,87 @@ static char *ngx_http_proxy_set_pass(ngx_conf_t *cf, ngx_command_t *cmd,
ngx_test_null(pass, ngx_push_array(lcf->proxy_pass), NGX_CONF_ERROR); ngx_test_null(pass, ngx_push_array(lcf->proxy_pass), NGX_CONF_ERROR);
if (ngx_strncasecmp(url, "http://", 7) == 0) { if (ngx_strncasecmp(url, "http://", 7) == 0) {
"invalid prefix in URL %s", url; /* STUB: "invalid prefix in URL %s", url */
return "invalid prefix";
} }
err = ngx_http_proxy_parse_upstream(url, u); err = ngx_http_proxy_parse_upstream(url, u);
if (err) { if (err) {
"%s %s", err, url; /* STUB: "%s %s", err, url */
return err;
} }
h = ngx_gethostbyname(cmd->pool, u->host); if (u.port == 0) {
u.port = 80;
}
ngx_test_null(host, ngx_palloc(cf->pool, u.host.len + 1), NGX_CONF_ERROR);
ngx_cpystr(host, u.host.data, u.host.len + 1);
addr.sin_addr.s_addr = inet_addr(host);
if (addr.sin_addr.s_addr == INADDR_NONE) {
h = gethostbyname(host);
if (h == NULL || h->h_addr_list[0] == NULL) {
/* STUB: "host %s not found", host */
return "host not found";
}
for (i = 0; h->h_addr_list[i] != NULL; i++) {
/* void */
}
/* MP: ngx_shared_palloc() */
ngx_test_null(upstreams,
ngx_palloc(cf->pool,
sizeof(ngx_http_proxy_upstreams_t)
+ sizeof(ngx_http_proxy_upstream_t) * (i - 1)),
NGX_CONF_ERROR);
upstreams->num = i;
for (i = 0; h->h_addr_list[i] != NULL; i++) {
upstreams->u[i].host.data = host;
upstreams->u[i].host.len = u.host.len;
upstreams->u[i].addr = *(struct in_addr *)(h->h_addr_list[i]);
upstreams->u[i].port = u.port;
len = INET_ADDRSTRLEN + u.port_name.len + 1;
ngx_test_null(upstreams->u[i].addr_port_name.data,
ngx_palloc(cf->pool, len),
NGX_CONF_ERROR);
s = (ngx_inet_ntop(AF_INET,
upstreams->u[i].addr,
upstreams->u[i].addr_port_name.data,
len),
upstreams->u[i].addr_port_name.data[s++] = ':';
ngx_cpystrn(upstreams->u[i].addr_port_name.data[s],
u.port_name.data,
u.port_name.len + 1);
upstreams->u[i].addr_port_name.len = s + u.port_name.len + 1;
}
} else {
/* MP: ngx_shared_palloc() */
ngx_test_null(upstreams,
ngx_palloc(cf->pool, sizeof(ngx_http_proxy_upstreams_t),
NGX_CONF_ERROR);
upstreams->num = 1;
upstreams->u[0].host.data = host;
upstreams->u[0].host.len = u.host.len;
upstreams->u[0].addr = *(struct in_addr *)(h->h_addr_list[i]);
upstreams->u[0].port = u.port;
}
return NULL; return NULL;
} }