Initial revision

1 files changed, 47 insertions, 165 deletions

diff --git a/mod_log_sql.c b/mod_log_sql.c
index d2c4d1d..82d0483 100644
--- a/mod_log_sql.c
+++ b/mod_log_sql.c
@@ -16,17 +16,7 @@
 /* ---------*
  * INCLUDES *
  * ---------*/
-#include "config.h"
-#if TIME_WITH_SYS_TIME
- #include <sys/time.h>
- #include <time.h>
-#else
- #if TM_IN_SYS_TIME
-  #include <sys/time.h>
- #else
-  #include <time.h>
- #endif
-#endif
+#include <time.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
@@ -62,7 +52,6 @@ MYSQL logsql_server, *logsql_server_p = NULL;
 int logsql_massvirtual = 0;
 int logsql_createtables = 0;
 int logsql_forcepreserve = 0;
-char *logsql_tabletype = NULL;
 char *logsql_dbname = NULL;
 char *logsql_dbhost = NULL;
 char *logsql_dbuser = NULL;
@@ -300,7 +289,7 @@ static const char *extract_request_duration(request_rec *r, char *a)
 {
         char duration[22];                       /* Long enough for 2^64 */
 
-        ap_snprintf(duration, sizeof(duration), "%ld", (long) time(NULL) - r->request_time);
+        ap_snprintf(duration, sizeof(duration), "%ld", time(NULL) - r->request_time);
         return pstrdup(r->pool, duration);
 }
 
@@ -505,7 +494,7 @@ static const char *extract_request_timestamp(request_rec *r, char *a)
 {
         char tstr[32];
 
-        ap_snprintf(tstr, 32, "%ld", (long) time(NULL));
+        ap_snprintf(tstr, 32, "%ld", time(NULL));
         return pstrdup(r->pool, tstr);
 }
 
@@ -826,8 +815,6 @@ int safe_create_tables(logsql_state *cls, request_rec *r)
         char *create_hin = NULL;
         char *create_cookies = NULL;
 
-        char *type_suffix = NULL;
-
         char *createprefix = "create table if not exists `";
         char *access_suffix =
          "` (id char(19),\
@@ -846,7 +833,7 @@ int safe_create_tables(logsql_state *cls, request_rec *r)
        request_method varchar(10),\
        request_protocol varchar(10),\
        request_time char(28),\
-       request_uri varchar(50),\
+       request_uri varchar(255),\
            request_args varchar(255),\
        server_port smallint unsigned,\
        ssl_cipher varchar(25),\
@@ -854,7 +841,7 @@ int safe_create_tables(logsql_state *cls, request_rec *r)
        ssl_maxkeysize smallint unsigned,\
        status smallint unsigned,\
        time_stamp int unsigned,\
-       virtual_host varchar(50))";
+       virtual_host varchar(255))";
 
         char *notes_suffix =
          "` (id char(19),\
@@ -871,15 +858,12 @@ int safe_create_tables(logsql_state *cls, request_rec *r)
            item varchar(80),\
        val varchar(80))";
 
-        if (logsql_tabletype)
-                type_suffix = ap_pstrcat( r->pool, " TYPE=", logsql_tabletype, NULL );
-
         /* Find memory long enough to hold the whole CREATE string + \0 */
-        create_access = ap_pstrcat(r->pool, createprefix, cls->transfer_table_name, access_suffix, type_suffix, NULL);
-        create_notes  = ap_pstrcat(r->pool, createprefix, cls->notes_table_name, notes_suffix, type_suffix, NULL);
-        create_hout   = ap_pstrcat(r->pool, createprefix, cls->hout_table_name, headers_suffix, type_suffix, NULL);
-        create_hin    = ap_pstrcat(r->pool, createprefix, cls->hin_table_name, headers_suffix, type_suffix, NULL);
-        create_cookies= ap_pstrcat(r->pool, createprefix, cls->cookie_table_name, cookies_suffix, type_suffix, NULL);
+        create_access = ap_pstrcat(r->pool, createprefix, cls->transfer_table_name, access_suffix, NULL);
+        create_notes  = ap_pstrcat(r->pool, createprefix, cls->notes_table_name, notes_suffix, NULL);
+        create_hout   = ap_pstrcat(r->pool, createprefix, cls->hout_table_name, headers_suffix, NULL);
+        create_hin    = ap_pstrcat(r->pool, createprefix, cls->hin_table_name, headers_suffix, NULL);
+        create_cookies= ap_pstrcat(r->pool, createprefix, cls->cookie_table_name, cookies_suffix, NULL);
 
         #ifdef DEBUG
                 ap_log_error(APLOG_MARK,DEBUGLEVEL,r->server,"mod_log_sql: create string: %s", create_access);
@@ -903,8 +887,7 @@ int safe_create_tables(logsql_state *cls, request_rec *r)
         }
 
         if ((create_results = safe_sql_query(r, create_hin))) {
-                ap_log_error(APLOG_MARK,
-                ERRLEVEL,r->server,"mod_log_sql: failed to create header_out table");
+                ap_log_error(APLOG_MARK,ERRLEVEL,r->server,"mod_log_sql: failed to create header_out table");
                 retval = create_results;
         }
 
@@ -953,17 +936,6 @@ const char *set_log_sql_create(cmd_parms *parms, void *dummy, int flag)
         return NULL;
 }
 
-const char *set_log_sql_tabletype(cmd_parms *parms, void *dummy, char *arg)
-{
-        /* These are the legal table types according to the MySQL docs:
-         * TYPE = {BDB | HEAP | ISAM | InnoDB | MERGE | MRG_MYISAM | MYISAM }
-         * However, for now the module does no checking.  If MySQL is passed
-         * a table type it does not understand, it defaults to MyISAM. */
-
-        logsql_tabletype = arg;
-        return NULL;
-}
-
 const char *set_log_sql_db(cmd_parms *parms, void *dummy, char *arg)
 {
         logsql_dbname = arg;
@@ -1228,12 +1200,12 @@ void *log_sql_make_state(pool *p, server_rec *s)
 
         /* These defaults are overridable in the httpd.conf file. */
         cls->transfer_table_name = NULL; /* No default b/c we want its absence to disable logging */
-        cls->transfer_log_format = NULL;
-        cls->notes_table_name    = NULL;
-        cls->hin_table_name      = NULL;
-        cls->hout_table_name     = NULL;
-        cls->cookie_table_name   = NULL;
-        cls->preserve_file               = NULL;
+        cls->transfer_log_format = "AbHhmRSsTUuv";
+        cls->notes_table_name    = "notes";
+        cls->hin_table_name      = "headers_in";
+        cls->hout_table_name     = "headers_out";
+        cls->cookie_table_name   = "cookies";
+        cls->preserve_file               = "/tmp/sql-preserve";
 
         cls->transfer_ignore_list = make_array(p, 1, sizeof(char *));
         cls->transfer_accept_list = make_array(p, 1, sizeof(char *));
@@ -1247,106 +1219,6 @@ void *log_sql_make_state(pool *p, server_rec *s)
         return (void *) cls;
 }
 
-static void *log_sql_merge_state(pool *p, void *basev, void *addv)
-{
-        /* Make room for the merged state */
-        logsql_state *merged =
-                (logsql_state*)ap_pcalloc(p, sizeof(logsql_state));
-
-        /* Fetch the two states to merge */
-        logsql_state *parent = (logsql_state *) basev;
-        logsql_state *child = (logsql_state *) addv;
-
-        /* Child can override these, otherwise they default to parent's choice.
-         * If the parent didn't set them, create reasonable defaults for the
-         * ones that should have such default settings.  Leave the others null. */
-
-        merged->transfer_table_name = child->transfer_table_name ?
-                                child->transfer_table_name : parent->transfer_table_name;
-        /* No default for transfer_table_name because we want its absence
-         * to disable logging. */
-
-
-        merged->transfer_log_format = child->transfer_log_format ?
-                                child->transfer_log_format : parent->transfer_log_format;
-        if (!merged->transfer_log_format)
-                merged->transfer_log_format = "AbHhmRSsTUuv";
-
-
-        merged->preserve_file = child->preserve_file ?
-                                child->preserve_file : parent->preserve_file;
-        if (!merged->preserve_file)
-                merged->preserve_file = "/tmp/sql-preserve";
-
-
-        merged->notes_table_name = child->notes_table_name ?
-                                child->notes_table_name : parent->notes_table_name;
-        if (!merged->notes_table_name)
-                merged->notes_table_name = "notes";
-
-
-        merged->hin_table_name = child->hin_table_name ?
-                                child->hin_table_name : parent->hin_table_name;
-        if (!merged->hin_table_name)
-                merged->hin_table_name = "headers_in";
-
-
-        merged->hout_table_name = child->hout_table_name ?
-                                child->hout_table_name : parent->hout_table_name;
-        if (!merged->hout_table_name)
-                merged->hout_table_name = "headers_out";
-
-
-        merged->cookie_table_name = child->cookie_table_name ?
-                                child->cookie_table_name : parent->cookie_table_name;
-        if (!merged->cookie_table_name)
-                merged->cookie_table_name = "cookies";
-
-
-        merged->transfer_ignore_list = child->transfer_ignore_list ?
-                                child->transfer_ignore_list : parent->transfer_ignore_list;
-
-        merged->transfer_accept_list = child->transfer_accept_list ?
-                                child->transfer_accept_list : parent->transfer_accept_list;
-
-        merged->remhost_ignore_list = child->remhost_ignore_list ?
-                                child->remhost_ignore_list : parent->remhost_ignore_list;
-
-        merged->notes_list = child->notes_list ?
-                                child->notes_list : parent->notes_list ;
-
-        merged->hin_list = child->hin_list ?
-                                child->hin_list : parent->hin_list ;
-
-        merged->hout_list = child->hout_list ?
-                                child->hout_list : parent->hout_list ;
-
-        merged->cookie_list = child->cookie_list ?
-                                child->cookie_list : parent->cookie_list ;
-
-        merged->cookie_name = child->cookie_name ?
-                                child->cookie_name : parent->cookie_name ;
-
-        return (void*) merged;
-
-        /* Here is how mod_log_config does it: */
-
-        /*
-    multi_log_state *base = (multi_log_state *) basev;
-    multi_log_state *add = (multi_log_state *) addv;
-
-    add->server_config_logs = base->config_logs;
-    if (!add->default_format) {
-        add->default_format_string = base->default_format_string;
-        add->default_format = base->default_format;
-    }
-    add->formats = ap_overlay_tables(p, base->formats, add->formats);
-
-    return add;
-        */
-}
-
-
 
 /* Setup of the available httpd.conf configuration commands.
  * Structure: command, function called, NULL, where available, how many arguments, verbose description
@@ -1373,7 +1245,7 @@ command_rec log_sql_cmds[] = {
         {"LogSQLMachineID", set_log_sql_machine_id,                                             NULL,   RSRC_CONF,      TAKE1,
          "Machine ID that the module will log, useful in web clusters to differentiate machines"}
         ,
-        {"LogSQLRequestAccept", add_log_sql_transfer_accept,                    NULL,   RSRC_CONF,      ITERATE,
+        {"LogSQLRequestAccept", add_log_sql_transfer_accept,            NULL,   RSRC_CONF,      ITERATE,
          "List of URIs to accept for logging. Accesses that don't match will not be logged"}
         ,
         {"LogSQLRequestIgnore", add_log_sql_transfer_ignore,                    NULL,   RSRC_CONF,      ITERATE,
@@ -1405,9 +1277,6 @@ command_rec log_sql_cmds[] = {
         ,
         {"LogSQLSocketFile", set_log_sql_socket_file,                                   NULL,   RSRC_CONF,      TAKE1,
          "Name of the file to employ for socket connections to database"}
-    ,
-    {"LogSQLTableType", set_log_sql_tabletype,                                          NULL,   RSRC_CONF,      TAKE1,
-     "What kind of table to create (MyISAM, InnoDB...) when creating tables"}
         ,
         {"LogSQLTCPPort", set_log_sql_tcp_port,                                                 NULL,   RSRC_CONF,      TAKE1,
          "Port number to use for TCP connections to database, defaults to 3306 if not set"}
@@ -1453,23 +1322,36 @@ int log_sql_transaction(request_rec *orig)
                 char *i_tablename;
                 char *o_tablename;
                 char *c_tablename;
-
-                /* Determine the hostname and convert it to all-lower-case.
-                 * Also change any dots to underscores.
-                 */
-                char *p;
-                char *servname = (char *)ap_get_server_name(orig);
-                for (p = servname; *p != '\0'; p++) {
-                    *p = tolower((unsigned char) *p);
-                        if (*p == '.') *p = '_';
-                }
+                unsigned int i;
 
                 /* Find memory long enough to hold the table name + \0. */
-                a_tablename = ap_pstrcat(orig->pool, access_base, servname, NULL);
-                n_tablename = ap_pstrcat(orig->pool, notes_base,  servname, NULL);
-                i_tablename = ap_pstrcat(orig->pool, hin_base,    servname, NULL);
-                o_tablename = ap_pstrcat(orig->pool, hout_base,   servname, NULL);
-                c_tablename = ap_pstrcat(orig->pool, cookie_base, servname, NULL);
+                a_tablename = ap_pstrcat(orig->pool, access_base, ap_get_server_name(orig), NULL);
+                n_tablename = ap_pstrcat(orig->pool, notes_base,  ap_get_server_name(orig), NULL);
+                i_tablename = ap_pstrcat(orig->pool, hin_base,    ap_get_server_name(orig), NULL);
+                o_tablename = ap_pstrcat(orig->pool, hout_base,   ap_get_server_name(orig), NULL);
+                c_tablename = ap_pstrcat(orig->pool, cookie_base, ap_get_server_name(orig), NULL);
+
+                /* Transform any dots to underscores */
+                for (i = 0; i < strlen(a_tablename); i++) {
+                        if (a_tablename[i] == '.')
+                          a_tablename[i] = '_';
+                }
+                for (i = 0; i < strlen(n_tablename); i++) {
+                        if (n_tablename[i] == '.')
+                          n_tablename[i] = '_';
+                }
+                for (i = 0; i < strlen(i_tablename); i++) {
+                        if (i_tablename[i] == '.')
+                          i_tablename[i] = '_';
+                }
+                for (i = 0; i < strlen(o_tablename); i++) {
+                        if (o_tablename[i] == '.')
+                          o_tablename[i] = '_';
+                }
+                for (i = 0; i < strlen(c_tablename); i++) {
+                        if (c_tablename[i] == '.')
+                          c_tablename[i] = '_';
+                }
 
                 /* Tell this virtual server its transfer table name, and
                  * turn on create_tables, which is implied by massvirtual.
@@ -1785,7 +1667,7 @@ module sql_log_module = {
         NULL,                                    /* create per-dir config                       */
         NULL,                                    /* merge per-dir config                        */
         log_sql_make_state,              /* create server config                        */
-        log_sql_merge_state,     /* merge server config                         */
+        NULL,                                    /* merge server config                         */
         log_sql_cmds,                    /* config directive table                      */
         NULL,                                    /* [9] content handlers                        */
         NULL,                                    /* [2] URI-to-filename translation */