netdev.c 34 KB

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