X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fapache.c;h=df1b560f092e89bbc8dd9cb65309fb55b20216f5;hb=0cc57e3f854e7903d7ec46d8d4b0e46bba4a8739;hp=f36f5141a0db30b6c3a2ce47abb645a158009924;hpb=d699bec9841c88fcda04f08ce51fb8fc916df3d5;p=collectd.git diff --git a/src/apache.c b/src/apache.c index f36f5141..df1b560f 100644 --- a/src/apache.c +++ b/src/apache.c @@ -31,16 +31,24 @@ #include +enum server_enum +{ + APACHE = 0, + LIGHTTPD +}; + struct apache_s { + int server_type; char *name; char *host; char *url; char *user; char *pass; - char *verify_peer; - char *verify_host; + int verify_peer; + int verify_host; char *cacert; + char *server; /* user specific server type */ char *apache_buffer; char apache_curl_error[CURL_ERROR_SIZE]; size_t apache_buffer_size; @@ -63,9 +71,8 @@ static void apache_free (apache_t *st) sfree (st->url); sfree (st->user); sfree (st->pass); - sfree (st->verify_peer); - sfree (st->verify_host); sfree (st->cacert); + sfree (st->server); sfree (st->apache_buffer); if (st->curl) { curl_easy_cleanup(st->curl); @@ -112,6 +119,42 @@ static size_t apache_curl_callback (void *buf, size_t size, size_t nmemb, return (len); } /* int apache_curl_callback */ +static size_t apache_header_callback (void *buf, size_t size, size_t nmemb, + void *user_data) +{ + size_t len = size * nmemb; + apache_t *st; + + st = user_data; + if (st == NULL) + { + ERROR ("apache plugin: apache_header_callback: " + "user_data pointer is NULL."); + return (0); + } + + if (len <= 0) + return (len); + + /* look for the Server header */ + if (strncasecmp (buf, "Server: ", strlen ("Server: ")) != 0) + return (len); + + if (strstr (buf, "Apache") != NULL) + st->server_type = APACHE; + else if (strstr (buf, "lighttpd") != NULL) + st->server_type = LIGHTTPD; + else + { + const char *hdr = buf; + + hdr += strlen ("Server: "); + NOTICE ("apache plugin: Unknown server software: %s", hdr); + } + + return (len); +} /* apache_header_callback */ + /* Configuration handling functiions * * @@ -120,7 +163,7 @@ static size_t apache_curl_callback (void *buf, size_t size, size_t nmemb, * URL ... * */ -static int config_set_string (char **ret_string, +static int config_set_string (char **ret_string, /* {{{ */ oconfig_item_t *ci) { char *string; @@ -145,7 +188,44 @@ static int config_set_string (char **ret_string, *ret_string = string; return (0); -} /* int config_set_string */ +} /* }}} int config_set_string */ + +static int config_set_boolean (int *ret_boolean, /* {{{ */ + oconfig_item_t *ci) +{ + if ((ci->values_num != 1) + || ((ci->values[0].type != OCONFIG_TYPE_BOOLEAN) + && (ci->values[0].type != OCONFIG_TYPE_STRING))) + { + WARNING ("apache plugin: The `%s' config option " + "needs exactly one boolean argument.", ci->key); + return (-1); + } + + if (ci->values[0].type != OCONFIG_TYPE_BOOLEAN) + { + if (ci->values[0].value.boolean) + *ret_boolean = 1; + else + *ret_boolean = 0; + } + else /* if (ci->values[0].type != OCONFIG_TYPE_STRING) */ + { + char *string = ci->values[0].value.string; + if (IS_TRUE (string)) + *ret_boolean = 1; + else if (IS_FALSE (string)) + *ret_boolean = 0; + else + { + ERROR ("apache plugin: Cannot parse string " + "as boolean value: %s", string); + return (-1); + } + } + + return (0); +} /* }}} int config_set_boolean */ static int config_add (oconfig_item_t *ci) { @@ -176,6 +256,7 @@ static int config_add (oconfig_item_t *ci) sfree (st); return (status); } + assert (st->name != NULL); for (i = 0; i < ci->children_num; i++) { @@ -190,14 +271,17 @@ static int config_add (oconfig_item_t *ci) else if (strcasecmp ("Password", child->key) == 0) status = config_set_string (&st->pass, child); else if (strcasecmp ("VerifyPeer", child->key) == 0) - status = config_set_string (&st->verify_peer, child); + status = config_set_boolean (&st->verify_peer, child); else if (strcasecmp ("VerifyHost", child->key) == 0) - status = config_set_string (&st->verify_host, child); + status = config_set_boolean (&st->verify_host, child); else if (strcasecmp ("CACert", child->key) == 0) status = config_set_string (&st->cacert, child); + else if (strcasecmp ("Server", child->key) == 0) + status = config_set_string (&st->server, child); else { - WARNING ("apache plugin: Option `%s' not allowed here.", child->key); + WARNING ("apache plugin: Option `%s' not allowed here.", + child->key); status = -1; } @@ -205,6 +289,15 @@ static int config_add (oconfig_item_t *ci) break; } + /* Check if struct is complete.. */ + if ((status == 0) && (st->url == NULL)) + { + ERROR ("apache plugin: Instance `%s': " + "No URL has been configured.", + st->name); + status = -1; + } + if (status == 0) { user_data_t ud; @@ -297,16 +390,13 @@ static int init_host (apache_t *st) /* {{{ */ { static char credentials[1024]; - if (st->url == NULL) - { - WARNING ("apache plugin: init_host: No URL configured, returning " - "an error."); - return (-1); - } + assert (st->url != NULL); + /* (Assured by `config_add') */ if (st->curl != NULL) { curl_easy_cleanup (st->curl); + st->curl = NULL; } if ((st->curl = curl_easy_init ()) == NULL) @@ -317,6 +407,30 @@ static int init_host (apache_t *st) /* {{{ */ curl_easy_setopt (st->curl, CURLOPT_WRITEFUNCTION, apache_curl_callback); curl_easy_setopt (st->curl, CURLOPT_WRITEDATA, st); + + /* not set as yet if the user specified string doesn't match apache or + * lighttpd, then ignore it. Headers will be parsed to find out the + * server type */ + st->server_type = -1; + + if (st->server != NULL) + { + if (strcasecmp(st->server, "apache") == 0) + st->server_type = APACHE; + else if (strcasecmp(st->server, "lighttpd") == 0) + st->server_type = LIGHTTPD; + else + WARNING ("apache plugin: Unknown `Server' setting: %s", + st->server); + } + + /* if not found register a header callback to determine the server_type */ + if (st->server_type == -1) + { + curl_easy_setopt (st->curl, CURLOPT_HEADERFUNCTION, apache_header_callback); + curl_easy_setopt (st->curl, CURLOPT_WRITEHEADER, st); + } + curl_easy_setopt (st->curl, CURLOPT_USERAGENT, PACKAGE_NAME"/"PACKAGE_VERSION); curl_easy_setopt (st->curl, CURLOPT_ERRORBUFFER, st->apache_curl_error); @@ -340,8 +454,9 @@ static int init_host (apache_t *st) /* {{{ */ } curl_easy_setopt (st->curl, CURLOPT_URL, st->url); + curl_easy_setopt (st->curl, CURLOPT_FOLLOWLOCATION, 1); - if ((st->verify_peer == NULL) || (strcmp (st->verify_peer, "true") == 0)) + if (st->verify_peer != 0) { curl_easy_setopt (st->curl, CURLOPT_SSL_VERIFYPEER, 1); } @@ -350,7 +465,7 @@ static int init_host (apache_t *st) /* {{{ */ curl_easy_setopt (st->curl, CURLOPT_SSL_VERIFYPEER, 0); } - if ((st->verify_host == NULL) || (strcmp (st->verify_host, "true") == 0)) + if (st->verify_host != 0) { curl_easy_setopt (st->curl, CURLOPT_SSL_VERIFYHOST, 2); } @@ -411,10 +526,15 @@ static void submit_scoreboard (char *buf, apache_t *st) { /* * Scoreboard Key: - * "_" Waiting for Connection, "S" Starting up, "R" Reading Request, + * "_" Waiting for Connection, "S" Starting up, + * "R" Reading Request for apache and read-POST for lighttpd, * "W" Sending Reply, "K" Keepalive (read), "D" DNS Lookup, * "C" Closing connection, "L" Logging, "G" Gracefully finishing, * "I" Idle cleanup of worker, "." Open slot with no current process + * Lighttpd specific legends - + * "E" hard error, "." connect, "h" handle-request, + * "q" request-start, "Q" request-end, "s" response-start + * "S" response-end, "r" read */ long long open = 0LL; long long waiting = 0LL; @@ -428,8 +548,16 @@ static void submit_scoreboard (char *buf, apache_t *st) long long finishing = 0LL; long long idle_cleanup = 0LL; - int i; + /* lighttpd specific */ + long long hard_error = 0LL; + long long lighttpd_read = 0LL; + long long handle_request = 0LL; + long long request_start = 0LL; + long long request_end = 0LL; + long long response_start = 0LL; + long long response_end = 0LL; + int i; for (i = 0; buf[i] != '\0'; i++) { if (buf[i] == '.') open++; @@ -443,19 +571,43 @@ static void submit_scoreboard (char *buf, apache_t *st) else if (buf[i] == 'L') logging++; else if (buf[i] == 'G') finishing++; else if (buf[i] == 'I') idle_cleanup++; + else if (buf[i] == 'r') lighttpd_read++; + else if (buf[i] == 'h') handle_request++; + else if (buf[i] == 'E') hard_error++; + else if (buf[i] == 'q') request_start++; + else if (buf[i] == 'Q') request_end++; + else if (buf[i] == 's') response_start++; + else if (buf[i] == 'S') response_end++; } - submit_gauge ("apache_scoreboard", "open" , open, st); - submit_gauge ("apache_scoreboard", "waiting" , waiting, st); - submit_gauge ("apache_scoreboard", "starting" , starting, st); - submit_gauge ("apache_scoreboard", "reading" , reading, st); - submit_gauge ("apache_scoreboard", "sending" , sending, st); - submit_gauge ("apache_scoreboard", "keepalive", keepalive, st); - submit_gauge ("apache_scoreboard", "dnslookup", dnslookup, st); - submit_gauge ("apache_scoreboard", "closing" , closing, st); - submit_gauge ("apache_scoreboard", "logging" , logging, st); - submit_gauge ("apache_scoreboard", "finishing", finishing, st); - submit_gauge ("apache_scoreboard", "idle_cleanup", idle_cleanup, st); + if (st->server_type == APACHE) + { + submit_gauge ("apache_scoreboard", "open" , open, st); + submit_gauge ("apache_scoreboard", "waiting" , waiting, st); + submit_gauge ("apache_scoreboard", "starting" , starting, st); + submit_gauge ("apache_scoreboard", "reading" , reading, st); + submit_gauge ("apache_scoreboard", "sending" , sending, st); + submit_gauge ("apache_scoreboard", "keepalive", keepalive, st); + submit_gauge ("apache_scoreboard", "dnslookup", dnslookup, st); + submit_gauge ("apache_scoreboard", "closing" , closing, st); + submit_gauge ("apache_scoreboard", "logging" , logging, st); + submit_gauge ("apache_scoreboard", "finishing", finishing, st); + submit_gauge ("apache_scoreboard", "idle_cleanup", idle_cleanup, st); + } + else + { + submit_gauge ("apache_scoreboard", "connect" , open, st); + submit_gauge ("apache_scoreboard", "close" , closing, st); + submit_gauge ("apache_scoreboard", "hard_error" , hard_error, st); + submit_gauge ("apache_scoreboard", "read" , lighttpd_read, st); + submit_gauge ("apache_scoreboard", "read_post" , reading, st); + submit_gauge ("apache_scoreboard", "write" , sending, st); + submit_gauge ("apache_scoreboard", "handle_request", handle_request, st); + submit_gauge ("apache_scoreboard", "request_start" , request_start, st); + submit_gauge ("apache_scoreboard", "request_end" , request_end, st); + submit_gauge ("apache_scoreboard", "response_start", response_start, st); + submit_gauge ("apache_scoreboard", "response_end" , response_end, st); + } } static int apache_read_host (user_data_t *user_data) /* {{{ */ @@ -474,6 +626,9 @@ static int apache_read_host (user_data_t *user_data) /* {{{ */ st = user_data->data; + assert (st->url != NULL); + /* (Assured by `config_add') */ + if (st->curl == NULL) { int status; @@ -484,9 +639,6 @@ static int apache_read_host (user_data_t *user_data) /* {{{ */ } assert (st->curl != NULL); - if (st->url == NULL) - return (-1); - st->apache_buffer_fill = 0; if (curl_easy_perform (st->curl) != 0) { @@ -495,6 +647,14 @@ static int apache_read_host (user_data_t *user_data) /* {{{ */ return (-1); } + /* fallback - server_type to apache if not set at this time */ + if (st->server_type == -1) + { + WARNING ("apache plugin: Unable to determine server software " + "automatically. Will assume Apache."); + st->server_type = APACHE; + } + ptr = st->apache_buffer; saveptr = NULL; while ((lines[lines_num] = strtok_r (ptr, "\n\r", &saveptr)) != NULL)