logparse.cc

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "logparse.h"

// Read next line into file
int lf_get_next_entry(FILE *fp, lf_entry &ne)
{
        char buf[MAXBUF]; // must be large enough for a cache log

        if ((fgets(buf, MAXBUF, fp) == NULL) || feof(fp) || ferror(fp)) {
                return 1;
        }

        // Parse a line and fill an lf_entry
        char *p = buf, *q, *tmp1, *tmp2, *ret_code;
        u_int32_t lapse;

        // first two entries: <TimeStamp> and <Elapsed Time>
        q = strtok(p, " ");
        ne.rt = strtod(q, NULL);
        q = strtok(NULL, " ");
        lapse = strtoul(q, NULL, 10);
        ne.rt -= (double)lapse/1000.0;

        // Client address
        q = strtok(NULL, " ");
        ne.cid = (u_int32_t)inet_addr(q);

        // Log tags, do not store them but use it to filter entries
        ret_code = strtok(NULL, " ");
        if (ret_code == NULL) { abort(); } 
        // XXX Have to handle this return code in the end because we are using
        // strtok() and it cannot interleave two strings :( STUPID!!

        // Page size
        q = strtok(NULL, " "); 
        ne.size = strtoul(q, NULL, 10);

        // Request method, GET only
        q = strtok(NULL, " ");
        if (strcmp(q, "GET") != 0) 
                return -1;

        // URL
        q = strtok(NULL, " ");
        if (q == NULL) abort(); 
        if (strchr(q, '?') != NULL) 
                // Do not accept any URL containing '?'
                return -1;
        ne.url = new char[strlen(q) + 1];
        strcpy(ne.url, q);
        // Try to locate server name from the URL
        // XXX no more parsing from the original string!!!!
        tmp1 = strtok(q, "/");
        if (strcmp(tmp1, "http:") != 0) {
                // How come this isn't a http request???
                delete []ne.url;
                return -1;
        }
        tmp1 = strtok(NULL, "/"); 
        if (tmp1 == NULL) abort();
        ne.sid = new char[strlen(tmp1) + 1];
        strcpy(ne.sid, tmp1);

        // Now check return codes
        if (ret_code == NULL) abort();
        tmp1 = new char[strlen(ret_code)+1];
        strcpy(tmp1, ret_code);
        tmp2 = strtok(tmp1, "/");
        tmp2 += 4; // Ignore the first 4 char "TCP_"
        if ((strcmp(tmp2, "MISS") == 0) || 
            (strcmp(tmp2, "CLIENT_REFRESH_MISS") == 0) || 
            (strcmp(tmp2, "IMS_MISS") == 0) || 
            (strcmp(tmp2, "DENIED") == 0)) {
                delete []ne.url;
                delete []ne.sid;
                delete []tmp1;
                return -1;      // Return negative to discard this entry
        }
        delete []tmp1;

        // All the rest are useless, do not parse them
        return 0;
}

---