Home
last modified time | relevance | path

Searched refs:tcp_pcb (Results 1 – 21 of 21) sorted by relevance

/third_party/lwip/src/core/
Daltcp_tcp.c70 static void altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb);
74 altcp_tcp_accept(void *arg, struct tcp_pcb *new_tpcb, err_t err) in altcp_tcp_accept()
90 altcp_tcp_connected(void *arg, struct tcp_pcb *tpcb, err_t err) in altcp_tcp_connected()
103 altcp_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) in altcp_tcp_recv()
120 altcp_tcp_sent(void *arg, struct tcp_pcb *tpcb, u16_t len) in altcp_tcp_sent()
133 altcp_tcp_poll(void *arg, struct tcp_pcb *tpcb) in altcp_tcp_poll()
161 altcp_tcp_remove_callbacks(struct tcp_pcb *tpcb) in altcp_tcp_remove_callbacks()
173 altcp_tcp_setup_callbacks(struct altcp_pcb *conn, struct tcp_pcb *tpcb) in altcp_tcp_setup_callbacks()
186 altcp_tcp_setup(struct altcp_pcb *conn, struct tcp_pcb *tpcb) in altcp_tcp_setup()
198 struct tcp_pcb *tpcb = tcp_new_ip_type(ip_type); in altcp_tcp_new_ip_type()
[all …]
Dtcp.c174 struct tcp_pcb *tcp_bound_pcbs;
179 struct tcp_pcb *tcp_active_pcbs;
181 struct tcp_pcb *tcp_tw_pcbs;
184 struct tcp_pcb **const tcp_pcb_lists[] = {&tcp_listen_pcbs.pcbs, &tcp_bound_pcbs,
195 static err_t tcp_close_shutdown_fin(struct tcp_pcb *pcb);
201 void set_tcp_pcb_net_group(struct tcp_pcb *pcb, struct net_group *group) in set_tcp_pcb_net_group()
206 struct net_group *get_net_group_from_tcp_pcb(const struct tcp_pcb *pcb) in get_net_group_from_tcp_pcb()
224 tcp_free(struct tcp_pcb *pcb) in tcp_free()
235 tcp_free_listen(struct tcp_pcb *pcb) in tcp_free_listen()
264 tcp_set_timer_tick_by_persist(struct tcp_pcb *pcb, u32_t tick) in tcp_set_timer_tick_by_persist()
[all …]
Dtcp_in.c88 struct tcp_pcb *tcp_input_pcb;
91 static err_t tcp_process(struct tcp_pcb *pcb);
92 static void tcp_receive(struct tcp_pcb *pcb);
93 static void tcp_parseopt(struct tcp_pcb *pcb);
96 static void tcp_timewait_input(struct tcp_pcb *pcb);
98 static int tcp_input_delayed_close(struct tcp_pcb *pcb);
101 static void tcp_add_sack(struct tcp_pcb *pcb, u32_t left, u32_t right);
102 static void tcp_remove_sacks_lt(struct tcp_pcb *pcb, u32_t seq);
104 static void tcp_remove_sacks_gt(struct tcp_pcb *pcb, u32_t seq);
120 struct tcp_pcb *pcb, *prev;
[all …]
Dtcp_out.c128 static err_t tcp_output_segment(struct tcp_seg *seg, struct tcp_pcb *pcb, struct netif *netif);
132 tcp_route(const struct tcp_pcb *pcb, const ip_addr_t *src, const ip_addr_t *dst) in tcp_route()
170 tcp_create_segment(const struct tcp_pcb *pcb, struct pbuf *p, u8_t hdrflags, u32_t seqno, u8_t optf… in tcp_create_segment()
238 u16_t *oversize, const struct tcp_pcb *pcb, u8_t apiflags, in tcp_pbuf_prealloc()
317 tcp_write_checks(struct tcp_pcb *pcb, u16_t len) in tcp_write_checks()
402 tcp_write(struct tcp_pcb *pcb, const void *arg, u16_t len, u8_t apiflags) in tcp_write()
839 tcp_split_unsent_seg(struct tcp_pcb *pcb, u16_t split) in tcp_split_unsent_seg()
1014 tcp_send_fin(struct tcp_pcb *pcb) in tcp_send_fin()
1045 tcp_enqueue_flags(struct tcp_pcb *pcb, u8_t flags) in tcp_enqueue_flags()
1152 tcp_build_timestamp_option(const struct tcp_pcb *pcb, u32_t *opts) in tcp_build_timestamp_option()
[all …]
Dpbuf.c130 struct tcp_pcb *pcb; in pbuf_free_ooseq()
/third_party/lwip/src/include/lwip/
Dtcp.h58 struct tcp_pcb;
70 typedef err_t (*tcp_accept_fn)(void *arg, struct tcp_pcb *newpcb, err_t err);
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);
182 …(*tcp_extarg_callback_passive_open_fn)(u8_t id, struct tcp_pcb_listen *lpcb, struct tcp_pcb *cpcb);
242 struct tcp_pcb { struct
246 TCP_PCB_COMMON(struct tcp_pcb);
402 err_t lwip_tcp_event(void *arg, struct tcp_pcb *pcb, argument
[all …]
Daltcp_tcp.h63 struct tcp_pcb;
64 struct altcp_pcb *altcp_tcp_wrap(struct tcp_pcb *tpcb);
Dapi.h208 struct tcp_pcb;
226 struct tcp_pcb *tcp;
Daltcp.h158 #define altcp_pcb tcp_pcb
/third_party/lwip/src/include/lwip/priv/
Dtcp_priv.h79 struct tcp_pcb * tcp_alloc (u8_t prio);
80 void tcp_free (struct tcp_pcb *pcb);
81 void tcp_abandon (struct tcp_pcb *pcb, int reset);
82 err_t tcp_send_empty_ack(struct tcp_pcb *pcb);
83 err_t tcp_rexmit (struct tcp_pcb *pcb);
84 err_t tcp_rexmit_rto_prepare(struct tcp_pcb *pcb);
85 void tcp_rexmit_rto_commit(struct tcp_pcb *pcb);
86 void tcp_rexmit_rto (struct tcp_pcb *pcb);
87 void tcp_rexmit_fast (struct tcp_pcb *pcb);
88 u32_t tcp_update_rcv_ann_wnd(struct tcp_pcb *pcb);
[all …]
Dmemp_std.h50 LWIP_MEMPOOL(TCP_PCB, MEMP_NUM_TCP_PCB, sizeof(struct tcp_pcb), "TCP_PCB")
Dapi_msg.h192 u8_t poll_tcp_needed(void *arg, struct tcp_pcb *pcb);
/third_party/lwip/test/unit/tcp/
Dtcp_helper.h41 struct pbuf* tcp_create_rx_segment(struct tcp_pcb* pcb, void* data, size_t data_len,
43 struct pbuf* tcp_create_rx_segment_wnd(struct tcp_pcb* pcb, void* data, size_t data_len,
45 void tcp_set_state(struct tcp_pcb* pcb, enum tcp_state state, const ip_addr_t* local_ip,
48 err_t test_tcp_counters_recv(void* arg, struct tcp_pcb* pcb, struct pbuf* p, err_t err);
50 struct tcp_pcb* test_tcp_new_counters_pcb(struct test_tcp_counters* counters);
Dtcp_helper.c19 tcp_remove(struct tcp_pcb* pcb_list) in tcp_remove()
21 struct tcp_pcb *pcb = pcb_list; in tcp_remove()
22 struct tcp_pcb *pcb2; in tcp_remove()
125 tcp_create_rx_segment(struct tcp_pcb* pcb, void* data, size_t data_len, u32_t seqno_offset, in tcp_create_rx_segment()
137 struct pbuf* tcp_create_rx_segment_wnd(struct tcp_pcb* pcb, void* data, size_t data_len, in tcp_create_rx_segment_wnd()
146 tcp_set_state(struct tcp_pcb* pcb, enum tcp_state state, const ip_addr_t* local_ip, in tcp_set_state()
213 test_tcp_counters_recv(void* arg, struct tcp_pcb* pcb, struct pbuf* p, err_t err) in test_tcp_counters_recv()
238 struct tcp_pcb*
241 struct tcp_pcb* pcb = tcp_new(); in test_tcp_new_counters_pcb()
Dtest_tcp_oos.c28 static int tcp_oos_count(struct tcp_pcb* pcb) in tcp_oos_count()
41 static int tcp_oos_pbuf_count(struct tcp_pcb* pcb) in tcp_oos_pbuf_count()
60 tcp_oos_seg_seqno(struct tcp_pcb* pcb, int seg_index) in tcp_oos_seg_seqno()
84 tcp_oos_seg_tcplen(struct tcp_pcb* pcb, int seg_index) in tcp_oos_seg_tcplen()
107 tcp_oos_tcplen(struct tcp_pcb* pcb) in tcp_oos_tcplen()
157 struct tcp_pcb* pcb; in START_TEST()
293 struct tcp_pcb* pcb; in START_TEST()
465 struct tcp_pcb* pcb; in START_TEST()
552 struct tcp_pcb* pcb; in START_TEST()
638 struct tcp_pcb* pcb; in START_TEST()
[all …]
Dtest_tcp.c49 struct tcp_pcb dummy_pcb; /* we need this for tcp_next_iss() only */ in tcp_setup()
84 struct tcp_pcb* pcb; in START_TEST()
102 struct tcp_pcb *pcb, *pcbl; in START_TEST()
162 struct tcp_pcb* pcb; in START_TEST()
208 struct tcp_pcb* pcb; in START_TEST()
257 static err_t test_tcp_recv_expect1byte(void* arg, struct tcp_pcb* pcb, struct pbuf* p, err_t err);
260 test_tcp_recv_expectclose(void* arg, struct tcp_pcb* pcb, struct pbuf* p, err_t err) in test_tcp_recv_expectclose()
279 test_tcp_recv_expect1byte(void* arg, struct tcp_pcb* pcb, struct pbuf* p, err_t err) in test_tcp_recv_expect1byte()
301 struct tcp_pcb* pcb; in START_TEST()
336 struct tcp_pcb* pcb; in START_TEST()
[all …]
/third_party/lwip/src/apps/snmp/
Dsnmp_mib2_tcp.c98 struct tcp_pcb *pcb = tcp_active_pcbs; in tcp_get_value()
165 tcp_ConnTable_get_cell_value_core(struct tcp_pcb *pcb, const u32_t *column, union snmp_variant_valu… in tcp_ConnTable_get_cell_value_core()
210 struct tcp_pcb *pcb; in tcp_ConnTable_get_cell_value()
259 struct tcp_pcb *pcb; in tcp_ConnTable_get_next_cell_instance_and_value()
300 …return tcp_ConnTable_get_cell_value_core((struct tcp_pcb *)state.reference, column, value, value_l… in tcp_ConnTable_get_next_cell_instance_and_value()
312 tcp_ConnectionTable_get_cell_value_core(const u32_t *column, struct tcp_pcb *pcb, union snmp_varian… in tcp_ConnectionTable_get_cell_value_core()
334 struct tcp_pcb *pcb; in tcp_ConnectionTable_get_cell_value()
337 …struct tcp_pcb **const tcp_pcb_nonlisten_lists[] = {&tcp_bound_pcbs, &tcp_active_pcbs, &tcp_tw_pcb… in tcp_ConnectionTable_get_cell_value()
376 struct tcp_pcb *pcb; in tcp_ConnectionTable_get_next_cell_instance_and_value()
382 …struct tcp_pcb **const tcp_pcb_nonlisten_lists[] = {&tcp_bound_pcbs, &tcp_active_pcbs, &tcp_tw_pcb… in tcp_ConnectionTable_get_next_cell_instance_and_value()
[all …]
/third_party/lwip/src/apps/lwiperf/
Dlwiperf.c116 struct tcp_pcb *server_pcb;
117 struct tcp_pcb *conn_pcb;
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()
369 lwiperf_tcp_client_connected(void *arg, struct tcp_pcb *tpcb, err_t err) in lwiperf_tcp_client_connected()
392 struct tcp_pcb *newpcb; in lwiperf_tx_start_impl()
456 lwiperf_tcp_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err) in lwiperf_tcp_recv()
573 lwiperf_tcp_poll(void *arg, struct tcp_pcb *tpcb) in lwiperf_tcp_poll()
592 lwiperf_tcp_accept(void *arg, struct tcp_pcb *newpcb, err_t err) in lwiperf_tcp_accept()
689 struct tcp_pcb *pcb; in lwiperf_start_tcp_server_impl()
/third_party/lwip/src/api/
Dapi_msg.c293 recv_tcp(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
357 poll_tcp(void *arg, struct tcp_pcb *pcb)
393 poll_tcp_needed(void *arg, struct tcp_pcb *pcb)
427 sent_tcp(void *arg, struct tcp_pcb *pcb, u16_t len)
545 struct tcp_pcb *pcb;
562 accept_function(void *arg, struct tcp_pcb *newpcb, err_t err)
609 struct tcp_pcb *pcb = newconn->pcb.tcp;
974 struct tcp_pcb *tpcb;
1360 lwip_netconn_do_connected(void *arg, struct tcp_pcb *pcb, err_t err)
1516 struct tcp_pcb *lpcb;
/third_party/lwip/test/unit/api/
Dtest_sockets.c778 struct tcp_pcb *pcb = sact_conn->pcb.tcp; in START_TEST()
/third_party/lwip/
DCHANGELOG3377 and has to be explicitly disabled with 'tcp_pcb->flags |= TF_NODELAY'
3527 * tcp_out.c: Added check to prevent tcp_pcb->snd_queuelen from overflowing.