netdev.c 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181
  1. /*
  2. * Copyright (c) 2006-2019, RT-Thread Development Team
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. *
  6. * Change Logs:
  7. * Date Author Notes
  8. * 2019-03-18 ChenYong First version
  9. */
  10. #include <stdio.h>
  11. #include <string.h>
  12. #include <rtthread.h>
  13. #include <rthw.h>
  14. #include <netdev_ipaddr.h>
  15. #include <netdev.h>
  16. #ifdef RT_USING_SAL
  17. #include <sal_netdb.h>
  18. #include <sal.h>
  19. #endif /* RT_USING_SAL */
  20. #define DBG_TAG "netdev"
  21. #define DBG_LVL DBG_INFO
  22. #include <rtdbg.h>
  23. /* The list of network interface device */
  24. struct netdev *netdev_list;
  25. /* The default network interface device */
  26. struct netdev *netdev_default;
  27. /**
  28. * This function will register network interface device and
  29. * add it to network interface device list.
  30. *
  31. * @param netdev the network interface device object
  32. * @param name the network interface device name
  33. * @param user_data user-specific data
  34. *
  35. * @return 0: registered successfully
  36. * -1: registered failed
  37. */
  38. int netdev_register(struct netdev *netdev, const char *name, void *user_data)
  39. {
  40. rt_base_t level;
  41. uint16_t flags_mask;
  42. int index;
  43. RT_ASSERT(netdev);
  44. RT_ASSERT(name);
  45. /* clean network interface device */
  46. flags_mask = NETDEV_FLAG_UP | NETDEV_FLAG_LINK_UP | NETDEV_FLAG_INTERNET_UP | NETDEV_FLAG_DHCP;
  47. netdev->flags &= ~flags_mask;
  48. ip_addr_set_zero(&(netdev->ip_addr));
  49. ip_addr_set_zero(&(netdev->netmask));
  50. ip_addr_set_zero(&(netdev->gw));
  51. IP_SET_TYPE_VAL(netdev->ip_addr, IPADDR_TYPE_V4);
  52. IP_SET_TYPE_VAL(netdev->netmask, IPADDR_TYPE_V4);
  53. IP_SET_TYPE_VAL(netdev->gw, IPADDR_TYPE_V4);
  54. #if NETDEV_IPV6
  55. for (index = 0; index < NETDEV_IPV6_NUM_ADDRESSES; index++)
  56. {
  57. ip_addr_set_zero(&(netdev->ip6_addr[index]));
  58. IP_SET_TYPE_VAL(netdev->ip_addr, IPADDR_TYPE_V6);
  59. }
  60. #endif /* NETDEV_IPV6 */
  61. for (index = 0; index < NETDEV_DNS_SERVERS_NUM; index++)
  62. {
  63. ip_addr_set_zero(&(netdev->dns_servers[index]));
  64. IP_SET_TYPE_VAL(netdev->ip_addr, IPADDR_TYPE_V4);
  65. }
  66. netdev->status_callback = RT_NULL;
  67. netdev->addr_callback = RT_NULL;
  68. /* fill network interface device */
  69. rt_strncpy(netdev->name, name, rt_strlen(name));
  70. netdev->user_data = user_data;
  71. /* initialize current network interface device single list */
  72. rt_slist_init(&(netdev->list));
  73. level = rt_hw_interrupt_disable();
  74. if (netdev_list == RT_NULL)
  75. {
  76. netdev_list = netdev;
  77. netdev_default = netdev;
  78. }
  79. else
  80. {
  81. /* tail insertion */
  82. rt_slist_append(&(netdev_list->list), &(netdev->list));
  83. }
  84. rt_hw_interrupt_enable(level);
  85. return RT_EOK;
  86. }
  87. /**
  88. * This function will unregister network interface device and
  89. * delete it from network interface device list.
  90. *
  91. * @param netdev the network interface device object
  92. *
  93. * @return 0: unregistered successfully
  94. * -1: unregistered failed
  95. */
  96. int netdev_unregister(struct netdev *netdev)
  97. {
  98. rt_base_t level;
  99. rt_slist_t *node = RT_NULL;
  100. struct netdev *cur_netdev = RT_NULL;
  101. RT_ASSERT(netdev);
  102. if (netdev_list == RT_NULL)
  103. {
  104. return -RT_ERROR;
  105. }
  106. level = rt_hw_interrupt_disable();
  107. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  108. {
  109. cur_netdev = rt_slist_entry(node, struct netdev, list);
  110. if (cur_netdev && (rt_memcpy(cur_netdev, netdev, sizeof(struct netdev)) == 0))
  111. {
  112. rt_slist_remove(&(netdev_list->list), &(cur_netdev->list));
  113. rt_hw_interrupt_enable(level);
  114. return RT_EOK;
  115. }
  116. }
  117. rt_hw_interrupt_enable(level);
  118. /* not find this network interface device in network interface device list */
  119. return -RT_ERROR;
  120. }
  121. /**
  122. * This function will get the first network interface device
  123. * with the flags in network interface device list.
  124. *
  125. * @param flags the network interface device flags
  126. *
  127. * @return != NULL: network interface device object
  128. * NULL: get failed
  129. */
  130. struct netdev *netdev_get_first_by_flags(uint16_t flags)
  131. {
  132. rt_base_t level;
  133. rt_slist_t *node = RT_NULL;
  134. struct netdev *netdev = RT_NULL;
  135. if (netdev_list == RT_NULL)
  136. {
  137. return RT_NULL;
  138. }
  139. level = rt_hw_interrupt_disable();
  140. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  141. {
  142. netdev = rt_slist_entry(node, struct netdev, list);
  143. if (netdev && (netdev->flags & flags) != 0)
  144. {
  145. rt_hw_interrupt_enable(level);
  146. return netdev;
  147. }
  148. }
  149. rt_hw_interrupt_enable(level);
  150. return RT_NULL;
  151. }
  152. /**
  153. * This function will get the first network interface device
  154. * in network interface device list by IP address.
  155. *
  156. * @param addr the network interface device IP address
  157. *
  158. * @return != NULL: network interface device object
  159. * NULL: get failed
  160. */
  161. struct netdev *netdev_get_by_ipaddr(ip_addr_t *ip_addr)
  162. {
  163. rt_base_t level;
  164. rt_slist_t *node = RT_NULL;
  165. struct netdev *netdev = RT_NULL;
  166. if (netdev_list == RT_NULL)
  167. {
  168. return RT_NULL;
  169. }
  170. level = rt_hw_interrupt_disable();
  171. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  172. {
  173. netdev = rt_slist_entry(node, struct netdev, list);
  174. if (netdev && ip_addr_cmp(&(netdev->ip_addr), ip_addr))
  175. {
  176. rt_hw_interrupt_enable(level);
  177. return netdev;
  178. }
  179. }
  180. rt_hw_interrupt_enable(level);
  181. return RT_NULL;
  182. }
  183. /**
  184. * This function will get network interface device
  185. * in network interface device list by netdev name.
  186. *
  187. * @param name the network interface device name
  188. *
  189. * @return != NULL: network interface device object
  190. * NULL: get failed
  191. */
  192. struct netdev *netdev_get_by_name(const char *name)
  193. {
  194. rt_base_t level;
  195. rt_slist_t *node = RT_NULL;
  196. struct netdev *netdev = RT_NULL;
  197. if (netdev_list == RT_NULL)
  198. {
  199. return RT_NULL;
  200. }
  201. level = rt_hw_interrupt_disable();
  202. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  203. {
  204. netdev = rt_slist_entry(node, struct netdev, list);
  205. if (netdev && (rt_strncmp(netdev->name, name, rt_strlen(netdev->name)) == 0))
  206. {
  207. rt_hw_interrupt_enable(level);
  208. return netdev;
  209. }
  210. }
  211. rt_hw_interrupt_enable(level);
  212. return RT_NULL;
  213. }
  214. #ifdef RT_USING_SAL
  215. /**
  216. * This function will get the first network interface device
  217. * in network interface device list by protocol family type.
  218. *
  219. * @param family the network interface device protocol family type
  220. *
  221. * @return != NULL: network interface device object
  222. * NULL: get failed
  223. */
  224. struct netdev *netdev_get_by_family(int family)
  225. {
  226. rt_base_t level;
  227. rt_slist_t *node = RT_NULL;
  228. struct netdev *netdev = RT_NULL;
  229. struct sal_proto_family *pf = RT_NULL;
  230. if (netdev_list == RT_NULL)
  231. {
  232. return RT_NULL;
  233. }
  234. level = rt_hw_interrupt_disable();
  235. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  236. {
  237. netdev = rt_slist_entry(node, struct netdev, list);
  238. pf = (struct sal_proto_family *) netdev->sal_user_data;
  239. if (pf && pf->skt_ops && pf->family == family && netdev_is_up(netdev))
  240. {
  241. rt_hw_interrupt_enable(level);
  242. return netdev;
  243. }
  244. }
  245. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  246. {
  247. netdev = rt_slist_entry(node, struct netdev, list);
  248. pf = (struct sal_proto_family *) netdev->sal_user_data;
  249. if (pf && pf->skt_ops && pf->sec_family == family && netdev_is_up(netdev))
  250. {
  251. rt_hw_interrupt_enable(level);
  252. return netdev;
  253. }
  254. }
  255. rt_hw_interrupt_enable(level);
  256. return RT_NULL;
  257. }
  258. /**
  259. * This function will get the family type from network interface device
  260. *
  261. * @param netdev network interface device object
  262. *
  263. * @return the network interface device family type
  264. */
  265. int netdev_family_get(struct netdev *netdev)
  266. {
  267. RT_ASSERT(netdev);
  268. return ((struct sal_proto_family *)netdev->sal_user_data)->family;
  269. }
  270. #endif /* RT_USING_SAL */
  271. /**
  272. * This function will set default network interface device.
  273. *
  274. * @param netdev the network interface device to change
  275. */
  276. void netdev_set_default(struct netdev *netdev)
  277. {
  278. if (netdev)
  279. {
  280. netdev_default = netdev;
  281. LOG_D("Setting default network interface device name(%s) successfully.", netdev->name);
  282. }
  283. }
  284. /**
  285. * This function will enable network interface device .
  286. *
  287. * @param netdev the network interface device to change
  288. *
  289. * @return 0: set status successfully
  290. * -1: set status failed
  291. */
  292. int netdev_set_up(struct netdev *netdev)
  293. {
  294. RT_ASSERT(netdev);
  295. if (!netdev->ops || !netdev->ops->set_up)
  296. {
  297. LOG_E("The network interface device(%s) not support to set status.", netdev->name);
  298. return -RT_ERROR;
  299. }
  300. /* network interface device status flags check */
  301. if (netdev_is_up(netdev))
  302. {
  303. return RT_EOK;
  304. }
  305. /* execute enable network interface device operations by network interface device driver */
  306. return netdev->ops->set_up(netdev);
  307. }
  308. /**
  309. * This function will disable network interface device.
  310. *
  311. * @param netdev the network interface device to change
  312. *
  313. * @return 0: set status successfully
  314. * -1: set sttaus failed
  315. */
  316. int netdev_set_down(struct netdev *netdev)
  317. {
  318. RT_ASSERT(netdev);
  319. if (!netdev->ops || !netdev->ops->set_down)
  320. {
  321. LOG_E("The network interface device(%s) not support to set status.", netdev->name);
  322. return -RT_ERROR;
  323. }
  324. /* network interface device status flags check */
  325. if (!netdev_is_up(netdev))
  326. {
  327. return RT_EOK;
  328. }
  329. /* execute disable network interface device operations by network interface driver */
  330. return netdev->ops->set_down(netdev);
  331. }
  332. /**
  333. * This function will control network interface device DHCP capability enable or disable.
  334. *
  335. * @param netdev the network interface device device to change
  336. * @param is_enable the new DHCP status
  337. *
  338. * @return 0: set DHCP status successfully
  339. * -1: set DHCP status failed
  340. */
  341. int netdev_dhcp_enabled(struct netdev *netdev, rt_bool_t is_enabled)
  342. {
  343. RT_ASSERT(netdev);
  344. if (!netdev->ops || !netdev->ops->set_dhcp)
  345. {
  346. LOG_E("The network interface device(%s) not support to set DHCP status.", netdev->name);
  347. return -RT_ERROR;
  348. }
  349. /* network interface device DHCP flags check */
  350. if (netdev_is_dhcp_enabled(netdev) == is_enabled)
  351. {
  352. return RT_EOK;
  353. }
  354. /* execute network interface device DHCP capability control operations */
  355. return netdev->ops->set_dhcp(netdev, is_enabled);
  356. }
  357. /**
  358. * This function will set network interface device IP address.
  359. *
  360. * @param netdev the network interface device to change
  361. * @param ipaddr the new IP address
  362. *
  363. * @return 0: set IP address successfully
  364. * -1: set IP address failed
  365. */
  366. int netdev_set_ipaddr(struct netdev *netdev, const ip_addr_t *ip_addr)
  367. {
  368. RT_ASSERT(netdev);
  369. RT_ASSERT(ip_addr);
  370. if (!netdev->ops || !netdev->ops->set_addr_info)
  371. {
  372. LOG_E("The network interface device(%s) not support to set IP address.", netdev->name);
  373. return -RT_ERROR;
  374. }
  375. if (netdev_is_dhcp_enabled(netdev))
  376. {
  377. LOG_E("The network interface device(%s) DHCP capability is enable, not support set IP address.", netdev->name);
  378. return -RT_ERROR;
  379. }
  380. /* execute network interface device set IP address operations */
  381. return netdev->ops->set_addr_info(netdev, (ip_addr_t *)ip_addr, RT_NULL, RT_NULL);
  382. }
  383. /**
  384. * This function will set network interface device netmask address.
  385. *
  386. * @param netdev the network interface device to change
  387. * @param netmask the new netmask address
  388. *
  389. * @return 0: set netmask address successfully
  390. * -1: set netmask address failed
  391. */
  392. int netdev_set_netmask(struct netdev *netdev, const ip_addr_t *netmask)
  393. {
  394. RT_ASSERT(netdev);
  395. RT_ASSERT(netmask);
  396. if (!netdev->ops || !netdev->ops->set_addr_info)
  397. {
  398. LOG_E("The network interface device(%s) not support to set netmask address.", netdev->name);
  399. return -RT_ERROR;
  400. }
  401. if (netdev_is_dhcp_enabled(netdev))
  402. {
  403. LOG_E("The network interface device(%s) DHCP capability is enable, not support set netmask address.", netdev->name);
  404. return -RT_ERROR;
  405. }
  406. /* execute network interface device set netmask address operations */
  407. return netdev->ops->set_addr_info(netdev, RT_NULL, (ip_addr_t *)netmask, RT_NULL);
  408. }
  409. /**
  410. * This function will set network interface device gateway address.
  411. *
  412. * @param netdev the network interface device to change
  413. * @param gateway the new gateway address
  414. *
  415. * @return 0: set gateway address successfully
  416. * -1: set gateway address failed
  417. */
  418. int netdev_set_gw(struct netdev *netdev, const ip_addr_t *gw)
  419. {
  420. RT_ASSERT(netdev);
  421. RT_ASSERT(gw);
  422. if (!netdev->ops || !netdev->ops->set_addr_info)
  423. {
  424. LOG_E("The network interface device(%s) not support to set gateway address.", netdev->name);
  425. return -RT_ERROR;
  426. }
  427. if (netdev_is_dhcp_enabled(netdev))
  428. {
  429. LOG_E("The network interface device(%s) DHCP capability is enable, not support set gateway address.", netdev->name);
  430. return -RT_ERROR;
  431. }
  432. /* execute network interface device set gateway address operations */
  433. return netdev->ops->set_addr_info(netdev, RT_NULL, RT_NULL, (ip_addr_t *)gw);
  434. }
  435. /**
  436. * This function will set network interface device DNS server address.
  437. *
  438. * @param netdev the network interface device to change
  439. * @param dns_server the new DNS server address
  440. *
  441. * @return 0: set netmask address successfully
  442. * -1: set netmask address failed
  443. */
  444. int netdev_set_dns_server(struct netdev *netdev, uint8_t dns_num, const ip_addr_t *dns_server)
  445. {
  446. RT_ASSERT(netdev);
  447. RT_ASSERT(dns_server);
  448. if (dns_num >= NETDEV_DNS_SERVERS_NUM)
  449. {
  450. LOG_E("The number of DNS servers(%d) set exceeds the maximum number(%d).", dns_num + 1, NETDEV_DNS_SERVERS_NUM);
  451. return -RT_ERROR;
  452. }
  453. if (!netdev->ops || !netdev->ops->set_dns_server)
  454. {
  455. LOG_E("The network interface device(%s) not support to set DNS server address.", netdev->name);
  456. return -RT_ERROR;
  457. }
  458. /* execute network interface device set DNS server address operations */
  459. return netdev->ops->set_dns_server(netdev, dns_num, (ip_addr_t *)dns_server);
  460. }
  461. /**
  462. * This function will set callback to be called when the network interface device status has been changed.
  463. *
  464. * @param netdev the network interface device to change
  465. * @param status_callback the callback be called when the status has been changed.
  466. */
  467. void netdev_set_status_callback(struct netdev *netdev, netdev_callback_fn status_callback)
  468. {
  469. RT_ASSERT(netdev);
  470. RT_ASSERT(status_callback);
  471. netdev->status_callback = status_callback;
  472. }
  473. /**
  474. * This function will set callback to be called when the network interface device address has been changed.
  475. *
  476. * @param netdev the network interface device to change
  477. * @param addr_callback the callback be called when the address has been changed.
  478. */
  479. void netdev_set_addr_callback(struct netdev *netdev, netdev_callback_fn addr_callback)
  480. {
  481. RT_ASSERT(netdev);
  482. RT_ASSERT(addr_callback);
  483. netdev->addr_callback = addr_callback;
  484. }
  485. /**
  486. * This function will set network interface device IP address.
  487. * @NOTE it can only be called in the network interface device driver.
  488. *
  489. * @param netdev the network interface device to change
  490. * @param ipaddr the new IP address
  491. */
  492. void netdev_low_level_set_ipaddr(struct netdev *netdev, const ip_addr_t *ip_addr)
  493. {
  494. RT_ASSERT(ip_addr);
  495. if (netdev && ip_addr_cmp(&(netdev->ip_addr), ip_addr) == 0)
  496. {
  497. ip_addr_copy(netdev->ip_addr, *ip_addr);
  498. #ifdef RT_USING_SAL
  499. /* set network interface device flags to internet up */
  500. if (netdev_is_up(netdev) && netdev_is_link_up(netdev))
  501. {
  502. sal_check_netdev_internet_up(netdev);
  503. }
  504. #endif /* RT_USING_SAL */
  505. /* execute IP address change callback function */
  506. if (netdev->addr_callback)
  507. {
  508. netdev->addr_callback(netdev, NETDEV_CB_ADDR_IP);
  509. }
  510. }
  511. }
  512. /**
  513. * This function will set network interface device netmask address.
  514. * @NOTE it can only be called in the network interface device driver.
  515. *
  516. * @param netdev the network interface device to change
  517. * @param netmask the new netmask address
  518. */
  519. void netdev_low_level_set_netmask(struct netdev *netdev, const ip_addr_t *netmask)
  520. {
  521. RT_ASSERT(netmask);
  522. if (netdev && ip_addr_cmp(&(netdev->netmask), netmask) == 0)
  523. {
  524. ip_addr_copy(netdev->netmask, *netmask);
  525. #ifdef RT_USING_SAL
  526. /* set network interface device flags to internet up */
  527. if (netdev_is_up(netdev) && netdev_is_link_up(netdev) &&
  528. !ip_addr_isany(&(netdev->ip_addr)))
  529. {
  530. sal_check_netdev_internet_up(netdev);
  531. }
  532. #endif /* RT_USING_SAL */
  533. /* execute netmask address change callback function */
  534. if (netdev->addr_callback)
  535. {
  536. netdev->addr_callback(netdev, NETDEV_CB_ADDR_NETMASK);
  537. }
  538. }
  539. }
  540. /**
  541. * This function will set network interface device gateway address.
  542. * @NOTE it can only be called in the network interface device driver.
  543. *
  544. * @param netdev the network interface device to change
  545. * @param gateway the new gateway address
  546. */
  547. void netdev_low_level_set_gw(struct netdev *netdev, const ip_addr_t *gw)
  548. {
  549. RT_ASSERT(gw);
  550. if (netdev && ip_addr_cmp(&(netdev->gw), gw) == 0)
  551. {
  552. ip_addr_copy(netdev->gw, *gw);
  553. #ifdef RT_USING_SAL
  554. /* set network interface device flags to internet up */
  555. if (netdev_is_up(netdev) && netdev_is_link_up(netdev) &&
  556. !ip_addr_isany(&(netdev->ip_addr)))
  557. {
  558. sal_check_netdev_internet_up(netdev);
  559. }
  560. #endif /* RT_USING_SAL */
  561. /* execute gateway address change callback function */
  562. if (netdev->addr_callback)
  563. {
  564. netdev->addr_callback(netdev, NETDEV_CB_ADDR_GATEWAY);
  565. }
  566. }
  567. }
  568. /**
  569. * This function will set network interface device DNS server address.
  570. * @NOTE it can only be called in the network interface device driver.
  571. *
  572. * @param netdev the network interface device to change
  573. * @param dns_server the new DNS server address
  574. *
  575. */
  576. void netdev_low_level_set_dns_server(struct netdev *netdev, uint8_t dns_num, const ip_addr_t *dns_server)
  577. {
  578. int index;
  579. RT_ASSERT(dns_server);
  580. /* check DNS servers is exist */
  581. for (index = 0; index < NETDEV_DNS_SERVERS_NUM; index++)
  582. {
  583. if (ip_addr_cmp(&(netdev->dns_servers[index]), dns_server))
  584. {
  585. return;
  586. }
  587. }
  588. if (netdev && dns_num < NETDEV_DNS_SERVERS_NUM)
  589. {
  590. ip_addr_copy(netdev->dns_servers[dns_num], *dns_server);
  591. /* execute DNS servers address change callback function */
  592. if (netdev->addr_callback)
  593. {
  594. netdev->addr_callback(netdev, NETDEV_CB_ADDR_DNS_SERVER);
  595. }
  596. }
  597. }
  598. #ifdef NETDEV_USING_AUTO_DEFAULT
  599. /* Change to the first link_up network interface device automatically */
  600. static void netdev_auto_change_default(struct netdev *netdev)
  601. {
  602. struct netdev *new_netdev = RT_NULL;
  603. if (rt_memcmp(netdev, netdev_default, sizeof(struct netdev)) == 0)
  604. {
  605. new_netdev = netdev_get_first_by_flags(NETDEV_FLAG_LINK_UP);
  606. if (new_netdev)
  607. {
  608. netdev_set_default(new_netdev);
  609. }
  610. }
  611. }
  612. #endif /* NETDEV_USING_AUTO_DEFAULT */
  613. /**
  614. * This function will set network interface device status.
  615. * @NOTE it can only be called in the network interface device driver.
  616. *
  617. * @param netdev the network interface device to change
  618. * @param is_up the new status
  619. */
  620. void netdev_low_level_set_status(struct netdev *netdev, rt_bool_t is_up)
  621. {
  622. if (netdev && netdev_is_up(netdev) != is_up)
  623. {
  624. if (is_up)
  625. {
  626. netdev->flags |= NETDEV_FLAG_UP;
  627. }
  628. else
  629. {
  630. netdev->flags &= ~NETDEV_FLAG_UP;
  631. #ifdef NETDEV_USING_AUTO_DEFAULT
  632. /* change to the first link_up network interface device automatically */
  633. netdev_auto_change_default(netdev);
  634. #endif /* NETDEV_USING_AUTO_DEFAULT */
  635. }
  636. /* execute network interface device status change callback function */
  637. if (netdev->status_callback)
  638. {
  639. netdev->status_callback(netdev, is_up ? NETDEV_CB_STATUS_UP : NETDEV_CB_STATUS_DOWN);
  640. }
  641. }
  642. }
  643. /**
  644. * This function will set network interface device active link status.
  645. * @NOTE it can only be called in the network interface device driver.
  646. *
  647. * @param netdev the network interface device to change
  648. * @param is_up the new link status
  649. */
  650. void netdev_low_level_set_link_status(struct netdev *netdev, rt_bool_t is_up)
  651. {
  652. if (netdev && netdev_is_link_up(netdev) != is_up)
  653. {
  654. if (is_up)
  655. {
  656. netdev->flags |= NETDEV_FLAG_LINK_UP;
  657. #ifdef RT_USING_SAL
  658. /* set network interface device flags to internet up */
  659. if (netdev_is_up(netdev) && !ip_addr_isany(&(netdev->ip_addr)))
  660. {
  661. sal_check_netdev_internet_up(netdev);
  662. }
  663. #endif /* RT_USING_SAL */
  664. }
  665. else
  666. {
  667. netdev->flags &= ~NETDEV_FLAG_LINK_UP;
  668. /* set network interface device flags to internet down */
  669. netdev->flags &= ~NETDEV_FLAG_INTERNET_UP;
  670. #ifdef NETDEV_USING_AUTO_DEFAULT
  671. /* change to the first link_up network interface device automatically */
  672. netdev_auto_change_default(netdev);
  673. #endif /* NETDEV_USING_AUTO_DEFAULT */
  674. }
  675. /* execute link status change callback function */
  676. if (netdev->status_callback)
  677. {
  678. netdev->status_callback(netdev, is_up ? NETDEV_CB_STATUS_LINK_UP : NETDEV_CB_STATUS_LINK_DOWN);
  679. }
  680. }
  681. }
  682. /**
  683. * This function will set network interface device DHCP status.
  684. * @NOTE it can only be called in the network interface device driver.
  685. *
  686. * @param netdev the network interface device to change
  687. * @param is_up the new DHCP status
  688. */
  689. void netdev_low_level_set_dhcp_status(struct netdev *netdev, rt_bool_t is_enable)
  690. {
  691. if (netdev && netdev_is_dhcp_enabled(netdev) != is_enable)
  692. {
  693. if (is_enable)
  694. {
  695. netdev->flags |= NETDEV_FLAG_DHCP;
  696. }
  697. else
  698. {
  699. netdev->flags &= ~NETDEV_FLAG_DHCP;
  700. }
  701. /* execute DHCP status change callback function */
  702. if (netdev->status_callback)
  703. {
  704. netdev->status_callback(netdev, is_enable ? NETDEV_CB_STATUS_DHCP_ENABLE : NETDEV_CB_STATUS_DHCP_DISABLE);
  705. }
  706. }
  707. }
  708. #ifdef RT_USING_FINSH
  709. #include <finsh.h>
  710. #ifdef NETDEV_USING_IFCONFIG
  711. static void netdev_list_if(void)
  712. {
  713. #define NETDEV_IFCONFIG_MAC_MAX_LEN 6
  714. #define NETDEV_IFCONFIG_IEMI_MAX_LEN 8
  715. rt_ubase_t index;
  716. rt_slist_t *node = RT_NULL;
  717. struct netdev *netdev = RT_NULL;
  718. struct netdev *cur_netdev_list = netdev_list;
  719. if (cur_netdev_list == RT_NULL)
  720. {
  721. rt_kprintf("ifconfig: network interface device list error.\n");
  722. return;
  723. }
  724. for (node = &(cur_netdev_list->list); node; node = rt_slist_next(node))
  725. {
  726. netdev = rt_list_entry(node, struct netdev, list);
  727. rt_kprintf("network interface device: %.*s%s\n",
  728. RT_NAME_MAX, netdev->name,
  729. (netdev == netdev_default) ? " (Default)" : "");
  730. rt_kprintf("MTU: %d\n", netdev->mtu);
  731. /* 6 - MAC address, 8 - IEMI */
  732. if (netdev->hwaddr_len == NETDEV_IFCONFIG_MAC_MAX_LEN)
  733. {
  734. rt_kprintf("MAC: ");
  735. for (index = 0; index < netdev->hwaddr_len; index++)
  736. {
  737. rt_kprintf("%02x ", netdev->hwaddr[index]);
  738. }
  739. }
  740. else if (netdev->hwaddr_len == NETDEV_IFCONFIG_IEMI_MAX_LEN)
  741. {
  742. rt_kprintf("IEMI: ");
  743. for (index = 0; index < netdev->hwaddr_len; index++)
  744. {
  745. /* two numbers are displayed at one time*/
  746. if (netdev->hwaddr[index] < 10 && index != netdev->hwaddr_len - 1)
  747. rt_kprintf("0");
  748. rt_kprintf("%d", netdev->hwaddr[index]);
  749. }
  750. }
  751. rt_kprintf("\nFLAGS:");
  752. if (netdev->flags & NETDEV_FLAG_UP) rt_kprintf(" UP");
  753. else rt_kprintf(" DOWN");
  754. if (netdev->flags & NETDEV_FLAG_LINK_UP) rt_kprintf(" LINK_UP");
  755. else rt_kprintf(" LINK_DOWN");
  756. if (netdev->flags & NETDEV_FLAG_INTERNET_UP) rt_kprintf(" INTERNET_UP");
  757. else rt_kprintf(" INTERNET_DOWN");
  758. if (netdev->flags & NETDEV_FLAG_DHCP) rt_kprintf(" DHCP_ENABLE");
  759. else rt_kprintf(" DHCP_DISABLE");
  760. if (netdev->flags & NETDEV_FLAG_ETHARP) rt_kprintf(" ETHARP");
  761. if (netdev->flags & NETDEV_FLAG_BROADCAST) rt_kprintf(" BROADCAST");
  762. if (netdev->flags & NETDEV_FLAG_IGMP) rt_kprintf(" IGMP");
  763. rt_kprintf("\n");
  764. rt_kprintf("ip address: %s\n", inet_ntoa(netdev->ip_addr));
  765. rt_kprintf("gw address: %s\n", inet_ntoa(netdev->gw));
  766. rt_kprintf("net mask : %s\n", inet_ntoa(netdev->netmask));
  767. #if NETDEV_IPV6
  768. {
  769. ip_addr_t *addr;
  770. int i;
  771. addr = &netdev->ip6_addr[0];
  772. if (!ip_addr_isany(addr))
  773. {
  774. rt_kprintf("ipv6 link-local: %s %s\n", inet_ntoa(*addr),
  775. !ip_addr_isany(addr) ? "VALID" : "INVALID");
  776. for (i = 1; i < NETDEV_IPV6_NUM_ADDRESSES; i++)
  777. {
  778. addr = &netdev->ip6_addr[i];
  779. rt_kprintf("ipv6[%d] address: %s %s\n", i, inet_ntoa(*addr),
  780. !ip_addr_isany(addr) ? "VALID" : "INVALID");
  781. }
  782. }
  783. }
  784. #endif /* NETDEV_IPV6 */
  785. for (index = 0; index < NETDEV_DNS_SERVERS_NUM; index++)
  786. {
  787. rt_kprintf("dns server #%d: %s\n", index, inet_ntoa(netdev->dns_servers[index]));
  788. }
  789. if (rt_slist_next(node))
  790. {
  791. rt_kprintf("\n");
  792. }
  793. }
  794. }
  795. static void netdev_set_if(char* netdev_name, char* ip_addr, char* gw_addr, char* nm_addr)
  796. {
  797. struct netdev *netdev = RT_NULL;
  798. ip_addr_t addr;
  799. netdev = netdev_get_by_name(netdev_name);
  800. if (netdev == RT_NULL)
  801. {
  802. rt_kprintf("bad network interface device name(%s).\n", netdev_name);
  803. return;
  804. }
  805. /* set IP address */
  806. if ((ip_addr != RT_NULL) && inet_aton(ip_addr, &addr))
  807. {
  808. netdev_set_ipaddr(netdev, &addr);
  809. }
  810. /* set gateway address */
  811. if ((gw_addr != RT_NULL) && inet_aton(gw_addr, &addr))
  812. {
  813. netdev_set_gw(netdev, &addr);
  814. }
  815. /* set netmask address */
  816. if ((nm_addr != RT_NULL) && inet_aton(nm_addr, &addr))
  817. {
  818. netdev_set_netmask(netdev, &addr);
  819. }
  820. }
  821. int netdev_ifconfig(int argc, char **argv)
  822. {
  823. if (argc == 1)
  824. {
  825. netdev_list_if();
  826. }
  827. else if (argc == 5)
  828. {
  829. rt_kprintf("config : %s\n", argv[1]);
  830. rt_kprintf("IP addr: %s\n", argv[2]);
  831. rt_kprintf("Gateway: %s\n", argv[3]);
  832. rt_kprintf("netmask: %s\n", argv[4]);
  833. netdev_set_if(argv[1], argv[2], argv[3], argv[4]);
  834. }
  835. else
  836. {
  837. rt_kprintf("bad parameter! e.g: ifconfig e0 192.168.1.30 192.168.1.1 255.255.255.0\n");
  838. }
  839. return 0;
  840. }
  841. FINSH_FUNCTION_EXPORT_ALIAS(netdev_ifconfig, __cmd_ifconfig, list the information of all network interfaces);
  842. #endif /* NETDEV_USING_IFCONFIG */
  843. #ifdef NETDEV_USING_PING
  844. int netdev_cmd_ping(char* target_name, rt_uint32_t times, rt_size_t size)
  845. {
  846. #define NETDEV_PING_DATA_SIZE 32
  847. /** ping receive timeout - in milliseconds */
  848. #define NETDEV_PING_RECV_TIMEO (2 * RT_TICK_PER_SECOND)
  849. /** ping delay - in milliseconds */
  850. #define NETDEV_PING_DELAY (1 * RT_TICK_PER_SECOND)
  851. /* check netdev ping options */
  852. #define NETDEV_PING_IS_COMMONICABLE(netdev) \
  853. ((netdev) && (netdev)->ops && (netdev)->ops->ping && \
  854. netdev_is_up(netdev) && netdev_is_link_up(netdev)) \
  855. struct netdev *netdev = RT_NULL;
  856. struct netdev_ping_resp ping_resp;
  857. int index, ret = 0;
  858. if (size == 0)
  859. {
  860. size = NETDEV_PING_DATA_SIZE;
  861. }
  862. if (NETDEV_PING_IS_COMMONICABLE(netdev_default))
  863. {
  864. /* using default network interface device for ping */
  865. netdev = netdev_default;
  866. }
  867. else
  868. {
  869. /* using first internet up status network interface device */
  870. netdev = netdev_get_first_by_flags(NETDEV_FLAG_LINK_UP);
  871. if (netdev == RT_NULL || NETDEV_PING_IS_COMMONICABLE(netdev) == 0)
  872. {
  873. rt_kprintf("ping: network interface device get error.\n");
  874. return -RT_ERROR;
  875. }
  876. }
  877. for (index = 0; index < times; index++)
  878. {
  879. rt_memset(&ping_resp, 0x00, sizeof(struct netdev_ping_resp));
  880. ret = netdev->ops->ping(netdev, (const char *)target_name, size, NETDEV_PING_RECV_TIMEO, &ping_resp);
  881. if (ret == -RT_ETIMEOUT)
  882. {
  883. rt_kprintf("ping: from %s icmp_seq=%d timeout\n",
  884. (ip_addr_isany(&(ping_resp.ip_addr))) ? target_name : inet_ntoa(ping_resp.ip_addr), index);
  885. }
  886. else if (ret == -RT_ERROR)
  887. {
  888. rt_kprintf("ping: unknown %s %s\n",
  889. (ip_addr_isany(&(ping_resp.ip_addr))) ? "host" : "address",
  890. (ip_addr_isany(&(ping_resp.ip_addr))) ? target_name : inet_ntoa(ping_resp.ip_addr));
  891. }
  892. else
  893. {
  894. if (ping_resp.ttl == 0)
  895. {
  896. rt_kprintf("%d bytes from %s icmp_seq=%d time=%d ms\n",
  897. ping_resp.data_len, inet_ntoa(ping_resp.ip_addr), index, ping_resp.ticks);
  898. }
  899. else
  900. {
  901. rt_kprintf("%d bytes from %s icmp_seq=%d ttl=%d time=%d ms\n",
  902. ping_resp.data_len, inet_ntoa(ping_resp.ip_addr), index, ping_resp.ttl, ping_resp.ticks);
  903. }
  904. }
  905. rt_thread_mdelay(NETDEV_PING_DELAY);
  906. }
  907. return RT_EOK;
  908. }
  909. int netdev_ping(int argc, char **argv)
  910. {
  911. if (argc == 1)
  912. {
  913. rt_kprintf("Please input: ping <host address>\n");
  914. }
  915. else
  916. {
  917. netdev_cmd_ping(argv[1], 4, 0);
  918. }
  919. return 0;
  920. }
  921. FINSH_FUNCTION_EXPORT_ALIAS(netdev_ping, __cmd_ping, ping network host);
  922. #endif /* NETDEV_USING_IFCONFIG */
  923. static void netdev_list_dns(void)
  924. {
  925. int index = 0;
  926. struct netdev *netdev = RT_NULL;
  927. rt_slist_t *node = RT_NULL;
  928. for (node = &(netdev_list->list); node; node = rt_slist_next(node))
  929. {
  930. netdev = rt_list_entry(node, struct netdev, list);
  931. rt_kprintf("network interface device: %.*s%s\n",
  932. RT_NAME_MAX, netdev->name,
  933. (netdev == netdev_default)?" (Default)":"");
  934. for(index = 0; index < NETDEV_DNS_SERVERS_NUM; index++)
  935. {
  936. rt_kprintf("dns server #%d: %s\n", index, inet_ntoa(netdev->dns_servers[index]));
  937. }
  938. if (rt_slist_next(node))
  939. {
  940. rt_kprintf("\n");
  941. }
  942. }
  943. }
  944. static void netdev_set_dns(char *netdev_name, uint8_t dns_num, char *dns_server)
  945. {
  946. struct netdev *netdev = RT_NULL;
  947. ip_addr_t dns_addr;
  948. netdev = netdev_get_by_name(netdev_name);
  949. if (netdev == RT_NULL)
  950. {
  951. rt_kprintf("bad network interface device name(%s).\n", netdev_name);
  952. return;
  953. }
  954. inet_aton(dns_server, &dns_addr);
  955. netdev_set_dns_server(netdev, dns_num, &dns_addr);
  956. rt_kprintf("set network interface device(%s) dns server #0: %s\n", netdev_name, dns_server);
  957. }
  958. int netdev_dns(int argc, char **argv)
  959. {
  960. if (argc == 1)
  961. {
  962. netdev_list_dns();
  963. }
  964. else if (argc == 3)
  965. {
  966. netdev_set_dns(argv[1], 0, argv[2]);
  967. }
  968. else if (argc == 4)
  969. {
  970. netdev_set_dns(argv[1], atoi(argv[2]), argv[3]);
  971. }
  972. else
  973. {
  974. rt_kprintf("bad parameter! input: dns <netdev_name> [dns_num] <dns_server>\n");
  975. return -1;
  976. }
  977. return 0;
  978. }
  979. FINSH_FUNCTION_EXPORT_ALIAS(netdev_dns, __cmd_dns, list and set the information of dns);
  980. #ifdef NETDEV_USING_NETSTAT
  981. static void netdev_cmd_netstat(void)
  982. {
  983. rt_slist_t *node = RT_NULL;
  984. struct netdev *netdev = RT_NULL;
  985. struct netdev *cur_netdev_list = netdev_list;
  986. if (cur_netdev_list == RT_NULL)
  987. {
  988. rt_kprintf("netstat: network interface device list error.\n");
  989. return;
  990. }
  991. for (node = &(cur_netdev_list->list); node; node = rt_slist_next(node))
  992. {
  993. netdev = rt_list_entry(node, struct netdev, list);
  994. if (netdev && netdev->ops && netdev->ops->netstat)
  995. {
  996. break;
  997. }
  998. }
  999. netdev->ops->netstat(netdev);
  1000. }
  1001. int netdev_netstat(int argc, char **argv)
  1002. {
  1003. if (argc != 1)
  1004. {
  1005. rt_kprintf("Please input: netstat \n");
  1006. }
  1007. else
  1008. {
  1009. netdev_cmd_netstat();
  1010. }
  1011. return 0;
  1012. }
  1013. FINSH_FUNCTION_EXPORT_ALIAS(netdev_netstat, __cmd_netstat, list the information of TCP / IP);
  1014. #endif /* NETDEV_USING_NETSTAT */
  1015. #endif /* RT_USING_FINSH */