summaryrefslogtreecommitdiff
path: root/src/mod_extforward.c
diff options
context:
space:
mode:
authorJan Kneschke <jan@kneschke.de>2007-04-10 08:47:30 +0000
committerJan Kneschke <jan@kneschke.de>2007-04-10 08:47:30 +0000
commit7f5aabdaafdfd022b883f07a4cb221760b9602a4 (patch)
treec43f2851dc75a7a4c970bd8e381938000a5cb545 /src/mod_extforward.c
parentaa37da474577a9db545ee8544093e16979a747ee (diff)
downloadlighttpd-git-7f5aabdaafdfd022b883f07a4cb221760b9602a4.tar.gz
* fixed possible crash in debug-message in mod_extforward
* fixed compilation of mod_extforward on glibc < 2.3.4 git-svn-id: svn://svn.lighttpd.net/lighttpd/branches/lighttpd-1.4.x@1736 152afb58-edef-0310-8abb-c4023f1b3aa9
Diffstat (limited to 'src/mod_extforward.c')
-rw-r--r--src/mod_extforward.c197
1 files changed, 105 insertions, 92 deletions
diff --git a/src/mod_extforward.c b/src/mod_extforward.c
index df1341e3..c7d722f0 100644
--- a/src/mod_extforward.c
+++ b/src/mod_extforward.c
@@ -282,7 +282,18 @@ struct addrinfo *ipstr_to_sockaddr(const char *host)
{
struct addrinfo hints, *res0;
int result;
+
memset(&hints, 0, sizeof(hints));
+#ifndef AI_NUMERICSERV
+/**
+ * quoting $ man getaddrinfo
+ *
+ * NOTES
+ * AI_ADDRCONFIG, AI_ALL, and AI_V4MAPPED are available since glibc 2.3.3.
+ * AI_NUMERICSERV is available since glibc 2.3.4.
+ */
+#define AI_NUMERICSERV 0
+#endif
hints.ai_flags = AI_NUMERICHOST | AI_NUMERICSERV;
result = getaddrinfo(host, NULL, &hints, &res0);
@@ -321,122 +332,124 @@ URIHANDLER_FUNC(mod_extforward_uri_handler) {
data_string *forwarded = NULL;
#ifdef HAVE_IPV6
char b2[INET6_ADDRSTRLEN + 1];
+ struct addrinfo *addrlist = NULL;
#endif
- const char *s;
- UNUSED(srv);
+ const char *dst_addr_str = NULL;
+ int i;
+ array *forward_array = NULL;
+ char *real_remote_addr = NULL;
+#ifdef HAVE_IPV6
+#endif
+
+ if (!con->request.headers) return HANDLER_GO_ON;
+
mod_extforward_patch_connection(srv, con, p);
-/* log_error_write(srv, __FILE__, __LINE__,"s","mod_extforward_uri_handler called\n"); */
+ if (con->conf.log_request_handling) {
+ log_error_write(srv, __FILE__, __LINE__, "s",
+ "-- mod_extforward_uri_handler called");
+ }
+
+ if ((NULL == (forwarded = (data_string *) array_get_element(con->request.headers,"X-Forwarded-For")) &&
+ NULL == (forwarded = (data_string *) array_get_element(con->request.headers, "Forwarded-For")))) {
+
+ if (con->conf.log_request_handling) {
+ log_error_write(srv, __FILE__, __LINE__, "s",
+ "no X-Forwarded-For|Forwarded-For: found, skipping");
+ }
+
+ return HANDLER_GO_ON;
+ }
/* if the remote ip itself is not trusted , then do nothing */
#ifdef HAVE_IPV6
- s = inet_ntop(con->dst_addr.plain.sa_family,
+ dst_addr_str = inet_ntop(con->dst_addr.plain.sa_family,
con->dst_addr.plain.sa_family == AF_INET6 ?
- &(con->dst_addr.ipv6.sin6_addr) :
- &(con->dst_addr.ipv4.sin_addr),
+ (struct sockaddr *)&(con->dst_addr.ipv6.sin6_addr) :
+ (struct sockaddr *)&(con->dst_addr.ipv4.sin_addr),
b2,
(sizeof b2) - 1);
#else
- s = inet_ntoa(con->dst_addr.ipv4.sin_addr);
+ dst_addr_str = inet_ntoa(con->dst_addr.ipv4.sin_addr);
#endif
- if (IP_UNTRUSTED == is_proxy_trusted (s, p) )
+ if (IP_UNTRUSTED == is_proxy_trusted (dst_addr_str, p) ) {
+ if (con->conf.log_request_handling) {
+ log_error_write(srv, __FILE__, __LINE__, "s",
+ "remote address is NOT a trusted proxy, skipping");
+ }
+
return HANDLER_GO_ON;
+ }
+
+ forward_array = extract_forward_array(forwarded->value);
+
+ /* Testing shows that multiple headers and multiple values in one header
+ come in _reverse_ order. So the first one we get is the last one in the request. */
+ for (i = forward_array->used - 1; i >= 0; i--) {
+ data_string *ds = (data_string *) forward_array->data[i];
+ if (ds) {
+ real_remote_addr = ds->value->ptr;
+ break;
+ } else {
+ /* bug ? bailing out here */
+ break;
+ }
+ }
+
+ if (real_remote_addr != NULL) { /* parsed */
+ sock_addr sock;
- /* log_error_write(srv, __FILE__, __LINE__,"s","remote address is trusted proxy, go on\n");*/
- if (con->request.headers &&
- ((forwarded = (data_string *) array_get_element(con->request.headers,"X-Forwarded-For")) ||
- (forwarded = (data_string *) array_get_element(con->request.headers, "Forwarded-For"))))
- {
- /* log_error_write(srv, __FILE__, __LINE__,"s","found forwarded header\n");*/
- /* found forwarded for header */
- int i;
- array *forward_array = extract_forward_array(forwarded->value);
- char *real_remote_addr = NULL;
+ struct addrinfo *addrs_left;
+
+ if (con->conf.log_request_handling) {
+ log_error_write(srv, __FILE__, __LINE__, "ss",
+ "using address:", real_remote_addr);
+ }
#ifdef HAVE_IPV6
- struct addrinfo *addrlist = NULL;
-#endif
- /* Testing shows that multiple headers and multiple values in one header
- come in _reverse_ order. So the first one we get is the last one in the request. */
- for (i = forward_array->used - 1; i >= 0; i--)
- {
- data_string *ds = (data_string *) forward_array->data[i];
- if (ds) {
-/* log_error_write(srv, __FILE__, __LINE__,"ss","forward",ds->value->ptr); */
- real_remote_addr = ds->value->ptr;
+ addrlist = ipstr_to_sockaddr(real_remote_addr);
+ sock.plain.sa_family = AF_UNSPEC;
+ for (addrs_left = addrlist; addrs_left != NULL;
+ addrs_left = addrs_left -> ai_next) {
+ sock.plain.sa_family = addrs_left->ai_family;
+ if ( sock.plain.sa_family == AF_INET ) {
+ sock.ipv4.sin_addr = ((struct sockaddr_in*)addrs_left->ai_addr)->sin_addr;
break;
- /* LEM: What the hell is this about?
- We test whether the forwarded for IP is trusted?
- This looks like an ugly hack to handle multiple Forwarded-For's
- and avoid those set to our proxies, or something like that.
- My testing shows that reverse proxies add a new X-Forwarded-For header,
- and we should thus take the last one, which is the first one we see.
-
- The net result of the old code is that we use the first untrusted IP,
- or if all are trusted, the last trusted IP.
- That's crazy. So I've disabled this.
- */
- /* check whether it is trusted */
-/* if (IP_UNTRUSTED == is_proxy_trusted(ds->value->ptr,p) ) */
-/* break; */
-/* log_error_write(srv, __FILE__, __LINE__,"ss",ds->value->ptr," is trusted."); */
-
- }
- else {
- /* bug ? bailing out here */
+ } else if ( sock.plain.sa_family == AF_INET6 ) {
+ sock.ipv6.sin6_addr = ((struct sockaddr_in6*)addrs_left->ai_addr)->sin6_addr;
break;
}
}
- if (real_remote_addr != NULL) /* parsed */
- {
- sock_addr s;
- struct addrinfo *addrs_left;
-/* log_error_write(srv, __FILE__, __LINE__,"ss","use forward",real_remote_addr); */
-#ifdef HAVE_IPV6
- addrlist = ipstr_to_sockaddr(real_remote_addr);
- s.plain.sa_family = AF_UNSPEC;
- for (addrs_left = addrlist; addrs_left != NULL;
- addrs_left = addrs_left -> ai_next)
- {
- s.plain.sa_family = addrs_left->ai_family;
- if ( s.plain.sa_family == AF_INET )
- {
- s.ipv4.sin_addr = ((struct sockaddr_in*)addrs_left->ai_addr)->sin_addr;
- break;
- }
- else if ( s.plain.sa_family == AF_INET6 )
- {
- s.ipv6.sin6_addr = ((struct sockaddr_in6*)addrs_left->ai_addr)->sin6_addr;
- break;
- }
- }
#else
- s.ipv4.sin_addr.s_addr = inet_addr(real_remote_addr);
- s.plain.sa_family = (s.ipv4.sin_addr.s_addr == 0xFFFFFFFF) ? AF_UNSPEC : AF_INET;
+ sock.ipv4.sin_addr.s_addr = inet_addr(real_remote_addr);
+ sock.plain.sa_family = (s.ipv4.sin_addr.s_addr == 0xFFFFFFFF) ? AF_UNSPEC : AF_INET;
#endif
- if (s.plain.sa_family != AF_UNSPEC)
- {
- /* we found the remote address, modify current connection and save the old address */
- if (con->plugin_ctx[p->id]) {
- log_error_write(srv, __FILE__, __LINE__,"patching an already patched connection!");
- handler_ctx_free(con->plugin_ctx[p->id]);
- con->plugin_ctx[p->id] = NULL;
- }
- /* save old address */
- con->plugin_ctx[p->id] = handler_ctx_init(con->dst_addr, con->dst_addr_buf);
- /* patch connection address */
- con->dst_addr = s;
- con->dst_addr_buf = buffer_init();
- buffer_copy_string(con->dst_addr_buf, real_remote_addr);
-/* log_error_write(srv, __FILE__, __LINE__,"ss","Set dst_addr_buf to ", real_remote_addr); */
- /* Now, clean the conf_cond cache, because we may have changed the results of tests */
- clean_cond_cache(srv, con);
+ if (sock.plain.sa_family != AF_UNSPEC) {
+ /* we found the remote address, modify current connection and save the old address */
+ if (con->plugin_ctx[p->id]) {
+ log_error_write(srv, __FILE__, __LINE__, "s",
+ "patching an already patched connection!");
+ handler_ctx_free(con->plugin_ctx[p->id]);
+ con->plugin_ctx[p->id] = NULL;
+ }
+ /* save old address */
+ con->plugin_ctx[p->id] = handler_ctx_init(con->dst_addr, con->dst_addr_buf);
+ /* patch connection address */
+ con->dst_addr = sock;
+ con->dst_addr_buf = buffer_init();
+ buffer_copy_string(con->dst_addr_buf, real_remote_addr);
+
+ if (con->conf.log_request_handling) {
+ log_error_write(srv, __FILE__, __LINE__, "ss",
+ "patching con->dst_addr_buf for the accesslog:", real_remote_addr);
}
+ /* Now, clean the conf_cond cache, because we may have changed the results of tests */
+ clean_cond_cache(srv, con);
+ }
#ifdef HAVE_IPV6
- if (addrlist != NULL ) freeaddrinfo(addrlist);
+ if (addrlist != NULL ) freeaddrinfo(addrlist);
#endif
- }
- array_free(forward_array);
}
+ array_free(forward_array);
/* not found */
return HANDLER_GO_ON;