summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/reqs.c53
1 files changed, 44 insertions, 9 deletions
diff --git a/src/reqs.c b/src/reqs.c
index 23b7e7a..0f6935a 100644
--- a/src/reqs.c
+++ b/src/reqs.c
@@ -1,4 +1,4 @@
-/* $Id: reqs.c,v 1.37 2001-11-05 15:23:34 rjkaes Exp $
+/* $Id: reqs.c,v 1.38 2001-11-21 00:59:33 rjkaes Exp $
*
* This is where all the work in tinyproxy is actually done. Incoming
* connections have a new thread created for them. The thread then
@@ -214,13 +214,6 @@ static int establish_http_connection(struct conn_s *connptr,
if (safe_write(connptr->server_fd, "\r\n", 2) < 0)
return -1;
- /*
- * Send the Connection header since we don't support persistant
- * connections.
- */
- if (safe_write(connptr->server_fd, "Connection: close\r\n", 19) < 0)
- return -1;
-
return 0;
}
@@ -368,6 +361,14 @@ static struct request_s *process_request(struct conn_s *connptr,
return NULL;
}
+ /*
+ * Break apart the protocol and update the connection structure.
+ */
+ if (strncasecmp(request->protocol, "http", 4) == 0) {
+ memcpy(request->protocol, "HTTP", 4);
+ sscanf(request->protocol, "HTTP/%hu.%hu", &connptr->protocol.major, &connptr->protocol.minor);
+ }
+
return request;
}
@@ -466,10 +467,13 @@ static int process_client_headers(struct conn_s *connptr)
{
char *header;
long content_length = -1;
+ short int sent_via_header = 0;
static char *skipheaders[] = {
"proxy-connection",
- "host",
+ "keep-alive",
+ "proxy-authenticate",
+ "proxy-authorization",
"connection"
};
int i;
@@ -500,6 +504,24 @@ static int process_client_headers(struct conn_s *connptr)
continue;
/*
+ * If we find a Via header we need to append our information
+ * to the end of it.
+ */
+ if (strncasecmp(header, "via", 3) == 0) {
+ char hostname[128];
+ char via_header_buffer[256];
+
+ sent_via_header = 1;
+
+ gethostname(hostname, sizeof(hostname));
+ snprintf(via_header_buffer, sizeof(via_header_buffer), ", %hu.%hu %s (%s/%s)\r\n", connptr->protocol.major, connptr->protocol.minor, hostname, PACKAGE, VERSION);
+
+ trim(header, strlen(header));
+
+ strlcat(header, via_header_buffer, LINE_LENGTH);
+ }
+
+ /*
* Don't send certain headers.
*/
for (i = 0; i < (sizeof(skipheaders) / sizeof(char *)); i++) {
@@ -525,6 +547,19 @@ static int process_client_headers(struct conn_s *connptr)
}
}
+ if (sent_via_header == 0) {
+ /*
+ * We're the first proxy so send the first Via header.
+ */
+ char via_header_buffer[256];
+ char hostname[128];
+
+ gethostname(hostname, sizeof(hostname));
+ snprintf(via_header_buffer, sizeof(via_header_buffer), "Via: %hu.%hu %s (%s/%s)\r\n", connptr->protocol.major, connptr->protocol.minor, hostname, PACKAGE, VERSION);
+
+ safe_write(connptr->server_fd, via_header_buffer, strlen(via_header_buffer));
+ }
+
if (!connptr->send_message && (connptr->upstream || !connptr->ssl)) {
#ifdef XTINYPROXY_ENABLE
if (config.my_domain