netdev.c 36 KB

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