| /seL4-camkes-master/projects/lwip/src/core/ |
| H A D | altcp_tcp.c | 59 #define ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb) do { \
60 LWIP_ASSERT("pcb mismatch", (conn)->state == tpcb); \
61 LWIP_UNUSED_ARG(tpcb); /* for LWIP_NOASSERT */ \
69 static void altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb);
89 altcp_tcp_connected(void *arg, struct tcp_pcb *tpcb, err_t err) argument
93 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb);
102 altcp_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) argument
106 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb);
119 altcp_tcp_sent(void *arg, struct tcp_pcb *tpcb, u16_t len) argument
123 ALTCP_TCP_ASSERT_CONN_PCB(conn, tpcb);
132 altcp_tcp_poll(void *arg, struct tcp_pcb *tpcb) argument
160 altcp_tcp_remove_callbacks(struct tcp_pcb *tpcb) argument
170 altcp_tcp_setup_callbacks(struct altcp_pcb *conn, struct tcp_pcb *tpcb) argument
181 altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb) argument
193 struct tcp_pcb *tpcb = tcp_new_ip_type(ip_type); local
219 altcp_tcp_wrap(struct tcp_pcb *tpcb) argument
[all...] |
| /seL4-camkes-master/projects/lwip/src/include/lwip/ |
| H A D | altcp_tcp.h | 64 struct altcp_pcb *altcp_tcp_wrap(struct tcp_pcb *tpcb);
|
| H A D | tcp.h | 76 * @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);
|
| /seL4-camkes-master/projects/lwip/src/include/lwip/priv/ |
| H A D | tcp_priv.h | 100 #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...] |
| /seL4-camkes-master/projects/lwip/src/apps/lwiperf/ |
| H A 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) argument
358 LWIP_ASSERT("invalid conn", conn->conn_pcb == tpcb);
359 LWIP_UNUSED_ARG(tpcb);
369 lwiperf_tcp_client_connected(void *arg, struct tcp_pcb *tpcb, err_t err) argument
372 LWIP_ASSERT("invalid conn", conn->conn_pcb == tpcb);
373 LWIP_UNUSED_ARG(tpcb);
456 lwiperf_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) argument
464 LWIP_ASSERT("pcb mismatch", conn->conn_pcb == tpcb);
465 LWIP_UNUSED_ARG(tpcb);
573 lwiperf_tcp_poll(void *arg, struct tcp_pcb *tpcb) argument
[all...] |
| /seL4-camkes-master/projects/lwip/src/api/ |
| H A D | api_msg.c | 925 struct tcp_pcb *tpcb; local
936 tpcb = conn->pcb.tcp;
945 ((tpcb->state == FIN_WAIT_1) ||
946 (tpcb->state == FIN_WAIT_2) ||
947 (tpcb->state == CLOSING))) {
949 } else if (shut_tx && ((tpcb->flags & TF_RXCLOSED) != 0)) {
957 tcp_arg(tpcb, NULL);
959 if (tpcb->state == LISTEN) {
960 tcp_accept(tpcb, NULL);
964 tcp_recv(tpcb, NUL
[all...] |
| /seL4-camkes-master/projects/lwip/src/apps/mqtt/ |
| H A D | mqtt.c | 231 * @param tpcb TCP connection handle
234 mqtt_output_send(struct mqtt_ringbuf_t *rb, struct altcp_pcb *tpcb) argument
239 u16_t send_len = altcp_sndbuf(tpcb);
240 LWIP_ASSERT("mqtt_output_send: tpcb != NULL", tpcb != NULL);
255 err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY | (wrap ? TCP_WRITE_FLAG_MORE : 0));
259 send_len = LWIP_MIN(altcp_sndbuf(tpcb), mqtt_ringbuf_linear_read_length(rb));
260 err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY);
266 altcp_output(tpcb);
971 * @param tpcb TC
976 mqtt_tcp_sent_cb(void *arg, struct altcp_pcb *tpcb, u16_t len) argument
1027 mqtt_tcp_poll_cb(void *arg, struct altcp_pcb *tpcb) argument
1044 mqtt_tcp_connect_cb(void *arg, struct altcp_pcb *tpcb, err_t err) argument
[all...] |
| /seL4-camkes-master/projects/lwip/src/apps/http/ |
| H A D | http_client.c | 159 struct altcp_pcb* tpcb; local
170 tpcb = req->pcb;
174 if (tpcb != NULL) {
176 altcp_arg(tpcb, NULL);
177 altcp_recv(tpcb, NULL);
178 altcp_err(tpcb, NULL);
179 altcp_poll(tpcb, NULL, 0);
180 altcp_sent(tpcb, NULL);
181 r = altcp_close(tpcb);
183 altcp_abort(tpcb);
[all...] |