made a first cruel handling for keep-alive and non keep-alive requests. @TODO: this MUST BE cleaned

+2012-02-10 09:52:27 +0100 Georg Hopp 
+
+	* made a first cruel handling for keep-alive and non keep-alive requests. @TODO: this MUST BE cleaned (HEAD, master)
+
+2012-02-10 08:14:31 +0100 Georg Hopp 
+
+	* now only use keep-alive.... (origin/master, origin/HEAD)
+
 2012-02-10 06:36:43 +0100 Georg Hopp 
 2012-02-10 06:36:43 +0100 Georg Hopp 
 
 
-	* moved request_parser.h and request_queue.h in separeate request subfolder (HEAD, master)
+	* moved request_parser.h and request_queue.h in separeate request subfolder
 
 
 2012-02-10 06:22:39 +0100 Georg Hopp 
 2012-02-10 06:22:39 +0100 Georg Hopp 
 
 
@@ -20,7 +28,7 @@
 
 
 2012-02-09 22:34:32 +0100 Georg Hopp 
 2012-02-09 22:34:32 +0100 Georg Hopp 
 
 
-	* start split of request parser (origin/master, origin/HEAD)
+	* start split of request parser
 
 
 2012-02-09 11:44:17 +0100 Georg Hopp 
 2012-02-09 11:44:17 +0100 Georg Hopp 
 
 

@@ -42,6 +42,7 @@ CLASS(Server) {
 		Sock         sock;
 		Sock         sock;
 		void *       reader;
 		void *       reader;
 
 
+		char         keep_alive;
 		char         wbuf[2048];
 		char         wbuf[2048];
 		char *       rbuf;
 		char *       rbuf;
 		unsigned int rpos;
 		unsigned int rpos;

+#include <stdlib.h>
 #include <string.h>
 #include <string.h>
 
 
 #include "http/request.h"
 #include "http/request.h"

@@ -3,6 +3,7 @@
 #include <stdlib.h>     /* for exit */
 #include <stdlib.h>     /* for exit */
 #include <errno.h>      /* for errno */
 #include <errno.h>      /* for errno */
 #include <unistd.h>
 #include <unistd.h>
+#include <ctype.h>
 #include <time.h>
 #include <time.h>
 
 
 #include "server.h"
 #include "server.h"
@@ -17,6 +18,7 @@
 #include "http/request.h"
 #include "http/request.h"
 #include "http/request/parser.h"
 #include "http/request/parser.h"
 #include "http/request/queue.h"
 #include "http/request/queue.h"
+#include "http/header.h"
 //* until here
 //* until here
 
 
 #undef  MAX
 #undef  MAX
@@ -79,16 +81,35 @@ serverRun(Server this)
 
 
 						for (j=0; j<queue->nrequests; j++) {
 						for (j=0; j<queue->nrequests; j++) {
 							HttpRequest request = queue->requests[j];
 							HttpRequest request = queue->requests[j];
+							char *  header;
+							char *  header_ptr;
 
 
 							//if (NULL != request->body) {
 							//if (NULL != request->body) {
 							//	puts("==REQUEST BODY==");
 							//	puts("==REQUEST BODY==");
 							//	puts(request->body);
 							//	puts(request->body);
 							//}
 							//}
 
 
+							header = httpHeaderGet(
+									request->header,
+									request->nheader,
+									"connection");
+
+							if (NULL != header) {
+								for (header_ptr = header;
+										0 != *header_ptr;
+										header_ptr++) {
+									*header_ptr = tolower(*header_ptr);
+								}
+
+								if (0 == strcmp(header, "keep-alive")) {
+									(this->conns)[fd].keep_alive = 1;
+								}
+							}
 							/**
 							/**
 							 * @TODO: for now simply remove request and send not found.
 							 * @TODO: for now simply remove request and send not found.
 							 * Make this sane.
 							 * Make this sane.
 							 */
 							 */
+
 							delete(&request);
 							delete(&request);
 
 
 							/**
 							/**
@@ -99,7 +120,6 @@ serverRun(Server this)
 							char timestr[200];
 							char timestr[200];
 
 
 #define RESP_HEAD "HTTP/1.1 404 Not Found\r\n" \
 #define RESP_HEAD "HTTP/1.1 404 Not Found\r\n" \
-							"Connection: Keep-Alive\r\n" \
 							"Content-Type: text/html\r\n" \
 							"Content-Type: text/html\r\n" \
 							"Content-Length: %lu\r\n" \
 							"Content-Length: %lu\r\n" \
 							"Date: %s\r\n" \
 							"Date: %s\r\n" \
@@ -121,7 +141,12 @@ serverRun(Server this)
 							 * @TODO: just to send an answer and be able to make some
 							 * @TODO: just to send an answer and be able to make some
 							 * apache benchs i do it here...this definetly MUST BE moved
 							 * apache benchs i do it here...this definetly MUST BE moved
 							 */
 							 */
-							sprintf((this->conns)[fd].wbuf, RESP_HEAD "\r\n" RESP_DATA, sizeof(RESP_DATA) - 1, timestr);
+							if ((this->conns)[fd].keep_alive) {
+								sprintf((this->conns)[fd].wbuf, RESP_HEAD "Connection: Keep-Alive\r\n\r\n" RESP_DATA, sizeof(RESP_DATA) - 1, timestr);
+							}
+							else {
+								sprintf((this->conns)[fd].wbuf, RESP_HEAD "Connection: close\r\n\r\n" RESP_DATA, sizeof(RESP_DATA) - 1, timestr);
+							}
 							(this->fds)[i].events |= POLLOUT;
 							(this->fds)[i].events |= POLLOUT;
 						}
 						}
 
 
@@ -148,8 +173,12 @@ serverRun(Server this)
 								"write error, closing connection");
 								"write error, closing connection");
 					}
 					}
 
 
-					//serverCloseConn(this, i);
-					(this->fds)[i].events &= ~POLLOUT;
+					if ((this->conns)[fd].keep_alive) {
+						(this->fds)[i].events &= ~POLLOUT;
+					}
+					else {
+						serverCloseConn(this, i);
+					}
 				}
 				}
 				else {
 				else {
 					memmove((this->conns)[fd].wbuf,
 					memmove((this->conns)[fd].wbuf,