/third_party/lwip/ |
D | 0029-fix-EISCONN-err-and-remove-same-customized-modificat.patch | 28 - struct lwip_sock *sock = get_socket_without_errno(s); 55 @@ -93,13 +93,14 @@ struct lwip_sock { 71 @@ -124,38 +125,12 @@ struct lwip_sock { 74 extern struct lwip_sock *sockets; 79 - * @return struct lwip_sock for the socket or NULL if not found 81 -static inline struct lwip_sock * 84 - struct lwip_sock *sock = NULL; 105 extern ssize_t read_lwip_data(struct lwip_sock *sock, int32_t flags, u8_t apiflags); 106 …extern struct pbuf *write_lwip_data(struct lwip_sock *sock, uint16_t remain_size, uint8_t *apiflag… 108 +extern void write_lwip_over(struct lwip_sock *sock, uint32_t n); [all …]
|
D | 0073-lstack_lwip-external-api-start-with-do_lwip_-prefix.patch | 78 @@ -1170,7 +1170,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 87 @@ -1369,7 +1369,7 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg, … 126 - p = write_lwip_data((struct lwip_sock *)arg, len - pos, &apiflags); 127 + p = do_lwip_get_from_sendring((struct lwip_sock *)arg, len - pos, &apiflags); 135 - write_lwip_over((struct lwip_sock*)arg); 136 + do_lwip_get_from_sendring_over((struct lwip_sock*)arg); 148 - struct pbuf *udp_pbuf = write_lwip_data((struct lwip_sock *)(p->payload), p->tot_len, &apiflags); 149 - write_lwip_over((struct lwip_sock *)(p->payload)); 150 + struct pbuf *udp_pbuf = do_lwip_get_from_sendring((struct lwip_sock *)(p->payload), p->tot_len, … 151 + do_lwip_get_from_sendring_over((struct lwip_sock *)(p->payload)); [all …]
|
D | 0039-optimize-app-thread-write-buff-block.patch | 20 - write_lwip_over((struct lwip_sock*)arg, 1); 21 + write_lwip_over((struct lwip_sock*)arg); 43 @@ -93,17 +93,30 @@ struct lwip_sock { 82 struct lwip_sock *listen_next; /* listenfd list */ 83 @@ -131,7 +144,7 @@ extern ssize_t read_lwip_data(struct lwip_sock *sock, int32_t flags, u8_t apifla 84 …extern struct pbuf *write_lwip_data(struct lwip_sock *sock, uint16_t remain_size, uint8_t *apiflag… 87 -extern void write_lwip_over(struct lwip_sock *sock, uint32_t n); 88 +extern void write_lwip_over(struct lwip_sock *sock); 91 struct lwip_sock *get_socket(int s);
|
D | 0077-adpat-event-for-rtc-mode.patch | 112 struct lwip_sock; 113 extern void add_sock_event(struct lwip_sock *sock, uint32_t event); 114 +extern void add_sock_event_nolock(struct lwip_sock *sock, uint32_t event); 115 +extern void del_sock_event(struct lwip_sock *sock, uint32_t event); 116 +extern void del_sock_event_nolock(struct lwip_sock *sock, uint32_t event);
|
D | 0016-lstack-support-mysql-mode.patch | 67 struct lwip_sock *sock = get_socket_without_errno(s); 124 @@ -714,13 +704,6 @@ free_socket(struct lwip_sock *sock, int is_tcp) 230 struct lwip_sock *sock; 242 - /* No matter what the result of close, lwip_sock resources should release 272 struct lwip_sock *sock; 331 lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 345 @@ -1173,6 +1050,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 353 @@ -1182,13 +1060,6 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 367 @@ -1258,23 +1129,21 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 400 @@ -1461,37 +1330,6 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg,… [all …]
|
D | 0024-refactor-pkt-read-send-performance.patch | 63 @@ -60,7 +60,7 @@ static struct lwip_sock *chld_get_socket(int fd) 85 @@ -1039,11 +1039,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 97 @@ -1134,6 +1130,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 257 struct lwip_sock { 258 @@ -92,28 +93,21 @@ struct lwip_sock { 275 + struct lwip_sock *listen_next; /* listenfd list */ 287 - struct lwip_sock *shadowed_sock; 299 extern ssize_t read_lwip_data(struct lwip_sock *sock, int32_t flags, u8_t apiflags); 300 …extern struct pbuf *write_lwip_data(struct lwip_sock *sock, uint16_t remain_size, uint8_t *apiflag…
|
D | 0033-alloc-socket-fail-clean-sock.patch | 30 extern ssize_t read_lwip_data(struct lwip_sock *sock, int32_t flags, u8_t apiflags); 31 …extern struct pbuf *write_lwip_data(struct lwip_sock *sock, uint16_t remain_size, uint8_t *apiflag… 34 extern void write_lwip_over(struct lwip_sock *sock, uint32_t n);
|
D | 0017-support-REUSEPOR-option.patch | 31 @@ -94,7 +94,8 @@ struct lwip_sock { 41 @@ -103,8 +104,13 @@ struct lwip_sock { 48 + struct lwip_sock *shadowed_sock;
|
D | 0026-del-redundant-wait_close-and-move-epoll_events-pos.patch | 14 @@ -98,12 +98,11 @@ struct lwip_sock { 25 struct lwip_sock *listen_next; /* listenfd list */
|
D | 0057-same-node-gazellectl-a.patch | 35 @@ -716,6 +720,11 @@ free_socket(struct lwip_sock *sock, int is_tcp) 195 + struct lwip_sock *sock = NULL; 410 struct lwip_sock { 412 @@ -120,9 +132,25 @@ struct lwip_sock { 426 +static inline unsigned same_node_ring_count(struct lwip_sock *sock) 438 @@ -142,6 +170,15 @@ extern struct pbuf *write_lwip_data(struct lwip_sock *sock, uint16_t remain_si… 441 extern void write_lwip_over(struct lwip_sock *sock); 444 +extern err_t find_same_node_memzone(struct tcp_pcb *pcb, struct lwip_sock *nsock); 453 struct lwip_sock *get_socket(int s);
|
D | 0021-refactor-event-if-ring-is-full-the-node-is-added-to-.patch | 14 @@ -104,12 +104,16 @@ struct lwip_sock { 21 struct lwip_sock *shadowed_sock;
|
D | 0018-exec-gazelle_init_sock-before-read-event.patch | 29 extern ssize_t read_lwip_data(struct lwip_sock *sock, int32_t flags, u8_t apiflags); 34 struct lwip_sock *get_socket(int s);
|
D | 0012-fix-incomplete-resource-release-in-lwip-close.patch | 16 struct lwip_sock *sock; 29 + /* No matter what the result of close, lwip_sock resources should release
|
D | 0060-lwip-add-udp-multicast.patch | 57 @@ -1274,6 +1275,7 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg, … 65 @@ -1361,6 +1363,18 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg,… 93 struct lwip_sock *sock = posix_api->get_socket(s); 165 + struct pbuf *udp_pbuf = write_lwip_data((struct lwip_sock *)(p->payload), p->tot_len, &apiflags); 166 + write_lwip_over((struct lwip_sock *)(p->payload));
|
D | 0062-drop-netbuf-in-recv_udp-to-fix-mem-overflow.patch | 95 @@ -1179,7 +1179,7 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg, … 104 @@ -1267,7 +1267,7 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg, … 113 @@ -1278,7 +1278,7 @@ lwip_recvfrom_udp_raw(struct lwip_sock *sock, int flags, struct msghdr *msg, … 133 struct pbuf *udp_pbuf = write_lwip_data((struct lwip_sock *)(p->payload), p->tot_len, &apiflags);
|
D | 0031-refactor-add-event-limit-send-pkts-num.patch | 64 +struct lwip_sock; 65 +extern void add_sock_event(struct lwip_sock *sock, uint32_t event);
|
D | 0007-gazelle-fix-epoll_ctl-EPOLLET-mode-error.patch | 13 @@ -714,6 +714,13 @@ free_socket(struct lwip_sock *sock, int is_tcp) 41 @@ -1191,7 +1191,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags)
|
D | 0075-adapt-read-write-for-rtc-mode.patch | 46 @@ -1087,7 +1087,15 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 63 @@ -1166,15 +1174,10 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 181 - p = do_lwip_get_from_sendring((struct lwip_sock *)arg, len - pos, &apiflags); 223 - do_lwip_get_from_sendring_over((struct lwip_sock*)arg); 296 + p = do_lwip_get_from_sendring((struct lwip_sock *)arg, len - pos, &apiflags); 343 + do_lwip_get_from_sendring_over((struct lwip_sock*)arg);
|
D | 0058-lwip-send-recv-thread-bind-numa.patch | 14 @@ -138,6 +138,7 @@ struct lwip_sock {
|
D | 0045-add-variable-in-struct-sock.patch | 14 @@ -105,8 +105,7 @@ struct lwip_sock {
|
D | 0054-reduce-cpu-usage-when-send.patch | 22 @@ -110,6 +111,7 @@ struct lwip_sock {
|
D | 0053-cleancode-improve-lwipopts.h-readability.patch | 136 struct lwip_sock *sockets; 138 static struct lwip_sock sockets[NUM_SOCKETS]; 160 * @return struct lwip_sock for the socket or NULL if not found 164 struct lwip_sock * 167 static struct lwip_sock * 172 struct lwip_sock *sock = tryget_socket(fd); 263 @@ -1065,7 +1065,7 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 272 @@ -1146,13 +1146,13 @@ lwip_recv_tcp(struct lwip_sock *sock, void *mem, size_t len, int flags) 1161 p = write_lwip_data((struct lwip_sock *)arg, len - pos, &apiflags); 1195 write_lwip_over((struct lwip_sock*)arg); [all …]
|
D | 0027-modify-EISCONN-condition.patch | 28 @@ -98,6 +98,8 @@ struct lwip_sock {
|
/third_party/lwip/src/api/ |
D | sockets.c | 234 struct lwip_sock *sock; 253 struct lwip_sock *sock; 268 static struct lwip_sock sockets[NUM_SOCKETS]; 308 static int free_socket_locked(struct lwip_sock *sock, int is_tcp, struct netconn **conn, 343 sock_inc_used(struct lwip_sock *sock) in sock_inc_used() 365 sock_inc_used_locked(struct lwip_sock *sock) in sock_inc_used_locked() 385 done_socket(struct lwip_sock *sock) in done_socket() 418 static struct lwip_sock * 429 struct lwip_sock * 436 static struct lwip_sock * [all …]
|
/third_party/lwip/src/include/lwip/priv/ |
D | sockets_priv.h | 67 struct lwip_sock { struct 134 struct lwip_sock* lwip_socket_dbg_get_socket(int fd);
|