/*
- * $Id: snmp_core.cc,v 1.12 1998/09/29 16:33:51 wessels Exp $
+ * $Id: snmp_core.cc,v 1.13 1998/11/11 20:04:19 glenn Exp $
*
* DEBUG: section 49 SNMP support
- * AUTHOR: Kostas Anagnostakis
+ * AUTHOR: Glenn Chisholm
*
* SQUID Internet Object Cache http://squid.nlanr.net/Squid/
* ----------------------------------------------------------
* 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., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
*
*/
-
-/**********************************************************************
- *
- * Copyright 1996 by Carnegie Mellon University
- *
- * All Rights Reserved
- *
- * Permission to use, copy, modify, and distribute this software and its
- * documentation for any purpose and without fee is hereby granted,
- * provided that the above copyright notice appear in all copies and that
- * both that copyright notice and this permission notice appear in
- * supporting documentation, and that the name of CMU not be
- * used in advertising or publicity pertaining to distribution of the
- * software without specific, written prior permission.
- *
- * CMU DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
- * ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHAL
- * CMU BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR
- * ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
- * WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,
- * ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS
- * SOFTWARE.
- *
- * Author: Ryan Troll <ryan+@andrew.cmu.edu>
- *
- **********************************************************************/
-
-
#include "squid.h"
-
#include "cache_snmp.h"
-#include "squid_mib.h"
#define SNMP_REQUEST_SIZE 4096
#define MAX_PROTOSTAT 5
-int snmp_dump_packet;
-void *users, *communities;
-
-static struct sockaddr_in local_snmpd;
-static int snmp_init_config = 0;
-struct snmp_session *Session;
-struct snmp_pdu *snmpAgentResponse(struct snmp_pdu *PDU);
-
-void snmpFwd_insertPending(struct sockaddr_in *, long);
-int snmpFwd_removePending(struct sockaddr_in *, long);
-
-extern void (*snmplib_debug_hook) (int, char *);
-static void snmpSnmplibDebug(int lvl, char *buf);
+struct _mib_tree_entry {
+ oid *name;
+ int len;
+ oid_ParseFn *parsefunction;
+ int children;
+ struct _mib_tree_entry **leaves;
+ struct _mib_tree_entry *parent;
+};
-struct snmpUdpData {
+struct _snmpUdpData {
struct sockaddr_in address;
void *msg;
int len;
- struct snmpUdpData *next;
+ struct _snmpUdpData *next;
};
-typedef struct snmpUdpData snmpUdpData;
-
-struct snmpFwdQueue {
- struct sockaddr_in addr;
- long req_id;
- time_t req_time;
- struct snmpFwdQueue *next;
-};
+typedef struct _snmpUdpData snmpUdpData;
+typedef struct _mib_tree_entry mib_tree_entry;
-struct snmpFwdQueue *snmpHead = NULL;
+mib_tree_entry *mib_tree_head;
+snmpUdpData *snmpUdpHead = NULL;
+snmpUdpData *snmpUdpTail = NULL;
-struct snmpUdpData *snmpUdpHead = NULL;
-struct snmpUdpData *snmpUdpTail = NULL;
+extern void (*snmplib_debug_hook) (int, char *);
-void snmpUdpReply(int, void *);
-void snmpAppendUdp(snmpUdpData *);
-void snmpUdpSend(int, const struct sockaddr_in *, void *, int);
+static void snmpDecodePacket(snmp_request_t * rq);
+static void snmpConstructReponse(snmp_request_t * rq, struct snmp_session *Session);
+static struct snmp_pdu* snmpAgentResponse(struct snmp_pdu *PDU);
-/* now include mib location definitions
- * and magic numbers */
+static void snmpUdpSend(int, const struct sockaddr_in *, void *, int);
+static void snmpUdpReply(int, void *);
+static void snmpAppendUdp(snmpUdpData *);
-#include "cache_snmp.h"
+static mib_tree_entry* snmpAddNode(oid *name, int len, oid_ParseFn *parsefunction, int children, ...);
+static oid_ParseFn *snmpTreeNext(oid *Current, snint CurrentLen, oid **Next, snint *NextLen);
+static mib_tree_entry* snmpTreeEntry(oid entry, snint len, mib_tree_entry *current);
-static void
-snmpSnmplibDebug(int lvl, char *buf)
-{
- debug(49, lvl) ("%s", buf);
-}
+static oid* snmpCreateOid(int length, ...);
+static oid* snmpOidDup(oid * A, snint ALen);
+static void snmpSnmplibDebug(int lvl, char *buf);
-void
-snmpHandleUdp(int sock, void *not_used)
-{
- struct sockaddr_in from;
- socklen_t from_len;
- LOCAL_ARRAY(char, buf, SNMP_REQUEST_SIZE);
- LOCAL_ARRAY(char, deb_line, 4096);
- int len;
- snmp_request_t *snmp_rq;
- debug(49, 5) ("snmpHandleUdp: Called.\n");
- commSetSelect(sock, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
- from_len = sizeof(struct sockaddr_in);
- memset(&from, '\0', from_len);
- Counter.syscalls.sock.recvfroms++;
- len = recvfrom(sock,
- buf,
- SNMP_REQUEST_SIZE,
- 0,
- (struct sockaddr *) &from,
- &from_len);
- if (len < 0) {
-#ifdef _SQUID_LINUX_
- /* Some Linux systems seem to set the FD for reading and then
- * return ECONNREFUSED when sendto() fails and generates an ICMP
- * port unreachable message. */
- /* or maybe an EHOSTUNREACH "No route to host" message */
- if (errno != ECONNREFUSED && errno != EHOSTUNREACH)
-#endif
- debug(49, 1) ("snmpHandleUdp: FD %d recvfrom: %s\n",
- sock, xstrerror());
- return;
- }
- if (snmp_dump_packet) {
- int count;
- debug(49, 6) ("received %d bytes from %s:\n", (int) len,
- inet_ntoa(from.sin_addr));
- for (count = 0; count < len; count++) {
- snprintf(deb_line, 4096, "%s %02X ", deb_line, (u_char) buf[count]);
- if ((count % 16) == 15 || count == (len - 1)) {
- debug(49, 8) ("snmp in: %s\n", deb_line);
- deb_line[0] = '\0';
- }
- }
- }
- buf[len] = '\0';
- debug(49, 3) ("snmpHandleUdp: FD %d: received %d bytes from %s.\n",
- sock,
- len,
- inet_ntoa(from.sin_addr));
-
- snmp_rq = xcalloc(1, sizeof(snmp_request_t));
- snmp_rq->buf = (u_char *) buf;
- snmp_rq->len = len;
- snmp_rq->sock = sock;
- snmp_rq->outbuf = xmalloc(snmp_rq->outlen = SNMP_REQUEST_SIZE);
- memcpy(&snmp_rq->from, &from, sizeof(struct sockaddr_in));
- snmpAgentParse(snmp_rq);
-}
-
-void
-snmpAgentParseDone(int errstat, void *data)
-{
- snmp_request_t *snmp_rq = (snmp_request_t *) data;
- LOCAL_ARRAY(char, deb_line, 4096);
- int sock = snmp_rq->sock;
- long this_reqid = snmp_rq->reqid;
- debug(49, 2) ("snmpAgentParseDone: errstat=%d, reqid=%d _t=%x\n",
- errstat, this_reqid, snmp_rq);
-
- if (memcmp(&snmp_rq->from, &local_snmpd, sizeof(struct sockaddr_in)) == 0) {
- /* look it up */
- if (snmpFwd_removePending(&snmp_rq->from, this_reqid)) { /* failed */
- debug(49, 2) ("snmp: bogus response from %s.\n",
- inet_ntoa(snmp_rq->from.sin_addr));
- if (snmp_rq->community)
- xfree(snmp_rq->community);
- xfree(snmp_rq->outbuf);
- xfree(snmp_rq);
- return;
- }
- }
- switch (errstat) {
- case 2: /* we might have to forward */
- if (Config.Snmp.localPort != 0) {
- snmpFwd_insertPending(&snmp_rq->from, this_reqid);
- snmpUdpSend(sock, &local_snmpd, snmp_rq->outbuf, snmp_rq->outlen);
- break;
- }
- debug(49, 4) ("snmp: can't forward.\n");
- break;
- case 1: /* everything is ok */
- debug(49, 5) ("snmp: parsed.\n");
- if (snmp_dump_packet) {
- int count = 0;
- debug(49, 5) ("snmp: sent %d bytes to %s\n", (int) snmp_rq->outlen,
- inet_ntoa(snmp_rq->from.sin_addr));
- for (count = 0; count < snmp_rq->outlen; count++) {
- snprintf(deb_line, 4096, "%s %02X ", deb_line,
- (u_char) snmp_rq->outbuf[count]);
- if ((count % 16) == 15 || count == (snmp_rq->len - 1)) {
- debug(49, 7) ("snmp out: %s\n", deb_line);
- deb_line[0] = '\0';
- }
- }
- }
- snmpUdpSend(snmp_rq->sock, &snmp_rq->from, snmp_rq->outbuf, snmp_rq->outlen);
- break;
- case 0:
- debug(49, 5) ("snmpagentparsedone failed\n");
- if (snmp_rq->outbuf)
- xfree(snmp_rq->outbuf);
- break;
- }
- if (snmp_rq->community)
- xfree(snmp_rq->community);
- cbdataFree(snmp_rq);
- return;
-}
+/*
+ * The functions used during startup:
+ * snmpInit
+ * snmpConnectionOpen
+ * snmpConnectionShutdown
+ * snmpConnectionClose
+ */
+/*
+ Turns the MIB into a Tree structure. Called during the startup process.
+*/
void
snmpInit(void)
{
- assert(NULL != Config.Snmp.mibPath);
- if (!snmpInitConfig())
- debug(49, 0) ("snmpInit: snmpInitConfig() failed.\n");
+ debug(49, 5) ("snmpInit: Called.\n");
+
+ debug(49, 5) ("snmpInit: Building SNMP mib tree structure\n");
+
snmplib_debug_hook = snmpSnmplibDebug;
-}
-int
-snmpInitConfig()
-{
- wordlist *w;
- char *buf;
- char *tokens[10];
-
- if (snmp_init_config)
- return 1;
-
- snmp_init_config = 1;
- assert(NULL != Config.Snmp.mibPath);
- if (Mib == NULL) {
- debug(49, 3) ("init_mib: calling with %s\n", Config.Snmp.mibPath);
- init_mib(Config.Snmp.mibPath);
- }
- if (Mib == NULL) {
- debug(49, 0) ("WARNING: Failed to open MIB '%s'\n",
- Config.Snmp.mibPath);
- return 0;
- }
- /*
- * Process 'snmp_agent_conf' lines
- */
- for (w = Config.Snmp.snmpconf; w != NULL; w = w->next) {
- buf = xstrdup(w->key);
- snmpTokenize(buf, tokens, 10);
- if (0 == strcmp("view", tokens[0])) {
- if (snmpCreateView(tokens) < 0) {
- debug(49, 1) ("snmpInit: error parsing '%s'\n", w->key);
- safe_free(buf);
- return 0;
- }
- } else if (0 == strcmp("user", tokens[0])) {
- if (snmpCreateUser(tokens) < 0) {
- debug(49, 1) ("snmpInit: error parsing '%s'\n", w->key);
- safe_free(buf);
- return 0;
- }
- } else if (0 == strcmp("community", tokens[0])) {
- if (snmpCreateCommunity(tokens) < 0)
- debug(49, 1) ("snmpInit: error parsing '%s'\n", w->key);
- } else {
- debug(49, 1) ("snmpInit: error parsing '%s'\n", w->key);
- safe_free(buf);
- return 0;
- }
- safe_free(buf);
- }
- if (!Config.Snmp.communities) {
- debug(49, 2) ("snmpInit: WARNING: communities not defined.\n");
- } else
- debug(49, 5) ("snmpInit: communities defined.\n");
- snmpInitAgentAuth();
- assert(0 <= snmpDefaultAuth());
- return 1;
+ mib_tree_head = snmpAddNode(snmpCreateOid(1, 1),
+ 1, NULL, 1,
+ snmpAddNode(snmpCreateOid(2, 1, 3),
+ 2, NULL, 1,
+ snmpAddNode(snmpCreateOid(3, 1, 3, 6),
+ 3, NULL, 1,
+ snmpAddNode(snmpCreateOid(4, 1, 3, 6, 1),
+ 4, NULL, 1,
+ snmpAddNode(snmpCreateOid(5, 1, 3, 6, 1, 4),
+ 5, NULL, 1,
+ snmpAddNode(snmpCreateOid(6, 1, 3, 6, 1, 4, 1),
+ 6, NULL, 1,
+ snmpAddNode(snmpCreateOid(7, 1, 3, 6, 1, 4, 1, 3495),
+ 7, NULL, 1,
+ snmpAddNode(snmpCreateOid(LEN_SQUIDMIB, SQUIDMIB),
+ 8, NULL, 5,
+ snmpAddNode(snmpCreateOid(LEN_SQ_SYS, SQ_SYS),
+ LEN_SQ_SYS, NULL, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 1),
+ LEN_SQ_SYS + 1, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 2),
+ LEN_SQ_SYS + 1, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 3),
+ LEN_SQ_SYS + 1, snmp_sysFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF, SQ_CONF),
+ LEN_SQ_CONF, NULL, 5,
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 1),
+ LEN_SQ_CONF + 1, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 2),
+ LEN_SQ_CONF + 1, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 3),
+ LEN_SQ_CONF + 1, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 4),
+ LEN_SQ_CONF + 1, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 5),
+ LEN_SQ_CONF + 1, NULL, 6,
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 1),
+ LEN_SQ_CONF + 2, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 2),
+ LEN_SQ_CONF + 2, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 3),
+ LEN_SQ_CONF + 2, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 4),
+ LEN_SQ_CONF + 2, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 5),
+ LEN_SQ_CONF + 2, snmp_confFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 6),
+ LEN_SQ_CONF + 2, snmp_confFn, 0))),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF, SQ_PRF),
+ LEN_SQ_PRF, snmp_confFn, 2,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 1, SQ_PRF, 1),
+ LEN_SQ_PRF + 1, snmp_sysFn, 11,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 1),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 2),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 3),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 4),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 5),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 6),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 7),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 8),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 9),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 10),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 11),
+ LEN_SQ_PRF + 2, snmp_sysFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 1, SQ_PRF, 2),
+ LEN_SQ_PRF + 1, snmp_sysFn, 2,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 2, 1),
+ LEN_SQ_PRF + 2, snmp_sysFn, 14,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 1),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 2),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 3),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 4),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 5),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 6),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 7),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 8),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 9),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 10),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 11),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 12),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 13),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 14),
+ LEN_SQ_PRF + 3, snmp_sysFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 2, 2),
+ LEN_SQ_PRF + 2, snmp_sysFn, 1,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 2, 1),
+ LEN_SQ_PRF + 3, snmp_sysFn, 8,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 1),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 2),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 3),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 4),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 5),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 6),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 7),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 8),
+ LEN_SQ_PRF + 4, snmp_sysFn, 0))))),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET, SQ_NET),
+ LEN_SQ_NET, snmp_confFn, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 1),
+ LEN_SQ_NET + 1, snmp_sysFn, 9,
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 1),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 2),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 3),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 4),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 5),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 6),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 7),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 8),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 9),
+ LEN_SQ_NET + 2, snmp_sysFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 2),
+ LEN_SQ_NET + 1, snmp_sysFn, 8,
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 1),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 2),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 3),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 4),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 5),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 6),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 7),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 8),
+ LEN_SQ_NET + 2, snmp_sysFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 3),
+ LEN_SQ_NET + 1, snmp_sysFn, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 1),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 2),
+ LEN_SQ_NET + 2, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 3),
+ LEN_SQ_NET + 2, snmp_sysFn, 0))),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH, SQ_MESH),
+ LEN_SQ_MESH, snmp_confFn, 2,
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 1, SQ_MESH, 1),
+ LEN_SQ_MESH + 1, snmp_sysFn, 1,
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 2, SQ_MESH, 1, 1),
+ LEN_SQ_MESH + 2, snmp_sysFn, 13,
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 1),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 2),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 3),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 4),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 5),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 6),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 7),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 8),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 9),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 10),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 11),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 12),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 13),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0))),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 1, SQ_MESH, 2),
+ LEN_SQ_MESH + 1, snmp_sysFn, 1,
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 2, SQ_MESH, 2, 1),
+ LEN_SQ_MESH + 2, snmp_sysFn, 9,
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 1),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 2),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 3),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 4),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 5),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 6),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 7),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 8),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 9),
+ LEN_SQ_MESH + 3, snmp_sysFn, 0))))
+ )
+ )
+ )
+ )
+ )
+ )
+ )
+ );
+
+ debug(49, 9) ("snmpInit: Completed SNMP mib tree structure\n");
}
void
snmpConnectionOpen(void)
{
u_short port;
- struct in_addr addr;
struct sockaddr_in xaddr;
socklen_t len;
int x;
+ debug(49, 5) ("snmpConnectionOpen: Called\n");
if ((port = Config.Port.snmp) > (u_short) 0) {
- enter_suid();
- theInSnmpConnection = comm_open(SOCK_DGRAM,
- 0,
- Config.Addrs.snmp_incoming,
- port,
- COMM_NONBLOCKING,
- "SNMP Port");
- leave_suid();
- if (theInSnmpConnection < 0)
- fatal("Cannot open snmp Port");
- commSetSelect(theInSnmpConnection, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
- debug(1, 1) ("Accepting SNMP messages on port %d, FD %d.\n",
- (int) port, theInSnmpConnection);
- if ((addr = Config.Addrs.snmp_outgoing).s_addr != no_addr.s_addr) {
- enter_suid();
- theOutSnmpConnection = comm_open(SOCK_DGRAM,
- 0,
- addr,
- port,
- COMM_NONBLOCKING,
- "SNMP Port");
- leave_suid();
- if (theOutSnmpConnection < 0)
- fatal("Cannot open Outgoing SNMP Port");
- commSetSelect(theOutSnmpConnection,
- COMM_SELECT_READ,
- snmpHandleUdp,
- NULL, 0);
- debug(1, 1) ("Outgoing SNMP messages on port %d, FD %d.\n",
- (int) port, theOutSnmpConnection);
- fd_note(theOutSnmpConnection, "Outgoing SNMP socket");
- fd_note(theInSnmpConnection, "Incoming SNMP socket");
- } else {
- theOutSnmpConnection = theInSnmpConnection;
- }
- memset(&theOutSNMPAddr, '\0', sizeof(struct in_addr));
- len = sizeof(struct sockaddr_in);
- memset(&xaddr, '\0', len);
- x = getsockname(theOutSnmpConnection,
- (struct sockaddr *) &xaddr, &len);
- if (x < 0)
- debug(51, 1) ("theOutSnmpConnection FD %d: getsockname: %s\n",
- theOutSnmpConnection, xstrerror());
- else {
- theOutSNMPAddr = xaddr.sin_addr;
- if (Config.Snmp.localPort != 0) {
- local_snmpd.sin_addr = xaddr.sin_addr;
- local_snmpd.sin_port = Config.Snmp.localPort;
- }
- }
+ enter_suid();
+ theInSnmpConnection = comm_open(SOCK_DGRAM,
+ 0,
+ Config.Addrs.snmp_incoming,
+ port,
+ COMM_NONBLOCKING,
+ "SNMP Port");
+ leave_suid();
+ if (theInSnmpConnection < 0)
+ fatal("Cannot open snmp Port");
+ commSetSelect(theInSnmpConnection, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
+ debug(1, 1) ("Accepting SNMP messages on port %d, FD %d.\n",
+ (int) port, theInSnmpConnection);
+ if (Config.Addrs.snmp_outgoing.s_addr != no_addr.s_addr) {
+ enter_suid();
+ theOutSnmpConnection = comm_open(SOCK_DGRAM,
+ 0,
+ Config.Addrs.snmp_outgoing,
+ port,
+ COMM_NONBLOCKING,
+ "SNMP Port");
+ leave_suid();
+ if (theOutSnmpConnection < 0)
+ fatal("Cannot open Outgoing SNMP Port");
+ commSetSelect(theOutSnmpConnection,
+ COMM_SELECT_READ,
+ snmpHandleUdp,
+ NULL, 0);
+ debug(1, 1) ("Outgoing SNMP messages on port %d, FD %d.\n",
+ (int) port, theOutSnmpConnection);
+ fd_note(theOutSnmpConnection, "Outgoing SNMP socket");
+ fd_note(theInSnmpConnection, "Incoming SNMP socket");
+ } else {
+ theOutSnmpConnection = theInSnmpConnection;
+ }
+ memset(&theOutSNMPAddr, '\0', sizeof(struct in_addr));
+ len = sizeof(struct sockaddr_in);
+ memset(&xaddr, '\0', len);
+ x = getsockname(theOutSnmpConnection,
+ (struct sockaddr *) &xaddr, &len);
+ if (x < 0)
+ debug(51, 1) ("theOutSnmpConnection FD %d: getsockname: %s\n",
+ theOutSnmpConnection, xstrerror());
+ else
+ theOutSNMPAddr = xaddr.sin_addr;
}
}
-void
-snmpFwd_insertPending(struct sockaddr_in *ad, long reqid)
-{
- struct snmpFwdQueue *new;
-
- new = (struct snmpFwdQueue *) xcalloc(1, sizeof(struct snmpFwdQueue));
- xmemcpy(&new->addr, ad, sizeof(struct sockaddr_in));
- new->req_id = reqid;
- new->req_time = squid_curtime;
- if (snmpHead == NULL) {
- new->next = NULL;
- snmpHead = new;
- }
- new->next = snmpHead;
- snmpHead = new;
-}
-
-int
-snmpFwd_removePending(struct sockaddr_in *fr, long reqid)
-{
- struct snmpFwdQueue *p, *prev = NULL;
- for (p = snmpHead; p != NULL; p = p->next, prev = p)
- if (reqid == p->req_id) {
- xmemcpy(fr, &p->addr, sizeof(struct sockaddr_in));
- if (p == snmpHead)
- snmpHead = p->next;
- else if (p->next == NULL)
- prev->next = NULL;
- debug(49, 3) ("snmpFwd_removePending: freeing %p\n", p);
- xfree(p);
- return 0;
- }
- return 1;
-}
-
-void
-snmpUdpSend(int fd,
- const struct sockaddr_in *to,
- void *msg, int len)
-{
- snmpUdpData *data = xcalloc(1, sizeof(snmpUdpData));
- debug(49, 5) ("snmpUdpSend: Queueing response for %s\n",
- inet_ntoa(to->sin_addr));
- data->address = *to;
- data->msg = msg;
- data->len = len;
- snmpAppendUdp(data);
- commSetSelect(fd, COMM_SELECT_WRITE, snmpUdpReply, snmpUdpHead, 0);
-
-}
-void
-snmpUdpReply(int fd, void *data)
-{
- snmpUdpData *queue = data;
- int x;
- /* Disable handler, in case of errors. */
- commSetSelect(fd, COMM_SELECT_WRITE, NULL, NULL, 0);
- while ((queue = snmpUdpHead) != NULL) {
- debug(49, 5) ("snmpUdpReply: FD %d sending %d bytes to %s port %d\n",
- fd,
- queue->len,
- inet_ntoa(queue->address.sin_addr),
- ntohs(queue->address.sin_port));
- x = comm_udp_sendto(fd,
- &queue->address,
- sizeof(struct sockaddr_in),
- queue->msg,
- queue->len);
- if (x < 0) {
- if (ignoreErrno(errno))
- break; /* don't de-queue */
- }
- snmpUdpHead = queue->next;
- debug(49, 3) ("snmpUdpReply: freeing %p\n", queue->msg);
- safe_free(queue->msg);
- debug(49, 3) ("snmpUdpReply: freeing %p\n", queue);
- safe_free(queue);
- }
- /* Reinstate handler if needed */
- if (snmpUdpHead) {
- commSetSelect(fd, COMM_SELECT_WRITE, snmpUdpReply, snmpUdpHead, 0);
- }
-}
-
-void
-snmpAppendUdp(snmpUdpData * item)
-{
- item->next = NULL;
- if (snmpUdpHead == NULL) {
- snmpUdpHead = item;
- snmpUdpTail = item;
- } else if (snmpUdpTail == snmpUdpHead) {
- snmpUdpTail = item;
- snmpUdpHead->next = item;
- } else {
- snmpUdpTail->next = item;
- snmpUdpTail = item;
- }
-
-}
-
void
snmpConnectionShutdown(void)
{
if (theInSnmpConnection < 0)
- return;
+ return;
if (theInSnmpConnection != theOutSnmpConnection) {
- debug(49, 1) ("FD %d Closing SNMP socket\n", theInSnmpConnection);
- comm_close(theInSnmpConnection);
+ debug(49, 1) ("FD %d Closing SNMP socket\n", theInSnmpConnection);
+ comm_close(theInSnmpConnection);
}
/*
* Here we set 'theInSnmpConnection' to -1 even though the SNMP 'in'
* function from executing repeatedly. When we are really ready to
* exit or restart, main will comm_close the 'out' descriptor.
*/ theInSnmpConnection = -1;
- /*
+ /*
* Normally we only write to the outgoing SNMP socket, but we
* also have a read handler there to catch messages sent to that
* specific interface. During shutdown, we must disable reading
{
snmpConnectionShutdown();
if (theOutSnmpConnection > -1) {
- debug(49, 1) ("FD %d Closing SNMP socket\n", theOutSnmpConnection);
- comm_close(theOutSnmpConnection);
+ debug(49, 1) ("FD %d Closing SNMP socket\n", theOutSnmpConnection);
+ comm_close(theOutSnmpConnection);
}
}
-/* returns:
- * 2: no such object in this mib
- * 1: ok
- * 0: failed */
+/*
+ Functions for handling the requests.
+*/
+/*
+ * Accept the UDP packet
+ */
void
-snmpAgentParse(void *data)
+snmpHandleUdp(int sock, void *not_used)
{
- snmp_request_t *rq = (snmp_request_t *) data;
- u_char *buf = rq->buf;
- int len = rq->len;
+ LOCAL_ARRAY(char, buf, SNMP_REQUEST_SIZE);
+ struct sockaddr_in from;
+ socklen_t from_len;
+ snmp_request_t *snmp_rq;
+ int len;
+
+ debug(49, 5) ("snmpHandleUdp: Called.\n");
+
+ commSetSelect(sock, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
+ from_len = sizeof(struct sockaddr_in);
+ memset(&from, '\0', from_len);
+
+ Counter.syscalls.sock.recvfroms++;
+
+ len = recvfrom(sock,
+ buf,
+ SNMP_REQUEST_SIZE,
+ 0,
+ (struct sockaddr *) &from,
+ &from_len);
+
+ if (len > 0) {
+ buf[len] = '\0';
+ debug(49, 3) ("snmpHandleUdp: FD %d: received %d bytes from %s.\n",
+ sock,
+ len,
+ inet_ntoa(from.sin_addr));
+
+ snmp_rq = xcalloc(1, sizeof(snmp_request_t));
+ snmp_rq->buf = (u_char *) buf;
+ snmp_rq->len = len;
+ snmp_rq->sock = sock;
+ snmp_rq->outbuf = xmalloc(snmp_rq->outlen = SNMP_REQUEST_SIZE);
+ memcpy(&snmp_rq->from, &from, sizeof(struct sockaddr_in));
+ snmpDecodePacket(snmp_rq);
+ } else {
+ debug(49, 1) ("snmpHandleUdp: FD %d recvfrom: %s\n", sock, xstrerror());
+ }
+}
+/*
+ * Turn SNMP packet into a PDU, check available ACL's
+ */
+void
+snmpDecodePacket(snmp_request_t * rq)
+{
struct snmp_pdu *PDU;
+ struct snmp_session *Session;
+ aclCheck_t checklist;
u_char *Community;
+ u_char *buf = rq->buf;
+ int len = rq->len;
+ int allow = 0;
+ debug(49, 5) ("snmpDecodePacket: Called.\n");
/* Now that we have the data, turn it into a PDU */
+ Session = (struct snmp_session *) xmalloc(sizeof(struct snmp_session));
+ Session->Version = SNMP_VERSION_1;
+ Session->authenticator = NULL;
+ Session->community = (u_char *) xstrdup("public");
+ Session->community_len = 6;
cbdataAdd(rq, MEM_NONE);
PDU = snmp_pdu_create(0);
Community = snmp_parse(Session, PDU, buf, len);
- if (!snmp_coexist_V2toV1(PDU)) { /* incompatibility */
- debug(49, 3) ("snmpAgentParse: Incompatible V2 packet.\n");
+ checklist.src_addr = rq->from.sin_addr;
+ checklist.snmp_community = Community;
+
+ allow = aclCheckFast(Config.accessList.snmp, &checklist);
+ if ((snmp_coexist_V2toV1(PDU)) && (Community) && (allow)) {
+ rq->community = Community;
+ rq->PDU = PDU;
+ debug(49, 5) ("snmpAgentParse: reqid=[%d]\n", PDU->reqid);
+ snmpConstructReponse(rq, Session);
+ } else {
snmp_free_pdu(PDU);
- snmpAgentParseDone(0, rq);
- return;
}
- rq->community = Community;
- rq->PDU = PDU;
- debug(49, 5) ("snmpAgentParse: reqid=[%d]\n", PDU->reqid);
+}
- if (!Community) {
- debug(49, 2) ("snmpAgentParse: WARNING: Could not parse community\n");
+/*
+ * Packet OK, ACL Check OK, Create reponse.
+ */
+void
+snmpConstructReponse(snmp_request_t * rq, struct snmp_session *Session)
+{
+ struct snmp_pdu *RespPDU;
+ int ret;
- snmp_free_pdu(PDU);
- snmpAgentParseDone(0, rq);
- return;
+ debug(49, 5) ("snmpConstructReponse: Called.\n");
+
+ Session->community = rq->community;
+ Session->community_len = strlen((char *) rq->community);
+
+ RespPDU = snmpAgentResponse(rq->PDU);
+ snmp_free_pdu(rq->PDU);
+ xfree(Session);
+ if (RespPDU == NULL) {
+ } else {
+ ret = snmp_build(Session, RespPDU, rq->outbuf, &rq->outlen);
+ snmpUdpSend(rq->sock, &rq->from, rq->outbuf, rq->outlen);
+ snmp_free_pdu(RespPDU);
}
- snmpAclCheckStart(rq);
}
+/*
+ * Decide how to respond to the request, construct a response and
+ * return the response to the requester.
+ *
+ * If configured forward any reponses which are not for this agent.
+ */
struct snmp_pdu *
snmpAgentResponse(struct snmp_pdu *PDU)
{
struct snmp_pdu *Answer = NULL;
- variable_list *VarPtr, *VarNew = NULL;
- variable_list **VarPtrP, **RespVars;
- int index = 0;
- oid_ParseFn *ParseFn;
-
- debug(49, 9) ("snmpAgentResponse: Received a %d PDU\n", PDU->command);
+ oid_ParseFn *ParseFn = NULL;
+ variable_list *VarNew = NULL;
- /* Create a response */
- Answer = snmp_pdu_create(SNMP_PDU_RESPONSE);
- if (Answer == NULL)
- return (NULL);
- Answer->reqid = PDU->reqid;
- Answer->errindex = 0;
+ debug(49, 5) ("snmpAgentResponse: Called.\n");
- if (PDU->command == SNMP_PDU_GET) {
+ if ((Answer = snmp_pdu_create(SNMP_PDU_RESPONSE))) {
+ Answer->reqid = PDU->reqid;
+ Answer->errindex = 0;
+ if (PDU->command == SNMP_PDU_GET) {
- RespVars = &(Answer->variables);
- /* Loop through all variables */
- for (VarPtrP = &(PDU->variables);
- *VarPtrP;
- VarPtrP = &((*VarPtrP)->next_variable)) {
- VarPtr = *VarPtrP;
+ } else if (PDU->command == SNMP_PDU_GETNEXT) {
+ oid *NextOidName = NULL;
+ int NextOidNameLen = 0;
- index++;
-
- /* Find the parsing function for this variable */
- ParseFn = oidlist_Find(VarPtr->name, VarPtr->name_length);
+ ParseFn = snmpTreeNext(PDU->variables->name, PDU->variables->name_length,
+ &(NextOidName), (snint *) &NextOidNameLen);
if (ParseFn == NULL) {
Answer->errstat = SNMP_ERR_NOSUCHNAME;
- debug(49, 5) ("snmpAgentResponse: No such oid. ");
- } else
- VarNew = (*ParseFn) (VarPtr, (snint *) & (Answer->errstat));
+ debug(49, 5) ("snmpAgentResponse: No such oid: ");
+ snmpDebugOid(5, PDU->variables->name, PDU->variables->name_length);
+ } else {
+ xfree(PDU->variables->name);
+ PDU->variables->name = NextOidName;
+ PDU->variables->name_length = NextOidNameLen;
+ VarNew = (*ParseFn) (PDU->variables, (snint *) &Answer->errstat);
+ }
/* Was there an error? */
- if ((Answer->errstat != SNMP_ERR_NOERROR) ||
- (VarNew == NULL)) {
- Answer->errindex = index;
- debug(49, 5) ("snmpAgentParse: successful.\n");
- /* Just copy the rest of the variables. Quickly. */
- *RespVars = VarPtr;
- *VarPtrP = NULL;
- return (Answer);
+ if (Answer->errstat != SNMP_ERR_NOERROR) {
+ Answer->errindex = 1;
+
+ /* Just copy this variable */
+ Answer->variables = PDU->variables;
+ PDU->variables = NULL;
+ } else {
+ Answer->variables = VarNew;
}
- /* No error. Insert this var at the end, and move on to the next.
- */
- *RespVars = VarNew;
- RespVars = &(VarNew->next_variable);
- }
- return (Answer);
- } else if (PDU->command == SNMP_PDU_GETNEXT) {
- oid *TmpOidName;
- int TmpOidNameLen = 0;
-
- /* Find the next OID. */
- VarPtr = PDU->variables;
-
- ParseFn = oidlist_Next(VarPtr->name, VarPtr->name_length,
- &(TmpOidName), (snint *) & (TmpOidNameLen));
-
- if (ParseFn == NULL) {
- Answer->errstat = SNMP_ERR_NOSUCHNAME;
- debug(49, 5) ("snmpAgentResponse: No such oid: ");
- snmpDebugOid(5, VarPtr->name, VarPtr->name_length);
- } else {
- xfree(VarPtr->name);
- VarPtr->name = TmpOidName;
- VarPtr->name_length = TmpOidNameLen;
- VarNew = (*ParseFn) (VarPtr, (snint *) & (Answer->errstat));
+
+ }else{
+ snmp_free_pdu(Answer);
+ Answer = NULL;
}
+ }
+ return (Answer);
+}
- /* Was there an error? */
- if (Answer->errstat != SNMP_ERR_NOERROR) {
- Answer->errindex = 1;
+oid_ParseFn *
+snmpTreeNext(oid * Current, snint CurrentLen, oid ** Next, snint * NextLen)
+{
+ oid_ParseFn *Fn = NULL;
+ mib_tree_entry *mibTreeEntry = NULL, *new_oid = NULL;
+ int count = 0;
+
+ debug(49, 5) ("snmpTreeNext: Called\n");
+
+ debug(49, 6) ("snmpTreeNext: Current : \n");
+ snmpDebugOid(6, Current, CurrentLen);
- /* Just copy this variable */
- Answer->variables = VarPtr;
- PDU->variables = NULL;
- } else {
- Answer->variables = VarNew;
+ mibTreeEntry = mib_tree_head;
+ if (Current[count] == mibTreeEntry->name[count]) {
+ count++;
+ while ((mibTreeEntry) && (count < CurrentLen)) {
+ mibTreeEntry = snmpTreeEntry(Current[count], count , mibTreeEntry);
+ count++;
}
+ debug(49, 5) ("snmpTreeNext: Past first\n");
+
+ if (mibTreeEntry->parsefunction) {
+ while(!new_oid){
+ new_oid = snmpTreeEntry(Current[count]+1, count , mibTreeEntry->parent);
+ if(!new_oid){
+ mibTreeEntry = mibTreeEntry->parent;
+ count--;
+ }
+ }
+ }
+ debug(49, 5) ("snmpTreeNext: Past Second\n");
- /* Done. Return this PDU */
- return (Answer);
- } /* end SNMP_PDU_GETNEXT */
- debug(49, 5) ("snmpAgentResponse: Ignoring PDU %d unknown command\n", PDU->command);
- snmp_free_pdu(Answer);
- return (NULL);
+ if ((!mibTreeEntry->parsefunction) && (mibTreeEntry)) {
+ while (!mibTreeEntry->parsefunction) {
+ mibTreeEntry = snmpTreeEntry(1, count , mibTreeEntry);
+ count++;
+ }
+ }
+ debug(49, 5) ("snmpTreeNext: Past Third\n");
+ }
+ if(mibTreeEntry){
+ *Next = snmpOidDup(mibTreeEntry->name, mibTreeEntry->len);
+ *NextLen = mibTreeEntry->len;
+ Fn = mibTreeEntry->parsefunction;
+ }
+ debug(49, 5) ("snmpTreeNext: return\n");
+ return (Fn);
}
-void
-snmpDebugOid(int lvl, oid * Name, snint Len)
+mib_tree_entry *
+snmpTreeEntry(oid entry, snint len, mib_tree_entry * current)
{
- char mbuf[16], objid[1024];
- int x;
- objid[0] = '\0';
+ mib_tree_entry *next = NULL;
+ int count = 0;
- for (x = 0; x < Len; x++) {
- snprintf(mbuf, sizeof(mbuf), ".%u", (unsigned int) Name[x]);
- strncat(objid, mbuf, sizeof(objid));
- }
+ debug(49, 5) ("snmpTreeEntry: Called\n");
- debug(49, lvl) (" oid = %s\n", objid);
-}
+ debug(49, 6) ("snmpTreeEntry: Oid: %d, Len: %d, Current : \n",entry, len);
+ snmpDebugOid(6, current->name, current->len);
-int
-oidcmp(oid * A, snint ALen, oid * B, snint BLen)
-{
- oid *aptr = A;
- oid *bptr = B;
- snint m = MIN(ALen, BLen);
-
- /* Compare the first M bytes. */
- while (m) {
- if (*aptr < *bptr)
- return (-1);
- if (*aptr++ > *bptr++)
- return (1);
- m--;
+ while ((!next) && (count < current->children)) {
+ debug(49, 6) ("snmpTreeEntry: While loop count: %d, children: %d \n", count, current->children);
+ snmpDebugOid(6, current->leaves[count]->name, current->leaves[count]->len);
+ if (current->leaves[count]->name[len] == entry) {
+ next = current->leaves[count];
+ }
+ count++;
}
+ if(next){
+ debug(49, 6) ("snmpTreeEntry: Returned : \n");
+ snmpDebugOid(6, next->name, next->len);
+ }
+ return (next);
+}
- /* The first M bytes were identical. So, they share the same
- * root. The shorter one must come first.
- */
- if (ALen < BLen)
- return (-1);
+/*
+ Send the UDP reply.
+*/
+void
+snmpUdpSend(int fd, const struct sockaddr_in *to, void *msg, int len)
+{
+ snmpUdpData *data = xcalloc(1, sizeof(snmpUdpData));
+ debug(49, 5) ("snmpUdpSend: Queueing response for %s\n",
+ inet_ntoa(to->sin_addr));
+ data->address = *to;
+ data->msg = msg;
+ data->len = len;
+ snmpAppendUdp(data);
+ commSetSelect(fd, COMM_SELECT_WRITE, snmpUdpReply, snmpUdpHead, 0);
- if (ALen > BLen)
- return (1);
+}
- /* Same length, all bytes identical. Must be the same OID. */
- return (0);
+void
+snmpUdpReply(int fd, void *data)
+{
+ snmpUdpData *queue = data;
+ int x;
+ /* Disable handler, in case of errors. */
+ commSetSelect(fd, COMM_SELECT_WRITE, NULL, NULL, 0);
+ while ((queue = snmpUdpHead) != NULL) {
+ debug(49, 5) ("snmpUdpReply: FD %d sending %d bytes to %s port %d\n",
+ fd,
+ queue->len,
+ inet_ntoa(queue->address.sin_addr),
+ ntohs(queue->address.sin_port));
+ x = comm_udp_sendto(fd,
+ &queue->address,
+ sizeof(struct sockaddr_in),
+ queue->msg,
+ queue->len);
+ if (x < 0) {
+ if (ignoreErrno(errno))
+ break; /* don't de-queue */
+ }
+ snmpUdpHead = queue->next;
+ debug(49, 3) ("snmpUdpReply: freeing %p\n", queue->msg);
+ safe_free(queue->msg);
+ debug(49, 3) ("snmpUdpReply: freeing %p\n", queue);
+ safe_free(queue);
+ }
+ /* Reinstate handler if needed */
+ if (snmpUdpHead) {
+ commSetSelect(fd, COMM_SELECT_WRITE, snmpUdpReply, snmpUdpHead, 0);
+ }
}
-int
-oidncmp(oid * A, snint ALen, oid * B, snint BLen, snint CompLen)
+void
+snmpAppendUdp(snmpUdpData * item)
{
- oid *aptr = A;
- oid *bptr = B;
- snint m = MIN(MIN(ALen, BLen), CompLen);
- snint count = 0;
-
- /* Compare the first M bytes. */
- while (count != m) {
- if (*aptr < *bptr)
- return (-1);
- if (*aptr++ > *bptr++)
- return (1);
- count++;
+ item->next = NULL;
+ if (snmpUdpHead == NULL) {
+ snmpUdpHead = item;
+ snmpUdpTail = item;
+ } else if (snmpUdpTail == snmpUdpHead) {
+ snmpUdpTail = item;
+ snmpUdpHead->next = item;
+ } else {
+ snmpUdpTail->next = item;
+ snmpUdpTail = item;
}
- if (m == CompLen)
- return (0);
+}
+/*
+ Utility functions
+*/
- if (ALen < BLen)
- return (-1);
+/*
+ Tree utility functions.
+*/
- if (ALen > BLen)
- return (1);
+/*
+ Adds a node to the MIB tree structure and adds the appropriate children
+*/
+mib_tree_entry*
+snmpAddNode(oid *name, int len, oid_ParseFn *parsefunction, int children, ...)
+{
+ va_list args;
+ int loop;
+ mib_tree_entry *entry = NULL;
+
+ debug(49, 6) ("snmpAddNode: Children : %d, Oid : \n", children);
+ snmpDebugOid(6, name, len);
+
+ va_start(args, children);
+ entry = xmalloc(sizeof(mib_tree_entry));
+ entry->name = snmpOidDup(name, len);
+ entry->len = len;
+ entry->parsefunction = parsefunction;
+ entry->children = children;
+
+ if(children > 0){
+ entry->leaves = xmalloc(sizeof(mib_tree_entry*)*children);
+ for(loop = 0;loop < children;loop++){
+ entry->leaves[loop] = va_arg(args, mib_tree_entry*);
+ entry->leaves[loop]->parent = entry;
+ }
+ }
+ return(entry);
+}
+/* End of tree utility functions */
- /* Same length, all bytes identical. Must be the same OID. */
- return (0);
+/*
+ Returns the list of parameters in an oid[]
+*/
+oid*
+snmpCreateOid(int length, ...)
+{
+ va_list args;
+ oid *new_oid;
+ int loop;
+
+ va_start(args, length);
+ new_oid = xmalloc(sizeof(oid)*length);
+
+ if(length > 0){
+ for(loop = 0;loop < length;loop++){
+ new_oid[loop] = va_arg(args, int);
+ }
+ }
+ return(new_oid);
}
-/* Allocate space for, and copy, an OID. Returns new oid, or NULL.
+/*
+ Allocate space for, and copy, an OID. Returns new oid, or NULL.
*/
oid *
-oiddup(oid * A, snint ALen)
+snmpOidDup(oid * A, snint ALen)
{
oid *Ans;
-
- Ans = (oid *) xmalloc(sizeof(oid) * ALen);
+
+ Ans = (oid *) xmalloc(sizeof(oid) * ALen);
if (Ans)
- memcpy(Ans, A, (sizeof(oid) * ALen));
+ memcpy(Ans, A, (sizeof(oid) * ALen));
return (Ans);
}
+/*
+ Debug calls, prints out the OID for debugging purposes.
+*/
+void
+snmpDebugOid(int lvl, oid * Name, snint Len)
+{
+ char mbuf[16], objid[1024];
+ int x;
+ objid[0] = '\0';
-/**********************************************************************
- * OIDLIST FUNCTIONS
- *
- * Find the parsing function for OIDs registered in this agent.
- **********************************************************************/
-
-oid_ParseFn *
-oidlist_Find(oid * Src, snint SrcLen)
-{
- struct MIBListEntry *Ptr;
- int ret;
-
- debug(49, 7) ("oidlist_Find: Called.\n ");
- snmpDebugOid(7, Src, SrcLen);
-
- for (Ptr = squidMIBList; Ptr->GetFn; Ptr++) {
-
- ret = oidncmp(Src, SrcLen, Ptr->Name, Ptr->NameLen, Ptr->NameLen);
-
- if (!ret) {
-
- /* Cool. We found the mib it's in. Let it find the function.
- */
- debug(49, 7) ("oidlist_Find: found, returning GetFn Ptr! \n");
-
- return ((*Ptr->GetFn) (Src, SrcLen));
- }
- if (ret < 0) {
- debug(49, 7) ("oidlist_Find: We just passed it, so it doesn't exist.\n ");
- /* We just passed it, so it doesn't exist. */
- return (NULL);
- }
+ for (x = 0; x < Len; x++) {
+ snprintf(mbuf, sizeof(mbuf), ".%u", (unsigned int) Name[x]);
+ strncat(objid, mbuf, sizeof(objid));
}
-
- debug(49, 5) ("oidlist_Find: the request was past the end. It doesn't exist.\n");
- /* We get here if the request was past the end. It doesn't exist. */
- return (NULL);
+
+ debug(49, lvl) (" oid = %s\n", objid);
}
-/* Find the next item. For SNMP_PDU_GETNEXT requests.
- *
- * Returns a pointer to the parser function, and copies the oid to dest.
- *
- * This is just plain ugly and needs a total rewrite, these changes are
- * to make it work, nothing else!
- *
- */
-oid_ParseFn *
-oidlist_Next(oid * Src, snint SrcLen, oid ** DestP, snint * DestLenP)
-{
- struct MIBListEntry *Ptr;
- int ret;
- oid_ParseFn *Fn = NULL;
-
- debug(49, 7) ("oidlist_Next: Looking for next of:\n");
- snmpDebugOid(7, Src, SrcLen);
-
- for (Ptr = squidMIBList; Ptr->GetNextFn; Ptr++) {
-
- /* Only look at as much as we have stored */
- ret = oidncmp(Src, SrcLen, Ptr->Name, Ptr->NameLen, Ptr->NameLen);
- if (!ret) {
- debug(49, 6) ("oidlist_Next: Checking MIB\n");
-
- /* Cool. We found the mib it's in. Ask it.
- */
- while (Ptr != NULL && Ptr->GetNextFn) {
- Fn = ((*Ptr->GetNextFn) (Src, SrcLen, DestP, DestLenP));
- if (Fn == NULL) {
- /* If this returned NULL, we're looking for the first
- * in the next MIB.
- */
- debug(49, 6) ("oidlist_Next: Not in this entry. Trying next.\n");
- Ptr++;
- continue;
- }
- return Fn;
- }
- /* Return what we found. NULL if it wasn't in the MIB, and there
- * were no more MIBs.
- */
- debug(49, 3) ("oidlist_Next: No next mib.\n");
- return NULL;
- }
- if (ret < 0) {
- /* We just passed the mib it would be in. Return
- * the next in this MIB.
- */
- debug(49, 3) ("oidlist_Next: Passed mib. Checking this one.\n");
- while (Ptr != NULL && Ptr->GetNextFn) {
- Fn = ((*Ptr->GetNextFn) (Src, SrcLen, DestP, DestLenP));
- if (Fn == NULL && oidncmp(Src, SrcLen, Ptr->Name, Ptr->NameLen, Ptr->NameLen) < 0) {
- debug(49, 6) ("oidlist_Next: Not in this entry. Trying next.\n");
- Ptr++;
- continue;
- } else {
- return Fn;
- }
- }
- debug(49, 3) ("oidlist_Next: No next mib.\n");
- return NULL;
- }
- }
+static void
+snmpSnmplibDebug(int lvl, char *buf)
+{
+ debug(49, lvl) ("%s", buf);
+}
- /* We get here if the request was past the end. It doesn't exist. */
- debug(49, 7) ("oidlist_Next: Found nothing.\n");
- return (NULL);
-}
-struct in_addr *
-gen_getMax()
-{
- static struct in_addr maddr;
-#if USE_ICMP
- safe_inet_addr("255.255.255.255", &maddr);
-#else
- safe_inet_addr("0.0.0.0", &maddr);
-#endif
- return &maddr;
-}
projects / thirdparty / squid.git / commitdiff
