snmp_api.c 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291
  1. /********************************* (C) ROTEK ***********************************
  2. * @module template
  3. * @file template.c
  4. * @version 1.0.0
  5. * @date XX.XX.XXXX
  6. * $brief Template
  7. *******************************************************************************
  8. * @history Version Author Comment
  9. * XX.XX.XXXX 1.0.0 Telenkov D.A. First release.
  10. *******************************************************************************
  11. */
  12. #include "stm32f4xx.h"
  13. #include "snmp_api.h"
  14. #include "trap_api.h"
  15. #include "settings_api.h"
  16. #include "common_config.h"
  17. #include "rtc.h"
  18. #include "megatec.h"
  19. #include "apps/snmp.h"
  20. #include "snmp_mib2.h"
  21. #include "snmp_core.h"
  22. #include "private_mib.h"
  23. #ifdef PRINTF_STDLIB
  24. #include <stdio.h>
  25. #endif
  26. #ifdef PRINTF_CUSTOM
  27. #include "tinystdio.h"
  28. #endif
  29. #include <stdbool.h>
  30. #include <string.h>
  31. #include "lwip/opt.h"
  32. #include "lwip/api.h"
  33. #include "lwip/sys.h"
  34. #include "lwip/udp.h"
  35. //#include "snmp.h"
  36. //#include "snmp_msg.h"
  37. //#include "private_mib.h"
  38. #include "FreeRTOS.h"
  39. #include "task.h"
  40. #include "queue.h"
  41. /**
  42. * @brief Пул всех возможных трапов устройства
  43. */
  44. extern TRAP_t traps[];
  45. /**
  46. * @brief Общая структура настроек
  47. */
  48. extern SETTINGS_t sSettings;
  49. /**
  50. * @brief Очередь для отправки трапов
  51. */
  52. QueueHandle_t SNMP_TrapQueue;
  53. /**
  54. * @brief Инициализация параметров SNMP
  55. * @retval
  56. */
  57. void SNMP_Init(void)
  58. {
  59. //snmp_mib *my_snmp_mibs[] = { &mib2, &private_mib };
  60. //SETTINGS_SetSnmpDef();
  61. SNMP_AgentInit();
  62. lwip_privmib_init();
  63. //snmp_set_mibs(my_snmp_mibs, LWIP_ARRAYSIZE(my_snmp_mibs));
  64. }
  65. /**
  66. * @brief Системный тик SNMP. Таск должен вызываться с частотой 100Гц.
  67. * @retval
  68. */
  69. void SNMP_SysUpTimeTask(void *arg)
  70. {
  71. TickType_t xLastWakeTime;
  72. const TickType_t xFrequency = 10;
  73. xLastWakeTime = xTaskGetTickCount();
  74. while(1)
  75. {
  76. vTaskDelayUntil( &xLastWakeTime, xFrequency );
  77. //snmp_inc_sysuptime();
  78. }
  79. }
  80. /**
  81. * @brief Тестовый таск для проверки отправки трапов
  82. * @retval
  83. */
  84. void snmp_trap_tread(void *arg)
  85. {
  86. uint8_t trapName;
  87. while(1)
  88. {
  89. if (xQueueReceive(SNMP_TrapQueue, &trapName, 0) == pdTRUE)
  90. {
  91. //SNMP_SetManagerIP(sSettings.sSnmp.managerIP);
  92. SNMP_SendVarbindTrap(&traps[trapName]);
  93. /*
  94. SNMP_SetManagerIP(sSettings.sSnmp.managerIP2);
  95. SNMP_SendVarbindTrap(&traps[trapName]);
  96. SNMP_SetManagerIP(sSettings.sSnmp.managerIP3);
  97. SNMP_SendVarbindTrap(&traps[trapName]);
  98. SNMP_SetManagerIP(sSettings.sSnmp.managerIP4);
  99. SNMP_SendVarbindTrap(&traps[trapName]);
  100. SNMP_SetManagerIP(sSettings.sSnmp.managerIP5);
  101. SNMP_SendVarbindTrap(&traps[trapName]);
  102. */
  103. }
  104. }
  105. }
  106. /**
  107. * @brief Инициализация SNMP агента
  108. * @retval
  109. */
  110. void SNMP_AgentInit(void)
  111. {
  112. SNMP_SetObjDescr();
  113. SNMP_SetReadCommunity(sSettings.sSnmp.readCommunity);
  114. SNMP_SetWriteCommunity(sSettings.sSnmp.writeCommunity);
  115. SNMP_SetSysContact(sSettings.sSnmp.sysContact);
  116. SNMP_SetSysName(sSettings.sSnmp.sysName);
  117. SNMP_SetSysLocation(sSettings.sSnmp.sysLocation);
  118. SNMP_SetManagerIP("192.162.14.37"); //SNMP_SetManagerIP(sSettings.sSnmp.managerIP);
  119. SNMP_SetObjID();
  120. SNMP_SetTrapOnOff(1);
  121. SNMP_InitTrapsBase();
  122. snmp_init();
  123. udp_init();
  124. SNMP_TrapQueue = xQueueCreate(SNMP_TRAP_QUEUE_SIZE, sizeof(uint8_t));
  125. }
  126. /**
  127. * @brief Пользовательская функция для отправки трапа из массива traps[]
  128. * Трап помещается в очередь. Работа с очередью происходит по принципу
  129. * FIFO буфера.
  130. * Если в настройках трапа отправка отключена, то трап игнорируется.
  131. * @retval
  132. */
  133. void SNMP_SendUserTrap(uint8_t trapName)
  134. {
  135. uint16_t availableSpace;
  136. uint8_t dummyTrap;
  137. if (traps[trapName].trapEnable)
  138. {
  139. availableSpace = uxQueueSpacesAvailable(SNMP_TrapQueue);
  140. if (availableSpace == 0)
  141. xQueueReceive(SNMP_TrapQueue, &dummyTrap, 0);
  142. xQueueSend(SNMP_TrapQueue, &trapName, 0);
  143. }
  144. }
  145. /**
  146. * @brief Установить SNMP Descriptor
  147. * @retval
  148. */
  149. // TODO
  150. void SNMP_SetObjDescr(void)
  151. {
  152. static uint16_t len;
  153. strcpy(sSettings.sSnmp.sysDescr, sSettings.sSnmp.sysName);
  154. strcat(sSettings.sSnmp.sysDescr, " ");
  155. strcat(sSettings.sSnmp.sysDescr, VERSION);
  156. strcat(sSettings.sSnmp.sysDescr, " ");
  157. strcat(sSettings.sSnmp.sysDescr, sSettings.sSnmp.sysContact);
  158. strcat(sSettings.sSnmp.sysDescr, " ");
  159. strcat(sSettings.sSnmp.sysDescr, sSettings.sInfo.serialNumber);
  160. strcat(sSettings.sSnmp.sysDescr, " ");
  161. strcat(sSettings.sSnmp.sysDescr, UPS.model);
  162. len = strlen(sSettings.sSnmp.sysDescr);
  163. snmp_mib2_set_sysdescr((u8_t*)sSettings.sSnmp.sysDescr, &len);
  164. }
  165. /**
  166. * @brief Установить SNMP Community для чтения
  167. */
  168. void SNMP_SetReadCommunity(char *comm)
  169. {
  170. //strcpy(sSettings.sSnmp.readCommunity, comm);
  171. snmp_set_community(comm);
  172. }
  173. /**
  174. * @brief Установить SNMP Community для записи
  175. */
  176. void SNMP_SetWriteCommunity(char *comm)
  177. {
  178. //strcpy(sSettings.sSnmp.writeCommunity, comm);
  179. snmp_set_community_write(comm);
  180. }
  181. /**
  182. * @brief Установить SNMP SysContact
  183. * @retval
  184. */
  185. void SNMP_SetSysContact(char *con)
  186. {
  187. static uint16_t len;
  188. len = strlen(con);
  189. //snmp_set_syscontact((u8_t*)con, &len);
  190. snmp_mib2_set_syscontact((u8_t*)con, &len, len);
  191. }
  192. /**
  193. * @brief Установить SNMP SysName
  194. * @retval
  195. */
  196. void SNMP_SetSysName(char *name)
  197. {
  198. static uint16_t len;
  199. len = strlen(name);
  200. //snmp_set_sysname((u8_t*)name, &len);
  201. snmp_mib2_set_sysname((u8_t*)name, &len, len);
  202. }
  203. /**
  204. * @brief Установить SNMP SysLocation
  205. * @retval
  206. */
  207. void SNMP_SetSysLocation(char *loc)
  208. {
  209. static uint16_t len;
  210. len = strlen(loc);
  211. //snmp_set_syslocation((u8_t*)loc, &len);
  212. snmp_mib2_set_syslocation((u8_t*)loc, &len, len);
  213. }
  214. /**
  215. * @brief Установить SNMP SysManagerIP
  216. * @retval
  217. */
  218. void SNMP_SetManagerIP(char *ip)
  219. {
  220. static ip_addr_t trap_addr;
  221. ipaddr_aton(ip, &trap_addr);
  222. snmp_trap_dst_ip_set(0, &trap_addr);
  223. }
  224. /**
  225. * @brief Установить SNMP Object ID
  226. * @retval
  227. */
  228. void SNMP_SetObjID(void)
  229. {
  230. static struct snmp_obj_id my_object_id = {9, {1, 3, 6, 1, 4, 1, 41752, 911, 3}};
  231. //static struct snmp_obj_id my_object_id = {5, {1, 3, 6, 1, 4}};
  232. //snmp_set_sysobjid(&my_object_id);
  233. snmp_set_device_enterprise_oid(&my_object_id);
  234. }
  235. /**
  236. * @brief Вкл/выкл трапы
  237. * @retval
  238. */
  239. void SNMP_SetTrapOnOff(uint8_t state)
  240. {
  241. snmp_trap_dst_enable(0, (u8_t)state);
  242. }
  243. /********************************* (C) ROTEK **********************************/