| /third_party/lwip/src/core/ |
| D | altcp_tcp.c | 60 #define ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb) do { \ argument
61 LWIP_ASSERT("pcb mismatch", (conn)->state == tpcb); \
62 LWIP_UNUSED_ARG(tpcb); /* for LWIP_NOASSERT */ \
70 static void altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb);
90 altcp_tcp_connected(void *arg, struct tcp_pcb *tpcb, err_t err) in altcp_tcp_connected() argument
94 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb); in altcp_tcp_connected()
103 altcp_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) in altcp_tcp_recv() argument
107 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb); in altcp_tcp_recv()
120 altcp_tcp_sent(void *arg, struct tcp_pcb *tpcb, u16_t len) in altcp_tcp_sent() argument
124 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb); in altcp_tcp_sent()
[all …]
|
| /third_party/lwip/src/include/lwip/priv/ |
| D | tcp_priv.h | 100 #define tcp_do_output_nagle(tpcb) ((((tpcb)->unacked == NULL) || \ argument
101 ((tpcb)->flags & (TF_NODELAY | TF_INFR)) || \
102 (((tpcb)->unsent != NULL) && (((tpcb)->unsent->next != NULL) || \
103 ((tpcb)->unsent->len >= (tpcb)->mss))) || \
104 … ((tcp_sndbuf(tpcb) == 0) || (tcp_sndqueuelen(tpcb) >= TCP_SND_QUEUELEN)) \
106 #define tcp_output_nagle(tpcb) (tcp_do_output_nagle(tpcb) ? tcp_output(tpcb) : ERR_OK) argument
|
| /third_party/lwip/src/apps/lwiperf/ |
| D | lwiperf.c | 178 static err_t lwiperf_tcp_poll(void *arg, struct tcp_pcb *tpcb);
354 lwiperf_tcp_client_sent(void *arg, struct tcp_pcb *tpcb, u16_t len) in lwiperf_tcp_client_sent() argument
358 LWIP_ASSERT("invalid conn", conn->conn_pcb == tpcb); in lwiperf_tcp_client_sent()
359 LWIP_UNUSED_ARG(tpcb); in lwiperf_tcp_client_sent()
369 lwiperf_tcp_client_connected(void *arg, struct tcp_pcb *tpcb, err_t err) in lwiperf_tcp_client_connected() argument
372 LWIP_ASSERT("invalid conn", conn->conn_pcb == tpcb); in lwiperf_tcp_client_connected()
373 LWIP_UNUSED_ARG(tpcb); in lwiperf_tcp_client_connected()
456 lwiperf_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) in lwiperf_tcp_recv() argument
464 LWIP_ASSERT("pcb mismatch", conn->conn_pcb == tpcb); in lwiperf_tcp_recv()
465 LWIP_UNUSED_ARG(tpcb); in lwiperf_tcp_recv()
[all …]
|
| /third_party/lwip/src/api/ |
| D | api_msg.c | 974 struct tcp_pcb *tpcb; local
985 tpcb = conn->pcb.tcp;
994 ((tpcb->state == FIN_WAIT_1) ||
995 (tpcb->state == FIN_WAIT_2) ||
996 (tpcb->state == CLOSING))) {
998 } else if (shut_tx && ((tpcb->flags & TF_RXCLOSED) != 0)) {
1006 tcp_arg(tpcb, NULL);
1008 if (tpcb->state == LISTEN) {
1009 tcp_accept(tpcb, NULL);
1013 tcp_recv(tpcb, NULL);
[all …]
|
| /third_party/lwip/src/apps/mqtt/ |
| D | mqtt.c | 234 mqtt_output_send(struct mqtt_ringbuf_t *rb, struct altcp_pcb *tpcb) in mqtt_output_send() argument
239 u16_t send_len = altcp_sndbuf(tpcb); in mqtt_output_send()
240 LWIP_ASSERT("mqtt_output_send: tpcb != NULL", tpcb != NULL); in mqtt_output_send()
255 …err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY | (wrap ? TCP_WRIT… in mqtt_output_send()
259 send_len = LWIP_MIN(altcp_sndbuf(tpcb), mqtt_ringbuf_linear_read_length(rb)); in mqtt_output_send()
260 err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY); in mqtt_output_send()
266 altcp_output(tpcb); in mqtt_output_send()
975 mqtt_tcp_sent_cb(void *arg, struct altcp_pcb *tpcb, u16_t len) in mqtt_tcp_sent_cb() argument
979 LWIP_UNUSED_ARG(tpcb); in mqtt_tcp_sent_cb()
1026 mqtt_tcp_poll_cb(void *arg, struct altcp_pcb *tpcb) in mqtt_tcp_poll_cb() argument
[all …]
|
| /third_party/lwip/src/apps/http/ |
| D | http_client.c | 159 struct altcp_pcb* tpcb; in httpc_free_state() local
170 tpcb = req->pcb; in httpc_free_state()
174 if (tpcb != NULL) { in httpc_free_state()
176 altcp_arg(tpcb, NULL); in httpc_free_state()
177 altcp_recv(tpcb, NULL); in httpc_free_state()
178 altcp_err(tpcb, NULL); in httpc_free_state()
179 altcp_poll(tpcb, NULL, 0); in httpc_free_state()
180 altcp_sent(tpcb, NULL); in httpc_free_state()
181 r = altcp_close(tpcb); in httpc_free_state()
183 altcp_abort(tpcb); in httpc_free_state()
|
| /third_party/lwip/ |
| D | backport-tcp-fix-sequence-number-comparison.patch | 17 #define tcp_output_nagle(tpcb) (tcp_do_output_nagle(tpcb) ? tcp_output(tpcb) : ERR_OK)
|
| /third_party/lwip/src/include/lwip/ |
| D | tcp.h | 82 typedef err_t (*tcp_recv_fn)(void *arg, struct tcp_pcb *tpcb,
96 typedef err_t (*tcp_sent_fn)(void *arg, struct tcp_pcb *tpcb,
108 typedef err_t (*tcp_poll_fn)(void *arg, struct tcp_pcb *tpcb);
134 typedef err_t (*tcp_connected_fn)(void *arg, struct tcp_pcb *tpcb, err_t err);
|
| D | altcp_tcp.h | 64 struct altcp_pcb *altcp_tcp_wrap(struct tcp_pcb *tpcb);
|