luat_network_adapter.h 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804
  1. #ifndef __LUAT_NW_ADAPTER_H__
  2. #define __LUAT_NW_ADAPTER_H__
  3. #include "luat_base.h"
  4. // #ifdef LUAT_USE_NETWORK
  5. #if defined(LUAT_EC7XX_CSDK) || defined(CHIP_EC618) || defined(__AIR105_BSP__) || defined(CONFIG_SOC_8910) || defined(CONFIG_SOC_8850)
  6. #include "bsp_common.h"
  7. #endif
  8. #include "luat_rtos.h"
  9. #ifndef __BSP_COMMON_H__
  10. #include "c_common.h"
  11. #endif
  12. #ifdef LUAT_USE_TLS
  13. #include "mbedtls/ssl.h"
  14. #include "mbedtls/platform.h"
  15. #include "mbedtls/debug.h"
  16. #include "mbedtls/x509_crt.h"
  17. #include "mbedtls/base64.h"
  18. #include "mbedtls/ctr_drbg.h"
  19. #include "mbedtls/entropy.h"
  20. #include "mbedtls/sha1.h"
  21. #endif
  22. #ifdef LUAT_USE_LWIP
  23. #include "lwip/opt.h"
  24. #include "lwip/netif.h"
  25. #include "lwip/timeouts.h"
  26. #include "lwip/priv/tcp_priv.h"
  27. #include "lwip/def.h"
  28. #include "lwip/memp.h"
  29. #include "lwip/priv/tcpip_priv.h"
  30. #include "lwip/ip4_frag.h"
  31. #include "lwip/etharp.h"
  32. #include "lwip/dhcp.h"
  33. #include "lwip/prot/dhcp.h"
  34. #include "lwip/autoip.h"
  35. #include "lwip/igmp.h"
  36. #include "lwip/dns.h"
  37. #include "lwip/nd6.h"
  38. #include "lwip/ip6_frag.h"
  39. #include "lwip/mld6.h"
  40. #include "lwip/dhcp6.h"
  41. #include "lwip/sys.h"
  42. #include "lwip/pbuf.h"
  43. #include "lwip/inet.h"
  44. #endif
  45. #define MAX_DNS_IP (4) //每个URL最多保留4个IP
  46. enum
  47. {
  48. EV_NW_RESET = USER_EVENT_ID_START + 0x1000000,
  49. EV_NW_STATE,
  50. EV_NW_TIMEOUT,
  51. EV_NW_DNS_RESULT,
  52. EV_NW_SOCKET_TX_OK,
  53. EV_NW_SOCKET_RX_NEW,
  54. EV_NW_SOCKET_RX_FULL,
  55. EV_NW_SOCKET_CLOSE_OK,
  56. EV_NW_SOCKET_REMOTE_CLOSE,
  57. EV_NW_SOCKET_CONNECT_OK,
  58. EV_NW_SOCKET_ERROR,
  59. EV_NW_SOCKET_LISTEN,
  60. EV_NW_SOCKET_NEW_CONNECT, //作为server接收到新的connect,只有允许accept操作的才有,否则直接上报CONNECT_OK
  61. EV_NW_BREAK_WAIT,
  62. EV_NW_END,
  63. NW_STATE_LINK_OFF = 0,
  64. NW_STATE_OFF_LINE,
  65. NW_STATE_WAIT_DNS,
  66. NW_STATE_CONNECTING,
  67. NW_STATE_SHAKEHAND,
  68. NW_STATE_ONLINE,
  69. NW_STATE_LISTEN,
  70. NW_STATE_DISCONNECTING,
  71. NW_WAIT_NONE = 0,
  72. NW_WAIT_LINK_UP,
  73. NW_WAIT_ON_LINE,
  74. NW_WAIT_TX_OK,
  75. NW_WAIT_OFF_LINE,
  76. NW_WAIT_EVENT,
  77. //一旦使用高级API,回调会改为下面的,param1 = 0成功,其他失败
  78. EV_NW_RESULT_BASE = EV_NW_END + 1,
  79. EV_NW_RESULT_LINK = EV_NW_RESULT_BASE + NW_WAIT_LINK_UP,
  80. EV_NW_RESULT_CONNECT = EV_NW_RESULT_BASE + NW_WAIT_ON_LINE,
  81. EV_NW_RESULT_CLOSE = EV_NW_RESULT_BASE + NW_WAIT_OFF_LINE,
  82. EV_NW_RESULT_TX = EV_NW_RESULT_BASE + NW_WAIT_TX_OK,
  83. EV_NW_RESULT_EVENT = EV_NW_RESULT_BASE + NW_WAIT_EVENT,
  84. NW_ADAPTER_INDEX_LWIP_NONE = 0,
  85. NW_ADAPTER_INDEX_LWIP_GPRS, //蜂窝网络模块
  86. NW_ADAPTER_INDEX_LWIP_WIFI_STA, //WIFI SOC
  87. NW_ADAPTER_INDEX_LWIP_WIFI_AP, //WIFI SOC
  88. NW_ADAPTER_INDEX_LWIP_ETH, //自带以太网控制器的SOC
  89. NW_ADAPTER_INDEX_LWIP_SPI, // SPI协议的网卡,无MAC,纯IP包
  90. NW_ADAPTER_INDEX_LWIP_UART, // UART协议的网卡,无MAC,纯IP包
  91. NW_ADAPTER_INDEX_LWIP_USER0,
  92. NW_ADAPTER_INDEX_LWIP_USER1,
  93. NW_ADAPTER_INDEX_LWIP_USER2,
  94. NW_ADAPTER_INDEX_LWIP_USER3,
  95. NW_ADAPTER_INDEX_LWIP_USER4,
  96. NW_ADAPTER_INDEX_LWIP_USER5,
  97. NW_ADAPTER_INDEX_LWIP_USER6,
  98. NW_ADAPTER_INDEX_LWIP_USER7,
  99. NW_ADAPTER_INDEX_LWIP_NETIF_QTY,
  100. NW_ADAPTER_INDEX_HW_PS_DEVICE = NW_ADAPTER_INDEX_LWIP_NETIF_QTY,
  101. NW_ADAPTER_INDEX_ETH0 = NW_ADAPTER_INDEX_HW_PS_DEVICE, //外挂以太网+硬件协议栈
  102. NW_ADAPTER_INDEX_USB, //USB网卡
  103. NW_ADAPTER_INDEX_POSIX, // 对接POSIX
  104. NW_ADAPTER_INDEX_LUAPROXY, // 代理到Lua层
  105. NW_ADAPTER_INDEX_CUSTOM, // 对接到自定义适配器
  106. NW_ADAPTER_QTY,
  107. NW_CMD_AUTO_HEART_TIME = 0,
  108. };
  109. #ifdef LUAT_USE_LWIP
  110. #define luat_ip_addr_t ip_addr_t
  111. #else
  112. typedef struct
  113. {
  114. union
  115. {
  116. uint32_t ipv4;
  117. uint32_t ipv6_u32_addr[4];
  118. uint8_t ipv6_u8_addr[16];
  119. };
  120. uint8_t is_ipv6;
  121. }luat_ip_addr_t;
  122. uint8_t network_string_is_ipv4(const char *string, uint32_t len);
  123. uint32_t network_string_to_ipv4(const char *string, uint32_t len);
  124. int network_string_to_ipv6(const char *string, luat_ip_addr_t *ip_addr);
  125. #endif
  126. typedef struct
  127. {
  128. uint64_t tag;
  129. void *param;
  130. }luat_network_cb_param_t;
  131. typedef struct
  132. {
  133. uint32_t ttl_end;
  134. luat_ip_addr_t ip;
  135. }luat_dns_ip_result;
  136. typedef struct
  137. {
  138. /* data */
  139. llist_head node;
  140. Buffer_Struct uri;
  141. luat_dns_ip_result result[MAX_DNS_IP];
  142. uint8_t ip_nums;
  143. }luat_dns_cache_t;
  144. typedef struct
  145. {
  146. uint64_t tx_size;
  147. uint64_t ack_size;
  148. uint64_t tag;
  149. #ifdef LUAT_USE_TLS
  150. //SSL相关数据均为动态生成的,需要在close的时候释放
  151. mbedtls_ssl_context *ssl; /**< mbed TLS control context. */
  152. mbedtls_ssl_config *config; /**< mbed TLS configuration context. */
  153. mbedtls_x509_crt *ca_cert;
  154. #endif
  155. CBFuncEx_t user_callback;
  156. void *user_data; //传递给user_callback的pParam
  157. void *socket_param; //一般用来存放network_ctrl本身,用于快速查找
  158. HANDLE task_handle;
  159. HANDLE timer;
  160. HANDLE tls_short_timer;
  161. HANDLE tls_long_timer;
  162. HANDLE mutex;
  163. uint32_t tcp_keep_idle;
  164. int socket_id;
  165. char *domain_name; //动态生成的,需要在close的时候释放
  166. uint32_t domain_name_len;
  167. luat_ip_addr_t remote_ip;
  168. luat_dns_ip_result *dns_ip; //动态生成的,需要在close的时候释放
  169. luat_ip_addr_t *online_ip; //指向某个ip,无需释放
  170. uint16_t remote_port;
  171. uint16_t local_port;
  172. uint8_t *cache_data; //动态生成的,需要在close的时候释放
  173. uint32_t cache_len;
  174. int tls_timer_state;
  175. uint32_t tcp_timeout_ms;
  176. uint8_t tls_mode;
  177. uint8_t tls_need_reshakehand;
  178. uint8_t need_close;
  179. uint8_t new_rx_flag;
  180. uint8_t dns_ip_cnt;
  181. uint8_t dns_ip_nums;
  182. uint8_t tcp_keep_alive;
  183. uint8_t tcp_keep_interval;
  184. uint8_t tcp_keep_cnt;
  185. uint8_t adapter_index;
  186. uint8_t is_tcp;
  187. uint8_t is_server_mode;
  188. uint8_t auto_mode;
  189. uint8_t wait_target_state;
  190. uint8_t state;
  191. uint8_t is_debug;
  192. uint8_t domain_ipv6;
  193. }network_ctrl_t;
  194. typedef struct
  195. {
  196. uint64_t tag;
  197. #ifdef LUAT_USE_LWIP
  198. llist_head wait_ack_head;
  199. #endif
  200. llist_head tx_head;
  201. llist_head rx_head;
  202. uint32_t rx_wait_size;
  203. uint32_t tx_wait_size;
  204. #ifdef LUAT_USE_LWIP
  205. union {
  206. struct ip_pcb *ip;
  207. struct tcp_pcb *tcp;
  208. struct udp_pcb *udp;
  209. struct raw_pcb *raw;
  210. } pcb;
  211. struct tcp_pcb_listen *listen_tcp;
  212. HANDLE mutex;
  213. uint16_t local_port;
  214. uint16_t remote_port;
  215. #endif
  216. void *param;
  217. uint8_t state;
  218. uint8_t is_tcp;
  219. uint8_t is_ipv6;
  220. uint8_t in_use;
  221. uint8_t rx_waiting;
  222. uint8_t remote_close;
  223. uint8_t fast_rx_ack; //TCP快速应答
  224. }socket_ctrl_t; //推荐底层协议栈适配用的socket状态结构
  225. /*
  226. * info内的api必须全部是非阻塞的及任务的,并且对socket_id和tag做合法性检查
  227. * 目前只支持tcp和udp,不支持raw
  228. * 如果没有特殊说明,成功返回=0,失败返回<0
  229. */
  230. typedef struct
  231. {
  232. //检查网络是否准备好,返回非0准备好,user_data是注册时的user_data,传入给底层api
  233. uint8_t (*check_ready)(void *user_data);
  234. //创建一个socket,并设置成非阻塞模式,user_data传入对应适配器, tag作为socket的合法依据,给check_socket_vaild比对用
  235. //成功返回socketid,失败 < 0
  236. int (*create_soceket)(uint8_t is_tcp, uint64_t *tag, void *param, uint8_t is_ipv6, void *user_data);
  237. //作为client绑定一个port,并连接remote_ip和remote_port对应的server
  238. //成功返回0,失败 < 0
  239. int (*socket_connect)(int socket_id, uint64_t tag, uint16_t local_port, luat_ip_addr_t *remote_ip, uint16_t remote_port, void *user_data);
  240. //作为server绑定一个port,开始监听
  241. //成功返回0,失败 < 0
  242. int (*socket_listen)(int socket_id, uint64_t tag, uint16_t local_port, void *user_data);
  243. //作为server接受一个client
  244. //成功返回0,失败 < 0
  245. int (*socket_accept)(int socket_id, uint64_t tag, luat_ip_addr_t *remote_ip, uint16_t *remote_port, void *user_data);
  246. //主动断开一个tcp连接,需要走完整个tcp流程,用户需要接收到close ok回调才能确认彻底断开
  247. //成功返回0,失败 < 0
  248. int (*socket_disconnect)(int socket_id, uint64_t tag, void *user_data);
  249. //释放掉socket的控制权,除了tag异常外,必须立刻生效
  250. //成功返回0,失败 < 0
  251. int (*socket_close)(int socket_id, uint64_t tag, void *user_data);
  252. //强行释放掉socket的控制权,必须立刻生效
  253. //成功返回0,失败 < 0
  254. int (*socket_force_close)(int socket_id, void *user_data);
  255. //tcp时,不需要remote_ip和remote_port,如果buf为NULL,则返回当前缓存区的数据量,当返回值小于len时说明已经读完了
  256. //udp时,只返回1个block数据,需要多次读直到没有数据为止
  257. //成功返回实际读取的值,失败 < 0
  258. int (*socket_receive)(int socket_id, uint64_t tag, uint8_t *buf, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t *remote_port, void *user_data);
  259. //tcp时,不需要remote_ip和remote_port
  260. //成功返回>0的len,缓冲区满了=0,失败 < 0,如果发送了len=0的空包,也是返回0,注意判断
  261. int (*socket_send)(int socket_id, uint64_t tag, const uint8_t *buf, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t remote_port, void *user_data);
  262. //检查socket合法性,成功返回0,失败 < 0
  263. int (*socket_check)(int socket_id, uint64_t tag, void *user_data);
  264. //保留有效的socket,将无效的socket关闭
  265. void (*socket_clean)(int *vaild_socket_list, uint32_t num, void *user_data);
  266. int (*getsockopt)(int socket_id, uint64_t tag, int level, int optname, void *optval, uint32_t *optlen, void *user_data);
  267. int (*setsockopt)(int socket_id, uint64_t tag, int level, int optname, const void *optval, uint32_t optlen, void *user_data);
  268. //非posix的socket,用这个根据实际硬件设置参数
  269. int (*user_cmd)(int socket_id, uint64_t tag, uint32_t cmd, uint32_t value, void *user_data);
  270. int (*dns)(const char *domain_name, uint32_t len, void *param, void *user_data);
  271. int (*dns_ipv6)(const char *domain_name, uint32_t len, void *param, void *user_data);
  272. int (*set_dns_server)(uint8_t server_index, luat_ip_addr_t *ip, void *user_data);
  273. int (*set_mac)(uint8_t *mac, void *user_data);
  274. int (*set_static_ip)(luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, luat_ip_addr_t *ipv6, void *user_data);
  275. int (*get_full_ip_info)(luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, luat_ip_addr_t *ipv6, void *user_data);
  276. int (*get_local_ip_info)(luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, void *user_data);
  277. //所有网络消息都是通过cb_fun回调
  278. //cb_fun回调时第一个参数为OS_EVENT,包含了socket的必要信息,第二个是luat_network_cb_param_t,其中的param是这里传入的param(就是适配器序号)
  279. //OS_EVENT ID为EV_NW_XXX,param1是socket id param2是各自参数 param3是create_soceket传入的socket_param(就是network_ctrl *)
  280. //dns结果是特别的,ID为EV_NW_SOCKET_DNS_RESULT,param1是获取到的IP数据量,0就是失败了,param2是ip组,动态分配的, param3是dns传入的param(就是network_ctrl *)
  281. void (*socket_set_callback)(CBFuncEx_t cb_fun, void *param, void *user_data);
  282. int (*check_ack)(uint8_t adapter_index, int socket_id); // 2024.4.11新增
  283. char *name;
  284. int max_socket_num;//最大socket数量,也是最大network_ctrl申请数量的基础值
  285. uint8_t no_accept;
  286. uint8_t is_posix;
  287. }network_adapter_info;
  288. /*
  289. * api有可能涉及到任务安全要求,不可以在中断里运行,只能在task中运行
  290. */
  291. /**
  292. * 获取最后一个注册的网卡适配器序号
  293. * @return 注册的网卡适配器序号 NW_ADAPTER_INDEX_XXX
  294. */
  295. int network_get_last_register_adapter(void);
  296. /****************************以下是通用基础api********************************************************/
  297. /**
  298. * 注册网卡适配器相关的协议栈接口
  299. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  300. * @param info 协议栈接口
  301. * @param user_data 用户数据
  302. * @return 0成功,其他失败
  303. */
  304. int network_register_adapter(uint8_t adapter_index, network_adapter_info *info, void *user_data);
  305. /**
  306. * 将某个网卡适配器配置成默认适配器
  307. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  308. */
  309. void network_register_set_default(uint8_t adapter_index);
  310. /**
  311. * 设置某个网卡适配器的DNS服务器地址
  312. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  313. * @param server_index DNS服务器序号
  314. * @param ip DNS服务器地址
  315. */
  316. void network_set_dns_server(uint8_t adapter_index, uint8_t server_index, luat_ip_addr_t *ip);
  317. /**
  318. * 在某个网卡适配器上申请一个网络资源
  319. * @param adapter_index 适配器序号 NW_ADAPTER_INDEX_XXX
  320. * @return 网络资源,network_ctrl_t结构类型
  321. */
  322. network_ctrl_t *network_alloc_ctrl(uint8_t adapter_index);
  323. /**
  324. * 归还一个网络资源
  325. * @param ctrl 网络资源
  326. */
  327. void network_release_ctrl(network_ctrl_t *ctrl);
  328. /**
  329. * 初始化网络资源
  330. * lua调用c时,必须使用非阻塞接口,task_handle不需要
  331. * 在纯c调用时,如果不需要则塞应用,必须有callback和param
  332. * 在纯c调用时,如果需要阻塞应用,则必须有task_handle,建议有callback,param,可以等待消息时,同时在callback中处理其他类型的消息
  333. * @param ctrl 网络资源
  334. * @param task_handle socket阻塞应用时所在的task,可以是空的
  335. * @param callback socket非阻塞应用时回调函数
  336. * @param param socket非阻塞应用时回调时的用户自定义参数
  337. */
  338. void network_init_ctrl(network_ctrl_t *ctrl, HANDLE task_handle, CBFuncEx_t callback, void *param);
  339. /**
  340. * 网络资源基本配置
  341. * 设置是tcp还是udp模式及TCP自动保活相关参数,也可以直接改network_ctrl_t中的is_tcp参数
  342. * 设置必须在socket处于close状态,在进行connect和tls初始之前
  343. * @param ctrl 网络资源
  344. * @param is_tcp 0UDP 其他TCP,默认是UDP
  345. * @param tcp_timeout_ms tcp超时时间,目前未启用
  346. * @param keep_alive tcp自动保活是否启用,0不启用,其他启用
  347. * @param keep_idle tcp自动保活空闲时间,单位秒
  348. * @param keep_interval tcp自动保活启动时,tcp探针发送时间间隔,单位秒
  349. * @param keep_cnt tcp自动保活启动时,tcp探针发送总次数
  350. */
  351. void network_set_base_mode(network_ctrl_t *ctrl, uint8_t is_tcp, uint32_t tcp_timeout_ms, uint8_t keep_alive, uint32_t keep_idle, uint8_t keep_interval, uint8_t keep_cnt);
  352. /**
  353. * 是否开启debug功能
  354. * @param ctrl 网络资源
  355. * @param on_off 0关,其他开,默认是关
  356. */
  357. void network_set_debug_onoff(network_ctrl_t *ctrl, uint8_t on_off);
  358. /**
  359. * 使用域名时是否选择IPV6地址
  360. * @param ctrl 网络资源
  361. * @param onoff 0关,其他开,默认是关
  362. */
  363. void network_connect_ipv6_domain(network_ctrl_t *ctrl, uint8_t onoff);
  364. /**
  365. * 检测某个网卡是否能上网
  366. * 具体哪个网卡,看socket或者适配器序号
  367. * @param ctrl 网络资源,如果为NULL,则看下面的适配器序号
  368. * @param adapter_index 适配器序号 NW_ADAPTER_INDEX_XXX
  369. * @return 0不能上网 其他能
  370. */
  371. uint8_t network_check_ready(network_ctrl_t *ctrl, uint8_t adapter_index);
  372. /**
  373. * 设置本地port,注意不要用60000及以上,如果local_port为0,系统从60000开始随机抽一个
  374. * 默认就是0,一般不需要配置,由系统去分配
  375. * @param ctrl 网络资源
  376. * @param local_port 本地端口号
  377. * @return local_port不为0,且重复了,则返回-1,其他返回0
  378. */
  379. int network_set_local_port(network_ctrl_t *ctrl, uint16_t local_port);
  380. /**
  381. * 创建一个socket
  382. * @param ctrl 网络资源
  383. * @param is_ipv6 是否是IPV6,0否 1是,默认是0
  384. * @return 成功返回0,失败 < 0
  385. */
  386. int network_create_socket(network_ctrl_t *ctrl, uint8_t is_ipv6);
  387. /**
  388. * 连接服务器,在连接前,需要配置好网络资源中的remote_port
  389. * @param ctrl 网络资源
  390. * @param remote_ip 服务器地址
  391. * @return 成功返回0,失败 < 0
  392. */
  393. int network_socket_connect(network_ctrl_t *ctrl, luat_ip_addr_t *remote_ip);
  394. /**
  395. * 作为服务器监听
  396. * @param ctrl 网络资源 用于监听的网络资源
  397. * @return 成功返回0,失败 < 0
  398. */
  399. int network_socket_listen(network_ctrl_t *ctrl);
  400. /**
  401. * 查询网络资源对应的网卡是否有服务器功能
  402. * @param ctrl 网络资源 用于监听的网络资源
  403. * @return 1有 0无
  404. */
  405. uint8_t network_accept_enable(network_ctrl_t *ctrl);
  406. /**
  407. * 作为服务器接受一个客户端的接入请求
  408. * @param ctrl 网络资源 用于监听的网络资源
  409. * @param accept_ctrl 用于和客户端通讯的网络资源
  410. * @return 成功返回0,失败 < 0
  411. */
  412. int network_socket_accept(network_ctrl_t *ctrl, network_ctrl_t *accept_ctrl);
  413. /**
  414. * 主动断开一个tcp连接,需要走完整个tcp挥手流程,用户需要接收到close ok回调才能确认彻底断开
  415. * @param ctrl 网络资源
  416. * @return 均为0
  417. */
  418. int network_socket_disconnect(network_ctrl_t *ctrl);
  419. /**
  420. * 释放掉socket的控制权
  421. * @param ctrl 网络资源
  422. * @return 均为0
  423. */
  424. int network_socket_close(network_ctrl_t *ctrl);
  425. /**
  426. * 强行释放掉socket的控制权
  427. * @param ctrl 网络资源
  428. * @return 均为0
  429. */
  430. int network_socket_force_close(network_ctrl_t *ctrl);
  431. /**
  432. * 读取对端发送过来的数据
  433. * tcp时,不需要remote_ip和remote_port,如果buf为NULL,则返回当前缓存区的数据量,当返回值小于len时说明已经读完了
  434. * udp时,只返回1个block数据,需要多次读直到没有数据为止
  435. * @param ctrl 网络资源
  436. * @param buf 数据读取后缓存的地址
  437. * @param len 期望读取的长度
  438. * @param flags 读取时的标志,一般为0
  439. * @param remote_ip 存放对端IP,UDP才有
  440. * @param remote_port 存放对端端口,UDP才有
  441. * @return 成功返回实际读取的值,失败 < 0
  442. */
  443. int network_socket_receive(network_ctrl_t *ctrl,uint8_t *buf, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t *remote_port);
  444. /**
  445. * 缓存发送数据,准备发送给对端
  446. * tcp时,不需要remote_ip和remote_port
  447. * @param ctrl 网络资源
  448. * @param buf 缓存发送数据的地址
  449. * @param len 发送长度
  450. * @param flags 发送标志,一般为0
  451. * @param remote_ip 对端IP,UDP才有
  452. * @param remote_port 对端端口,UDP才有
  453. * @return 存入发送缓存返回0,失败 < 0
  454. */
  455. int network_socket_send(network_ctrl_t *ctrl,const uint8_t *buf, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t remote_port);
  456. /**
  457. * 获取socket一个配置,和POSIX socket一致,非POSIX的网卡(比如w5500的硬件协议栈)不支持
  458. * @param ctrl 网络资源
  459. * @param level 配置参数级别
  460. * @param optname 参数名称
  461. * @param optval 参数指针
  462. * @param optlen 参数长度
  463. * @return 成功返回0,其他失败
  464. */
  465. int network_getsockopt(network_ctrl_t *ctrl, int level, int optname, void *optval, uint32_t *optlen);
  466. /**
  467. * 设置socket一个配置,和POSIX socket一致,非POSIX的网卡(比如w5500的硬件协议栈)不支持
  468. * @param ctrl 网络资源
  469. * @param level 配置参数级别
  470. * @param optname 参数名称
  471. * @param optval 参数指针
  472. * @param optlen 参数长度
  473. * @return 成功返回0,其他失败
  474. */
  475. int network_setsockopt(network_ctrl_t *ctrl, int level, int optname, const void *optval, uint32_t optlen);
  476. /**
  477. * 设置socket一个配置,仅支持非POSIX的网卡(比如w5500的硬件协议栈)
  478. * @param ctrl 网络资源
  479. * @param cmd 配置命令
  480. * @param value 配置值
  481. * @return 成功返回0,其他失败
  482. */
  483. int network_user_cmd(network_ctrl_t *ctrl, uint32_t cmd, uint32_t value);
  484. #ifdef LUAT_USE_LWIP
  485. /**
  486. * 设置网卡的MAC
  487. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  488. * @param mac MAC地址
  489. * @return 成功返回0,其他失败
  490. */
  491. int network_set_mac(uint8_t adapter_index, uint8_t *mac);
  492. /**
  493. * 设置网卡的静态地址
  494. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  495. * @param ip IPV4地址
  496. * @param submask 子网掩码
  497. * @param gateway 网关
  498. * @param ipv6 IPV6地址
  499. * @return 成功返回0,其他失败
  500. */
  501. int network_set_static_ip_info(uint8_t adapter_index, luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, luat_ip_addr_t *ipv6);
  502. #endif
  503. /**
  504. * 获取网卡的地址信息
  505. * @param ctrl 网络资源
  506. * @param ip IPV4地址
  507. * @param submask 子网掩码
  508. * @param gateway 网关
  509. * @return 成功返回0,其他失败
  510. */
  511. int network_get_local_ip_info(network_ctrl_t *ctrl, luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway);
  512. /**
  513. * 强制释放socket资源,同时也释放部分网络资源
  514. * @param ctrl 网络资源
  515. */
  516. void network_force_close_socket(network_ctrl_t *ctrl);
  517. /**
  518. * 启动DNS解析,启动前,需要设置好domain_name和domain_name_len
  519. * domain_name已经是ip形式了,返回1,并且填充remote_ip
  520. * @param ctrl 网络资源
  521. * @return domain_name已经是ip形式了返回1, DNS开始返回0,失败 < 0
  522. */
  523. int network_dns(network_ctrl_t *ctrl);
  524. /**
  525. * 查询网卡下所有网络资源是否需要释放,需要释放的立刻释放掉
  526. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  527. */
  528. void network_clean_invaild_socket(uint8_t adapter_index);
  529. //下列API仅内部调试使用,用户不用
  530. const char *network_ctrl_state_string(uint8_t state);
  531. const char *network_ctrl_wait_state_string(uint8_t state);
  532. const char *network_ctrl_callback_event_string(uint32_t event);
  533. /****************************通用基础api结束********************************************************/
  534. /****************************tls相关api************************************************************/
  535. /**
  536. * 给DTLS设置PSK,给UDP加密传输时用的
  537. * @param ctrl 网络资源
  538. * @param psk psk数据
  539. * @param psk_len psk数据长度
  540. * @param psk_identity psk_identity数据
  541. * @param psk_identity_len psk_identity数据长度
  542. * @return 成功返回0,其他失败
  543. */
  544. int network_set_psk_info(network_ctrl_t *ctrl,
  545. const unsigned char *psk, size_t psk_len,
  546. const unsigned char *psk_identity, size_t psk_identity_len);
  547. /**
  548. * TLS设置验证服务器的证书,可以不用
  549. * @param ctrl 网络资源
  550. * @param cert 服务器证书数据
  551. * @param cert_len 服务器证书数据长度
  552. * @return 成功返回0,其他失败
  553. */
  554. int network_set_server_cert(network_ctrl_t *ctrl, const unsigned char *cert, size_t cert_len);
  555. /**
  556. * TLS设置验证客户端的证书,只有双向认证才需要,而且一般只有金融领域才需要
  557. * @param ctrl 网络资源
  558. * @param cert 客户端证书数据
  559. * @param certLen客户端证书数据长度
  560. * @param key 客户端证书私钥数据
  561. * @param keylen 客户端证书私钥数据长度
  562. * @param pwd 客户端证书私钥的密码数据
  563. * @param pwdlen 客户端证书私钥的密码数据长度
  564. * @return 成功返回0,其他失败
  565. */
  566. int network_set_client_cert(network_ctrl_t *ctrl,
  567. const unsigned char *cert, size_t certLen,
  568. const unsigned char *key, size_t keylen,
  569. const unsigned char *pwd, size_t pwdlen);
  570. /**
  571. * 获取证书验证结果
  572. * @param ctrl 网络资源
  573. * @return 成功返回0,其他失败
  574. */
  575. int network_cert_verify_result(network_ctrl_t *ctrl);
  576. /**
  577. * 初始化加密传输
  578. * @param ctrl 网络资源
  579. * @param verify_mode 参考MBEDTLS_SSL_VERIFY_XXX
  580. * @return 成功返回0,其他失败
  581. */
  582. int network_init_tls(network_ctrl_t *ctrl, int verify_mode);
  583. /**
  584. * 结束加密传输模式,恢复成正常模式,必须在socket关闭情况下才可以修改
  585. * @param ctrl 网络资源
  586. */
  587. void network_deinit_tls(network_ctrl_t *ctrl);
  588. /*
  589. * 加密传输其他非阻塞api和通用api共用,阻塞api和rtos环境相关阻塞api通用,均由api内部做相关处理
  590. */
  591. /****************************tls相关api结束************************************************************/
  592. /****************************高级api,用于实现一个完整功能***********************/
  593. //一旦使用下面的api,将由network内部自动判断状态并进行下一步操作,中间处理过程除了主动强制关闭socket,其他用户不能干预,直到达到目标状态,即使非阻塞回调也只回调最终结果。
  594. //所有阻塞状态接口,一旦收到link down,socket close, error之类的消息就会返回错误,如果是timeout,只有wait event会返回成功,其他返回失败
  595. //以下api是阻塞和非则塞均可,当network_ctrl中设置了task_handle 而且 timeout_ms > 0时为阻塞接口,timeout_ms = 0xffffffff 为永远等待
  596. /**
  597. * 等待网络环境准备好
  598. * @param ctrl 网络资源
  599. * @param timeout_ms 超时时间
  600. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  601. */
  602. int network_wait_link_up(network_ctrl_t *ctrl, uint32_t timeout_ms);
  603. /**
  604. * 作为客户端去连接服务器
  605. * 域名或者IP至少写1个,如果写了有效IP,则不会去连接域名
  606. * 会自动等待网络环境准备好,无需network_wait_link_up
  607. * 如果是加密模式,自动进行握手
  608. * 使用前必须确保是在close状态,建议先用network_close
  609. * @param ctrl 网络资源
  610. * @param domain_name 服务器域名
  611. * @param domain_name_len 服务器域名长度
  612. * @param remote_ip 服务器IP
  613. * @param remote_port 服务器端口
  614. * @param timeout_ms 超时时间
  615. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  616. */
  617. int network_connect(network_ctrl_t *ctrl, const char *domain_name, uint32_t domain_name_len, luat_ip_addr_t *remote_ip, uint16_t remote_port, uint32_t timeout_ms);
  618. /**
  619. * 作为服务器监听
  620. * @param ctrl 网络资源
  621. * @param timeout_ms 超时时间
  622. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  623. */
  624. int network_listen(network_ctrl_t *ctrl, uint32_t timeout_ms);
  625. /**
  626. * 关闭连接
  627. * @param ctrl 网络资源
  628. * @param timeout_ms 超时时间
  629. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  630. */
  631. int network_close(network_ctrl_t *ctrl, uint32_t timeout_ms);
  632. /**
  633. * 发送数据给对端
  634. * UDP的时候,remote_ip和remote_port和connect不一致的时候才需要remote_ip和remote_port
  635. * TCP不看remote_ip和remote_port
  636. * 阻塞模式,*tx_len不需要看,非阻塞模式需要看*tx_len的实际长度是不是和len一致
  637. * @param ctrl 网络资源
  638. * @param data 需要发送的数据
  639. * @param len 需要发送的数据长度
  640. * @param flags 发送标志,一般写0
  641. * @param remote_ip 对端IP
  642. * @param remote_port 对端端口
  643. * @param tx_len 实际存入缓存区的长度
  644. * @param timeout_ms 超时时间
  645. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  646. */
  647. int network_tx(network_ctrl_t *ctrl, const uint8_t *data, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t remote_port, uint32_t *tx_len, uint32_t timeout_ms);
  648. /**
  649. * 读取接收到的数据
  650. * 实际读到的数据量在read_len里,如果是UDP模式且为server时,需要看remote_ip和remote_port
  651. * @param ctrl 网络资源
  652. * @param data 存放读取数据的地址
  653. * @param len 期望读取的长度
  654. * @param flags 接收标志,一般写0
  655. * @param remote_ip 对端IP
  656. * @param remote_port 对端端口
  657. * @param rx_len 实际读出的长度
  658. * @return 成功返回0,失败或者socket已经断开 < 0
  659. */
  660. int network_rx(network_ctrl_t *ctrl, uint8_t *data, uint32_t len, int flags, luat_ip_addr_t *remote_ip, uint16_t *remote_port, uint32_t *rx_len);
  661. /**
  662. * 等待网络状态变化
  663. * 接收到socket异常消息均会返回
  664. * 如果为阻塞接口,out_event保存消息(拷贝,非引用),is_timeout保存是否超时
  665. * 返回0表示有数据接收或者超时返回,返回1表示切换到非阻塞等待,其他为网络异常
  666. * @param ctrl 网络资源
  667. * @param out_event 网络消息
  668. * @param timeout_ms 超时时间
  669. * @param is_timeout 是否超时
  670. * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
  671. */
  672. int network_wait_event(network_ctrl_t *ctrl, OS_EVENT *out_event, uint32_t timeout_ms, uint8_t *is_timeout);
  673. /*
  674. */
  675. /**
  676. * 等待有数据接收
  677. * 接收到socket异常,用户发送EV_NW_BREAK_WAIT,或者有新数据都会退出,如果是其他消息,通过network_init_ctrl里输入的回调函数使用,如果没有回调函数,就直接抛弃了
  678. * timeout_ms=0时,依然为阻塞接口,而且是永远等待
  679. * 返回0表示有数据接收,用户打断或者超时返回,其他为网络异常
  680. * 用户打断,is_break = 1,超时 is_timeout = 1
  681. * @param ctrl 网络资源
  682. * @param timeout_ms 超时时间
  683. * @param is_break 是否是用户打断
  684. * @param is_timeout 是否超时
  685. * @return 成功返回0,失败 < 0
  686. */
  687. int network_wait_rx(network_ctrl_t *ctrl, uint32_t timeout_ms, uint8_t *is_break, uint8_t *is_timeout);
  688. /****************************高级api结束********************************************************************/
  689. /**
  690. * 获取网卡完整的地址信息
  691. * @param ctrl 网络资源,如果写NULL,则看下面的adapter_index
  692. * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
  693. * @param ip IPV4地址
  694. * @param submask 子网掩码
  695. * @param gateway 网关
  696. * @param ipv6 IPV6地址
  697. * @return 成功返回0,其他失败
  698. */
  699. int network_get_full_local_ip_info(network_ctrl_t *ctrl, uint8_t adapter_index, luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, luat_ip_addr_t *ipv6);
  700. /**
  701. * 将IP设置成无效状态
  702. * @param ip
  703. */
  704. void network_set_ip_invaild(luat_ip_addr_t *ip);
  705. /**
  706. * 检测IP是不是无效的
  707. * @param ip
  708. * @return 无效返回0,其他有效
  709. */
  710. uint8_t network_ip_is_vaild(luat_ip_addr_t *ip);
  711. /**
  712. * 检测IP是不是IPV6类型
  713. * @param ip
  714. * @return 不是返回0
  715. */
  716. uint8_t network_ip_is_ipv6(luat_ip_addr_t *ip);
  717. /**
  718. * 检测IP是不是有效的IPV4类型
  719. * @param ip
  720. * @return 不是返回0
  721. */
  722. uint8_t network_ip_is_vaild_ipv4(luat_ip_addr_t *ip);
  723. /**
  724. * 将IP设置成IPV4
  725. * @param 需要设置的ip地址
  726. * @param ipv4 ipv4
  727. */
  728. void network_set_ip_ipv4(luat_ip_addr_t *ip, uint32_t ipv4);
  729. #endif
  730. // #endif