summaryrefslogtreecommitdiff
path: root/tools
diff options
context:
space:
mode:
Diffstat (limited to 'tools')
-rw-r--r--tools/Makefile.am13
-rw-r--r--tools/rrdbot-get.c393
2 files changed, 405 insertions, 1 deletions
diff --git a/tools/Makefile.am b/tools/Makefile.am
index 94dfa06..a2185ab 100644
--- a/tools/Makefile.am
+++ b/tools/Makefile.am
@@ -1,8 +1,19 @@
-sbin_PROGRAMS = rrdbot-create
+sbin_PROGRAMS = rrdbot-create rrdbot-get
rrdbot_create_SOURCES = rrdbot-create.c ../common/usuals.h \
../common/config-parser.h ../common/config-parser.c \
../common/compat.h ../common/compat.c
rrdbot_create_CFLAGS = -I${top_srcdir}/common/ -I${top_srcdir} \
-DCONF_PREFIX=\"$(sysconfdir)\" -DDATA_PREFIX=\"$(datadir)\"
+
+rrdbot_get_SOURCES = rrdbot-get.c ../common/usuals.h \
+ ../common/compat.h ../common/compat.c \
+ ../common/config-parser.h ../common/config-parser.c \
+ ../common/server-mainloop.h ../common/server-mainloop.c \
+ ../common/sock-any.h ../common/sock-any.c \
+ ../mib/mib-parser.c ../mib/mib-parser.h \
+ ../bsnmp/asn1.h ../bsnmp/asn1.c \
+ ../bsnmp/snmp.h ../bsnmp/snmp.c
+rrdbot_get_CFLAGS = -I${top_srcdir}/common/ -I${top_srcdir} \
+ -DCONF_PREFIX=\"$(sysconfdir)\" -DDATA_PREFIX=\"$(datadir)\"
diff --git a/tools/rrdbot-get.c b/tools/rrdbot-get.c
new file mode 100644
index 0000000..3abdc77
--- /dev/null
+++ b/tools/rrdbot-get.c
@@ -0,0 +1,393 @@
+/*
+ * Copyright (c) 2005, Nate Nielsen
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * * Redistributions of source code must retain the above
+ * copyright notice, this list of conditions and the
+ * following disclaimer.
+ * * Redistributions in binary form must reproduce the
+ * above copyright notice, this list of conditions and
+ * the following disclaimer in the documentation and/or
+ * other materials provided with the distribution.
+ * * The names of contributors to this software may not be
+ * used to endorse or promote products derived from this
+ * software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+ * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
+ * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+ * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+ * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
+ * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
+ * DAMAGE.
+ *
+ *
+ * CONTRIBUTORS
+ * Nate Nielsen <nielsen@memberwebs.com>
+ *
+ */
+
+#include "usuals.h"
+#include <errno.h>
+#include <unistd.h>
+#include <syslog.h>
+#include <err.h>
+
+#include <bsnmp/asn1.h>
+#include <bsnmp/snmp.h>
+#include <mib/mib-parser.h>
+
+#include "sock-any.h"
+#include "server-mainloop.h"
+#include "config-parser.h"
+
+/* The socket to use */
+static int snmp_socket = -1;
+
+/* Since we only deal with one packet at a time, global buffer */
+static unsigned char snmp_buffer[0x1000];
+
+/* The actual request data */
+static struct snmp_pdu snmp_data;
+
+/* The first OID we've done */
+static struct asn_oid oid_first;
+
+/* The remote host */
+static struct sockaddr_any snmp_hostaddr;
+static char* snmp_hostname = NULL;
+
+static int retries = 0;
+
+/* Whether we're going recursive or not */
+static int recursive = 0;
+
+/* -----------------------------------------------------------------------------
+ * DUMMY CONFIG FUNCTIONS
+ */
+
+int
+cfg_value(const char* filename, const char* header, const char* name,
+ char* value, void* data)
+{
+ return 0;
+}
+
+int
+cfg_error(const char* filename, const char* errmsg, void* data)
+{
+ return 0;
+}
+
+/* -----------------------------------------------------------------------------
+ * SNMP ENGINE
+ */
+
+static void
+send_req()
+{
+ struct asn_buf b;
+ ssize_t ret;
+
+ b.asn_ptr = snmp_buffer;
+ b.asn_len = sizeof(snmp_buffer);
+
+ if(snmp_pdu_encode(&snmp_data, &b))
+ errx(1, "couldn't encode snmp buffer");
+
+ ret = sendto(snmp_socket, snmp_buffer, b.asn_ptr - snmp_buffer, 0,
+ &SANY_ADDR(snmp_hostaddr), SANY_LEN(snmp_hostaddr));
+ if(ret == -1)
+ err(1, "couldn't send snmp packet to: %s", snmp_hostname);
+
+}
+
+static void
+setup_req(char* uri)
+{
+ const char* msg;
+ char* scheme;
+ char* copy;
+ char* user;
+ char* path;
+
+ /* Parse the SNMP URI */
+ copy = strdup(uri);
+ msg = cfg_parse_uri(uri, &scheme, &snmp_hostname, &user, &path);
+ if(msg)
+ errx(2, "%s: %s", msg, copy);
+ free(copy);
+
+ ASSERT(host && path);
+
+ /* Currently we only support SNMP pollers */
+ if(strcmp(scheme, "snmp") != 0)
+ errx(2, "invalid scheme: %s", scheme);
+
+ if(sock_any_pton(snmp_hostname, &snmp_hostaddr,
+ SANY_OPT_DEFPORT(161) | SANY_OPT_DEFLOCAL) == -1)
+ err(1, "couldn't resolve host address (ignoring): %s", snmp_hostname);
+
+ memset(&snmp_data, 0, sizeof(snmp_data));
+ snmp_data.version = 1;
+ snmp_data.request_id = 0;
+ snmp_data.type = recursive ? SNMP_PDU_GETNEXT : SNMP_PDU_GET;
+ snmp_data.error_status = 0;
+ snmp_data.error_index = 0;
+ strlcpy(snmp_data.community, user ? user : "public",
+ sizeof(snmp_data.community));
+
+
+ /* And parse the OID */
+ snmp_data.bindings[0].syntax = 0;
+ if(mib_parse(path, &(snmp_data.bindings[0])) == -1)
+ errx(2, "invalid MIB: %s", path);
+
+ /* Add an item to this request */
+ snmp_data.nbindings = 1;
+
+ /* Keep track of top for recursiveness */
+ memcpy(&oid_first, &(snmp_data.bindings[0].var), sizeof(oid_first));
+
+}
+
+static void
+setup_next(struct snmp_value* value)
+{
+ snmp_data.request_id++;
+ snmp_data.type = SNMP_PDU_GETNEXT;
+
+ /* And parse the OID */
+ memcpy(&(snmp_data.bindings[0]), value, sizeof(struct snmp_value));
+ snmp_data.bindings[0].syntax = 0;
+ snmp_data.nbindings = 1;
+}
+
+
+static int
+print_resp(struct snmp_pdu* pdu, uint64_t when)
+{
+ struct snmp_value* value;
+ char *t;
+ int i;
+
+ ASSERT(req->id == pdu->request_id);
+
+ for(i = 0; i < pdu->nbindings; i++)
+ {
+ value = &(pdu->bindings[i]);
+
+ printf("%s: ", asn_oid2str(&(value->var)));
+
+ switch(value->syntax)
+ {
+ case SNMP_SYNTAX_NULL:
+ printf("[null]\n");
+ break;
+ case SNMP_SYNTAX_INTEGER:
+ printf("%d\n", value->v.integer);
+ break;
+ case SNMP_SYNTAX_COUNTER:
+ case SNMP_SYNTAX_GAUGE:
+ case SNMP_SYNTAX_TIMETICKS:
+ printf("%d\n", value->v.uint32);
+ break;
+ case SNMP_SYNTAX_COUNTER64:
+ printf("%lld\n", value->v.counter64);
+ break;
+ case SNMP_SYNTAX_OCTETSTRING:
+ t = xcalloc(value->v.octetstring.len + 1);
+ memcpy(t, value->v.octetstring.octets, value->v.octetstring.len);
+ printf("%s\n", t);
+ free(t);
+ break;
+ case SNMP_SYNTAX_OID:
+ printf("%s\n", asn_oid2str(&(value->v.oid)));
+ break;
+ case SNMP_SYNTAX_IPADDRESS:
+ printf("%c.%c.%c.%c\n", value->v.ipaddress[0], value->v.ipaddress[1],
+ value->v.ipaddress[2], value->v.ipaddress[3]);
+ break;
+ case SNMP_SYNTAX_NOSUCHOBJECT:
+ printf("[field not available on snmp server]\n");
+ break;
+ case SNMP_SYNTAX_NOSUCHINSTANCE:
+ printf("[no such instance on snmp server]\n");
+ break;
+ case SNMP_SYNTAX_ENDOFMIBVIEW:
+ return 0;
+ default:
+ printf("[unknown]\n");
+ break;
+ }
+ }
+
+ return 1;
+}
+
+static void
+receive_resp(int fd, int type, void* arg)
+{
+ char hostname[MAXPATHLEN];
+ struct sockaddr_any from;
+ struct snmp_pdu pdu;
+ struct snmp_value *val;
+ struct asn_buf b;
+ const char* msg;
+ int len, ret, subid;
+ int32_t ip;
+
+ ASSERT(snmp_socket == fd);
+
+ /* Read in the packet */
+
+ SANY_LEN(from) = sizeof(from);
+ len = recvfrom(snmp_socket, snmp_buffer, sizeof(snmp_buffer), 0,
+ &SANY_ADDR(from), &SANY_LEN(from));
+ if(len < 0)
+ {
+ if(errno != EAGAIN && errno != EWOULDBLOCK)
+ err(1, "error receiving snmp packet from network");
+ }
+
+ if(sock_any_ntop(&from, hostname, MAXPATHLEN, 0) == -1)
+ strcpy(hostname, "[UNKNOWN]");
+
+ /* Now parse the packet */
+
+ b.asn_ptr = snmp_buffer;
+ b.asn_len = len;
+
+ ret = snmp_pdu_decode(&b, &pdu, &ip);
+ if(ret != SNMP_CODE_OK)
+ errx(1, "invalid snmp packet received from: %s", hostname);
+
+ /* It needs to match something we're waiting for */
+ if(pdu.request_id != snmp_data.request_id)
+ return;
+
+ /* Check for errors */
+ if(pdu.error_status != SNMP_ERR_NOERROR)
+ {
+ snmp_pdu_dump (&pdu);
+ msg = snmp_get_errmsg (pdu.error_status);
+ if(msg)
+ errx(1, "snmp error from host '%s': %s", hostname, msg);
+ else
+ errx(1, "unknown snmp error from host '%s': %d", hostname, pdu.error_status);
+ return;
+ }
+
+ subid = ret = 1;
+
+ if(pdu.nbindings > 0)
+ {
+ val = &(pdu.bindings[pdu.nbindings - 1]);
+ subid = asn_compare_oid(&oid_first, &(val->var)) == 0 ||
+ asn_is_suboid(&oid_first, &(val->var));
+ }
+
+ /* Print the packet values */
+ if(!recursive || subid)
+ ret = print_resp(&pdu, server_get_time());
+
+ if(ret && recursive && subid)
+ {
+ /* If recursive, move onto next one */
+ setup_next(&(pdu.bindings[pdu.nbindings - 1]));
+ send_req();
+ return;
+ }
+
+ server_stop ();
+}
+
+/* -----------------------------------------------------------------------------
+ * STARTUP
+ */
+
+static void
+usage()
+{
+ fprintf(stderr, "usage: rrdbot-get [-nr] snmp://community@host/oid\n");
+ fprintf(stderr, " rrdbot-get -V\n");
+ exit(2);
+}
+
+static void
+version()
+{
+ printf("rrdbot-get (version %s)\n", VERSION);
+ exit(0);
+}
+
+int
+main(int argc, char* argv[])
+{
+ struct sockaddr_in addr;
+ int numeric = 0;
+ char ch;
+
+ /* Parse the arguments nicely */
+ while((ch = getopt(argc, argv, "nrV")) != -1)
+ {
+ switch(ch)
+ {
+
+ /* Numeric output */
+ case 'n':
+ numeric = 1;
+ break;
+
+ /* SNMP walk (recursive)*/
+ case 'r':
+ recursive = 1;
+ break;
+
+ /* Print version number */
+ case 'V':
+ version();
+ break;
+
+ /* Usage information */
+ case '?':
+ default:
+ usage();
+ break;
+ }
+ }
+
+ argc -= optind;
+ argv += optind;
+
+ if(argc != 1)
+ usage();
+
+ setup_req (argv[0]);
+
+ /* Setup the SNMP socket */
+ snmp_socket = socket(PF_INET, SOCK_DGRAM, 0);
+ if(snmp_socket < 0)
+ err(1, "couldn't open snmp socket");
+ memset(&addr, 0, sizeof(addr));
+ addr.sin_family = AF_INET;
+ if(bind(snmp_socket, (struct sockaddr*)&addr, sizeof(addr)) < 0)
+ err(1, "couldn't listen on port");
+ if(server_watch(snmp_socket, SERVER_READ, receive_resp, NULL) == -1)
+ err(1, "couldn't listen on socket");
+
+ send_req();
+
+ server_run();
+
+ return 0;
+}