求助 net-snmp 自定义mib 表格式更新问题

hubimaso

背景：基于net-snmp开源框架，自己定义私有MIB，这个MIB格式是table的方式，通过mib2c生成相应的源文件，在源文件的基础上修改。
问题：定义的私有MIB中，比如系统运行状态信息，如相关进程信息，这些是动态的，实时的，我的代码中只是在初始化话的时候，获取一次进程信息。不知道怎么去更新它，value的方式比较简单，但表格式就不知道怎么弄了，对net snmp的源码不熟。希望哪位大神在这方面有经验的，指导下，困恼了好多天了。

以下是部分关键代码：

//这一部分是初始化话我定义的MIB文件中的各个表，一进程table为例

1. void
   
2. init_dpiProject(void)
   
3. {
   
4.   /* here we initialize all the tables we're planning on supporting */
   
5.     initialize_table_DevBasicInfoTable();
   
6.     initialize_table_DevHardwareTable();
   
7.     initialize_table_DevSoftwareTable();
   
8.     initialize_table_DevProcessTable();
   
9.     initialize_table_DevCpuTable();
   
10.     initialize_table_DevinterAccessTable();
    
11.     initialize_table_DevStatisticTable();
    
12. }

复制代码

//这个代码我从系统中取出进程信息，插入到DevProcessTable_head链表中

1. /** Initialize the DevProcessTable table by defining its contents and how it's structured */
   
2. void
   
3. initialize_table_DevProcessTable(void)
   
4. {
   
5.     const oid DevProcessTable_oid[] = {1,3,6,1,4,1,ENTERPRISE_ID,0,1,0,4};
   
6.     const size_t DevProcessTable_oid_len   = OID_LENGTH(DevProcessTable_oid);
   
7.     netsnmp_handler_registration    *reg;
   
8.     netsnmp_iterator_info           *iinfo;
   
9.     netsnmp_table_registration_info *table_info;
   
10. 
    
11.     DEBUGMSGTL(("dpiProject:init", "initializing table DevProcessTable\n"));
    
12. 
    
13.     reg = netsnmp_create_handler_registration(
    
14.               "DevProcessTable",     DevProcessTable_handler,
    
15.               DevProcessTable_oid, DevProcessTable_oid_len,
    
16.               HANDLER_CAN_RONLY
    
17.               );
    
18. 
    
19.     table_info = SNMP_MALLOC_TYPEDEF( netsnmp_table_registration_info );
    
20.     netsnmp_table_helper_add_indexes(table_info,
    
21.                            ASN_INTEGER,  /* index: processIdx */
    
22.                            0);
    
23.                 //1.mod by zhouziheng                           
    
24.     table_info->min_column = COLUMN_MIN;
    
25.     table_info->max_column = COLUMN_MAX;
    
26.    
    
27.     //2.mod by zhouziheng
    
28.     //获取运行时信息,DevProcess
    
29.     get_runtime_devInfo(&dev_runtimeInfo);
    
30. 
    
31.     struct DevProcessTable_entry *p_devProcessTable_entry;
    
32.     int index;
    
33.     for (index = 1; index < dev_runtimeInfo.processNum + 1; ++index)
    
34.     {
    
35.         p_devProcessTable_entry = DevProcessTable_createEntry(index, &dev_runtimeInfo);
    
36.     }
    
37.    
    
38.     DevProcessTable_head = p_devProcessTable_entry;
    
39.     //end by zhouziheng
    
40.    
    
41.     iinfo = SNMP_MALLOC_TYPEDEF( netsnmp_iterator_info );
    
42.     iinfo->get_first_data_point = DevProcessTable_get_first_data_point;
    
43.     iinfo->get_next_data_point  = DevProcessTable_get_next_data_point;
    
44.     iinfo->table_reginfo        = table_info;
    
45.    
    
46.     netsnmp_register_table_iterator( reg, iinfo );
    
47.     netsnmp_inject_handler_before( reg,
    
48.         netsnmp_get_cache_handler(DEVPROCESSTABLE_TIMEOUT,
    
49.                                   DevProcessTable_load, DevProcessTable_free,
    
50.                                   DevProcessTable_oid, DevProcessTable_oid_len),
    
51.             TABLE_ITERATOR_NAME);
    
52. 
    
53.     /* Initialise the contents of the table here */
    
54. }

复制代码

//当snmp请求过来时，会进入这个函数

1. //add by zhouziheng
   
2. static int flag = 1 ;
   
3. /** handles requests for the DevProcessTable table */
   
4. int
   
5. DevProcessTable_handler(
   
6.     netsnmp_mib_handler               *handler,
   
7.     netsnmp_handler_registration      *reginfo,
   
8.     netsnmp_agent_request_info        *reqinfo,
   
9.     netsnmp_request_info              *requests)
   
10. {
    
11. 
    
12.     netsnmp_request_info       *request;
    
13.     netsnmp_table_request_info *table_info;
    
14.     struct DevProcessTable_entry          *table_entry;
    
15. 
    
16.     DEBUGMSGTL(("dpiProject:handler", "Processing request (%d)\n", reqinfo->mode));
    
17. 
    
18.     //mod by zhouziheng
    
19.     if ( 1 == flag )
    
20.     {
    
21.         DevProcessTable_free_head();
    
22.         DevProcessTable_load_head();
    
23.         flag = 0;
    
24.     }
    
25. 
    
26.     table_entry = DevProcessTable_head;
    
27. 
    
28.     switch (reqinfo->mode)
    
29.     {
    
30.         /*
    
31.          * Read-support (also covers GetNext requests)
    
32.          */
    
33.         case MODE_GET:
    
34.         for (request=requests; request; request=request->next)
    
35.             {
    
36. #if 0            
    
37.             table_entry = (struct DevProcessTable_entry *)
    
38.                               netsnmp_extract_iterator_context(request);
    
39. #endif
    
40.             table_info  =     netsnmp_extract_table_info(      request);
    
41.    
    
42.             switch (table_info->colnum) {
    
43.             case COLUMN_PROCESSIDX:
    
44.                 if ( !table_entry ) {
    
45.                     netsnmp_set_request_error(reqinfo, request,
    
46.                                               SNMP_NOSUCHINSTANCE);
    
47.                     continue;
    
48.                 }
    
49.                 snmp_set_var_typed_integer( request->requestvb, ASN_INTEGER,
    
50.                                             table_entry->processIdx);
    
51.                 break;
    
52.             case COLUMN_PROCESS:
    
53.                 if ( !table_entry ) {
    
54.                     netsnmp_set_request_error(reqinfo, request,
    
55.                                               SNMP_NOSUCHINSTANCE);
    
56.                     continue;
    
57.                 }
    
58.                 snmp_set_var_typed_value( request->requestvb, ASN_OCTET_STR,
    
59.                                           table_entry->process,
    
60.                                           table_entry->process_len);
    
61.                 break;
    
62.             default:
    
63.                 netsnmp_set_request_error(reqinfo, request,
    
64.                                           SNMP_NOSUCHOBJECT);
    
65.                 break;
    
66.             }
    
67.         }
    
68.         break;
    
69. 
    
70.     }
    
71. #if 0   
    
72.     if (NULL != DevProcessTable_head)
    
73.     {
    
74.         DevProcessTable_head = DevProcessTable_head->next;
    
75.     }
    
76.     else
    
77.     {
    
78.         flag = 1;
    
79.     }
    
80. #endif   
    
81.     return SNMP_ERR_NOERROR;
    
82. }

复制代码

现在问题就是只能读取内存中第一次存的信息，如果我再启动其他进程，它查不到啊 。。。怎么解决，急急急！！

hubimaso

帮帮忙啊，各位

lxyscls

    //mod by zhouziheng
    if ( 1 == flag )
    {
        DevProcessTable_free_head();
        DevProcessTable_load_head();
        flag = 0;
    }

    table_entry = DevProcessTable_head;

option 1、启动一个timer刷新这个list，这个和snmp的逻辑没有关系
option 2、每次进入这个callback的时候，刷新list

hubimaso

多谢，你以前这样搞过吗？回复 3# lxyscls


   

hubimaso

在回调函数前一步要修改源码，这个实时性要高一些，但是我不知道怎么改。定时器应该可以，我试试。回复 3# lxyscls


   

lxyscls

回复 5# hubimaso

option 3. 设置一个timestamp，就不需要用timer了

    iinfo->get_first_data_point = DevProcessTable_get_first_data_point;
    iinfo->get_next_data_point  = DevProcessTable_get_next_data_point;

这是两个核心函数，数据结构不一定要组织成链表（mib2c默认生成得格式），只要能够保证顺序（index升序）得给出下一个就可以了

链表的优点是取数据简单（O(1))，但是刷新起来比较耗时（O(n*n))

如果是树的话，取后继大概是O(lgn)，刷新的话应该是(O(n*lgn))

数据量灰常大的情况，可以考虑换个数据结构，一两百就算了，没所谓

   

hubimaso

在那设置时间措啊？大神能具体简单实例么？
回复 6# lxyscls


   

lxyscls

回复 7# hubimaso


    在建立链表数据结构的时候就设置一个时间戳，后面读数据的时候，先检查时间戳，查看是否超时，超时就先刷新链表

get_first_xxx里面就做检查

hubimaso

最后用了比较挫的方法解决了，感觉还是不爽，我看了下源码中的if-table.c 他是用mib2c.mfd.conf回复 8# lxyscls