Home
last modified time | relevance | path

Searched refs:pcb (Results 1 – 25 of 97) sorted by relevance

1234

/lib/lwip/lwip/src/core/
A Dtcp.c257 for (pcb = list; pcb != NULL; pcb = pcb->next) { in tcp_remove_listener()
360 tcp_rst(pcb, pcb->snd_nxt, pcb->rcv_nxt, &pcb->local_ip, &pcb->remote_ip, in tcp_close_shutdown()
1402 tcp_rst(pcb, pcb->snd_nxt, pcb->rcv_nxt, &pcb->local_ip, &pcb->remote_ip, in tcp_slowtmr()
1534 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_txnow()
1734 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_kill_prio()
1767 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_kill_state()
1796 for (pcb = tcp_tw_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_kill_timewait()
2501 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_debug_print_pcbs()
2515 for (pcb = tcp_tw_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_debug_print_pcbs()
2530 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) { in tcp_pcbs_sane()
[all …]
A Dtcp_in.c250 for (pcb = tcp_active_pcbs; pcb != NULL; pcb = pcb->next) {
286 for (pcb = tcp_tw_pcbs; pcb != NULL; pcb = pcb->next) {
447 TCP_EVENT_ERR(pcb->state, pcb->errf, pcb->callback_arg, ERR_RST);
611 TCP_EVENT_ERR(pcb->state, pcb->errf, pcb->callback_arg, ERR_CLSD);
880 pcb->mss = tcp_eff_send_mss(pcb->mss, &pcb->local_ip, &pcb->remote_ip);
1243 pcb->cwnd = pcb->ssthresh;
1251 pcb->rto = (s16_t)((pcb->sa >> 3) + pcb->sv);
1290 pcb->unacked = tcp_free_acked_segments(pcb, pcb->unacked, "unacked", pcb->unsent);
1297 pcb->unsent = tcp_free_acked_segments(pcb, pcb->unsent, "unsent", pcb->unacked);
1360 pcb->sa = (s16_t)(pcb->sa + m);
[all …]
A Draw.c163 pcb = raw_pcbs; in raw_input()
178 eaten = pcb->recv(pcb->recv_arg, pcb, p, ip_current_src_addr()); in raw_input()
199 prev = pcb; in raw_input()
200 pcb = pcb->next; in raw_input()
313 ip_addr_set_any(IP_IS_V6_VAL(pcb->remote_ip), &pcb->remote_ip); in raw_disconnect()
338 pcb->recv = recv; in raw_recv()
523 ttl = pcb->ttl; in raw_sendto_if_src()
549 return raw_sendto(pcb, p, &pcb->remote_ip); in raw_send()
615 raw_pcbs = pcb; in raw_new()
617 return pcb; in raw_new()
[all …]
A Dtcp_out.c1286 netif = tcp_route(pcb, &pcb->local_ip, &pcb->remote_ip); in tcp_output()
1487 pcb->rcv_ann_right_edge = pcb->rcv_nxt + pcb->rcv_ann_wnd; in tcp_output_segment()
1504 pcb->ts_lastacksent = pcb->rcv_nxt; in tcp_output_segment()
1603 err = ip_output_if(seg->p, &pcb->local_ip, &pcb->remote_ip, pcb->ttl, in tcp_output_segment()
1660 pcb->unsent = pcb->unacked; in tcp_rexmit_rto_prepare()
1793 pcb->ssthresh = LWIP_MIN(pcb->cwnd, pcb->snd_wnd) / 2; in tcp_rexmit_fast()
1801 pcb->ssthresh = 2 * pcb->mss; in tcp_rexmit_fast()
1804 pcb->cwnd = pcb->ssthresh + 3 * pcb->mss; in tcp_rexmit_fast()
1861 pcb->rcv_ann_right_edge = pcb->rcv_nxt + pcb->rcv_ann_wnd; in tcp_output_alloc_header()
2111 pcb->ts_lastacksent = pcb->rcv_nxt; in tcp_send_empty_ack()
[all …]
A Dudp.c110 for (pcb = udp_pcbs; pcb != NULL; pcb = pcb->next) { in udp_new_port()
246 pcb = NULL; in udp_input()
253 for (pcb = udp_pcbs; pcb != NULL; pcb = pcb->next) { in udp_input()
306 prev = pcb; in udp_input()
404 pcb->recv(pcb->recv_arg, pcb, p, ip_current_src_addr(), src); in udp_input()
477 return udp_sendto(pcb, p, &pcb->remote_ip, pcb->remote_port); in udp_send()
496 return udp_sendto_chksum(pcb, p, &pcb->remote_ip, pcb->remote_port, in udp_send_chksum()
748 err = udp_bind(pcb, &pcb->local_ip, pcb->local_port); in udp_sendto_if_src_chksum()
1085 err_t err = udp_bind(pcb, &pcb->local_ip, pcb->local_port); in udp_connect()
1243 return pcb; in udp_new()
[all …]
A Daltcp_tcp.c262 struct tcp_pcb *pcb; in altcp_tcp_bind() local
274 struct tcp_pcb *pcb; in altcp_tcp_connect() local
287 struct tcp_pcb *pcb; in altcp_tcp_listen() local
309 if (pcb) { in altcp_tcp_abort()
310 tcp_abort(pcb); in altcp_tcp_abort()
318 struct tcp_pcb *pcb; in altcp_tcp_close() local
324 if (pcb) { in altcp_tcp_close()
333 tcp_poll(pcb, oldpoll, pcb->pollinterval); in altcp_tcp_close()
505 if (pcb) { in altcp_tcp_get_ip()
522 if (pcb) { in altcp_tcp_get_port()
[all …]
/lib/lwip/lwip/src/netif/ppp/
A Dppp.c260 notify_phase_cb(pcb, pcb->phase, pcb->ctx_cb); in ppp_set_notify_phase_callback()
316 pcb->link_cb->listen(pcb, pcb->link_ctx_cb); in ppp_listen()
349 pcb->link_status_cb(pcb, pcb->err_code, pcb->ctx_cb); in ppp_close()
408 err = pcb->link_cb->free(pcb, pcb->link_ctx_cb); in ppp_free()
465 pcb->link_cb->connect(pcb, pcb->link_ctx_cb); in ppp_do_connect()
762 pcb->link_status_cb(pcb, pcb->err_code, pcb->ctx_cb); in ppp_link_failed()
772 pcb->link_status_cb(pcb, pcb->err_code, pcb->ctx_cb); in ppp_link_end()
1011 pcb->link_cb->disconnect(pcb, pcb->link_ctx_cb); in ppp_link_terminated()
1029 pcb->notify_phase_cb(pcb, p, pcb->ctx_cb); in new_phase()
1179 pcb->link_status_cb(pcb, pcb->err_code, pcb->ctx_cb); in sifup()
[all …]
A Dchap-new.c125 LWIP_UNUSED_ARG(pcb); in chap_init()
144 chap_timeout(pcb); in chap_lowerup()
185 chap_timeout(pcb); in chap_auth_peer()
247 ppp_write(pcb, p); in chap_timeout()
264 pcb->chap_server.digest->generate_challenge(pcb, p); in chap_generate_challenge()
332 ok = chap_verify_response(pcb, name, pcb->chap_server.name, id, pcb->chap_server.digest,
365 ppp_write(pcb, p);
478 pcb->chap_client.digest->make_response(pcb, outp, id, pcb->chap_client.name, pkt,
494 ppp_write(pcb, p);
510 if (!(*pcb->chap_client.digest->check_success)(pcb, pkt, len, pcb->chap_client.priv))
[all …]
A Dupap.c146 pcb->upap.us_id = 0; in upap_init()
194 TIMEOUT(upap_reqtimeout, pcb, pcb->settings.pap_req_timeout); in upap_authpeer()
207 if (pcb->upap.us_transmits >= pcb->settings.pap_max_transmits) { in upap_timeout()
254 TIMEOUT(upap_reqtimeout, pcb, pcb->settings.pap_req_timeout); in upap_lowerup()
298 upap_lowerdown(pcb); in upap_protrej()
537 pcb->upap.us_userlen + pcb->upap.us_passwdlen; in upap_sauthreq()
553 MEMCPY(outp, pcb->upap.us_user, pcb->upap.us_userlen); in upap_sauthreq()
556 MEMCPY(outp, pcb->upap.us_passwd, pcb->upap.us_passwdlen); in upap_sauthreq()
558 ppp_write(pcb, p); in upap_sauthreq()
560 TIMEOUT(upap_timeout, pcb, pcb->settings.pap_timeout_time); in upap_sauthreq()
[all …]
A Deap.c305 pcb->eap.es_server.ea_peer, pcb->eap.es_server.ea_peerlen); in eap_send_success()
437 pcb->settings.eap_timeout_time = pcb->eap.es_savedtime; in eap_figure_next_state()
658 if (pcb->settings.explicit_remote && pcb->remote_name) { in eap_send_request()
668 MEMCPY(pcb->eap.es_server.ea_peer, pcb->remote_name, len); in eap_send_request()
722 MEMCPY(outp, pcb->eap.es_challenge, pcb->eap.es_challen); in eap_send_request()
849 MEMCPY(outp, pcb->eap.es_challenge, pcb->eap.es_challen); in eap_send_request()
882 pcb->eap.es_savedtime = pcb->settings.eap_timeout_time; in eap_authpeer()
1094 ppp_pcb *pcb = &ppp_pcb_list[pcb->eap.es_unit]; local
1135 ppp_pcb *pcb = &ppp_pcb_list[pcb->eap.es_unit]; local
1446 if (!get_secret(pcb, pcb->eap.es_client.ea_name, in eap_request()
[all …]
A Dccp.c371 f->pcb = pcb; in ccp_init()
488 ppp_pcb *pcb = f->pcb; in ccp_extcode() local
542 ppp_pcb *pcb = f->pcb; in ccp_resetci() local
744 ppp_pcb *pcb = f->pcb; in ccp_cilen() local
769 ppp_pcb *pcb = f->pcb; in ccp_addci() local
836 ppp_pcb *pcb = f->pcb; in ccp_ackci() local
929 ppp_pcb *pcb = f->pcb; in ccp_nakci() local
1022 ppp_pcb *pcb = f->pcb; in ccp_rejci() local
1106 ppp_pcb *pcb = f->pcb; in ccp_reqci() local
1460 ppp_pcb *pcb = f->pcb; in ccp_up() local
[all …]
A Dauth.c601 lcp_lowerup(pcb);
670 lcp_lowerdown(pcb); in link_terminated()
822 upap_authpeer(pcb); in link_established()
831 eap_authwithpeer(pcb, pcb->settings.user); in link_established()
843 upap_authwithpeer(pcb, pcb->settings.user, pcb->settings.passwd); in link_established()
854 network_phase(pcb); in link_established()
1010 if (pcb->settings.user && pcb->settings.passwd) { in auth_check_passwd()
1192 network_phase(pcb); in auth_withpeer_success()
1229 TIMEOUT(connect_time_expired, (void*)pcb, pcb->settings.maxconnect); in np_up()
1245 ++pcb->num_np_up; in np_up()
[all …]
A Dipv6cp.c433 f->pcb = pcb;
510 ppp_pcb *pcb = f->pcb;
530 ppp_pcb *pcb = f->pcb;
550 ppp_pcb *pcb = f->pcb;
598 ppp_pcb *pcb = f->pcb;
672 ppp_pcb *pcb = f->pcb;
807 ppp_pcb *pcb = f->pcb;
888 ppp_pcb *pcb = f->pcb;
1152 ppp_pcb *pcb = f->pcb;
1274 ppp_pcb *pcb = f->pcb;
[all …]
/lib/lwip/lwip/src/include/lwip/
A Dtcp.h137 #define RCV_WND_SCALE(pcb, wnd) (((wnd) >> (pcb)->rcv_scale)) argument
138 #define SND_WND_SCALE(pcb, wnd) (((wnd) << (pcb)->snd_scale)) argument
291 #define LWIP_TCP_SACK_VALID(pcb, idx) ((pcb)->rcv_sacks[idx].left != (pcb)->rcv_sacks[idx].right) argument
423 #define tcp_set_flags(pcb, set_flags) do { (pcb)->flags = (tcpflags_t)((pcb)->flags | … argument
428 #define tcp_mss(pcb) (((pcb)->flags & TF_TIMESTAMP) ? ((pcb)->mss - 12) : (pc… argument
431 #define tcp_mss(pcb) ((pcb)->mss) argument
434 #define tcp_sndbuf(pcb) (TCPWND16((pcb)->snd_buf)) argument
436 #define tcp_sndqueuelen(pcb) ((pcb)->snd_queuelen) argument
438 #define tcp_nagle_disable(pcb) tcp_set_flags(pcb, TF_NODELAY) argument
440 #define tcp_nagle_enable(pcb) tcp_clear_flags(pcb, TF_NODELAY) argument
[all …]
A Dudp.h155 #define udp_flags(pcb) ((pcb)->flags) argument
156 #define udp_setflags(pcb, f) ((pcb)->flags = (f)) argument
158 #define udp_set_flags(pcb, set_flags) do { (pcb)->flags = (u8_t)((pcb)->flags | (set_… argument
159 #define udp_clear_flags(pcb, clr_flags) do { (pcb)->flags = (u8_t)((pcb)->flags & (u8_t)… argument
160 #define udp_is_flag_set(pcb, flag) (((pcb)->flags & (flag)) != 0) argument
172 #define udp_set_multicast_netif_addr(pcb, ip4addr) ip4_addr_copy((pcb)->mcast_ip4, *(ip4addr)) argument
173 #define udp_get_multicast_netif_addr(pcb) (&(pcb)->mcast_ip4) argument
175 #define udp_set_multicast_netif_index(pcb, idx) ((pcb)->mcast_ifindex = (idx)) argument
176 #define udp_get_multicast_netif_index(pcb) ((pcb)->mcast_ifindex) argument
177 #define udp_set_multicast_ttl(pcb, value) ((pcb)->mcast_ttl = (value)) argument
[all …]
A Draw.h106 void raw_remove (struct raw_pcb *pcb);
110 void raw_disconnect (struct raw_pcb *pcb);
118 #define raw_flags(pcb) ((pcb)->flags) argument
119 #define raw_setflags(pcb,f) ((pcb)->flags = (f)) argument
121 #define raw_set_flags(pcb, set_flags) do { (pcb)->flags = (u8_t)((pcb)->flags | (set_… argument
122 #define raw_clear_flags(pcb, clr_flags) do { (pcb)->flags = (u8_t)((pcb)->flags & (u8_t)… argument
123 #define raw_is_flag_set(pcb, flag) (((pcb)->flags & (flag)) != 0) argument
131 #define raw_set_multicast_netif_index(pcb, idx) ((pcb)->mcast_ifindex = (idx)) argument
132 #define raw_get_multicast_netif_index(pcb) ((pcb)->mcast_ifindex) argument
133 #define raw_set_multicast_ttl(pcb, value) ((pcb)->mcast_ttl = (value)) argument
[all …]
/lib/lwip/lwip/test/unit/tcp/
A Dtest_tcp.c472 pcb->cwnd = pcb->snd_wnd; in START_TEST()
657 pcb->ssthresh = pcb->cwnd; in START_TEST()
777 pcb->cwnd = pcb->snd_wnd; in START_TEST()
829 pcb->cwnd = pcb->snd_wnd; in test_tcp_tx_full_window_lost()
976 pcb->cwnd = pcb->snd_wnd; in START_TEST()
1127 EXPECT(pcb->rto_end == pcb->snd_nxt); in START_TEST()
1129 EXPECT(pcb->cwnd == pcb->mss); in START_TEST()
1139 EXPECT(pcb->rto_end == pcb->snd_nxt); in START_TEST()
1155 EXPECT(pcb->rto_end == pcb->snd_nxt); in START_TEST()
1171 EXPECT(TCP_SEQ_GT(pcb->snd_nxt, pcb->rto_end)); in START_TEST()
[all …]
A Dtest_tcp_oos.c157 struct tcp_pcb* pcb; in START_TEST() local
281 tcp_abort(pcb); in START_TEST()
293 struct tcp_pcb* pcb; in START_TEST() local
451 tcp_abort(pcb); in START_TEST()
465 struct tcp_pcb* pcb; in START_TEST() local
539 tcp_abort(pcb); in START_TEST()
552 struct tcp_pcb* pcb; in START_TEST() local
626 tcp_abort(pcb); in START_TEST()
701 tcp_abort(pcb); in START_TEST()
776 tcp_abort(pcb); in START_TEST()
[all …]
A Dtest_tcp_state.c58 pcb = tcp_new(); in create_listening_pcb()
62 if (pcb) { in create_listening_pcb()
174 pcb = tcp_new(); in START_TEST()
248 tcp_abort(pcb); in START_TEST()
472 pcb->local_port, NULL, 0, 12345, pcb->snd_nxt, TCP_RST); in START_TEST()
486 p = tcp_create_segment(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, in START_TEST()
487 pcb->local_port, NULL, 0, pcb->rcv_nxt-10, 54321, TCP_RST); in START_TEST()
494 pcb->local_port, NULL, 0, pcb->rcv_nxt, 54321, TCP_RST); in START_TEST()
520 p = tcp_create_segment(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, in START_TEST()
547 p = tcp_create_segment(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, in START_TEST()
[all …]
A Dtcp_helper.c25 while(pcb != NULL) { in tcp_remove()
26 pcb2 = pcb; in tcp_remove()
27 pcb = pcb->next; in tcp_remove()
133 return tcp_create_segment(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, pcb->local_port, in tcp_create_rx_segment()
145 return tcp_create_segment_wnd(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, pcb->local_port, in tcp_create_rx_segment_wnd()
158 pcb->state = state; in tcp_set_state()
161 pcb->snd_wl2 = iss; in tcp_set_state()
162 pcb->snd_nxt = iss; in tcp_set_state()
163 pcb->lastack = iss; in tcp_set_state()
247 if (pcb != NULL) { in test_tcp_new_counters_pcb()
[all …]
/lib/lwip/lwip/src/include/lwip/priv/
A Dtcp_priv.h163 #define TCP_EVENT_ACCEPT(lpcb,pcb,arg,err,ret) ret = lwip_tcp_event(arg, (pcb),\ argument
165 #define TCP_EVENT_SENT(pcb,space,ret) ret = lwip_tcp_event((pcb)->callback_arg, (pcb),\ argument
167 #define TCP_EVENT_RECV(pcb,p,err,ret) ret = lwip_tcp_event((pcb)->callback_arg, (pcb),\ argument
169 #define TCP_EVENT_CLOSED(pcb,ret) ret = lwip_tcp_event((pcb)->callback_arg, (pcb),\ argument
171 #define TCP_EVENT_CONNECTED(pcb,err,ret) ret = lwip_tcp_event((pcb)->callback_arg, (pcb),\ argument
194 (ret) = (pcb)->sent((pcb)->callback_arg,(pcb),(space)); \
201 (ret) = (pcb)->recv((pcb)->callback_arg,(pcb),(p),(err));\
210 (ret) = (pcb)->recv((pcb)->callback_arg,(pcb),NULL,ERR_OK);\
219 (ret) = (pcb)->connected((pcb)->callback_arg,(pcb),(err)); \
226 (ret) = (pcb)->poll((pcb)->callback_arg,(pcb)); \
[all …]
/lib/lwip/lwip/src/apps/snmp/
A Dsnmp_mib2_tcp.c104 pcb = pcb->next; in tcp_get_value()
210 struct tcp_pcb *pcb; in tcp_ConnTable_get_cell_value() local
247 pcb = pcb->next; in tcp_ConnTable_get_cell_value()
259 struct tcp_pcb *pcb; in tcp_ConnTable_get_next_cell_instance_and_value() local
292 pcb = pcb->next; in tcp_ConnTable_get_next_cell_instance_and_value()
334 struct tcp_pcb *pcb; in tcp_ConnectionTable_get_cell_value() local
365 pcb = pcb->next; in tcp_ConnectionTable_get_cell_value()
376 struct tcp_pcb *pcb; in tcp_ConnectionTable_get_next_cell_instance_and_value() local
406 pcb = pcb->next; in tcp_ConnectionTable_get_next_cell_instance_and_value()
462 pcb = pcb->next; in tcp_ListenerTable_get_cell_value()
[all …]
A Dsnmp_mib2_udp.c122 struct udp_pcb *pcb; in udp_endpointTable_get_cell_value() local
148 pcb = udp_pcbs; in udp_endpointTable_get_cell_value()
157 pcb = pcb->next; in udp_endpointTable_get_cell_value()
167 struct udp_pcb *pcb; in udp_endpointTable_get_next_cell_instance_and_value() local
181 pcb = udp_pcbs; in udp_endpointTable_get_next_cell_instance_and_value()
198 pcb = pcb->next; in udp_endpointTable_get_next_cell_instance_and_value()
251 struct udp_pcb *pcb; in udp_Table_get_cell_value() local
263 pcb = udp_pcbs; in udp_Table_get_cell_value()
271 pcb = pcb->next; in udp_Table_get_cell_value()
289 pcb = udp_pcbs; in udp_Table_get_next_cell_instance_and_value()
[all …]
/lib/lwip/lwip/src/include/netif/ppp/
A Dppp_impl.h286 void (*init) (ppp_pcb *pcb);
290 void (*protrej) (ppp_pcb *pcb);
296 void (*open) (ppp_pcb *pcb);
404 void ppp_start(ppp_pcb *pcb);
410 void ppp_link_end(ppp_pcb *pcb);
445 int sifup(ppp_pcb *pcb);
446 int sifdown (ppp_pcb *pcb);
453 int sif6up(ppp_pcb *pcb);
454 int sif6down (ppp_pcb *pcb);
469 void ccp_reset_comp(ppp_pcb *pcb);
[all …]
/lib/lwip/lwip/contrib/apps/netio/
A Dnetio.c15 tcp_recved(pcb, p->tot_len); in netio_recv()
22 tcp_arg(pcb, NULL); in netio_recv()
23 tcp_sent(pcb, NULL); in netio_recv()
24 tcp_recv(pcb, NULL); in netio_recv()
25 tcp_close(pcb); in netio_recv()
37 if (pcb != NULL) { in netio_accept()
38 tcp_arg(pcb, NULL); in netio_accept()
39 tcp_sent(pcb, NULL); in netio_accept()
40 tcp_recv(pcb, netio_recv); in netio_accept()
48 struct tcp_pcb *pcb; in netio_init() local
[all …]

Completed in 123 milliseconds

1234