Home
last modified time | relevance | path

Searched refs:tpcb (Results 1 - 8 of 8) sorted by relevance

/third_party/lwip/src/core/
H A Daltcp_tcp.c60 #define ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb) do { \
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()
133 altcp_tcp_poll(void *arg, struct tcp_pcb *tpcb) altcp_tcp_poll() argument
161 altcp_tcp_remove_callbacks(struct tcp_pcb *tpcb) altcp_tcp_remove_callbacks() argument
173 altcp_tcp_setup_callbacks(struct altcp_pcb *conn, struct tcp_pcb *tpcb) altcp_tcp_setup_callbacks() argument
186 altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb) altcp_tcp_setup() argument
198 struct tcp_pcb *tpcb = tcp_new_ip_type(ip_type); altcp_tcp_new_ip_type() local
224 altcp_tcp_wrap(struct tcp_pcb *tpcb) altcp_tcp_wrap() argument
[all...]
/third_party/lwip/src/apps/lwiperf/
H A Dlwiperf.c178 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()
573 lwiperf_tcp_poll(void *arg, struct tcp_pcb *tpcb) lwiperf_tcp_poll() argument
[all...]
/third_party/lwip/src/include/lwip/priv/
H A Dtcp_priv.h100 #define tcp_do_output_nagle(tpcb) ((((tpcb)->unacked == NULL) || \
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_nagl
[all...]
/third_party/lwip/src/api/
H A Dapi_msg.c974 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, NUL
[all...]
/third_party/lwip/src/apps/mqtt/
H A Dmqtt.c231 * @param tpcb TCP connection handle
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_WRITE_FLAG_MORE : 0)); 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()
970 * @param tpcb TC
975 mqtt_tcp_sent_cb(void *arg, struct altcp_pcb *tpcb, u16_t len) mqtt_tcp_sent_cb() argument
1026 mqtt_tcp_poll_cb(void *arg, struct altcp_pcb *tpcb) mqtt_tcp_poll_cb() argument
1043 mqtt_tcp_connect_cb(void *arg, struct altcp_pcb *tpcb, err_t err) mqtt_tcp_connect_cb() argument
[all...]
/third_party/lwip/src/apps/http/
H A Dhttp_client.c159 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()
[all...]
/third_party/lwip/src/include/lwip/
H A Dtcp.h76 * @param tpcb The connection pcb which received data
82 typedef err_t (*tcp_recv_fn)(void *arg, struct tcp_pcb *tpcb,
90 * @param tpcb The connection pcb for which data has been acknowledged
96 typedef err_t (*tcp_sent_fn)(void *arg, struct tcp_pcb *tpcb,
103 * @param tpcb tcp pcb
108 typedef err_t (*tcp_poll_fn)(void *arg, struct tcp_pcb *tpcb);
127 * @param tpcb The connection pcb which is connected
134 typedef err_t (*tcp_connected_fn)(void *arg, struct tcp_pcb *tpcb, err_t err);
H A Daltcp_tcp.h64 struct altcp_pcb *altcp_tcp_wrap(struct tcp_pcb *tpcb);

Completed in 8 milliseconds