开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 代理服务器 > 查看源码
snmp_core.c
资源名称：squid-2.2.devel3-src.tar.gz　[点击查看]
上传用户：liugui
上传日期：2007-01-04
资源大小：822k
文件大小：38k
源码类别：

代理服务器

开发平台：

Unix_Linux

snmp_core.c：源码内容
  1. /*
  2.  * $Id: snmp_core.c,v 1.34.2.1 1999/02/14 08:35:01 wessels Exp $
  3.  *
  4.  * DEBUG: section 49    SNMP support
  5.  * AUTHOR: Glenn Chisholm
  6.  *
  7.  * SQUID Internet Object Cache  http://squid.nlanr.net/Squid/
  8.  * ----------------------------------------------------------
  9.  *
  10.  *  Squid is the result of efforts by numerous individuals from the
  11.  *  Internet community.  Development is led by Duane Wessels of the
  12.  *  National Laboratory for Applied Network Research and funded by the
  13.  *  National Science Foundation.  Squid is Copyrighted (C) 1998 by
  14.  *  Duane Wessels and the University of California San Diego.  Please
  15.  *  see the COPYRIGHT file for full details.  Squid incorporates
  16.  *  software developed and/or copyrighted by other sources.  Please see
  17.  *  the CREDITS file for full details.
  18.  *
  19.  *  This program is free software; you can redistribute it and/or modify
  20.  *  it under the terms of the GNU General Public License as published by
  21.  *  the Free Software Foundation; either version 2 of the License, or
  22.  *  (at your option) any later version.
  23.  *
  24.  *  This program is distributed in the hope that it will be useful,
  25.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  26.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  27.  *  GNU General Public License for more details.
  28.  *
  29.  *  You should have received a copy of the GNU General Public License
  30.  *  along with this program; if not, write to the Free Software
  31.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
  32.  *
  33.  */
  34. #include "squid.h"
  35. #include "cache_snmp.h"
  37. #define SNMP_REQUEST_SIZE 4096
  38. #define MAX_PROTOSTAT 5
  40. struct _mib_tree_entry {
  41.     oid *name;
  42.     int len;
  43.     oid_ParseFn *parsefunction;
  44.     int children;
  45.     struct _mib_tree_entry **leaves;
  46.     struct _mib_tree_entry *parent;
  47. };
  49. typedef struct _mib_tree_entry mib_tree_entry;
  51. mib_tree_entry *mib_tree_head;
  53. #if STDC_HEADERS
  54. static mib_tree_entry *snmpAddNode(oid * name, int len, oid_ParseFn * parsefunction, int children,...);
  55. static oid *snmpCreateOid(int length,...);
  56. #else
  57. static mib_tree_entry *snmpAddNode();
  58. static oid *snmpCreateOid();
  59. #endif
  60. extern void (*snmplib_debug_hook) (int, char *);
  61. static void snmpDecodePacket(snmp_request_t * rq);
  62. static void snmpConstructReponse(snmp_request_t * rq);
  63. static struct snmp_pdu *snmpAgentResponse(struct snmp_pdu *PDU);
  64. static oid_ParseFn *snmpTreeNext(oid * Current, snint CurrentLen, oid ** Next, snint * NextLen);
  65. static oid_ParseFn *snmpTreeGet(oid * Current, snint CurrentLen);
  66. static mib_tree_entry *snmpTreeEntry(oid entry, snint len, mib_tree_entry * current);
  67. static mib_tree_entry *snmpTreeSiblingEntry(oid entry, snint len, mib_tree_entry * current);
  68. static oid *snmpOidDup(oid * A, snint ALen);
  69. static void snmpSnmplibDebug(int lvl, char *buf);
  72. /*
  73.  * The functions used during startup:
  74.  * snmpInit
  75.  * snmpConnectionOpen
  76.  * snmpConnectionShutdown
  77.  * snmpConnectionClose
  78.  */
  80. /*
  81.  * Turns the MIB into a Tree structure. Called during the startup process.
  82.  */
  83. void
  84. snmpInit(void)
  85. {
  86.     debug(49, 5) ("snmpInit: Called.n");
  88.     debug(49, 5) ("snmpInit: Building SNMP mib tree structuren");
  90.     snmplib_debug_hook = snmpSnmplibDebug;
  92.     mib_tree_head = snmpAddNode(snmpCreateOid(1, 1),
  93. 1, NULL, 1,
  94. snmpAddNode(snmpCreateOid(2, 1, 3),
  95.     2, NULL, 1,
  96.     snmpAddNode(snmpCreateOid(3, 1, 3, 6),
  97. 3, NULL, 1,
  98. snmpAddNode(snmpCreateOid(4, 1, 3, 6, 1),
  99.     4, NULL, 1,
  100.     snmpAddNode(snmpCreateOid(5, 1, 3, 6, 1, 4),
  101. 5, NULL, 1,
  102. snmpAddNode(snmpCreateOid(6, 1, 3, 6, 1, 4, 1),
  103.     6, NULL, 1,
  104.     snmpAddNode(snmpCreateOid(7, 1, 3, 6, 1, 4, 1, 3495),
  105. 7, NULL, 1,
  106. snmpAddNode(snmpCreateOid(LEN_SQUIDMIB, SQUIDMIB),
  107.     8, NULL, 5,
  108.     snmpAddNode(snmpCreateOid(LEN_SQ_SYS, SQ_SYS),
  109. LEN_SQ_SYS, NULL, 3,
  110. snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 1),
  111.     LEN_SQ_SYS + 1, snmp_sysFn, 1,
  112.     snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 2, SQ_SYS, 1, 0),
  113. LEN_SQ_SYS + 2, snmp_sysFn, 0)),
  114. snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 2),
  115.     LEN_SQ_SYS + 1, snmp_sysFn, 1,
  116.     snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 2, SQ_SYS, 2, 0),
  117. LEN_SQ_SYS + 2, snmp_sysFn, 0)),
  118. snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 1, SQ_SYS, 3),
  119.     LEN_SQ_SYS + 1, snmp_sysFn, 1,
  120.     snmpAddNode(snmpCreateOid(LEN_SQ_SYS + 2, SQ_SYS, 3, 0),
  121. LEN_SQ_SYS + 2, snmp_sysFn, 0))),
  122.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF, SQ_CONF),
  123. LEN_SQ_CONF, NULL, 5,
  124. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 1),
  125.     LEN_SQ_CONF + 1, snmp_confFn, 1,
  126.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 1, 0),
  127. LEN_SQ_CONF + 2, snmp_confFn, 0)),
  128. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 2),
  129.     LEN_SQ_CONF + 1, snmp_confFn, 1,
  130.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 2, 0),
  131. LEN_SQ_CONF + 2, snmp_confFn, 0)),
  132. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 3),
  133.     LEN_SQ_CONF + 1, snmp_confFn, 1,
  134.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 3, 0),
  135. LEN_SQ_CONF + 2, snmp_confFn, 0)),
  136. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 4),
  137.     LEN_SQ_CONF + 1, snmp_confFn, 1,
  138.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 4, 0),
  139. LEN_SQ_CONF + 2, snmp_confFn, 0)),
  140. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 1, SQ_CONF, 5),
  141.     LEN_SQ_CONF + 1, NULL, 4,
  142.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 1),
  143. LEN_SQ_CONF + 2, snmp_confFn, 1,
  144. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 3, SQ_CONF, 5, 1, 0),
  145.     LEN_SQ_CONF + 3, snmp_confFn, 0)),
  146.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 2),
  147. LEN_SQ_CONF + 2, snmp_confFn, 1,
  148. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 3, SQ_CONF, 5, 2, 0),
  149.     LEN_SQ_CONF + 3, snmp_confFn, 0)),
  150.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 3),
  151. LEN_SQ_CONF + 2, snmp_confFn, 1,
  152. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 3, SQ_CONF, 5, 3, 0),
  153.     LEN_SQ_CONF + 3, snmp_confFn, 0)),
  154.     snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 2, SQ_CONF, 5, 4),
  155. LEN_SQ_CONF + 2, snmp_confFn, 1,
  156. snmpAddNode(snmpCreateOid(LEN_SQ_CONF + 3, SQ_CONF, 5, 4, 0),
  157.     LEN_SQ_CONF + 3, snmp_confFn, 0)))),
  158.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF, SQ_PRF),
  159. LEN_SQ_PRF, NULL, 2,
  160. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 1, SQ_PRF, 1),
  161.     LEN_SQ_PRF + 1, NULL, 11,
  162.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 1),
  163. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  164. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 1, 0),
  165.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  166.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 2),
  167. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  168. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 2, 0),
  169.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  170.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 3),
  171. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  172. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 3, 0),
  173.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  174.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 4),
  175. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  176. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 4, 0),
  177.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  178.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 5),
  179. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  180. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 5, 0),
  181.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  182.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 6),
  183. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  184. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 6, 0),
  185.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  186.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 7),
  187. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  188. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 7, 0),
  189.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  190.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 8),
  191. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  192. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 8, 0),
  193.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  194.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 9),
  195. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  196. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 9, 0),
  197.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  198.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 10),
  199. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  200. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 10, 0),
  201.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0)),
  202.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 1, 11),
  203. LEN_SQ_PRF + 2, snmp_prfSysFn, 1,
  204. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 1, 11, 0),
  205.     LEN_SQ_PRF + 3, snmp_prfSysFn, 0))),
  206. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 1, SQ_PRF, 2),
  207.     LEN_SQ_PRF + 1, NULL, 2,
  208.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 2, 1),
  209. LEN_SQ_PRF + 2, NULL, 15,
  210. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 1),
  211.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  212.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 1, 0),
  213. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  214. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 2),
  215.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  216.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 2, 0),
  217. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  218. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 3),
  219.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  220.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 3, 0),
  221. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  222. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 4),
  223.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  224.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 4, 0),
  225. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  226. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 5),
  227.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  228.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 5, 0),
  229. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  230. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 6),
  231.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  232.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 6, 0),
  233. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  234. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 7),
  235.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  236.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 7, 0),
  237. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  238. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 8),
  239.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  240.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 8, 0),
  241. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  242. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 9),
  243.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  244.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 9, 0),
  245. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  246. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 10),
  247.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  248.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 10, 0),
  249. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  250. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 11),
  251.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  252.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 11, 0),
  253. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  254. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 12),
  255.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  256.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 12, 0),
  257. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  258. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 13),
  259.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  260.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 13, 0),
  261. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  262. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 14),
  263.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  264.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 14, 0),
  265. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0)),
  266. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 15),
  267.     LEN_SQ_PRF + 3, snmp_prfProtoFn, 1,
  268.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 1, 15, 0),
  269. LEN_SQ_PRF + 4, snmp_prfProtoFn, 0))),
  270.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 2, 2),
  271. LEN_SQ_PRF + 2, NULL, 1,
  272. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 2, 1),
  273.     LEN_SQ_PRF + 3, NULL, 10,
  274.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 1),
  275. LEN_SQ_PRF + 4, NULL, 3,
  276. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 1),
  277.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  278. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 5),
  279.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  280. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 60),
  281.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  282.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 2),
  283. LEN_SQ_PRF + 4, NULL, 3,
  284. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 1),
  285.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  286. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 5),
  287.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  288. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 60),
  289.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  290.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 3),
  291. LEN_SQ_PRF + 4, NULL, 3,
  292. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 1),
  293.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  294. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 5),
  295.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  296. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 60),
  297.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  298.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 4),
  299. LEN_SQ_PRF + 4, NULL, 3,
  300. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 1),
  301.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  302. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 5),
  303.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  304. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 60),
  305.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  306.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 5),
  307. LEN_SQ_PRF + 4, NULL, 3,
  308. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 1),
  309.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  310. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 5),
  311.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  312. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 60),
  313.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  314.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 6),
  315. LEN_SQ_PRF + 4, NULL, 3,
  316. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 1),
  317.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  318. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 5),
  319.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  320. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 60),
  321.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  322.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 7),
  323. LEN_SQ_PRF + 4, NULL, 3,
  324. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 1),
  325.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  326. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 5),
  327.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  328. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 60),
  329.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  330.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 8),
  331. LEN_SQ_PRF + 4, NULL, 3,
  332. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 1),
  333.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  334. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 5),
  335.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  336. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 60),
  337.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  338.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 9),
  339. LEN_SQ_PRF + 4, NULL, 3,
  340. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 1),
  341.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  342. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 5),
  343.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  344. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 60),
  345.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
  346.     snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 10),
  347. LEN_SQ_PRF + 4, NULL, 3,
  348. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 1),
  349.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  350. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 5),
  351.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
  352. snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 60),
  353.     LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)))))),
  354.     snmpAddNode(snmpCreateOid(LEN_SQ_NET, SQ_NET),
  355. LEN_SQ_NET, NULL, 3,
  356. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 1),
  357.     LEN_SQ_NET + 1, NULL, 8,
  358.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 1),
  359. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  360. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 1, 0),
  361.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  362.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 2),
  363. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  364. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 2, 0),
  365.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  366.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 3),
  367. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  368. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 3, 0),
  369.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  370.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 4),
  371. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  372. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 4, 0),
  373.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  374.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 5),
  375. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  376. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 5, 0),
  377.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  378.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 6),
  379. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  380. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 6, 0),
  381.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  382.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 7),
  383. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  384. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 7, 0),
  385.     LEN_SQ_NET + 3, snmp_netIpFn, 0)),
  386.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 1, 8),
  387. LEN_SQ_NET + 2, snmp_netIpFn, 1,
  388. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 1, 8, 0),
  389.     LEN_SQ_NET + 3, snmp_netIpFn, 0))),
  390. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 2),
  391.     LEN_SQ_NET + 1, NULL, 7,
  392.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 1),
  393. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  394. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 1, 0),
  395.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  396.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 2),
  397. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  398. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 2, 0),
  399.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  400.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 3),
  401. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  402. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 3, 0),
  403.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  404.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 4),
  405. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  406. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 4, 0),
  407.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  408.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 5),
  409. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  410. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 5, 0),
  411.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  412.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 6),
  413. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  414. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 6, 0),
  415.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0)),
  416.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 2, 7),
  417. LEN_SQ_NET + 2, snmp_netFqdnFn, 1,
  418. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 2, 7, 0),
  419.     LEN_SQ_NET + 3, snmp_netFqdnFn, 0))),
  420. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 3),
  421.     LEN_SQ_NET + 1, NULL, 3,
  422.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 1),
  423. LEN_SQ_NET + 2, snmp_netDnsFn, 1,
  424. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 3, 1, 0),
  425.     LEN_SQ_NET + 3, snmp_netDnsFn, 0)),
  426.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 2),
  427. LEN_SQ_NET + 2, snmp_netDnsFn, 1,
  428. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 3, 2, 0),
  429.     LEN_SQ_NET + 3, snmp_netDnsFn, 0)),
  430.     snmpAddNode(snmpCreateOid(LEN_SQ_NET + 2, SQ_NET, 3, 3),
  431. LEN_SQ_NET + 2, snmp_netDnsFn, 1,
  432. snmpAddNode(snmpCreateOid(LEN_SQ_NET + 3, SQ_NET, 3, 3, 0),
  433.     LEN_SQ_NET + 3, snmp_netDnsFn, 0)))),
  434.     snmpAddNode(snmpCreateOid(LEN_SQ_MESH, SQ_MESH),
  435. LEN_SQ_MESH, NULL, 2,
  436. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 1, SQ_MESH, 1),
  437.     LEN_SQ_MESH + 1, NULL, 1,
  438.     snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 2, SQ_MESH, 1, 1),
  439. LEN_SQ_MESH + 2, NULL, 13,
  440. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 1),
  441.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  442. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 2),
  443.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  444. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 3),
  445.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  446. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 4),
  447.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  448. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 5),
  449.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  450. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 6),
  451.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  452. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 7),
  453.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  454. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 8),
  455.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  456. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 9),
  457.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  458. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 10),
  459.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  460. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 11),
  461.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  462. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 12),
  463.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0),
  464. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 1, 1, 13),
  465.     LEN_SQ_MESH + 3, snmp_meshPtblFn, 0))),
  466. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 1, SQ_MESH, 2),
  467.     LEN_SQ_MESH + 1, NULL, 1,
  468.     snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 2, SQ_MESH, 2, 1),
  469. LEN_SQ_MESH + 2, NULL, 9,
  470. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 1),
  471.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  472. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 2),
  473.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  474. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 3),
  475.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  476. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 4),
  477.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  478. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 5),
  479.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  480. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 6),
  481.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  482. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 7),
  483.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  484. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 8),
  485.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0),
  486. snmpAddNode(snmpCreateOid(LEN_SQ_MESH + 3, SQ_MESH, 2, 1, 9),
  487.     LEN_SQ_MESH + 3, snmp_meshCtblFn, 0))))
  488. )
  489.     )
  490. )
  491.     )
  492. )
  493.     )
  494. )
  495. );
  497.     debug(49, 9) ("snmpInit: Completed SNMP mib tree structuren");
  498. }
  500. void
  501. snmpConnectionOpen(void)
  502. {
  503.     u_short port;
  504.     struct sockaddr_in xaddr;
  505.     socklen_t len;
  506.     int x;
  508.     debug(49, 5) ("snmpConnectionOpen: Calledn");
  509.     if ((port = Config.Port.snmp) > (u_short) 0) {
  510. enter_suid();
  511. theInSnmpConnection = comm_open(SOCK_DGRAM,
  512.     0,
  513.     Config.Addrs.snmp_incoming,
  514.     port,
  515.     COMM_NONBLOCKING,
  516.     "SNMP Port");
  517. leave_suid();
  518. if (theInSnmpConnection < 0)
  519.     fatal("Cannot open snmp Port");
  520. commSetSelect(theInSnmpConnection, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
  521. debug(1, 1) ("Accepting SNMP messages on port %d, FD %d.n",
  522.     (int) port, theInSnmpConnection);
  523. if (Config.Addrs.snmp_outgoing.s_addr != no_addr.s_addr) {
  524.     enter_suid();
  525.     theOutSnmpConnection = comm_open(SOCK_DGRAM,
  526. 0,
  527. Config.Addrs.snmp_outgoing,
  528. port,
  529. COMM_NONBLOCKING,
  530. "SNMP Port");
  531.     leave_suid();
  532.     if (theOutSnmpConnection < 0)
  533. fatal("Cannot open Outgoing SNMP Port");
  534.     commSetSelect(theOutSnmpConnection,
  535. COMM_SELECT_READ,
  536. snmpHandleUdp,
  537. NULL, 0);
  538.     debug(1, 1) ("Outgoing SNMP messages on port %d, FD %d.n",
  539. (int) port, theOutSnmpConnection);
  540.     fd_note(theOutSnmpConnection, "Outgoing SNMP socket");
  541.     fd_note(theInSnmpConnection, "Incoming SNMP socket");
  542. } else {
  543.     theOutSnmpConnection = theInSnmpConnection;
  544. }
  545. memset(&theOutSNMPAddr, '', sizeof(struct in_addr));
  546. len = sizeof(struct sockaddr_in);
  547. memset(&xaddr, '', len);
  548. x = getsockname(theOutSnmpConnection,
  549.     (struct sockaddr *) &xaddr, &len);
  550. if (x < 0)
  551.     debug(51, 1) ("theOutSnmpConnection FD %d: getsockname: %sn",
  552. theOutSnmpConnection, xstrerror());
  553. else
  554.     theOutSNMPAddr = xaddr.sin_addr;
  555.     }
  556. }
  558. void
  559. snmpConnectionShutdown(void)
  560. {
  561.     if (theInSnmpConnection < 0)
  562. return;
  563.     if (theInSnmpConnection != theOutSnmpConnection) {
  564. debug(49, 1) ("FD %d Closing SNMP socketn", theInSnmpConnection);
  565. comm_close(theInSnmpConnection);
  566.     }
  567.     /*
  568.      * Here we set 'theInSnmpConnection' to -1 even though the SNMP 'in'
  569.      * and 'out' sockets might be just one FD.  This prevents this
  570.      * function from executing repeatedly.  When we are really ready to
  571.      * exit or restart, main will comm_close the 'out' descriptor.
  572.      */ theInSnmpConnection = -1;
  573.     /*
  574.      * Normally we only write to the outgoing SNMP socket, but we
  575.      * also have a read handler there to catch messages sent to that
  576.      * specific interface.  During shutdown, we must disable reading
  577.      * on the outgoing socket.
  578.      */
  579.     assert(theOutSnmpConnection > -1);
  580.     commSetSelect(theOutSnmpConnection, COMM_SELECT_READ, NULL, NULL, 0);
  581. }
  583. void
  584. snmpConnectionClose(void)
  585. {
  586.     snmpConnectionShutdown();
  587.     if (theOutSnmpConnection > -1) {
  588. debug(49, 1) ("FD %d Closing SNMP socketn", theOutSnmpConnection);
  589. comm_close(theOutSnmpConnection);
  590.     }
  591. }
  593. /*
  594.  * Functions for handling the requests.
  595.  */
  597. /*
  598.  * Accept the UDP packet
  599.  */
  600. void
  601. snmpHandleUdp(int sock, void *not_used)
  602. {
  603.     LOCAL_ARRAY(char, buf, SNMP_REQUEST_SIZE);
  604.     struct sockaddr_in from;
  605.     socklen_t from_len;
  606.     snmp_request_t *snmp_rq;
  607.     int len;
  609.     debug(49, 5) ("snmpHandleUdp: Called.n");
  611.     commSetSelect(sock, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
  612.     from_len = sizeof(struct sockaddr_in);
  613.     memset(&from, '', from_len);
  615.     Counter.syscalls.sock.recvfroms++;
  617.     len = recvfrom(sock,
  618. buf,
  619. SNMP_REQUEST_SIZE,
  620. 0,
  621. (struct sockaddr *) &from,
  622. &from_len);
  624.     if (len > 0) {
  625. buf[len] = '';
  626. debug(49, 3) ("snmpHandleUdp: FD %d: received %d bytes from %s.n",
  627.     sock,
  628.     len,
  629.     inet_ntoa(from.sin_addr));
  631. snmp_rq = xcalloc(1, sizeof(snmp_request_t));
  632. snmp_rq->buf = (u_char *) buf;
  633. snmp_rq->len = len;
  634. snmp_rq->sock = sock;
  635. snmp_rq->outbuf = xmalloc(snmp_rq->outlen = SNMP_REQUEST_SIZE);
  636. xmemcpy(&snmp_rq->from, &from, sizeof(struct sockaddr_in));
  637. snmpDecodePacket(snmp_rq);
  638. xfree(snmp_rq);
  639.     } else {
  640. debug(49, 1) ("snmpHandleUdp: FD %d recvfrom: %sn", sock, xstrerror());
  641.     }
  642. }
  644. /*
  645.  * Turn SNMP packet into a PDU, check available ACL's
  646.  */
  647. void
  648. snmpDecodePacket(snmp_request_t * rq)
  649. {
  650.     struct snmp_pdu *PDU;
  651.     struct snmp_session Session;
  652.     aclCheck_t checklist;
  653.     u_char *Community;
  654.     u_char *buf = rq->buf;
  655.     int len = rq->len;
  656.     int allow = 0;
  658.     debug(49, 5) ("snmpDecodePacket: Called.n");
  659.     /* Now that we have the data, turn it into a PDU */
  660.     PDU = snmp_pdu_create(0);
  661.     Session.Version = SNMP_VERSION_1;
  662.     Community = snmp_parse(&Session, PDU, buf, len);
  664.     checklist.src_addr = rq->from.sin_addr;
  665.     checklist.snmp_community = (char *) Community;
  667.     allow = aclCheckFast(Config.accessList.snmp, &checklist);
  668.     if ((snmp_coexist_V2toV1(PDU)) && (Community) && (allow)) {
  669. rq->community = Community;
  670. rq->PDU = PDU;
  671. debug(49, 5) ("snmpAgentParse: reqid=[%d]n", PDU->reqid);
  672. snmpConstructReponse(rq);
  673.     } else {
  674. debug(49, 0) ("Failed SNMP agent query from : %s.n",
  675.     inet_ntoa(rq->from.sin_addr));
  676. snmp_free_pdu(PDU);
  677.     }
  678. }
  680. /*
  681.  * Packet OK, ACL Check OK, Create reponse.
  682.  */
  683. void
  684. snmpConstructReponse(snmp_request_t * rq)
  685. {
  686.     struct snmp_session Session;
  687.     struct snmp_pdu *RespPDU;
  688.     int ret;
  690.     debug(49, 5) ("snmpConstructReponse: Called.n");
  691.     RespPDU = snmpAgentResponse(rq->PDU);
  692.     snmp_free_pdu(rq->PDU);
  693.     if (RespPDU != NULL) {
  694. Session.Version = SNMP_VERSION_1;
  695. Session.community = rq->community;
  696. Session.community_len = strlen((char *) rq->community);
  697. ret = snmp_build(&Session, RespPDU, rq->outbuf, &rq->outlen);
  698. sendto(rq->sock, rq->outbuf, rq->outlen, 0, (struct sockaddr *) &rq->from, sizeof(rq->from));
  699. snmp_free_pdu(RespPDU);
  700. xfree(rq->outbuf);
  701.     }
  702. }
  704. /*
  705.  * Decide how to respond to the request, construct a response and
  706.  * return the response to the requester.
  707.  * 
  708.  * If configured forward any reponses which are not for this agent.
  709.  */
  710. struct snmp_pdu *
  711. snmpAgentResponse(struct snmp_pdu *PDU)
  712. {
  713.     struct snmp_pdu *Answer = NULL;
  714.     oid_ParseFn *ParseFn = NULL;
  716.     variable_list *VarPtr, *VarNew = NULL, **VarPtrP;
  717.     int index = 0;
  719.     debug(49, 5) ("snmpAgentResponse: Called.n");
  721.     if ((Answer = snmp_pdu_create(SNMP_PDU_RESPONSE))) {
  722. Answer->reqid = PDU->reqid;
  723. Answer->errindex = 0;
  724. if (PDU->command == SNMP_PDU_GET) {
  725.     variable_list **RespVars;
  727.     RespVars = &(Answer->variables);
  728.     /* Loop through all variables */
  729.     for (VarPtrP = &(PDU->variables);
  730. *VarPtrP;
  731. VarPtrP = &((*VarPtrP)->next_variable)) {
  732. VarPtr = *VarPtrP;
  734. index++;
  736. /* Find the parsing function for this variable */
  737. ParseFn = snmpTreeGet(VarPtr->name, VarPtr->name_length);
  739. if (ParseFn == NULL) {
  740.     Answer->errstat = SNMP_ERR_NOSUCHNAME;
  741.     debug(49, 5) ("snmpAgentResponse: No such oid. ");
  742. } else
  743.     VarNew = (*ParseFn) (VarPtr, (snint *) & (Answer->errstat));
  745. /* Was there an error? */
  746. if ((Answer->errstat != SNMP_ERR_NOERROR) ||
  747.     (VarNew == NULL)) {
  748.     Answer->errindex = index;
  749.     debug(49, 5) ("snmpAgentParse: successful.n");
  750.     /* Just copy the rest of the variables.  Quickly. */
  751.     *RespVars = VarPtr;
  752.     *VarPtrP = NULL;
  753.     return (Answer);
  754. }
  755. /* No error.  Insert this var at the end, and move on to the next.
  756.  */
  757. *RespVars = VarNew;
  758. RespVars = &(VarNew->next_variable);
  759.     }
  760.     return (Answer);
  761. } else if (PDU->command == SNMP_PDU_GETNEXT) {
  762.     oid *NextOidName = NULL;
  763.     int NextOidNameLen = 0;
  765.     ParseFn = snmpTreeNext(PDU->variables->name, PDU->variables->name_length,
  766. &(NextOidName), (snint *) & NextOidNameLen);
  768.     if (ParseFn == NULL) {
  769. Answer->errstat = SNMP_ERR_NOSUCHNAME;
  770. debug(49, 5) ("snmpAgentResponse: No such oid: ");
  771. snmpDebugOid(5, PDU->variables->name, PDU->variables->name_length);
  772.     } else {
  773. xfree(PDU->variables->name);
  774. PDU->variables->name = NextOidName;
  775. PDU->variables->name_length = NextOidNameLen;
  776. VarNew = (*ParseFn) (PDU->variables, (snint *) & Answer->errstat);
  777.     }
  779.     /* Was there an error? */
  780.     if (Answer->errstat != SNMP_ERR_NOERROR) {
  781. Answer->errindex = 1;
  782. Answer->variables = PDU->variables;
  783. PDU->variables = NULL;
  784.     } else {
  785. Answer->variables = VarNew;
  786.     }
  788. } else {
  789.     snmp_free_pdu(Answer);
  790.     Answer = NULL;
  791. }
  792.     }
  793.     return (Answer);
  794. }
  796. oid_ParseFn *
  797. snmpTreeGet(oid * Current, snint CurrentLen)
  798. {
  799.     oid_ParseFn *Fn = NULL;
  800.     mib_tree_entry *mibTreeEntry = NULL;
  801.     int count = 0;
  803.     debug(49, 5) ("snmpTreeGet: Calledn");
  805.     debug(49, 6) ("snmpTreeGet: Current : n");
  806.     snmpDebugOid(6, Current, CurrentLen);
  808.     mibTreeEntry = mib_tree_head;
  809.     if (Current[count] == mibTreeEntry->name[count]) {
  810. count++;
  811. while ((mibTreeEntry) && (count < CurrentLen)) {
  812.     mibTreeEntry = snmpTreeEntry(Current[count], count, mibTreeEntry);
  813.     count++;
  814. }
  815.     }
  816.     if (mibTreeEntry) {
  817. Fn = mibTreeEntry->parsefunction;
  818.     }
  819.     debug(49, 5) ("snmpTreeGet: returnn");
  820.     return (Fn);
  821. }
  823. oid_ParseFn *
  824. snmpTreeNext(oid * Current, snint CurrentLen, oid ** Next, snint * NextLen)
  825. {
  826.     oid_ParseFn *Fn = NULL;
  827.     mib_tree_entry *mibTreeEntry = NULL, *nextoid = NULL;
  828.     int count = 0;
  830.     debug(49, 5) ("snmpTreeNext: Calledn");
  832.     debug(49, 6) ("snmpTreeNext: Current : n");
  833.     snmpDebugOid(6, Current, CurrentLen);
  835.     mibTreeEntry = mib_tree_head;
  836.     if (Current[count] == mibTreeEntry->name[count]) {
  837. count++;
  838. while ((mibTreeEntry) && (count < CurrentLen)) {
  839.     mibTreeEntry = snmpTreeEntry(Current[count], count, mibTreeEntry);
  840.     count++;
  841. }
  842. debug(49, 5) ("snmpTreeNext: Recursed down to requested objectn");
  844. if ((mibTreeEntry) && (mibTreeEntry->parsefunction)) {
  845.     count--;
  846.     nextoid = snmpTreeSiblingEntry(Current[count], count, mibTreeEntry->parent);
  847.     if (nextoid) {
  848. mibTreeEntry = nextoid;
  849. count++;
  850.     } else {
  851. debug(49, 5) ("snmpTreeNext: Attempting to recurse up for next objectn");
  852. while (!nextoid) {
  853.     count--;
  854.     nextoid = mibTreeEntry->parent;
  855.     mibTreeEntry = snmpTreeEntry(Current[count] + 1, count, nextoid->parent);
  856.     if (!mibTreeEntry) {
  857. mibTreeEntry = nextoid;
  858. nextoid = NULL;
  859.     }
  860. }
  861.     }
  862. }
  863. debug(49, 5) ("snmpTreeNext: Past Secondn");
  865. while ((mibTreeEntry) && (!mibTreeEntry->parsefunction)) {
  866.     mibTreeEntry = mibTreeEntry->leaves[0];
  867. }
  869. if ((mibTreeEntry) && (mibTreeEntry->children == 1))
  870.     mibTreeEntry = mibTreeEntry->leaves[0];
  871.     }
  872.     if (mibTreeEntry) {
  873. *Next = snmpOidDup(mibTreeEntry->name, mibTreeEntry->len);
  874. *NextLen = mibTreeEntry->len;
  875. Fn = mibTreeEntry->parsefunction;
  876.     }
  877.     debug(49, 5) ("snmpTreeNext: returnn");
  878.     return (Fn);
  879. }
  881. mib_tree_entry *
  882. snmpTreeSiblingEntry(oid entry, snint len, mib_tree_entry * current)
  883. {
  884.     mib_tree_entry *next = NULL;
  885.     int count = 0;
  887.     while ((!next) && (count < current->children)) {
  888. if (current->leaves[count]->name[len] == entry) {
  889.     next = current->leaves[count];
  890. }
  891. count++;
  892.     }
  893.     if (count < current->children) {
  894. next = current->leaves[count];
  895.     } else {
  896. next = NULL;
  897.     }
  898.     return (next);
  899. }
  901. mib_tree_entry *
  902. snmpTreeEntry(oid entry, snint len, mib_tree_entry * current)
  903. {
  904.     mib_tree_entry *next = NULL;
  905.     int count = 0;
  907.     while ((!next) && (count < current->children)) {
  908. if (current->leaves[count]->name[len] == entry) {
  909.     next = current->leaves[count];
  910. }
  911. count++;
  912.     }
  913.     return (next);
  914. }
  916. /*
  917.  * Utility functions
  918.  */
  920. /*
  921.  * Tree utility functions. 
  922.  */
  924. /*
  925.  * Adds a node to the MIB tree structure and adds the appropriate children
  926.  */
  927. mib_tree_entry *
  928. #if STDC_HEADERS
  929. snmpAddNode(oid * name, int len, oid_ParseFn * parsefunction, int children,...)
  930. #else
  931. snmpAddNode(va_alist)
  932.      va_dcl
  933. #endif
  934. {
  935. #if STDC_HEADERS
  936.     va_list args;
  937.     int loop;
  938.     mib_tree_entry *entry = NULL;
  939.     va_start(args, children);
  940. #else
  941.     va_list args;
  942.     oid *name = NULL;
  943.     int len = 0, children = 0, loop;
  944.     oid_ParseFn *parsefunction = NULL;
  945.     mib_tree_entry *entry = NULL;
  946.     va_start(args);
  947.     name = va_arg(args, oid *);
  948.     len = va_arg(args, int);
  949.     parsefunction = va_arg(args, oid_ParseFn *);
  950.     children = va_arg(args, int);
  951. #endif
  953.     debug(49, 6) ("snmpAddNode: Children : %d, Oid : n", children);
  954.     snmpDebugOid(6, name, len);
  956.     va_start(args, children);
  957.     entry = xmalloc(sizeof(mib_tree_entry));
  958.     entry->name = snmpOidDup(name, len);
  959.     entry->len = len;
  960.     entry->parsefunction = parsefunction;
  961.     entry->children = children;
  963.     if (children > 0) {
  964. entry->leaves = xmalloc(sizeof(mib_tree_entry *) * children);
  965. for (loop = 0; loop < children; loop++) {
  966.     entry->leaves[loop] = va_arg(args, mib_tree_entry *);
  967.     entry->leaves[loop]->parent = entry;
  968. }
  969.     }
  970.     return (entry);
  971. }
  972. /* End of tree utility functions */
  974. /* 
  975.  * Returns the list of parameters in an oid
  976.  */
  977. oid *
  978. #if STDC_HEADERS
  979. snmpCreateOid(int length,...)
  980. #else
  981. snmpCreateOid(va_alist)
  982.      va_dcl
  983. #endif
  984. {
  985. #if STDC_HEADERS
  986.     va_list args;
  987.     oid *new_oid;
  988.     int loop;
  989.     va_start(args, length);
  990. #else
  991.     va_list args;
  992.     int length = 0, loop;
  993.     oid *new_oid;
  994.     va_start(args);
  995.     length va_arg(args, int);
  996. #endif
  998.     new_oid = xmalloc(sizeof(oid) * length);
  1000.     if (length > 0) {
  1001. for (loop = 0; loop < length; loop++) {
  1002.     new_oid[loop] = va_arg(args, int);
  1003. }
  1004.     }
  1005.     return (new_oid);
  1006. }
  1008. /*
  1009.  * Allocate space for, and copy, an OID.  Returns new oid.
  1010.  */
  1011. oid *
  1012. snmpOidDup(oid * A, snint ALen)
  1013. {
  1014.     oid *Ans = xmalloc(sizeof(oid) * ALen);
  1015.     xmemcpy(Ans, A, (sizeof(oid) * ALen));
  1016.     return Ans;
  1017. }
  1019. /*
  1020.  * Debug calls, prints out the OID for debugging purposes.
  1021.  */
  1022. void
  1023. snmpDebugOid(int lvl, oid * Name, snint Len)
  1024. {
  1025.     char mbuf[16], objid[1024];
  1026.     int x;
  1027.     objid[0] = '';
  1029.     for (x = 0; x < Len; x++) {
  1030. snprintf(mbuf, sizeof(mbuf), ".%u", (unsigned int) Name[x]);
  1031. strncat(objid, mbuf, sizeof(objid));
  1032.     }
  1034.     debug(49, lvl) ("   oid = %sn", objid);
  1035. }
  1037. static void
  1038. snmpSnmplibDebug(int lvl, char *buf)
  1039. {
  1040.     debug(49, lvl) ("%s", buf);
  1041. }