X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;ds=sidebyside;f=plugins%2Fcheck_mysql.c;h=8c7e4ef044586bc2b1c918acf1e6a5e5c1d168ea;hb=0c2be6a608135d8a45c82a1c0ada5e8020bc2409;hp=20901e639d908afd7f211469d8e50fe69f95a56b;hpb=43ab308923919380cba2164490c1969add1c0d4d;p=nagiosplug.git diff --git a/plugins/check_mysql.c b/plugins/check_mysql.c index 20901e6..8c7e4ef 100644 --- a/plugins/check_mysql.c +++ b/plugins/check_mysql.c @@ -6,7 +6,7 @@ * License: GPL * Copyright (c) 1999 Didi Rieder (adrieder@sbox.tu-graz.ac.at) * portions (c) 2000 Karl DeBisschop (kdebisschop@users.sourceforge.net) -* +* * $Id$ * * Description: @@ -16,32 +16,34 @@ const char *progname = "check_mysql"; const char *revision = "$Revision$"; -const char *copyright = "1999-2004"; +const char *copyright = "1999-2006"; const char *email = "nagiosplug-devel@lists.sourceforge.net"; -#define SLAVERESULTSIZE 40 +#define SLAVERESULTSIZE 70 #include "common.h" #include "utils.h" +#include "utils_base.h" #include "netutils.h" -#include -#include +#include +#include char *db_user = NULL; char *db_host = NULL; char *db_pass = NULL; char *db = NULL; unsigned int db_port = MYSQL_PORT; -int check_slave = 0; +int check_slave = 0, warn_sec = 0, crit_sec = 0; +int verbose = 0; + +thresholds *my_threshold = NULL; int process_arguments (int, char **); int validate_arguments (void); void print_help (void); void print_usage (void); - - int main (int argc, char **argv) { @@ -53,6 +55,7 @@ main (int argc, char **argv) /* should be status */ char *result = NULL; + char *error = NULL; char slaveresult[SLAVERESULTSIZE]; setlocale (LC_ALL, ""); @@ -65,6 +68,8 @@ main (int argc, char **argv) /* initialize mysql */ mysql_init (&mysql); + mysql_options(&mysql,MYSQL_READ_DEFAULT_GROUP,"client"); + /* establish a connection to the server and error checking */ if (!mysql_real_connect(&mysql,db_host,db_user,db_pass,db,db_port,NULL,0)) { if (mysql_errno (&mysql) == CR_UNKNOWN_HOST) @@ -97,21 +102,30 @@ main (int argc, char **argv) if(check_slave) { /* check the slave status */ if (mysql_query (&mysql, "show slave status") != 0) { + error = strdup(mysql_error(&mysql)); mysql_close (&mysql); - die (STATE_CRITICAL, _("slave query error: %s\n"), mysql_error (&mysql)); + die (STATE_CRITICAL, _("slave query error: %s\n"), error); } /* store the result */ if ( (res = mysql_store_result (&mysql)) == NULL) { + error = strdup(mysql_error(&mysql)); mysql_close (&mysql); - die (STATE_CRITICAL, _("slave store_result error: %s\n"), mysql_error (&mysql)); + die (STATE_CRITICAL, _("slave store_result error: %s\n"), error); + } + + /* Check there is some data */ + if (mysql_num_rows(res) == 0) { + mysql_close(&mysql); + die (STATE_WARNING, "%s\n", _("No slaves defined")); } /* fetch the first row */ if ( (row = mysql_fetch_row (res)) == NULL) { + error = strdup(mysql_error(&mysql)); mysql_free_result (res); mysql_close (&mysql); - die (STATE_CRITICAL, _("slave fetch row error: %s\n"), mysql_error (&mysql)); + die (STATE_CRITICAL, _("slave fetch row error: %s\n"), error); } if (mysql_field_count (&mysql) == 12) { @@ -125,37 +139,60 @@ main (int argc, char **argv) } else { /* mysql 4.x.x */ - int slave_io_field = -1 , slave_sql_field = -1, i, num_fields; + int slave_io_field = -1 , slave_sql_field = -1, seconds_behind_field = -1, i, num_fields; MYSQL_FIELD* fields; num_fields = mysql_num_fields(res); fields = mysql_fetch_fields(res); - for(i = 0; i < num_fields; i++) - { - if (0 == strcmp(fields[i].name, "Slave_IO_Running")) - { + for(i = 0; i < num_fields; i++) { + if (strcmp(fields[i].name, "Slave_IO_Running") == 0) { slave_io_field = i; continue; } - if (0 == strcmp(fields[i].name, "Slave_SQL_Running")) - { + if (strcmp(fields[i].name, "Slave_SQL_Running") == 0) { slave_sql_field = i; continue; } + if (strcmp(fields[i].name, "Seconds_Behind_Master") == 0) { + seconds_behind_field = i; + continue; + } } - if ((slave_io_field < 0) || (slave_sql_field < 0) || (num_fields == 0)) - { + if ((slave_io_field < 0) || (slave_sql_field < 0) || (num_fields == 0)) { mysql_free_result (res); mysql_close (&mysql); die (STATE_CRITICAL, "Slave status unavailable\n"); } - - snprintf (slaveresult, SLAVERESULTSIZE, "Slave IO: %s Slave SQL: %s", row[slave_io_field], row[slave_sql_field]); + + snprintf (slaveresult, SLAVERESULTSIZE, "Slave IO: %s Slave SQL: %s Seconds Behind Master: %s", row[slave_io_field], row[slave_sql_field], row[seconds_behind_field]); if (strcmp (row[slave_io_field], "Yes") != 0 || strcmp (row[slave_sql_field], "Yes") != 0) { mysql_free_result (res); mysql_close (&mysql); die (STATE_CRITICAL, "%s\n", slaveresult); } + + if (verbose >=3) { + if (seconds_behind_field == -1) { + printf("seconds_behind_field not found\n"); + } else { + printf ("seconds_behind_field(index %d)=%s\n", seconds_behind_field, row[seconds_behind_field]); + } + } + + if ((seconds_behind_field != -1) && (strcmp (row[seconds_behind_field], "NULL") != 0)) { + double value = atof(row[seconds_behind_field]); + int status; + + status = get_status(value, my_threshold); + + if (status == STATE_WARNING) { + printf("SLOW_SLAVE %s: %s\n", _("WARNING"), slaveresult); + exit(STATE_WARNING); + } else if (status == STATE_CRITICAL) { + printf("SLOW_SLAVE %s: %s\n", _("CRITICAL"), slaveresult); + exit(STATE_CRITICAL); + } + } } /* free the result */ @@ -181,6 +218,8 @@ int process_arguments (int argc, char **argv) { int c; + char *warning = NULL; + char *critical = NULL; int option = 0; static struct option longopts[] = { @@ -189,6 +228,8 @@ process_arguments (int argc, char **argv) {"username", required_argument, 0, 'u'}, {"password", required_argument, 0, 'p'}, {"port", required_argument, 0, 'P'}, + {"critical", required_argument, 0, 'c'}, + {"warning", required_argument, 0, 'w'}, {"check-slave", no_argument, 0, 'S'}, {"verbose", no_argument, 0, 'v'}, {"version", no_argument, 0, 'V'}, @@ -200,7 +241,7 @@ process_arguments (int argc, char **argv) return ERROR; while (1) { - c = getopt_long (argc, argv, "hVSP:p:u:d:H:", longopts, &option); + c = getopt_long (argc, argv, "hvVSP:p:u:d:H:c:w:", longopts, &option); if (c == -1 || c == EOF) break; @@ -229,12 +270,21 @@ process_arguments (int argc, char **argv) case 'S': check_slave = 1; /* check-slave */ break; + case 'w': + warning = optarg; + break; + case 'c': + critical = optarg; + break; case 'V': /* version */ print_revision (progname, revision); exit (STATE_OK); case 'h': /* help */ print_help (); exit (STATE_OK); + case 'v': + verbose++; + break; case '?': /* help */ usage2 (_("Unknown argument"), optarg); } @@ -242,6 +292,8 @@ process_arguments (int argc, char **argv) c = optind; + set_thresholds(&my_threshold, warning, critical); + while ( argc > c ) { if (strlen(db_host) == 0) @@ -296,29 +348,32 @@ print_help (void) printf (_(COPYRIGHT), copyright, email); - printf (_("This program tests connections to a mysql server\n")); + printf ("%s\n", _("This program tests connections to a mysql server")); + printf ("\n\n"); + print_usage (); printf (_(UT_HELP_VRSN)); printf (_(UT_HOST_PORT), 'P', myport); - printf (_("\ - -d, --database=STRING\n\ - Check database with indicated name\n\ - -u, --username=STRING\n\ - Connect using the indicated username\n\ - -p, --password=STRING\n\ - Use the indicated password to authenticate the connection\n\ - ==> IMPORTANT: THIS FORM OF AUTHENTICATION IS NOT SECURE!!! <==\n\ - Your clear-text password will be visible as a process table entry\n\ - -S, --check-slave\n\ - Check if the slave thread is running properly.\n")); - - printf (_("\n\ -There are no required arguments. By default, the local database with\n\ -a server listening on MySQL standard port %d will be checked\n"), MYSQL_PORT); + printf (" %s\n", "-d, --database=STRING"); + printf (" %s\n", _("Check database with indicated name")); + printf (" %s\n", "-u, --username=STRING"); + printf (" %s\n", _("Connect using the indicated username")); + printf (" %s\n", "-p, --password=STRING"); + printf (" %s\n", _("Use the indicated password to authenticate the connection")); + printf (" %s\n", _("==> IMPORTANT: THIS FORM OF AUTHENTICATION IS NOT SECURE!!! <==")); + printf (" %s\n", _("Your clear-text password will be visible as a process table entry")); + printf (" %s\n", "-S, --check-slave"); + printf (" %s\n", _("Check if the slave thread is running properly.")); + printf (" %s\n", "-w, --warning"); + printf (" %s\n", _("Exit with WARNING status if slave server is more then INTEGER seconds behind master")); + printf (" %s\n", "-c, --critical"); + printf (" %s\n", _("Exit with CRITICAL status if slave server is more then INTEGER seconds behind master")); + printf (" %s\n", _("There are no required arguments. By default, the local database with")); + printf (_("a server listening on MySQL standard port %d will be checked\n"), MYSQL_PORT); printf (_(UT_SUPPORT)); } @@ -327,7 +382,6 @@ a server listening on MySQL standard port %d will be checked\n"), MYSQL_PORT); void print_usage (void) { - printf ("\ -Usage: %s [-d database] [-H host] [-P port] [-u user] [-p password] [-S]\n", - progname); + printf (_("Usage:")); + printf ("%s [-d database] [-H host] [-P port] [-u user] [-p password] [-S]\n",progname); }