netdev.c 33 KB

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