r781 - trunk/varnish-cache/bin/varnishncsa

[andersb at projects.linpro.no]

Author: andersb
Date: 2006-08-10 09:38:47 +0200 (Thu, 10 Aug 2006)
New Revision: 781

Modified:
   trunk/varnish-cache/bin/varnishncsa/varnishncsa.c
Log:
Added some more meat to the program. Loads of debug code still on.

Next step is to add the correct time. It's a bit tricky, and I haven't gotten it right just yet.



Modified: trunk/varnish-cache/bin/varnishncsa/varnishncsa.c
===================================================================
--- trunk/varnish-cache/bin/varnishncsa/varnishncsa.c	2006-08-09 14:49:49 UTC (rev 780)
+++ trunk/varnish-cache/bin/varnishncsa/varnishncsa.c	2006-08-10 07:38:47 UTC (rev 781)
@@ -37,8 +37,11 @@
 
 struct logline {
 	char df_h[4 * (3 + 1)]; // Datafield for %h (IP adress)
+	int df_hfini;	// Set to 1 when a SessionClose is seen.
 	unsigned char *df_r; // Datafield for %r (Request)
-
+	int df_rfini;	// Set to 1 when a ReqServTime has come.
+	unsigned char *df_s; // Datafield for %s, Status
+	unsigned char *df_b; // Datafield for %b, Bytes
 };
 
 /* We make a array of pointers to vsb's. Sbuf is a string buffer.
@@ -88,6 +91,8 @@
 	
 	v = 0;
 	w = 0;
+	ll[u].df_rfini = 0;
+	ll[u].df_hfini = 0;
 
 	switch (p[0]) {
 
@@ -101,53 +106,105 @@
                 j = strlen(p + 4) - strlen(tmpPtr);                // length of IP
                 strncpy(ll[u].df_h, p + 4, j);
                 ll[u].df_h[j] = '\0'; // put on a NULL at end of buffer.
-                //printf("New session [%d]: %s \n",u, ll[u].df_h);
+                printf("New session [%d]: %s \n",u, ll[u].df_h);
 
 		break;
 
-	case SLT_RxRequest:
+	case SLT_XID:
 
+		// We use XID to catch that a new request is comming inn.
+
 		break;
 
+	case SLT_RxRequest:
+
+		sbuf_clear(ob[u]);
+
+		if (p[1] >= 4 && !strncasecmp((void *)&p[4], "HEAD",4)){
+			sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+			//printf("Got a HEAD\n");
+		}
+	
+		else if (p[1] >= 4 && !strncasecmp((void *)&p[4], "POST",4)){
+			sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+			//printf("Got a POST\n");
+		}
+		
+		else if (p[1] >= 3 && !strncasecmp((void *)&p[4], "GET",3)){
+			sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+			//printf("Got a GET\n");
+		}
+		
+		else {
+			sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+			//printf("Got something other than HEAD, POST, GET\n");
+		}
+		
+	break;
+
 	case SLT_RxURL:
-		
+
+		sbuf_cat(ob[u], " ");
+		sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+
 		break;
 
 	case SLT_RxProtocol:
 		
+		sbuf_cat(ob[u], " ");
+                sbuf_bcat(ob[u], p + 4, strlen(p + 4));
+
 		break;
 
+	case SLT_TxStatus:
+		
+		ll[u].df_s = strdup(p + 4);
+
+		break;
+	
 	case SLT_RxHeader:
 			
 		break;
+	
 
 	case SLT_ReqEnd:
 
+		// We use ReqServTime to find how the time the request was delivered
+		// also to define that a request is finished.
+		
+		ll[u].df_rfini = 1;
+		printf("ReqServTime [%d]\n", u);
+
 		break;
 
-	case SLT_TxStatus:
-
-		break;
-	
 	case SLT_Length:
 
+		// XXX ask DES or PHK about this one. Am I overflowing?
+
+		ll[u].df_b = strdup(p + 4);
+                if (!atoi(ll[u].df_b)){
+	                ll[u].df_b[0] = '-';
+        	        ll[u].df_b[1] = '\0';
+                }
+
+
 		break;
 
 	case SLT_SessionClose:
 
 		// Session is closed, we clean up things. But do not write.
 
-		//printf("Session close [%d]\n", u);
+		printf("Session close [%d]\n", u);
 		
-		v = 1;
+		ll[u].df_hfini = 1;
 
-
 		break;
 
 	case SLT_SessionReuse:
 
-		// It's in SessionReuse we wrap things up.
-		// SessionClose is not suited to use for a write, but to clean up.
+		// We use SessionReuse to catch the IP adress of a session that has already
+		// started with a SessionOpen that we did not catch.
+		// Other than that it is not used.
 
 		// Catch IP if not already done.
 		
@@ -161,10 +218,8 @@
 			printf("Got IP from Reuse [%d] : %s\n", u, ll[u].df_h);
 		}
 
-		//printf("Session reuse [%d]\n", u);
+		printf("Session reuse [%d]\n", u);
 
-		w = 1;
-
 		break;
 
 	default:
@@ -172,20 +227,44 @@
 		break;
 	}
 
-	if (v) {
-		// We have a SessionClose. Lets clean.
-		//
-		// Clean IP adress
-		ll[u].df_h[0] = '\0';
-										
-	}
 
-	if (w) {
-		// We have a SessionReuse. Lets print the logline
-		//
+	if (ll[u].df_rfini) {
+		// We have a ReqServTime. Lets print the logline
+		// and clear variables that are different for each request.
 		
-		printf("%s ", ll[u].df_h);
+		printf("[%d] %s ", u, ll[u].df_h );
+		sbuf_finish(ob[u]);
+		printf("\"%s\"", sbuf_data(ob[u]));
+		printf(" %s %s ", ll[u].df_s, ll[u].df_b);
 		printf("\n");
+                sbuf_clear(ob[u]);
+
+		ll[u].df_rfini = 0;
+
+		// Clear the TxStaus
+
+		if (ll[u].df_s != NULL){
+			free(ll[u].df_s);
+			printf("Freed df_s\n");
+		}
+
+		if (ll[u].df_b != NULL){
+			free(ll[u].df_b);
+			printf("Freed df_b\n");
+		}
+
+		if (ll[u].df_hfini) {
+			// We have a SessionClose. Lets clean data.
+			//
+			// Clean IP adress
+			ll[u].df_h[0] = '\0';
+			printf("Clearer [%d]\n", u);
+										
+		}
+
+
+
+
 	}