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

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

代理服务器

开发平台：

Unix_Linux

snmp_agent.c：源码内容
  2. /*
  3.  * $Id: snmp_agent.c,v 1.65 1999/01/26 06:16:33 glenn Exp $
  4.  *
  5.  * DEBUG: section 49     SNMP Interface
  6.  * AUTHOR: Kostas Anagnostakis
  7.  *
  8.  * SQUID Internet Object Cache  http://squid.nlanr.net/Squid/
  9.  * ----------------------------------------------------------
  10.  *
  11.  *  Squid is the result of efforts by numerous individuals from the
  12.  *  Internet community.  Development is led by Duane Wessels of the
  13.  *  National Laboratory for Applied Network Research and funded by the
  14.  *  National Science Foundation.  Squid is Copyrighted (C) 1998 by
  15.  *  Duane Wessels and the University of California San Diego.  Please
  16.  *  see the COPYRIGHT file for full details.  Squid incorporates
  17.  *  software developed and/or copyrighted by other sources.  Please see
  18.  *  the CREDITS file for full details.
  19.  *
  20.  *  This program is free software; you can redistribute it and/or modify
  21.  *  it under the terms of the GNU General Public License as published by
  22.  *  the Free Software Foundation; either version 2 of the License, or
  23.  *  (at your option) any later version.
  24.  *  
  25.  *  This program is distributed in the hope that it will be useful,
  26.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  27.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  28.  *  GNU General Public License for more details.
  29.  *  
  30.  *  You should have received a copy of the GNU General Public License
  31.  *  along with this program; if not, write to the Free Software
  32.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
  33.  *
  34.  */
  37. #include "squid.h"
  38. #include "cache_snmp.h"
  40. extern StatCounters *snmpStatGet(int);
  42. /************************************************************************
  44.  SQUID MIB Implementation
  46.  ************************************************************************/
  48. variable_list *
  49. snmp_sysFn(variable_list * Var, snint * ErrP)
  50. {
  51.     variable_list *Answer;
  53.     debug(49, 5) ("snmp_sysFn: Processing request:n", Var->name[LEN_SQ_SYS]);
  54.     snmpDebugOid(5, Var->name, Var->name_length);
  56.     Answer = snmp_var_new(Var->name, Var->name_length);
  57.     *ErrP = SNMP_ERR_NOERROR;
  59.     switch (Var->name[LEN_SQ_SYS]) {
  60.     case SYSVMSIZ:
  61. Answer->val_len = sizeof(snint);
  62. Answer->val.integer = xmalloc(Answer->val_len);
  63. Answer->type = ASN_INTEGER;
  64. *(Answer->val.integer) = store_mem_size;
  65. break;
  66.     case SYSSTOR:
  67. Answer->val_len = sizeof(snint);
  68. Answer->val.integer = xmalloc(Answer->val_len);
  69. Answer->type = ASN_INTEGER;
  70. *(Answer->val.integer) = store_swap_size;
  71. break;
  72.     case SYS_UPTIME:
  73. Answer->val_len = sizeof(snint);
  74. Answer->val.integer = xmalloc(Answer->val_len);
  75. Answer->type = SMI_TIMETICKS;
  76. *(Answer->val.integer) = tvSubDsec(squid_start, current_time) * 100;
  77. break;
  78.     default:
  79. *ErrP = SNMP_ERR_NOSUCHNAME;
  80. snmp_var_free(Answer);
  81. return (NULL);
  82.     }
  83.     return Answer;
  84. }
  86. variable_list *
  87. snmp_confFn(variable_list * Var, snint * ErrP)
  88. {
  89.     variable_list *Answer;
  90.     char *cp = NULL;
  91.     char *pp = NULL;
  92.     debug(49, 5) ("snmp_confFn: Processing request with magic %d!n", Var->name[8]);
  94.     Answer = snmp_var_new(Var->name, Var->name_length);
  95.     *ErrP = SNMP_ERR_NOERROR;
  97.     switch (Var->name[LEN_SQ_CONF]) {
  98.     case CONF_ADMIN:
  99. Answer->type = ASN_OCTET_STR;
  100. Answer->val_len = strlen(Config.adminEmail);
  101. Answer->val.string = (u_char *) xstrdup(Config.adminEmail);
  102. break;
  103.     case CONF_VERSION:
  104. Answer->type = ASN_OCTET_STR;
  105. Answer->val_len = strlen(appname);
  106. Answer->val.string = (u_char *) xstrdup(appname);
  107. break;
  108.     case CONF_VERSION_ID:
  109. pp = SQUID_VERSION;
  110. Answer->type = ASN_OCTET_STR;
  111. Answer->val_len = strlen(pp);
  112. Answer->val.string = (u_char *) xstrdup(pp);
  113. break;
  114.     case CONF_STORAGE:
  115. switch (Var->name[LEN_SQ_CONF + 1]) {
  116. case CONF_ST_MMAXSZ:
  117.     Answer->val_len = sizeof(snint);
  118.     Answer->val.integer = xmalloc(Answer->val_len);
  119.     Answer->type = ASN_INTEGER;
  120.     *(Answer->val.integer) = (snint) Config.memMaxSize;
  121.     break;
  122. case CONF_ST_SWMAXSZ:
  123.     Answer->val_len = sizeof(snint);
  124.     Answer->val.integer = xmalloc(Answer->val_len);
  125.     Answer->type = ASN_INTEGER;
  126.     *(Answer->val.integer) = (snint) Config.Swap.maxSize;
  127.     break;
  128. case CONF_ST_SWHIWM:
  129.     Answer->val_len = sizeof(snint);
  130.     Answer->val.integer = xmalloc(Answer->val_len);
  131.     Answer->type = ASN_INTEGER;
  132.     *(Answer->val.integer) = (snint) Config.Swap.highWaterMark;
  133.     break;
  134. case CONF_ST_SWLOWM:
  135.     Answer->val_len = sizeof(snint);
  136.     Answer->val.integer = xmalloc(Answer->val_len);
  137.     Answer->type = ASN_INTEGER;
  138.     *(Answer->val.integer) = (snint) Config.Swap.lowWaterMark;
  139.     break;
  140. default:
  141.     *ErrP = SNMP_ERR_NOSUCHNAME;
  142.     snmp_var_free(Answer);
  143.     return (NULL);
  144. }
  145. break;
  146.     case CONF_LOG_FAC:
  147. if (!(cp = Config.debugOptions))
  148.     cp = "None";
  149. Answer->type = ASN_OCTET_STR;
  150. Answer->val_len = strlen(cp);
  151. Answer->val.string = (u_char *) xstrdup(cp);
  152. break;
  153.     default:
  154. *ErrP = SNMP_ERR_NOSUCHNAME;
  155. snmp_var_free(Answer);
  156. return (NULL);
  157.     }
  158.     return Answer;
  159. }
  161. variable_list *
  162. snmp_meshPtblFn(variable_list * Var, snint * ErrP)
  163. {
  164.     variable_list *Answer;
  165.     struct in_addr *laddr;
  166.     char *cp = NULL;
  167.     peer *p = NULL;
  168.     int cnt = 0;
  169.     debug(49, 5) ("snmp_meshPtblFn: peer %d requested!n", Var->name[LEN_SQ_MESH + 3]);
  171.     Answer = snmp_var_new(Var->name, Var->name_length);
  172.     *ErrP = SNMP_ERR_NOERROR;
  174.     laddr = oid2addr(&Var->name[LEN_SQ_MESH + 3]);
  176.     for (p = Config.peers; p != NULL; p = p->next, cnt++)
  177. if (p->in_addr.sin_addr.s_addr == laddr->s_addr)
  178.     break;
  180. #if SNMP_OLD_INDEX
  181.     p = Config.peers;
  182.     cnt = Var->name[LEN_SQ_MESH + 3];
  183.     debug(49, 5) ("snmp_meshPtblFn: we want .x.%dn", Var->name[10]);
  184.     while (--cnt)
  185. if (!(p = p->next));
  186. #endif
  187.     if (p == NULL) {
  188. *ErrP = SNMP_ERR_NOSUCHNAME;
  189. snmp_var_free(Answer);
  190. return (NULL);
  191.     }
  192.     switch (Var->name[LEN_SQ_MESH + 2]) {
  193.     case MESH_PTBL_NAME:
  194. cp = p->host;
  195. Answer->type = ASN_OCTET_STR;
  196. Answer->val_len = strlen(cp);
  197. Answer->val.string = (u_char *) xstrdup(cp);
  198. break;
  199.     case MESH_PTBL_IP:
  200. Answer->type = SMI_IPADDRESS;
  201. Answer->val_len = sizeof(snint);
  202. Answer->val.integer = xmalloc(Answer->val_len);
  203. *(Answer->val.integer) = (snint) (p->in_addr.sin_addr.s_addr);
  204. break;
  205.     case MESH_PTBL_HTTP:
  206. Answer->val_len = sizeof(snint);
  207. Answer->val.integer = xmalloc(Answer->val_len);
  208. Answer->type = ASN_INTEGER;
  209. *(Answer->val.integer) = (snint) p->http_port;
  210. break;
  211.     case MESH_PTBL_ICP:
  212. Answer->val_len = sizeof(snint);
  213. Answer->val.integer = xmalloc(Answer->val_len);
  214. Answer->type = ASN_INTEGER;
  215. *(Answer->val.integer) = (snint) p->icp.port;
  216. break;
  217.     case MESH_PTBL_TYPE:
  218. Answer->val_len = sizeof(snint);
  219. Answer->val.integer = xmalloc(Answer->val_len);
  220. Answer->type = ASN_INTEGER;
  221. *(Answer->val.integer) = (snint) p->type;
  222. break;
  223.     case MESH_PTBL_STATE:
  224. Answer->val_len = sizeof(snint);
  225. Answer->val.integer = xmalloc(Answer->val_len);
  226. Answer->type = ASN_INTEGER;
  227. *(Answer->val.integer) = (snint) neighborUp(p);
  228. break;
  229.     case MESH_PTBL_SENT:
  230. Answer->val_len = sizeof(snint);
  231. Answer->val.integer = xmalloc(Answer->val_len);
  232. Answer->type = SMI_COUNTER32;
  233. *(Answer->val.integer) = p->stats.pings_sent;
  234. break;
  235.     case MESH_PTBL_PACKED:
  236. Answer->val_len = sizeof(snint);
  237. Answer->val.integer = xmalloc(Answer->val_len);
  238. Answer->type = SMI_COUNTER32;
  239. *(Answer->val.integer) = p->stats.pings_acked;
  240. break;
  241.     case MESH_PTBL_FETCHES:
  242. Answer->val_len = sizeof(snint);
  243. Answer->val.integer = xmalloc(Answer->val_len);
  244. Answer->type = SMI_COUNTER32;
  245. *(Answer->val.integer) = p->stats.fetches;
  246. break;
  247.     case MESH_PTBL_RTT:
  248. Answer->val_len = sizeof(snint);
  249. Answer->val.integer = xmalloc(Answer->val_len);
  250. Answer->type = ASN_INTEGER;
  251. *(Answer->val.integer) = p->stats.rtt;
  252. break;
  253.     case MESH_PTBL_IGN:
  254. Answer->val_len = sizeof(snint);
  255. Answer->val.integer = xmalloc(Answer->val_len);
  256. Answer->type = SMI_COUNTER32;
  257. *(Answer->val.integer) = p->stats.ignored_replies;
  258. break;
  259.     case MESH_PTBL_KEEPAL_S:
  260. Answer->val_len = sizeof(snint);
  261. Answer->val.integer = xmalloc(Answer->val_len);
  262. Answer->type = SMI_COUNTER32;
  263. *(Answer->val.integer) = p->stats.n_keepalives_sent;
  264. break;
  265.     case MESH_PTBL_KEEPAL_R:
  266. Answer->val_len = sizeof(snint);
  267. Answer->val.integer = xmalloc(Answer->val_len);
  268. Answer->type = SMI_COUNTER32;
  269. *(Answer->val.integer) = p->stats.n_keepalives_recv;
  270. break;
  272.     default:
  273. *ErrP = SNMP_ERR_NOSUCHNAME;
  274. snmp_var_free(Answer);
  275. return (NULL);
  276.     }
  277.     return Answer;
  278. }
  280. variable_list *
  281. snmp_prfSysFn(variable_list * Var, snint * ErrP)
  282. {
  283.     variable_list *Answer;
  284.     static struct rusage rusage;
  286.     debug(49, 5) ("snmp_prfSysFn: Processing request with magic %d!n", Var->name[LEN_SQ_PRF + 1]);
  288.     Answer = snmp_var_new(Var->name, Var->name_length);
  289.     *ErrP = SNMP_ERR_NOERROR;
  290.     Answer->val_len = sizeof(snint);
  291.     Answer->val.integer = xmalloc(Answer->val_len);
  292.     Answer->type = ASN_INTEGER;
  294.     switch (Var->name[LEN_SQ_PRF + 1]) {
  295.     case PERF_SYS_PF:
  296. squid_getrusage(&rusage);
  297. *(Answer->val.integer) = rusage_pagefaults(&rusage);
  298. Answer->type = SMI_COUNTER32;
  299. break;
  300.     case PERF_SYS_NUMR:
  301. *(Answer->val.integer) = IOStats.Http.reads;
  302. Answer->type = SMI_COUNTER32;
  303. break;
  304.     case PERF_SYS_DEFR: /* XXX unused, remove me */
  305. Answer->type = SMI_COUNTER32;
  306. *(Answer->val.integer) = 0;
  307. break;
  308.     case PERF_SYS_MEMUSAGE:
  309. *(Answer->val.integer) = (snint) memTotalAllocated() >> 10;
  310. break;
  311.     case PERF_SYS_CPUUSAGE:
  312. squid_getrusage(&rusage);
  313. *(Answer->val.integer) = (snint) rusage_cputime(&rusage);
  314. break;
  315.     case PERF_SYS_MAXRESSZ:
  316. squid_getrusage(&rusage);
  317. *(Answer->val.integer) = (snint) rusage_maxrss(&rusage);
  318. break;
  319.     case PERF_SYS_CURLRUEXP:
  320. Answer->type = SMI_TIMETICKS;
  321. *(Answer->val.integer) = (snint) (storeExpiredReferenceAge() * 100);
  322. break;
  323.     case PERF_SYS_CURUNLREQ:
  324. *(Answer->val.integer) = (snint) Counter.unlink.requests;
  325. Answer->type = SMI_COUNTER32;
  326. break;
  327.     case PERF_SYS_CURUNUSED_FD:
  328. *(Answer->val.integer) = (snint) Squid_MaxFD - Number_FD;
  329. Answer->type = SMI_GAUGE32;
  330. break;
  331.     case PERF_SYS_CURRESERVED_FD:
  332. *(Answer->val.integer) = (snint) Number_FD;
  333. Answer->type = SMI_GAUGE32;
  334. break;
  335.     case PERF_SYS_NUMOBJCNT:
  336. *(Answer->val.integer) = (snint) memInUse(MEM_STOREENTRY);
  337. Answer->type = SMI_COUNTER32;
  338. break;
  339.     default:
  340. *ErrP = SNMP_ERR_NOSUCHNAME;
  341. snmp_var_free(Answer);
  342. return (NULL);
  343.     }
  344.     return Answer;
  345. }
  347. variable_list *
  348. snmp_prfProtoFn(variable_list * Var, snint * ErrP)
  349. {
  350.     variable_list *Answer;
  351.     static StatCounters *f = NULL;
  352.     static StatCounters *l = NULL;
  353.     double x;
  354.     int minutes;
  356.     debug(49, 5) ("snmp_prfProtoFn: Processing request with magic %d!n", Var->name[LEN_SQ_PRF]);
  358.     Answer = snmp_var_new(Var->name, Var->name_length);
  359.     *ErrP = SNMP_ERR_NOERROR;
  361.     switch (Var->name[LEN_SQ_PRF + 1]) {
  362.     case PERF_PROTOSTAT_AGGR: /* cacheProtoAggregateStats */
  363. Answer->type = SMI_COUNTER32;
  364. Answer->val_len = sizeof(snint);
  365. Answer->val.integer = xmalloc(Answer->val_len);
  366. switch (Var->name[LEN_SQ_PRF + 2]) {
  367. case PERF_PROTOSTAT_AGGR_HTTP_REQ:
  368.     *(Answer->val.integer) = (snint) Counter.client_http.requests;
  369.     break;
  370. case PERF_PROTOSTAT_AGGR_HTTP_HITS:
  371.     *(Answer->val.integer) = (snint) Counter.client_http.hits;
  372.     break;
  373. case PERF_PROTOSTAT_AGGR_HTTP_ERRORS:
  374.     *(Answer->val.integer) = (snint) Counter.client_http.errors;
  375.     break;
  376. case PERF_PROTOSTAT_AGGR_HTTP_KBYTES_IN:
  377.     *(Answer->val.integer) = (snint) Counter.client_http.kbytes_in.kb;
  378.     break;
  379. case PERF_PROTOSTAT_AGGR_HTTP_KBYTES_OUT:
  380.     *(Answer->val.integer) = (snint) Counter.client_http.kbytes_out.kb;
  381.     break;
  382. case PERF_PROTOSTAT_AGGR_ICP_S:
  383.     *(Answer->val.integer) = (snint) Counter.icp.pkts_sent;
  384.     break;
  385. case PERF_PROTOSTAT_AGGR_ICP_R:
  386.     *(Answer->val.integer) = (snint) Counter.icp.pkts_recv;
  387.     break;
  388. case PERF_PROTOSTAT_AGGR_ICP_SKB:
  389.     *(Answer->val.integer) = (snint) Counter.icp.kbytes_sent.kb;
  390.     break;
  391. case PERF_PROTOSTAT_AGGR_ICP_RKB:
  392.     *(Answer->val.integer) = (snint) Counter.icp.kbytes_recv.kb;
  393.     break;
  394. case PERF_PROTOSTAT_AGGR_REQ:
  395.     *(Answer->val.integer) = (snint) Counter.server.all.requests;
  396.     Answer->type = SMI_INTEGER;
  397.     break;
  398. case PERF_PROTOSTAT_AGGR_ERRORS:
  399.     *(Answer->val.integer) = (snint) Counter.server.all.errors;
  400.     Answer->type = SMI_INTEGER;
  401.     break;
  402. case PERF_PROTOSTAT_AGGR_KBYTES_IN:
  403.     *(Answer->val.integer) = (snint) Counter.server.all.kbytes_in.kb;
  404.     break;
  405. case PERF_PROTOSTAT_AGGR_KBYTES_OUT:
  406.     *(Answer->val.integer) = (snint) Counter.server.all.kbytes_out.kb;
  407.     break;
  408. case PERF_PROTOSTAT_AGGR_CURSWAP:
  409.     *(Answer->val.integer) = (snint) store_swap_size;
  410.     break;
  411. case PERF_PROTOSTAT_AGGR_CLIENTS:
  412.     *(Answer->val.integer) = (snint) Counter.client_http.clients;
  413.     break;
  414. default:
  415.     *ErrP = SNMP_ERR_NOSUCHNAME;
  416.     snmp_var_free(Answer);
  417.     return (NULL);
  418. }
  419. return Answer;
  420.     case PERF_PROTOSTAT_MEDIAN:
  422. minutes = Var->name[LEN_SQ_PRF + 4];
  424. f = snmpStatGet(0);
  425. l = snmpStatGet(minutes);
  427. debug(49, 8) ("median: min= %d, %d l= %x , f = %xn", minutes,
  428.     Var->name[LEN_SQ_PRF + 3], l, f);
  429. Answer->type = SMI_INTEGER;
  430. Answer->val_len = sizeof(snint);
  431. Answer->val.integer = xmalloc(Answer->val_len);
  433. debug(49, 8) ("median: l= %x , f = %xn", l, f);
  434. switch (Var->name[LEN_SQ_PRF + 3]) {
  435. case PERF_MEDIAN_TIME:
  436.     x = minutes;
  437.     break;
  438. case PERF_MEDIAN_HTTP_ALL:
  439.     x = statHistDeltaMedian(&l->client_http.all_svc_time,
  440. &f->client_http.all_svc_time);
  441.     break;
  442. case PERF_MEDIAN_HTTP_MISS:
  443.     x = statHistDeltaMedian(&l->client_http.miss_svc_time,
  444. &f->client_http.miss_svc_time);
  445.     break;
  446. case PERF_MEDIAN_HTTP_NM:
  447.     x = statHistDeltaMedian(&l->client_http.nm_svc_time,
  448. &f->client_http.nm_svc_time);
  449.     break;
  450. case PERF_MEDIAN_HTTP_HIT:
  451.     x = statHistDeltaMedian(&l->client_http.hit_svc_time,
  452. &f->client_http.hit_svc_time);
  453.     break;
  454. case PERF_MEDIAN_ICP_QUERY:
  455.     x = statHistDeltaMedian(&l->icp.query_svc_time, &f->icp.query_svc_time);
  456.     break;
  457. case PERF_MEDIAN_ICP_REPLY:
  458.     x = statHistDeltaMedian(&l->icp.reply_svc_time, &f->icp.reply_svc_time);
  459.     break;
  460. case PERF_MEDIAN_DNS:
  461.     x = statHistDeltaMedian(&l->dns.svc_time, &f->dns.svc_time);
  462.     break;
  463. case PERF_MEDIAN_RHR:
  464.     x = statRequestHitRatio(minutes);
  465.     break;
  466. case PERF_MEDIAN_BHR:
  467.     x = statByteHitRatio(minutes);
  468.     break;
  469. default:
  470.     *ErrP = SNMP_ERR_NOSUCHNAME;
  471.     snmp_var_free(Answer);
  472.     return (NULL);
  473. }
  474. *(Answer->val.integer) = (snint) x;
  475. return Answer;
  476.     }
  477.     *ErrP = SNMP_ERR_NOSUCHNAME;
  478.     snmp_var_free(Answer);
  479.     return (NULL);
  480. }
  482. void
  483. addr2oid(struct in_addr addr, oid * Dest)
  484. {
  485.     u_char *cp;
  486.     cp = (u_char *) & (addr.s_addr);
  487.     Dest[0] = *cp++;
  488.     Dest[1] = *cp++;
  489.     Dest[2] = *cp++;
  490.     Dest[3] = *cp++;
  491. }
  493. struct in_addr *
  494. oid2addr(oid * id)
  495. {
  496.     static struct in_addr laddr;
  497.     u_char *cp = (u_char *) & (laddr.s_addr);
  498.     cp[0] = id[0];
  499.     cp[1] = id[1];
  500.     cp[2] = id[2];
  501.     cp[3] = id[3];
  502.     return &laddr;
  503. }