netdev.c 34 KB

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