upstream/monitoring-plugins
1
0
Fork 0
mirror of https://github.com/monitoring-plugins/monitoring-plugins.git synced 2026-02-25 19:00:23 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions
monitoring-plugins/plugins/check_real.c
Karl DeBisschop 0c3386274e convert PROGANE from a define to a const char 
git-svn-id: https://nagiosplug.svn.sourceforge.net/svnroot/nagiosplug/nagiosplug/trunk@238 f882894a-f735-0410-b71e-b25c423dba1c
2003-01-13 12:15:16 +00:00

616 lines
16 KiB
C
Raw Blame History

/*****************************************************************************
*
* CHECK_REAL.C
*
* Program: RealMedia plugin for Nagios
* License: GPL
* Copyright (c) 1999 Pedro Leite (leite@cic.ua.pt)
*
* Based on CHECK_HTTP.C
* Copyright (c) 1999 Ethan Galstad (nagios@nagios.org)
*
* Last Modified: $Date$
*
* Command line: CHECK_REAL <host_address> [-e expect] [-u url] [-p port]
* [-hn host_name] [-wt warn_time] [-ct crit_time]
* [-to to_sec]
*
* Description:
*
* This plugin will attempt to open an RTSP connection with the host.
* Successul connects return STATE_OK, refusals and timeouts return
* STATE_CRITICAL, other errors return STATE_UNKNOWN. Successful connects,
* but incorrect reponse messages from the host result in STATE_WARNING return
* values. If you are checking a virtual server that uses "host headers"you
* must supply the FQDN (fully qualified domain name) as the [host_name]
* argument.
*
* License Information:
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*
****************************************************************************/
#include "config.h"
#include "common.h"
#include "netutils.h"
#include "utils.h"
const char *progname = "check_real";
#define PORT 554
#define EXPECT "RTSP/1."
#define URL ""
int process_arguments (int, char **);
int validate_arguments (void);
int check_disk (int usp, int free_disk);
void print_help (void);
void print_usage (void);
int server_port = PORT;
char *server_address = "";
char *host_name = NULL;
char *server_url = NULL;
char *server_expect = EXPECT;
int warning_time = 0;
int check_warning_time = FALSE;
int critical_time = 0;
int check_critical_time = FALSE;
int verbose = FALSE;
int
main (int argc, char **argv)
{
int sd;
int result;
char buffer[MAX_INPUT_BUFFER];
char *status_line = NULL;
if (process_arguments (argc, argv) != OK)
usage ("Invalid command arguments supplied\n");
/* initialize alarm signal handling */
signal (SIGALRM, socket_timeout_alarm_handler);
/* set socket timeout */
alarm (socket_timeout);
time (&start_time);
/* try to connect to the host at the given port number */
if (my_tcp_connect (server_address, server_port, &sd) != STATE_OK)
terminate (STATE_CRITICAL, "Unable to connect to %s on port %d\n",
server_address, server_port);
/* Part I - Server Check */
/* send the OPTIONS request */
sprintf (buffer, "OPTIONS rtsp://%s:%d RTSP/1.0\n", host_name, server_port);
result = send (sd, buffer, strlen (buffer), 0);
/* send the header sync */
sprintf (buffer, "CSeq: 1\n");
result = send (sd, buffer, strlen (buffer), 0);
/* send a newline so the server knows we're done with the request */
sprintf (buffer, "\n");
result = send (sd, buffer, strlen (buffer), 0);
/* watch for the REAL connection string */
result = recv (sd, buffer, MAX_INPUT_BUFFER - 1, 0);
/* return a CRITICAL status if we couldn't read any data */
if (result == -1)
terminate (STATE_CRITICAL, "No data received from %s\n", host_name);
/* make sure we find the response we are looking for */
if (!strstr (buffer, server_expect)) {
if (server_port == PORT)
printf ("Invalid REAL response received from host\n");
else
printf ("Invalid REAL response received from host on port %d\n",
server_port);
}
else {
/* else we got the REAL string, so check the return code */
time (&end_time);
result = STATE_OK;
status_line = (char *) strtok (buffer, "\n");
if (strstr (status_line, "200"))
result = STATE_OK;
/* client errors result in a warning state */
else if (strstr (status_line, "400"))
result = STATE_WARNING;
else if (strstr (status_line, "401"))
result = STATE_WARNING;
else if (strstr (status_line, "402"))
result = STATE_WARNING;
else if (strstr (status_line, "403"))
result = STATE_WARNING;
else if (strstr (status_line, "404"))
result = STATE_WARNING;
/* server errors result in a critical state */
else if (strstr (status_line, "500"))
result = STATE_CRITICAL;
else if (strstr (status_line, "501"))
result = STATE_CRITICAL;
else if (strstr (status_line, "502"))
result = STATE_CRITICAL;
else if (strstr (status_line, "503"))
result = STATE_CRITICAL;
else
result = STATE_UNKNOWN;
}
/* Part II - Check stream exists and is ok */
if ((result == STATE_OK) && (server_url != NULL)) {
/* Part I - Server Check */
/* send the OPTIONS request */
sprintf (buffer, "DESCRIBE rtsp://%s:%d%s RTSP/1.0\n", host_name,
server_port, server_url);
result = send (sd, buffer, strlen (buffer), 0);
/* send the header sync */
sprintf (buffer, "CSeq: 2\n");
result = send (sd, buffer, strlen (buffer), 0);
/* send a newline so the server knows we're done with the request */
sprintf (buffer, "\n");
result = send (sd, buffer, strlen (buffer), 0);
/* watch for the REAL connection string */
result = recv (sd, buffer, MAX_INPUT_BUFFER - 1, 0);
/* return a CRITICAL status if we couldn't read any data */
if (result == -1) {
printf ("No data received from host\n");
result = STATE_CRITICAL;
}
else {
/* make sure we find the response we are looking for */
if (!strstr (buffer, server_expect)) {
if (server_port == PORT)
printf ("Invalid REAL response received from host\n");
else
printf ("Invalid REAL response received from host on port %d\n",
server_port);
}
else {
/* else we got the REAL string, so check the return code */
time (&end_time);
result = STATE_OK;
status_line = (char *) strtok (buffer, "\n");
if (strstr (status_line, "200"))
result = STATE_OK;
/* client errors result in a warning state */
else if (strstr (status_line, "400"))
result = STATE_WARNING;
else if (strstr (status_line, "401"))
result = STATE_WARNING;
else if (strstr (status_line, "402"))
result = STATE_WARNING;
else if (strstr (status_line, "403"))
result = STATE_WARNING;
else if (strstr (status_line, "404"))
result = STATE_WARNING;
/* server errors result in a critical state */
else if (strstr (status_line, "500"))
result = STATE_CRITICAL;
else if (strstr (status_line, "501"))
result = STATE_CRITICAL;
else if (strstr (status_line, "502"))
result = STATE_CRITICAL;
else if (strstr (status_line, "503"))
result = STATE_CRITICAL;
else
result = STATE_UNKNOWN;
}
}
}
/* Return results */
if (result == STATE_OK) {
if (check_critical_time == TRUE
&& (end_time - start_time) > critical_time) result = STATE_CRITICAL;
else if (check_warning_time == TRUE
&& (end_time - start_time) > warning_time) result =
STATE_WARNING;
/* Put some HTML in here to create a dynamic link */
printf ("REAL %s - %d second response time\n",
(result == STATE_OK) ? "ok" : "problem",
(int) (end_time - start_time));
}
else
printf ("%s\n", status_line);
/* close the connection */
close (sd);
/* reset the alarm */
alarm (0);
return result;
}
/* process command-line arguments */
int
process_arguments (int argc, char **argv)
{
int c;
#ifdef HAVE_GETOPT_H
int option_index = 0;
static struct option long_options[] = {
{"hostname", required_argument, 0, 'H'},
{"IPaddress", required_argument, 0, 'I'},
{"expect", required_argument, 0, 'e'},
{"url", required_argument, 0, 'u'},
{"port", required_argument, 0, 'p'},
{"critical", required_argument, 0, 'c'},
{"warning", required_argument, 0, 'w'},
{"timeout", required_argument, 0, 't'},
{"verbose", no_argument, 0, 'v'},
{"version", no_argument, 0, 'V'},
{"help", no_argument, 0, 'h'},
{0, 0, 0, 0}
};
#endif
if (argc < 2)
return ERROR;
for (c = 1; c < argc; c++) {
if (strcmp ("-to", argv[c]) == 0)
strcpy (argv[c], "-t");
else if (strcmp ("-wt", argv[c]) == 0)
strcpy (argv[c], "-w");
else if (strcmp ("-ct", argv[c]) == 0)
strcpy (argv[c], "-c");
}
while (1) {
#ifdef HAVE_GETOPT_H
c =
getopt_long (argc, argv, "+hVI:H:e:u:p:w:c:t:", long_options,
&option_index);
#else
c = getopt (argc, argv, "+?hVI:H:e:u:p:w:c:t");
#endif
if (c == -1 || c == EOF)
break;
switch (c) {
case 'I': /* hostname */
case 'H': /* hostname */
if (is_host (optarg)) {
server_address = optarg;
}
else {
usage ("Invalid host name\n");
}
break;
case 'e': /* string to expect in response header */
server_expect = optarg;
break;
case 'u': /* server URL */
server_url = optarg;
break;
case 'p': /* port */
if (is_intpos (optarg)) {
server_port = atoi (optarg);
}
else {
usage ("Server port must be a positive integer\n");
}
break;
case 'w': /* warning time threshold */
if (is_intnonneg (optarg)) {
warning_time = atoi (optarg);
check_warning_time = TRUE;
}
else {
usage ("Warning time must be a nonnegative integer\n");
}
break;
case 'c': /* critical time threshold */
if (is_intnonneg (optarg)) {
critical_time = atoi (optarg);
check_critical_time = TRUE;
}
else {
usage ("Critical time must be a nonnegative integer\n");
}
break;
case 'v': /* verbose */
verbose = TRUE;
break;
case 't': /* timeout */
if (is_intnonneg (optarg)) {
socket_timeout = atoi (optarg);
}
else {
usage ("Time interval must be a nonnegative integer\n");
}
break;
case 'V': /* version */
print_revision (progname, "$Revision$");
exit (STATE_OK);
case 'h': /* help */
print_help ();
exit (STATE_OK);
case '?': /* help */
usage ("Invalid argument\n");
}
}
c = optind;
if (strlen(server_address) == 0 && argc > c) {
if (is_host (argv[c])) {
server_address = argv[c++];
}
else {
usage ("Invalid host name");
}
}
return validate_arguments ();
}
int
validate_arguments (void)
{
return OK;
}
void
print_help (void)
{
print_revision (progname, "$Revision$");
printf
("Copyright (c) 2000 Pedro Leite (leite@cic.ua.pt)/Karl DeBisschop\n\n"
"This plugin tests the REAL service on the specified host.\n\n");
print_usage ();
printf
("\nOptions:\n"
" -H, --hostname=STRING or IPADDRESS\n"
" Check this server on the indicated host\n"
" -I, --IPaddress=STRING or IPADDRESS\n"
" Check server at this host address\n"
" -p, --port=INTEGER\n"
" Make connection on the indicated port (default: %d)\n"
" -u, --url=STRING\n"
" Connect to this url\n"
" -e, --expect=STRING\n"
" String to expect in first line of server response (default: %s)\n"
" -w, --warning=INTEGER\n"
" Seconds necessary to result in a warning status\n"
" -c, --critical=INTEGER\n"
" Seconds necessary to result in a critical status\n"
" -t, --timeout=INTEGER\n"
" Seconds before connection attempt times out (default: %d)\n"
" -v, --verbose\n"
" Print extra information (command-line use only)\n"
" -h, --help\n"
" Print detailed help screen\n"
" -V, --version\n"
" Print version information\n\n",
PORT, EXPECT, DEFAULT_SOCKET_TIMEOUT);
support ();
}
void
print_usage (void)
{
printf
("Usage: %s -H host [-e expect] [-p port] [-w warn] [-c crit]\n"
" [-t timeout] [-v]\n"
" %s --help\n"
" %s --version\n", progname, progname, progname);
}
/*
// process command-line arguments
int
process_arguments (int argc, char **argv)
{
int x;
// no options were supplied
if (argc < 2)
return ERROR;
// first option is always the server name/address
strncpy (server_address, argv[1], sizeof (server_address) - 1);
server_address[sizeof (server_address) - 1] = 0;
// set the host name to the server address (until its overridden)
strcpy (host_name, server_address);
// process all remaining arguments
for (x = 3; x <= argc; x++)
{
// we got the string to expect from the server
if (!strcmp (argv[x - 1], "-e"))
{
if (x < argc)
{
strncpy (server_expect, argv[x], sizeof (server_expect) - 1);
server_expect[sizeof (server_expect) - 1] = 0;
x++;
}
else
return ERROR;
}
// we got the URL to check
else if (!strcmp (argv[x - 1], "-u"))
{
if (x < argc)
{
strncpy (server_url, argv[x], sizeof (server_url) - 1);
server_url[sizeof (server_url) - 1] = 0;
x++;
}
else
return ERROR;
}
// we go the host name to use in the host header
else if (!strcmp (argv[x - 1], "-hn"))
{
if (x < argc)
{
strncpy (host_name, argv[x], sizeof (host_name) - 1);
host_name[sizeof (host_name) - 1] = 0;
x++;
}
else
return ERROR;
}
// we got the port number to use
else if (!strcmp (argv[x - 1], "-p"))
{
if (x < argc)
{
server_port = atoi (argv[x]);
x++;
}
else
return ERROR;
}
// we got the socket timeout
else if (!strcmp (argv[x - 1], "-to"))
{
if (x < argc)
{
socket_timeout = atoi (argv[x]);
if (socket_timeout <= 0)
return ERROR;
x++;
}
else
return ERROR;
}
// we got the warning threshold time
else if (!strcmp (argv[x - 1], "-wt"))
{
if (x < argc)
{
warning_time = atoi (argv[x]);
check_warning_time = TRUE;
x++;
}
else
return ERROR;
}
// we got the critical threshold time
else if (!strcmp (argv[x - 1], "-ct"))
{
if (x < argc)
{
critical_time = atoi (argv[x]);
check_critical_time = TRUE;
x++;
}
else
return ERROR;
}
// else we got something else...
else
return ERROR;
}
return OK;
}
result = process_arguments (argc, argv);
if (result != OK)
{
printf ("Incorrect number of arguments supplied\n");
printf ("\n");
print_revision(argv[0],"$Revision$");
printf ("Copyright (c) 1999 Pedro Leite (leite@cic.ua.pt)\n");
printf ("Last Modified: 30-10-1999\n");
printf ("License: GPL\n");
printf ("\n");
printf ("Usage: %s <host_address> [-e expect] [-u url] [-p port] [-hn host_name] [-wt warn_time]\n",argv[0]);
printf(" [-ct crit_time] [-to to_sec] [-a auth]\n");
printf ("\n");
printf ("Options:\n");
printf (" [expect] = String to expect in first line of server response - default is \"%s\"\n", EXPECT);
printf (" [url] = Optional URL to GET - default is root document\n");
printf (" [port] = Optional port number to use - default is %d\n", PORT);
printf (" [host_name] = Optional host name argument to GET command - used for servers using host headers\n");
printf (" [warn_time] = Response time in seconds necessary to result in a warning status\n");
printf (" [crit_time] = Response time in seconds necessary to result in a critical status\n");
printf (" [to_sec] = Number of seconds before connection attempt times out - default is %d seconds\n", DEFAULT_SOCKET_TIMEOUT);
printf (" [auth] = Optional username:password for sites requiring basic authentication\n");
printf ("\n");
printf ("This plugin attempts to contact the REAL service on the specified host.\n");
printf ("If possible, supply an IP address for the host address, as this will bypass the DNS lookup.\n");
printf ("\n");
return STATE_UNKNOWN;
}
*/
Reference in a new issue View git blame Copy permalink