| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825 |
- #ifndef __LUAT_NW_ADAPTER_H__
- #define __LUAT_NW_ADAPTER_H__
- #include "luat_base.h"
- // #ifdef LUAT_USE_NETWORK
- #if defined(__SOC_BSP__) || defined(LUAT_EC7XX_CSDK) || defined(CHIP_EC618) || defined(__AIR105_BSP__) || defined(CONFIG_SOC_8910) || defined(CONFIG_SOC_8850)
- #include "bsp_common.h"
- #endif
- #include "luat_rtos.h"
- #ifndef __BSP_COMMON_H__
- #include "c_common.h"
- #endif
- #ifdef LUAT_USE_TLS
- #include "mbedtls/ssl.h"
- #include "mbedtls/platform.h"
- #include "mbedtls/debug.h"
- #include "mbedtls/x509_crt.h"
- #include "mbedtls/base64.h"
- #include "mbedtls/ctr_drbg.h"
- #include "mbedtls/entropy.h"
- #include "mbedtls/sha1.h"
- #endif
- #ifdef LUAT_USE_LWIP
- #include "lwip/opt.h"
- #include "lwip/netif.h"
- #include "lwip/timeouts.h"
- #include "lwip/priv/tcp_priv.h"
- #include "lwip/def.h"
- #include "lwip/memp.h"
- #include "lwip/priv/tcpip_priv.h"
- #include "lwip/ip4_frag.h"
- #include "lwip/etharp.h"
- #include "lwip/dhcp.h"
- #include "lwip/prot/dhcp.h"
- #include "lwip/autoip.h"
- #include "lwip/igmp.h"
- #include "lwip/dns.h"
- #include "lwip/nd6.h"
- #include "lwip/ip6_frag.h"
- #include "lwip/mld6.h"
- #include "lwip/dhcp6.h"
- #include "lwip/sys.h"
- #include "lwip/pbuf.h"
- #include "lwip/inet.h"
- #endif
- #define MAX_DNS_IP (4) //每个URL最多保留4个IP
- enum
- {
- EV_NW_RESET = USER_EVENT_ID_START + 0x1000000,
- EV_NW_STATE,
- EV_NW_TIMEOUT,
- EV_NW_DNS_RESULT,
- EV_NW_SOCKET_TX_OK,
- EV_NW_SOCKET_RX_NEW,
- EV_NW_SOCKET_RX_FULL,
- EV_NW_SOCKET_CLOSE_OK,
- EV_NW_SOCKET_REMOTE_CLOSE,
- EV_NW_SOCKET_CONNECT_OK,
- EV_NW_SOCKET_ERROR,
- EV_NW_SOCKET_LISTEN,
- EV_NW_SOCKET_NEW_CONNECT, //作为server接收到新的connect,只有允许accept操作的才有,否则直接上报CONNECT_OK
- EV_NW_BREAK_WAIT,
- EV_NW_END,
- NW_STATE_LINK_OFF = 0,
- NW_STATE_OFF_LINE,
- NW_STATE_WAIT_DNS,
- NW_STATE_CONNECTING,
- NW_STATE_SHAKEHAND,
- NW_STATE_ONLINE,
- NW_STATE_LISTEN,
- NW_STATE_DISCONNECTING,
- NW_WAIT_NONE = 0,
- NW_WAIT_LINK_UP,
- NW_WAIT_ON_LINE,
- NW_WAIT_TX_OK,
- NW_WAIT_OFF_LINE,
- NW_WAIT_EVENT,
- //一旦使用高级API,回调会改为下面的,param1 = 0成功,其他失败
- EV_NW_RESULT_BASE = EV_NW_END + 1,
- EV_NW_RESULT_LINK = EV_NW_RESULT_BASE + NW_WAIT_LINK_UP,
- EV_NW_RESULT_CONNECT = EV_NW_RESULT_BASE + NW_WAIT_ON_LINE,
- EV_NW_RESULT_CLOSE = EV_NW_RESULT_BASE + NW_WAIT_OFF_LINE,
- EV_NW_RESULT_TX = EV_NW_RESULT_BASE + NW_WAIT_TX_OK,
- EV_NW_RESULT_EVENT = EV_NW_RESULT_BASE + NW_WAIT_EVENT,
- NW_ADAPTER_INDEX_LWIP_NONE = 0,
- NW_ADAPTER_INDEX_LWIP_GPRS, //蜂窝网络模块
- NW_ADAPTER_INDEX_LWIP_WIFI_STA, //WIFI SOC
- NW_ADAPTER_INDEX_LWIP_WIFI_AP, //WIFI SOC
- NW_ADAPTER_INDEX_LWIP_ETH, //自带以太网控制器的SOC
- NW_ADAPTER_INDEX_LWIP_SPI, // SPI协议的网卡,无MAC,纯IP包
- NW_ADAPTER_INDEX_LWIP_UART, // UART协议的网卡,无MAC,纯IP包
- NW_ADAPTER_INDEX_LWIP_USER0,
- NW_ADAPTER_INDEX_LWIP_USER1,
- NW_ADAPTER_INDEX_LWIP_USER2,
- NW_ADAPTER_INDEX_LWIP_USER3,
- NW_ADAPTER_INDEX_LWIP_USER4,
- NW_ADAPTER_INDEX_LWIP_USER5,
- NW_ADAPTER_INDEX_LWIP_USER6,
- NW_ADAPTER_INDEX_LWIP_USER7,
- NW_ADAPTER_INDEX_LWIP_GP_GW,
- NW_ADAPTER_INDEX_LWIP_NETIF_QTY,
- NW_ADAPTER_INDEX_HW_PS_DEVICE = NW_ADAPTER_INDEX_LWIP_NETIF_QTY,
- NW_ADAPTER_INDEX_ETH0 = NW_ADAPTER_INDEX_HW_PS_DEVICE, //外挂以太网+硬件协议栈
- NW_ADAPTER_INDEX_USB, //USB网卡
- NW_ADAPTER_INDEX_POSIX, // 对接POSIX
- NW_ADAPTER_INDEX_LUAPROXY, // 代理到Lua层
- NW_ADAPTER_INDEX_CUSTOM, // 对接到自定义适配器
- NW_ADAPTER_QTY,
- NW_CMD_AUTO_HEART_TIME = 0,
- };
- #ifdef LUAT_USE_LWIP
- #define luat_ip_addr_t ip_addr_t
- #else
- typedef struct
- {
- union
- {
- uint32_t ipv4;
- uint32_t ipv6_u32_addr[4];
- uint8_t ipv6_u8_addr[16];
- };
- uint8_t is_ipv6;
- }luat_ip_addr_t;
- uint8_t network_string_is_ipv4(const char *string, uint32_t len);
- uint32_t network_string_to_ipv4(const char *string, uint32_t len);
- int network_string_to_ipv6(const char *string, luat_ip_addr_t *ip_addr);
- #endif
- typedef struct
- {
- uint64_t tag;
- void *param;
- }luat_network_cb_param_t;
- typedef struct
- {
- uint32_t ttl_end;
- luat_ip_addr_t ip;
- }luat_dns_ip_result;
- typedef struct
- {
- /* data */
- llist_head node;
- Buffer_Struct uri;
- luat_dns_ip_result result[MAX_DNS_IP];
- uint8_t ip_nums;
- }luat_dns_cache_t;
- typedef struct
- {
- uint64_t tx_size;
- uint64_t ack_size;
- uint64_t tag;
- #ifdef LUAT_USE_TLS
- //SSL相关数据均为动态生成的,需要在close的时候释放
- mbedtls_ssl_context *ssl; /**< mbed TLS control context. */
- mbedtls_ssl_config *config; /**< mbed TLS configuration context. */
- mbedtls_x509_crt *ca_cert;
- #endif
- CBFuncEx_t user_callback;
- void *user_data; //传递给user_callback的pParam
- void *socket_param; //一般用来存放network_ctrl本身,用于快速查找
- HANDLE task_handle;
- HANDLE timer;
- HANDLE tls_short_timer;
- HANDLE tls_long_timer;
- HANDLE mutex;
- uint32_t tcp_keep_idle;
- int socket_id;
- char *domain_name; //动态生成的,需要在close的时候释放
- uint32_t domain_name_len;
- luat_ip_addr_t remote_ip;
- luat_dns_ip_result *dns_ip; //动态生成的,需要在close的时候释放
- luat_ip_addr_t online_ip; //指向某个ip,无需释放
- uint16_t remote_port;
- uint16_t local_port;
- uint8_t *cache_data; //动态生成的,需要在close的时候释放
- uint32_t cache_len;
- int tls_timer_state;
- uint32_t tcp_timeout_ms;
- uint8_t tls_mode;
- uint8_t tls_need_reshakehand;
- uint8_t need_close;
- uint8_t new_rx_flag;
- uint8_t dns_ip_cnt;
- uint8_t dns_ip_nums;
- uint8_t tcp_keep_alive;
- uint8_t tcp_keep_interval;
- uint8_t tcp_keep_cnt;
- uint8_t adapter_index;
- uint8_t is_tcp;
- uint8_t is_server_mode;
- uint8_t auto_mode;
- uint8_t wait_target_state;
- uint8_t state;
- uint8_t is_debug;
- uint8_t domain_ipv6;
- uint8_t max_wait_accept; // 作为server时,最多支持多少个等待accept的客户端
- }network_ctrl_t;
- typedef struct
- {
- uint64_t tag;
- #ifdef LUAT_USE_LWIP
- llist_head wait_ack_head;
- #endif
- llist_head tx_head;
- llist_head rx_head;
- uint32_t rx_wait_size;
- uint32_t tx_wait_size;
- #ifdef LUAT_USE_LWIP
- union {
- struct ip_pcb *ip;
- struct tcp_pcb *tcp;
- struct udp_pcb *udp;
- struct raw_pcb *raw;
- } pcb;
- struct tcp_pcb_listen *listen_tcp;
- HANDLE mutex;
- uint16_t local_port;
- uint16_t remote_port;
- #endif
- void *param;
- uint8_t state;
- uint8_t is_tcp;
- uint8_t is_ipv6;
- uint8_t in_use;
- uint8_t rx_waiting;
- uint8_t remote_close;
- uint8_t fast_rx_ack; //TCP快速应答
- }socket_ctrl_t; //推荐底层协议栈适配用的socket状态结构
- /*
- * info内的api必须全部是非阻塞的及任务的,并且对socket_id和tag做合法性检查
- * 目前只支持tcp和udp,不支持raw
- * 如果没有特殊说明,成功返回=0,失败返回<0
- */
- typedef struct
- {
- //检查网络是否准备好,返回非0准备好,user_data是注册时的user_data,传入给底层api
- uint8_t (*check_ready)(void *user_data);
- //创建一个socket,并设置成非阻塞模式,user_data传入对应适配器, tag作为socket的合法依据,给check_socket_vaild比对用
- //成功返回socketid,失败 < 0
- int (*create_soceket)(uint8_t is_tcp, uint64_t *tag, void *param, uint8_t is_ipv6, void *user_data);
- //作为client绑定一个port,并连接remote_ip和remote_port对应的server
- //成功返回0,失败 < 0
- 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);
- //作为server绑定一个port,开始监听
- //成功返回0,失败 < 0
- int (*socket_listen)(int socket_id, uint64_t tag, uint16_t local_port, void *user_data);
- //作为server接受一个client
- //成功返回0,失败 < 0
- int (*socket_accept)(int socket_id, uint64_t tag, luat_ip_addr_t *remote_ip, uint16_t *remote_port, void *user_data);
- //主动断开一个tcp连接,需要走完整个tcp流程,用户需要接收到close ok回调才能确认彻底断开
- //成功返回0,失败 < 0
- int (*socket_disconnect)(int socket_id, uint64_t tag, void *user_data);
- //释放掉socket的控制权,除了tag异常外,必须立刻生效
- //成功返回0,失败 < 0
- int (*socket_close)(int socket_id, uint64_t tag, void *user_data);
- //强行释放掉socket的控制权,必须立刻生效
- //成功返回0,失败 < 0
- int (*socket_force_close)(int socket_id, void *user_data);
- //tcp时,不需要remote_ip和remote_port,如果buf为NULL,则返回当前缓存区的数据量,当返回值小于len时说明已经读完了
- //udp时,只返回1个block数据,需要多次读直到没有数据为止
- //成功返回实际读取的值,失败 < 0
- 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);
- //tcp时,不需要remote_ip和remote_port
- //成功返回>0的len,缓冲区满了=0,失败 < 0,如果发送了len=0的空包,也是返回0,注意判断
- 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);
- //检查socket合法性,成功返回0,失败 < 0
- int (*socket_check)(int socket_id, uint64_t tag, void *user_data);
- //保留有效的socket,将无效的socket关闭
- void (*socket_clean)(int *vaild_socket_list, uint32_t num, void *user_data);
- int (*getsockopt)(int socket_id, uint64_t tag, int level, int optname, void *optval, uint32_t *optlen, void *user_data);
- int (*setsockopt)(int socket_id, uint64_t tag, int level, int optname, const void *optval, uint32_t optlen, void *user_data);
- //非posix的socket,用这个根据实际硬件设置参数
- int (*user_cmd)(int socket_id, uint64_t tag, uint32_t cmd, uint32_t value, void *user_data);
- int (*dns)(const char *domain_name, uint32_t len, void *param, void *user_data);
- int (*dns_ipv6)(const char *domain_name, uint32_t len, void *param, void *user_data);
- int (*set_dns_server)(uint8_t server_index, luat_ip_addr_t *ip, void *user_data);
- int (*set_mac)(uint8_t *mac, void *user_data);
- 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);
- 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);
- int (*get_local_ip_info)(luat_ip_addr_t *ip, luat_ip_addr_t *submask, luat_ip_addr_t *gateway, void *user_data);
- //所有网络消息都是通过cb_fun回调
- //cb_fun回调时第一个参数为OS_EVENT,包含了socket的必要信息,第二个是luat_network_cb_param_t,其中的param是这里传入的param(就是适配器序号)
- //OS_EVENT ID为EV_NW_XXX,param1是socket id param2是各自参数 param3是create_soceket传入的socket_param(就是network_ctrl *)
- //dns结果是特别的,ID为EV_NW_SOCKET_DNS_RESULT,param1是获取到的IP数据量,0就是失败了,param2是ip组,动态分配的, param3是dns传入的param(就是network_ctrl *)
- void (*socket_set_callback)(CBFuncEx_t cb_fun, void *param, void *user_data);
- int (*check_ack)(uint8_t adapter_index, int socket_id); // 2024.4.11新增
- char *name;
- int max_socket_num;//最大socket数量,也是最大network_ctrl申请数量的基础值
- uint8_t no_accept;
- uint8_t is_posix;
- }network_adapter_info;
- /*
- * api有可能涉及到任务安全要求,不可以在中断里运行,只能在task中运行
- */
- /**
- * 获取最后一个注册的网卡适配器序号
- * @return 注册的网卡适配器序号 NW_ADAPTER_INDEX_XXX
- */
- int network_get_last_register_adapter(void);
- /****************************以下是通用基础api********************************************************/
- /**
- * 注册网卡适配器相关的协议栈接口
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param info 协议栈接口
- * @param user_data 用户数据
- * @return 0成功,其他失败
- */
- int network_register_adapter(uint8_t adapter_index, network_adapter_info *info, void *user_data);
- /**
- * 将某个网卡适配器配置成默认适配器
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- */
- void network_register_set_default(uint8_t adapter_index);
- /**
- * 获取默认适配器
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- */
- int network_register_get_default(void);
- /**
- * 设置某个网卡适配器的DNS服务器地址
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param server_index DNS服务器序号
- * @param ip DNS服务器地址
- */
- void network_set_dns_server(uint8_t adapter_index, uint8_t server_index, luat_ip_addr_t *ip);
- /**
- * 在某个网卡适配器上申请一个网络资源
- * @param adapter_index 适配器序号 NW_ADAPTER_INDEX_XXX
- * @return 网络资源,network_ctrl_t结构类型
- */
- network_ctrl_t *network_alloc_ctrl(uint8_t adapter_index);
- /**
- * 归还一个网络资源
- * @param ctrl 网络资源
- */
- void network_release_ctrl(network_ctrl_t *ctrl);
- /**
- * 初始化网络资源
- * lua调用c时,必须使用非阻塞接口,task_handle不需要
- * 在纯c调用时,如果不需要则塞应用,必须有callback和param
- * 在纯c调用时,如果需要阻塞应用,则必须有task_handle,建议有callback,param,可以等待消息时,同时在callback中处理其他类型的消息
- * @param ctrl 网络资源
- * @param task_handle socket阻塞应用时所在的task,可以是空的
- * @param callback socket非阻塞应用时回调函数
- * @param param socket非阻塞应用时回调时的用户自定义参数
- */
- void network_init_ctrl(network_ctrl_t *ctrl, HANDLE task_handle, CBFuncEx_t callback, void *param);
- /**
- * 网络资源基本配置
- * 设置是tcp还是udp模式及TCP自动保活相关参数,也可以直接改network_ctrl_t中的is_tcp参数
- * 设置必须在socket处于close状态,在进行connect和tls初始之前
- * @param ctrl 网络资源
- * @param is_tcp 0UDP 其他TCP,默认是UDP
- * @param tcp_timeout_ms tcp超时时间,目前未启用
- * @param keep_alive tcp自动保活是否启用,0不启用,其他启用
- * @param keep_idle tcp自动保活空闲时间,单位秒
- * @param keep_interval tcp自动保活启动时,tcp探针发送时间间隔,单位秒
- * @param keep_cnt tcp自动保活启动时,tcp探针发送总次数
- */
- 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);
- /**
- * 是否开启debug功能
- * @param ctrl 网络资源
- * @param on_off 0关,其他开,默认是关
- */
- void network_set_debug_onoff(network_ctrl_t *ctrl, uint8_t on_off);
- /**
- * 使用域名时是否选择IPV6地址
- * @param ctrl 网络资源
- * @param onoff 0关,其他开,默认是关
- */
- void network_connect_ipv6_domain(network_ctrl_t *ctrl, uint8_t onoff);
- /**
- * 检测某个网卡是否能上网
- * 具体哪个网卡,看socket或者适配器序号
- * @param ctrl 网络资源,如果为NULL,则看下面的适配器序号
- * @param adapter_index 适配器序号 NW_ADAPTER_INDEX_XXX
- * @return 0不能上网 其他能
- */
- uint8_t network_check_ready(network_ctrl_t *ctrl, uint8_t adapter_index);
- /**
- * 设置本地port,注意不要用60000及以上,如果local_port为0,系统从60000开始随机抽一个
- * 默认就是0,一般不需要配置,由系统去分配
- * @param ctrl 网络资源
- * @param local_port 本地端口号
- * @return local_port不为0,且重复了,则返回-1,其他返回0
- */
- int network_set_local_port(network_ctrl_t *ctrl, uint16_t local_port);
- /**
- * 创建一个socket
- * @param ctrl 网络资源
- * @param is_ipv6 是否是IPV6,0否 1是,默认是0
- * @return 成功返回0,失败 < 0
- */
- int network_create_socket(network_ctrl_t *ctrl, uint8_t is_ipv6);
- /**
- * 连接服务器,在连接前,需要配置好网络资源中的remote_port
- * @param ctrl 网络资源
- * @param remote_ip 服务器地址
- * @return 成功返回0,失败 < 0
- */
- int network_socket_connect(network_ctrl_t *ctrl, luat_ip_addr_t *remote_ip);
- /**
- * 作为服务器监听
- * @param ctrl 网络资源 用于监听的网络资源
- * @return 成功返回0,失败 < 0
- */
- int network_socket_listen(network_ctrl_t *ctrl);
- /**
- * 查询网络资源对应的网卡是否有服务器功能
- * @param ctrl 网络资源 用于监听的网络资源
- * @return 1有 0无
- */
- uint8_t network_accept_enable(network_ctrl_t *ctrl);
- /**
- * 作为服务器接受一个客户端的接入请求
- * @param ctrl 网络资源 用于监听的网络资源
- * @param accept_ctrl 用于和客户端通讯的网络资源
- * @return 成功返回0,失败 < 0
- */
- int network_socket_accept(network_ctrl_t *ctrl, network_ctrl_t *accept_ctrl);
- /**
- * 主动断开一个tcp连接,需要走完整个tcp挥手流程,用户需要接收到close ok回调才能确认彻底断开
- * @param ctrl 网络资源
- * @return 均为0
- */
- int network_socket_disconnect(network_ctrl_t *ctrl);
- /**
- * 释放掉socket的控制权
- * @param ctrl 网络资源
- * @return 均为0
- */
- int network_socket_close(network_ctrl_t *ctrl);
- /**
- * 强行释放掉socket的控制权
- * @param ctrl 网络资源
- * @return 均为0
- */
- int network_socket_force_close(network_ctrl_t *ctrl);
- /**
- * 读取对端发送过来的数据
- * tcp时,不需要remote_ip和remote_port,如果buf为NULL,则返回当前缓存区的数据量,当返回值小于len时说明已经读完了
- * udp时,只返回1个block数据,需要多次读直到没有数据为止
- * @param ctrl 网络资源
- * @param buf 数据读取后缓存的地址
- * @param len 期望读取的长度
- * @param flags 读取时的标志,一般为0
- * @param remote_ip 存放对端IP,UDP才有
- * @param remote_port 存放对端端口,UDP才有
- * @return 成功返回实际读取的值,失败 < 0
- */
- 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);
- /**
- * 缓存发送数据,准备发送给对端
- * tcp时,不需要remote_ip和remote_port
- * @param ctrl 网络资源
- * @param buf 缓存发送数据的地址
- * @param len 发送长度
- * @param flags 发送标志,一般为0
- * @param remote_ip 对端IP,UDP才有
- * @param remote_port 对端端口,UDP才有
- * @return 存入发送缓存返回0,失败 < 0
- */
- 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);
- /**
- * 获取socket一个配置,和POSIX socket一致,非POSIX的网卡(比如w5500的硬件协议栈)不支持
- * @param ctrl 网络资源
- * @param level 配置参数级别
- * @param optname 参数名称
- * @param optval 参数指针
- * @param optlen 参数长度
- * @return 成功返回0,其他失败
- */
- int network_getsockopt(network_ctrl_t *ctrl, int level, int optname, void *optval, uint32_t *optlen);
- /**
- * 设置socket一个配置,和POSIX socket一致,非POSIX的网卡(比如w5500的硬件协议栈)不支持
- * @param ctrl 网络资源
- * @param level 配置参数级别
- * @param optname 参数名称
- * @param optval 参数指针
- * @param optlen 参数长度
- * @return 成功返回0,其他失败
- */
- int network_setsockopt(network_ctrl_t *ctrl, int level, int optname, const void *optval, uint32_t optlen);
- /**
- * 设置socket一个配置,仅支持非POSIX的网卡(比如w5500的硬件协议栈)
- * @param ctrl 网络资源
- * @param cmd 配置命令
- * @param value 配置值
- * @return 成功返回0,其他失败
- */
- int network_user_cmd(network_ctrl_t *ctrl, uint32_t cmd, uint32_t value);
- #ifdef LUAT_USE_LWIP
- /**
- * 设置网卡的MAC
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param mac MAC地址
- * @return 成功返回0,其他失败
- */
- int network_set_mac(uint8_t adapter_index, uint8_t *mac);
- /**
- * 设置网卡的静态地址
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param ip IPV4地址
- * @param submask 子网掩码
- * @param gateway 网关
- * @param ipv6 IPV6地址
- * @return 成功返回0,其他失败
- */
- 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);
- #endif
- /**
- * 获取网卡的地址信息
- * @param ctrl 网络资源
- * @param ip IPV4地址
- * @param submask 子网掩码
- * @param gateway 网关
- * @return 成功返回0,其他失败
- */
- 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);
- /**
- * 强制释放socket资源,同时也释放部分网络资源
- * @param ctrl 网络资源
- */
- void network_force_close_socket(network_ctrl_t *ctrl);
- /**
- * 启动DNS解析,启动前,需要设置好domain_name和domain_name_len
- * domain_name已经是ip形式了,返回1,并且填充remote_ip
- * @param ctrl 网络资源
- * @return domain_name已经是ip形式了返回1, DNS开始返回0,失败 < 0
- */
- int network_dns(network_ctrl_t *ctrl);
- /**
- * 查询网卡下所有网络资源是否需要释放,需要释放的立刻释放掉
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- */
- void network_clean_invaild_socket(uint8_t adapter_index);
- //下列API仅内部调试使用,用户不用
- const char *network_ctrl_state_string(uint8_t state);
- const char *network_ctrl_wait_state_string(uint8_t state);
- const char *network_ctrl_callback_event_string(uint32_t event);
- /****************************通用基础api结束********************************************************/
- /****************************tls相关api************************************************************/
- /**
- * 给DTLS设置PSK,给UDP加密传输时用的
- * @param ctrl 网络资源
- * @param psk psk数据
- * @param psk_len psk数据长度
- * @param psk_identity psk_identity数据
- * @param psk_identity_len psk_identity数据长度
- * @return 成功返回0,其他失败
- */
- int network_set_psk_info(network_ctrl_t *ctrl,
- const unsigned char *psk, size_t psk_len,
- const unsigned char *psk_identity, size_t psk_identity_len);
- /**
- * TLS设置验证服务器的证书,可以不用
- * @param ctrl 网络资源
- * @param cert 服务器证书数据
- * @param cert_len 服务器证书数据长度
- * @return 成功返回0,其他失败
- */
- int network_set_server_cert(network_ctrl_t *ctrl, const unsigned char *cert, size_t cert_len);
- /**
- * TLS设置验证客户端的证书,只有双向认证才需要,而且一般只有金融领域才需要
- * @param ctrl 网络资源
- * @param cert 客户端证书数据
- * @param certLen客户端证书数据长度
- * @param key 客户端证书私钥数据
- * @param keylen 客户端证书私钥数据长度
- * @param pwd 客户端证书私钥的密码数据
- * @param pwdlen 客户端证书私钥的密码数据长度
- * @return 成功返回0,其他失败
- */
- int network_set_client_cert(network_ctrl_t *ctrl,
- const unsigned char *cert, size_t certLen,
- const unsigned char *key, size_t keylen,
- const unsigned char *pwd, size_t pwdlen);
- /**
- * 获取证书验证结果
- * @param ctrl 网络资源
- * @return 成功返回0,其他失败
- */
- int network_cert_verify_result(network_ctrl_t *ctrl);
- /**
- * 初始化加密传输
- * @param ctrl 网络资源
- * @param verify_mode 参考MBEDTLS_SSL_VERIFY_XXX
- * @return 成功返回0,其他失败
- */
- int network_init_tls(network_ctrl_t *ctrl, int verify_mode);
- /**
- * 结束加密传输模式,恢复成正常模式,必须在socket关闭情况下才可以修改
- * @param ctrl 网络资源
- */
- void network_deinit_tls(network_ctrl_t *ctrl);
- /*
- * 加密传输其他非阻塞api和通用api共用,阻塞api和rtos环境相关阻塞api通用,均由api内部做相关处理
- */
- /****************************tls相关api结束************************************************************/
- /****************************高级api,用于实现一个完整功能***********************/
- //一旦使用下面的api,将由network内部自动判断状态并进行下一步操作,中间处理过程除了主动强制关闭socket,其他用户不能干预,直到达到目标状态,即使非阻塞回调也只回调最终结果。
- //所有阻塞状态接口,一旦收到link down,socket close, error之类的消息就会返回错误,如果是timeout,只有wait event会返回成功,其他返回失败
- //以下api是阻塞和非则塞均可,当network_ctrl中设置了task_handle 而且 timeout_ms > 0时为阻塞接口,timeout_ms = 0xffffffff 为永远等待
- /**
- * 等待网络环境准备好
- * @param ctrl 网络资源
- * @param timeout_ms 超时时间
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- int network_wait_link_up(network_ctrl_t *ctrl, uint32_t timeout_ms);
- /**
- * 作为客户端去连接服务器
- * 域名或者IP至少写1个,如果写了有效IP,则不会去连接域名
- * 会自动等待网络环境准备好,无需network_wait_link_up
- * 如果是加密模式,自动进行握手
- * 使用前必须确保是在close状态,建议先用network_close
- * @param ctrl 网络资源
- * @param domain_name 服务器域名
- * @param domain_name_len 服务器域名长度
- * @param remote_ip 服务器IP
- * @param remote_port 服务器端口
- * @param timeout_ms 超时时间
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- 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);
- /**
- * 作为服务器监听
- * @param ctrl 网络资源
- * @param timeout_ms 超时时间
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- int network_listen(network_ctrl_t *ctrl, uint32_t timeout_ms);
- /**
- * 关闭连接
- * @param ctrl 网络资源
- * @param timeout_ms 超时时间
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- int network_close(network_ctrl_t *ctrl, uint32_t timeout_ms);
- /**
- * 发送数据给对端
- * UDP的时候,remote_ip和remote_port和connect不一致的时候才需要remote_ip和remote_port
- * TCP不看remote_ip和remote_port
- * 阻塞模式,*tx_len不需要看,非阻塞模式需要看*tx_len的实际长度是不是和len一致
- * @param ctrl 网络资源
- * @param data 需要发送的数据
- * @param len 需要发送的数据长度
- * @param flags 发送标志,一般写0
- * @param remote_ip 对端IP
- * @param remote_port 对端端口
- * @param tx_len 实际存入缓存区的长度
- * @param timeout_ms 超时时间
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- 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);
- /**
- * 读取接收到的数据
- * 实际读到的数据量在read_len里,如果是UDP模式且为server时,需要看remote_ip和remote_port
- * @param ctrl 网络资源
- * @param data 存放读取数据的地址
- * @param len 期望读取的长度
- * @param flags 接收标志,一般写0
- * @param remote_ip 对端IP
- * @param remote_port 对端端口
- * @param rx_len 实际读出的长度
- * @return 成功返回0,失败或者socket已经断开 < 0
- */
- 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);
- /**
- * 等待网络状态变化
- * 接收到socket异常消息均会返回
- * 如果为阻塞接口,out_event保存消息(拷贝,非引用),is_timeout保存是否超时
- * 返回0表示有数据接收或者超时返回,返回1表示切换到非阻塞等待,其他为网络异常
- * @param ctrl 网络资源
- * @param out_event 网络消息
- * @param timeout_ms 超时时间
- * @param is_timeout 是否超时
- * @return 成功返回0,失败 < 0,非阻塞需要等待返回1
- */
- int network_wait_event(network_ctrl_t *ctrl, OS_EVENT *out_event, uint32_t timeout_ms, uint8_t *is_timeout);
- /*
- */
- /**
- * 等待有数据接收
- * 接收到socket异常,用户发送EV_NW_BREAK_WAIT,或者有新数据都会退出,如果是其他消息,通过network_init_ctrl里输入的回调函数使用,如果没有回调函数,就直接抛弃了
- * timeout_ms=0时,依然为阻塞接口,而且是永远等待
- * 返回0表示有数据接收,用户打断或者超时返回,其他为网络异常
- * 用户打断,is_break = 1,超时 is_timeout = 1
- * @param ctrl 网络资源
- * @param timeout_ms 超时时间
- * @param is_break 是否是用户打断
- * @param is_timeout 是否超时
- * @return 成功返回0,失败 < 0
- */
- int network_wait_rx(network_ctrl_t *ctrl, uint32_t timeout_ms, uint8_t *is_break, uint8_t *is_timeout);
- /****************************高级api结束********************************************************************/
- /**
- * 获取网卡完整的地址信息
- * @param ctrl 网络资源,如果写NULL,则看下面的adapter_index
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param ip IPV4地址
- * @param submask 子网掩码
- * @param gateway 网关
- * @param ipv6 IPV6地址
- * @return 成功返回0,其他失败
- */
- 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);
- /**
- * 将IP设置成无效状态
- * @param ip
- */
- void network_set_ip_invaild(luat_ip_addr_t *ip);
- /**
- * 检测IP是不是无效的
- * @param ip
- * @return 无效返回0,其他有效
- */
- uint8_t network_ip_is_vaild(luat_ip_addr_t *ip);
- /**
- * 检测IP是不是IPV6类型
- * @param ip
- * @return 不是返回0
- */
- uint8_t network_ip_is_ipv6(luat_ip_addr_t *ip);
- /**
- * 检测IP是不是有效的IPV4类型
- * @param ip
- * @return 不是返回0
- */
- uint8_t network_ip_is_vaild_ipv4(luat_ip_addr_t *ip);
- /**
- * 将IP设置成IPV4
- * @param 需要设置的ip地址
- * @param ipv4 ipv4
- */
- void network_set_ip_ipv4(luat_ip_addr_t *ip, uint32_t ipv4);
- network_adapter_info* network_adapter_fetch(int id, void** userdata);
- // 获取真正的最后一个注册的网卡适配器序号, network_get_last_register_adapter用的地方太多了,已经改不了
- int network_get_last_register_adapter_real(void);
- /**
- * 断开指定网卡的所有数据链接(实验性支持)
- * @param adapter_index 网卡适配器序号 NW_ADAPTER_INDEX_XXX
- * @param timeout_ms 超时时间
- * @return 成功返回0,其他失败
- */
- int network_close_all_ctrl_by_adapter(uint8_t adapter_index, uint32_t timeout_ms);
- #endif
- // #endif
|