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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > SNMP编程 > 查看源码
snmp_main.c
资源名称：snmp.src.rar　[点击查看]
上传用户：cxs890
上传日期：2021-05-22
资源大小：347k
文件大小：15k
源码类别：

SNMP编程

开发平台：

C/C++

snmp_main.c：源码内容
  1. #ifdef OS_VXWORKS
  2. #include <libsys/vos/vos_rtos.h>
  3. #include <libsys/vos/vos_msgq.h>
  4. #endif
  5. #include "config.h"
  7. #include <stdio.h>
  8. #include <stdlib.h>
  9. #include <assert.h>
  10. #include <libcmd/cmdparse.h>
  11. #include <sys/types.h>
  12. #include <ip/socket.h>
  13. #include <ip/in.h>
  14. #include <ip/inet.h>
  15. #include <ip/msg.h>
  16. #include <libsys/misc.h>
  17. #ifdef SWITCH
  18. #include <sys_conf.h>
  19. #else
  20. #include <../bsps/pub/bsps.h>
  21. #endif
  23. #include "asn1.h"
  24. #include "snmp_api.h"
  25. #include "snmp_impl.h"
  26. #include "system.h"
  27. #include "read_config.h"
  28. #include "snmp.h"
  29. #include "mib.h"
  30. #include "m2m.h"
  31. #include "snmp_vars.h"
  32. #include "agent_read_config.h"
  33. #include "snmpv3.h"
  34. #include "callback.h"
  35. #include "snmp_alarm.h"
  36. #include "default_store.h"
  37. #include "mib_module_config.h"
  39. #include "snmpd.h"
  40. #include "snmp_main.h"
  41. #include "config_struct.h"
  42. #include "snmp_debug.h"
  43. #include "snmp_timer.h"/*** sun define 2000.03.25 ***/
  44. #include "libres/resource.h"
  45. #include "var_struct.h"
  46. #include <objects.h>
  47. #include <boot/convert.h>
  48. #include <bspfuncs.h>
  49. #include <libsysverctl.h>
  50. #define sockadd_in soaddr_in
  51. #define sockaddr soaddr
  52. uint32 snmp_qid;/*snmp main queue identifier*/
  53. struct SNMPtimer   t,*snmptimer=&t;/*** sun define 2000.03.25 ***/
  54. SNMP_PARA snmp_para;
  55. ULONG snmp_source_ip;
  56. void snmpd_timeout(void);
  57. extern void hostname_callback (RESOURCE_ID id, uint32 arg1, uint32 arg2, uint32 param1, uint32 param2);
  58. extern int receive(void);
  59. int register_snmp(unsigned long mibgourp,void (*init_mib)());
  60. extern int snmpd_init(void);
  61. void dispatch_voip_oid(void);
  62. void snmp_version_register(void);
  63. void snmp_enterprise_oid_set(void);
  64. /*Function prototype*/
  65. /********************************************************
  66.  *
  67.  * Routine: snmp
  68.  *
  69.  * Description:
  70.  * This is the main loop of the SNMP module.
  71.  *
  72.  * Arguments:
  73.  *
  74.  * Return code:
  75.  *
  76.  * Side effects:
  77.  *
  78.  ********************************************************/
  79. void snmp_main()
  80. {
  81. #ifdef   OS_VXWORKS  /*SWITCH by yangyuhua 2005/7/22*/
  82. snmp_trace("snmp initn");
  83. snmpd_init();
  84. #endif 
  85. snmp_trace("snmp startn");      
  86. #ifndef OS_VXWORKS
  87. start_SNMPtimer(snmptimer);
  88. #endif
  89. #ifdef OLD_SNMP   
  90.     while (1){
  91.      if ((rc = q_receive(snmp_qid, Q_WAIT, 0, msg)) != 0){
  92. vty_console_output("SNMP:q_receive() error (rc %d)n",rc);
  93. continue;
  94. }
  95. msg_type = msg[0];
  96. switch(msg_type){
  97. /*收到数据*/
  98. case SOCKET_DATARCVD:
  99.  socketd  = msg[1];
  100.  sd_length = msg[2];
  101.        receive(socketd,sd_length);
  102.  break;
  103. /*连接建立*/
  104. case SOCKET_CONNECTED:
  105. /*连接正在断开*/
  106. case SOCKET_DISCONNECTING:
  107. /*连接已经断开*/
  108. case SOCKET_DISCONNECTED:
  109. /*socket不能再发送数据*/
  110. case SOCKET_CANTSENDMORE:
  111. /*socket不能再接收数据*/
  112. case SOCKET_CANTRCVMORE:
  113. break;
  114. case SNMP_TIMEOUT:
  115. break;
  116. default :
  117. break;
  119. }
  121. }
  122. #endif
  123. receive();
  124. }
  126. #include "snmp_vars.h"
  127. #include "mibgroup/mibII/system_mib.h"
  128. #include "mibgroup/mibII/snmp_mib.h"
  129. #ifndef OS_VXWORKS
  130. #include <boot/convert.h>
  131. #endif
  132. extern int do_snmp(int argc, char *argv[], struct user *u);
  135. static  struct topcmds snmp_topcmd = 
  136. { "snmp-server", cmdPref(PF_CMDNO, 0, 0) | cmdPriv(0, PV_SUBCMDSET, 0, 0), IF_ANY, ~FG_CFG_ST, IF_NULL, FG_CONFIG, 
  137. do_snmp, NULL, NULL, 2, 0,
  138. "snmp-server      -- Modify SNMP parameters", 
  139. "snmp-server      -- 设置 SNMP 参数 ", 
  140. NULLCHAR, NULLCHAR
  141. };
  144. extern long snmp_showrunning(DEVICE_ID diID);
  145. extern struct cmds debug_snmp_cmds[];
  146. extern struct cmds snmp_show_cmds[];
  147. #ifdef SWITCH
  148. #define DEFAULT_PRODUCT_ID 100 /* switch product id is based on this value */
  149. #else
  150. #define DEFAULT_PRODUCT_ID 32 /* router product id is based on this value */
  151. #endif
  152. oid default_enterprise[10] = {1, 3, 6, 1, 4, 1, ENTERPRISE_NUMBER, PRODUCEID, DEFAULT_PRODUCT_ID, 0};
  153. size_t default_enterprise_len = 10;
  154. unsigned char def_syscontact[SNMP_MAX_SYSCON_LEN];
  155. unsigned char def_syslocation[SNMP_MAX_SYSLOC_LEN];
  156. char version_descr[2048] = VERS_DESC;
  158. void snmp_module_init()
  159. {
  160. int    rc;
  161. RESOURCE_ID id;
  163. registercmd(&snmp_topcmd);
  164. interface_set_showrunning_service(MODULE_TYPE_SNMP,(INT32 (*)(DEVICE_ID))snmp_showrunning);
  165. register_snmp(1,init_system_mib);
  167. register_snmp(11,init_snmp_mib);
  168. rc =register_subcmd_tab("debug", cmdPref(PF_CMDNO, 0, 0), IF_NULL, FG_ENABLE,debug_snmp_cmds,1);
  169. assert(rc==1);
  170. rc = register_subcmd_tab("show", 0, IF_NULL, FG_ENABLE, snmp_show_cmds, 1);
  171. assert(rc == 1);
  174. memset(&snmp_para,0,sizeof(SNMP_PARA));
  175. snmp_para.packetsize = SNMP_DEFAULT_PACKETSIZE;
  176. snmp_para.queuelen = SNMP_DEFAULT_TRAP_QUEUELEN;
  177. snmp_para.timeout = SNMP_DEFAULT_TRAP_TIMEOUT;
  179.     /* Initialize timer 
  180.     snmptimer->func = (void (*)(void*))snmpd_timeout;
  181.     set_SNMPtimer(snmptimer, SNMPTIMER_TIMEOUT);
  182.     create_SNMPtimer(snmptimer);*/
  183. /* start_SNMPtimer(snmptimer);
  184.     stop_SNMPtimer(snmptimer);*/
  187. #ifdef OLD_SNMP
  188. if ((rc = q_create(SNMP_QUEUE_NAME, SNMP_QUEUE_LEN, Q_FIFO | Q_LIMIT, &snmp_qid)) != NOERR)
  189. vty_console_output("SNMP: q_create() error (rc %d)n",rc);
  190. #endif
  192. #ifndef OS_VXWORKS
  193. snmp_trace("snmp initn");/*add by yangyuhua, 2005-7-22*/
  194. snmpd_init();
  195. #endif
  196. rc = resource_register_synchronizer_callback (&id, RESOURCE_TYPE_HOSTNAME,
  197. RESOURCE_INDEX_TYPE_NONE, NULL, hostname_callback, 0, 0);
  198. assert(rc==0);
  200. #ifdef SWITCH
  201. sys_task_delay(1);
  202. #endif
  204. #ifdef OS_VXWORKS
  205.     /*finally, spawn snmp_main*/
  206.     sys_task_spawn(TASK_NAME_SNMP, SYS_TASK_PRI_NORMAL, 0,1024*64, snmp_main, NULL, 0);
  207. #endif
  208. snmp_version_register();
  209. }
  210. /********************************************************
  211.  *
  212.  * Routine:     snmp_wait_reset
  213.  *
  214.  * Description:
  215.  *      Wait until the SNMP module is initialized.
  216.  *      Loop until SNMP module is initialized:
  217.  *      Discard any message received until a RESET
  218.  *      action request is received and executed
  219.  *      sucessfully.
  220.  *
  221.  * Arguments:
  222.  *
  223.  * Return code:
  224.  *
  225.  * Side effects:
  226.  *
  227.  ********************************************************/
  231. void snmpd_timeout(void)
  232. {
  233. snmp_timeout();
  234. /*由于使用了循环定时器,不用每次超时重新启动定时器,孙希2003.1.8
  235. start_SNMPtimer(snmptimer);*/
  236. }
  239. #include "snmp/snmpreg.h"
  242. struct snmp_list *SnmpMibList=NULL;
  243. long    subtrees_enable = FALSE;/*** sun define 2000.07.27 ***/
  244. int register_snmp(unsigned long mibgourp,void (*init_mib)(void))
  245. {
  246.     struct snmp_list *vp;
  247.     if(subtrees_enable){/*** sun define 2000.07.27 ***/
  248.         (*init_mib)();
  249.         return 0;
  250.     }
  251.     
  253.     if((vp = (struct snmp_list *)sys_mem_malloc(sizeof(struct snmp_list)))==NULL){
  254.      return 0;
  255. }
  256. memset((void *)vp, 0, sizeof(struct snmp_list));
  257. vp->mibgroup = mibgourp;
  258. vp->init_mib = init_mib;
  260.     vp->next = SnmpMibList;
  261.     SnmpMibList = vp;
  263.     return 0;
  264. }
  266. void snmp_miblist_init(void)
  267. {
  268. SnmpMibList=NULL;
  269.     subtrees_enable = FALSE;/*** sun define 2000.07.27 ***/
  270.     snmp_enterprise_oid_set();
  271. }
  273. #ifndef SWITCH
  274. /*add by zhaoyonggang, 2004-12-14*/
  275. void dispatch_voip_oid(void)
  276. {
  277. USHORT t;
  278. char router_series[20];
  279. t = sys_get_router_type();
  281. if(get_extend_info_string(INFO_ROUTER_SERIES,router_series))
  282. strcpy(router_series,"");
  284. if(t==ROUTER_TYPE_V100)
  285. default_enterprise[8] = 251; /*IP phone V100*/
  286. else if (t==ROUTER_TYPE_V200)
  287. default_enterprise[8] = 252; /*IP phone V200*/
  288. else if (t==ROUTER_TYPE_V300)
  289. default_enterprise[8] = 253; /*IP phone V300*/
  290. else if (t==ROUTER_TYPE_V500)
  291. default_enterprise[8] = 254; /*IP phone V500*/
  292. else
  293. {
  294. if(strcmp(router_series, "SuperB GW300") == 0)
  295. default_enterprise[8] = 260;
  296. else if(strcmp(router_series, "SuperB GW500") == 0)
  297. default_enterprise[8] = 261;
  298. else if(strcmp(router_series, "SuperB GW204") == 0)
  299. default_enterprise[8] = 262;
  300. else if(strcmp(router_series, "SuperB GW232") == 0)
  301. default_enterprise[8] = 263;
  302. else if(strcmp(router_series, "SuperB MINI") == 0)
  303. default_enterprise[8] = 270;
  304. else if(strcmp(router_series, "SuperB GW1000") == 0)
  305. default_enterprise[8] = 280;
  306. else if(strcmp(router_series, "SuperB GW2000") == 0)
  307. default_enterprise[8] = 281;
  308. else if(strcmp(router_series, "SuperB GK300") == 0)
  309. default_enterprise[8] = 290;
  310. else if(strcmp(router_series, "SuperB GK1000") == 0)
  311. default_enterprise[8] = 291;
  312. else if(strcmp(router_series, "SuperB PROXY300") == 0)
  313. default_enterprise[8] = 300;
  314. else if(strcmp(router_series, "SuperB PROXY1000") == 0)
  315. default_enterprise[8] = 301;
  316. /* else
  317. default_enterprise[8] = 0;*/
  318. }
  319. }
  320. #endif
  322. /************************************************************************/
  323. /* DATE: 2006/1/13 */
  324. /* PURPOSE: rmon version                              */
  325. /* */
  326. /************************************************************************/
  328. void snmp_version_register(void)
  329. {
  330. struct version_list ver;
  332. /*register module cmd version*/
  333. ver.module_type = MODULE_TYPE_SNMP;
  334. ver.version = 0x00010003;
  335. strcpy(ver.module_name,"SNMP");
  336. sprintf(ver.module_description,"Simple Network Management Protocol(May23.2008)");
  337. ver.next = NULL;
  339. register_module_version(&ver);
  340. }
  342. void snmp_enterprise_oid_old_set(void)
  343. {
  344. unsigned char short_company_name[30];
  345. unsigned short switch_type;
  346. #ifdef SWITCH
  347. switch_type = sys_get_switch_type();
  348. if(switch_type < SWITCH_TYPE_BASE)
  349. switch_type = SWITCH_TYPE_BASE;
  350. switch_type -= SWITCH_TYPE_BASE;
  351. switch_type += DEFAULT_PRODUCT_ID;
  352. default_enterprise[8] = (oid) switch_type;
  354. #ifdef S3424
  355. if (!get_extend_info_string(INFO_SHORT_COMPANY_NAME, short_company_name)
  356. && stricmp(short_company_name, KYLAND_SHORT_VENDOR_NAME) == 0)
  357. {
  358. default_enterprise[6] = KYLAND_ENTERPRISE_NUMBER;
  359. default_enterprise[7] = 6;
  360. default_enterprise[8] = 5;
  361. default_enterprise_len = 9;
  362. memcpy(def_syslocation, "No 95 Building,Southeast Corner of XisanqiBridge,Haidian,Beijing,china", SNMP_MAX_SYSLOC_LEN);
  363. memcpy(def_syscontact, "+86-10-82900771", SNMP_MAX_SYSCON_LEN);
  364. memcpy(version_descr, "KYLAND", 10);
  365. }
  366. #endif
  367. #else
  368.      switch(sys_get_router_type()){
  369.       case ROUTER_TYPE_1760:
  370.       default_enterprise[8]=83;
  371.       break;
  372.       case ROUTER_TYPE_1750:
  373.       default_enterprise[8]=82;
  374.       break;
  375.         case ROUTER_TYPE_2750:
  376.             default_enterprise[8]=20;
  377.             break;
  378.         case ROUTER_TYPE_3700:
  379.             default_enterprise[8]=30;
  380.             break;
  381. case ROUTER_TYPE_3720:
  382. default_enterprise[8]=32;
  383. break;
  384.         case ROUTER_TYPE_5000:
  385.             default_enterprise[8]=50;       
  386.             break;
  387. case ROUTER_TYPE_V100:
  388. default_enterprise[8]=71;
  389. break;
  390. case ROUTER_TYPE_V200:
  391. default_enterprise[8]=72;
  392. break;
  393. case ROUTER_TYPE_V300:
  394. default_enterprise[8]=73;
  395. break;
  396. case ROUTER_TYPE_V500:
  397. default_enterprise[8]=75;
  398. break;
  399.         case ROUTER_TYPE_3660:
  400.             default_enterprise[8]=93;       
  401.             break;
  402.         case ROUTER_TYPE_3680:
  403.             default_enterprise[8]=98;       
  404.             break;
  405.         case ROUTER_TYPE_2640:
  406.             default_enterprise[8]=64;       
  407.             break;
  408.         case ROUTER_TYPE_2621:
  409. {
  410. EPPROM_INFO     *rom_info;
  411. rom_info = (EPPROM_INFO *)(sys_get_epprom_infoaddr()+0x40);/*by xujiasheng(a) 2006-7-19*/
  412. if (rom_info->hw_version == 0x10)
  413. {
  414. default_enterprise[8]=60;  /*this is 2621*/
  415.     break;
  416. }
  417. if (rom_info->hw_version == 0x20)
  418. {
  419.           default_enterprise[8]=61;  /*this is 2611*/
  420.    break;
  421. }
  422.   } 
  423.             break;
  424.  case ROUTER_TYPE_2650:
  425.    case ROUTER_TYPE_2650B:
  426.             default_enterprise[8]=88;       
  427.             break;
  428.  case ROUTER_TYPE_1720:
  429.             default_enterprise[8]=81;       
  430.             break;
  431.  case ROUTER_TYPE_1721:
  432. {
  433. EPPROM_INFO     *rom_info;
  434. rom_info = (EPPROM_INFO *)sys_get_epprom_infoaddr();
  435. if ((rom_info->hw_version == 0x10)||(rom_info->hw_version == 0x30))
  436. {
  437. default_enterprise[8]=84;  /*this is 1721*/
  438.     break;
  439. }
  440. if ((rom_info->hw_version == 0x20)||(rom_info->hw_version == 0x40))
  441. {
  442.           default_enterprise[8]=85;  /*this is 1710*/
  443.    break;
  444. }
  445.   }         
  446.             break;
  447.  case ROUTER_TYPE_2630:
  448.             default_enterprise[8]=62;       
  449.             break;
  450.      default:
  451.             default_enterprise[8]=sys_get_router_type();
  452.             break;
  453.      }
  455. memset (short_company_name, 0, sizeof(short_company_name));
  456.    if (!get_extend_info_string(INFO_SHORT_COMPANY_NAME, short_company_name))
  457. {
  458.    if (stricmp(short_company_name, DIGITAL_CHINA_SHORT_VENDOR_NAME) == 0) {
  459.    default_enterprise[6] = DIGITAL_CHINA_ENTERPRISE_NUMBER;
  460. }
  461. else if (stricmp(short_company_name, DLINK_SHORT_VENDOR_NAME) == 0) {
  462.     default_enterprise[6] = DLINK_ENTERPRISE_NUMBER;
  463.     default_enterprise[7] = 10;
  464.     default_enterprise[8] = 56;
  465.     switch(sys_get_router_type()) {
  466.     case ROUTER_TYPE_1750:
  467.         default_enterprise[9] = 1;
  468.         break;
  469.             case ROUTER_TYPE_2630:
  470.                 default_enterprise[9] = 2;
  471.                 break;
  472.         case ROUTER_TYPE_3660:
  473.             default_enterprise[9] = 3;
  474.             break;
  475.             default:
  476.             default_enterprise[9] = 0;
  477.                 break;
  478.     }
  479.     }
  480.     else if (stricmp(short_company_name, LEGEND_SHORT_VENDOR_NAME) == 0) 
  481.     {
  482.    default_enterprise[6] = LEGEND_ENTERPRISE_NUMBER;
  483. switch(sys_get_router_type()) 
  484. {
  485. case ROUTER_TYPE_1750:
  486. default_enterprise[8] = 1705;
  487.          break;
  488. default:
  489. default_enterprise[8] = 0;
  490. break;
  491. }
  492.     }
  493. }
  495. #ifndef SWITCH
  496. /*add by zhaoyonggang, 2004-12-14*/
  497. dispatch_voip_oid();
  498. #endif
  500. #endif
  502. }
  503. void snmp_enterprise_oid_set(void)
  504. {
  505. oid sys_id[10];
  506. int rc=0;
  507. int i=0;
  509.   if (!eprom_extend())
  510.     {
  511. get_sys_info(version_descr, SNMP_MAX_DESCR_LEN);
  512. snmp_enterprise_oid_old_set();
  513. return;
  514.     }
  515. else
  516. {
  517. get_extend_info_string(INFO_COMPANY_SNMP_SYSLOCATION,def_syslocation);
  518. get_extend_info_string(INFO_COMPANY_SNMP_SYSCONTACT,def_syscontact);
  519. if (get_extend_info_string(INFO_COMPANY_SNMP_SYSDESCR,version_descr))
  520. {
  521. get_sys_info(version_descr, SNMP_MAX_DESCR_LEN);
  522. }
  523. }
  525. rc = eprom_system_id((unsigned long *)sys_id);
  526. if (rc > 10)
  527. {
  528. Print("ERROR :snmp trace system_id, length =%dn",rc);
  529. rc =10;
  530. }
  531. if (rc > 0)
  532. {
  533. for (i=0;i<rc;i++)
  534. {
  535. default_enterprise[i]=sys_id[i];
  536. }
  537. for (i=rc; i<10; i++)
  538. {
  539. default_enterprise[i]=0;
  540. }
  541. default_enterprise_len = rc;
  542. }
  543. else 
  544. {
  545. rc = eprom_vendor_id();
  546. if (rc >0)
  547. default_enterprise[6] = rc;/*otherwise use the default value(3320)*/
  548. rc = eprom_product_id();
  549. if (rc >0)
  550. default_enterprise[8] = rc;
  551. else
  552. snmp_enterprise_oid_old_set();
  553. }
  554. }