| /freebsd/sys/netinet/ |
| H A D | tcp_var.h | 308 struct tcpcb { struct
311 #define t_zero_size (sizeof(struct tcpcb) - \ argument
312 offsetof(struct tcpcb, t_start_zero))
321 TAILQ_ENTRY(tcpcb) t_hpts; /* linkage to HPTS ring */ argument
614 int (*tfb_tcp_output)(struct tcpcb *);
615 void (*tfb_tcp_do_segment)(struct tcpcb *, struct mbuf *,
617 int (*tfb_do_segment_nounlock)(struct tcpcb *, struct mbuf *,
619 int (*tfb_do_queued_segments)(struct tcpcb *, int);
620 int (*tfb_tcp_ctloutput)(struct tcpcb *, struct sockopt *);
622 int (*tfb_tcp_fb_init)(struct tcpcb *, void **);
[all …]
|
| H A D | toecore.h | 39 struct tcpcb;
59 int (*tod_listen_start)(struct toedev *, struct tcpcb *);
60 int (*tod_listen_stop)(struct toedev *, struct tcpcb *);
66 void (*tod_input)(struct toedev *, struct tcpcb *, struct mbuf *);
73 void (*tod_rcvd)(struct toedev *, struct tcpcb *);
79 int (*tod_output)(struct toedev *, struct tcpcb *);
82 int (*tod_send_rst)(struct toedev *, struct tcpcb *);
85 int (*tod_send_fin)(struct toedev *, struct tcpcb *);
88 void (*tod_pcb_detach)(struct toedev *, struct tcpcb *);
108 void (*tod_ctloutput)(struct toedev *, struct tcpcb *, int, int);
[all …]
|
| H A D | tcp_offload.h | 41 struct tcpcb;
44 void tcp_offload_listen_start(struct tcpcb *);
45 void tcp_offload_listen_stop(struct tcpcb *);
46 void tcp_offload_input(struct tcpcb *, struct mbuf *);
47 int tcp_offload_output(struct tcpcb *);
48 void tcp_offload_rcvd(struct tcpcb *);
49 void tcp_offload_ctloutput(struct tcpcb *, int, int);
50 void tcp_offload_tcp_info(const struct tcpcb *, struct tcp_info *);
51 int tcp_offload_alloc_tls_session(struct tcpcb *, struct ktls_session *, int);
52 void tcp_offload_detach(struct tcpcb *);
[all …]
|
| H A D | tcp_log_buf.h | 393 tcp_bblogging_on(struct tcpcb *tp) in tcp_bblogging_on()
408 tcp_bblogging_point_on(struct tcpcb *tp, uint8_t bbpoint) in tcp_bblogging_point_on()
421 tcp_set_bblog_state(struct tcpcb *tp, uint8_t ls, uint8_t bbpoint) in tcp_set_bblog_state()
441 tcp_get_bblog_state(struct tcpcb *tp) in tcp_get_bblog_state()
447 tcp_trace_point(struct tcpcb *tp, int num) in tcp_trace_point()
536 struct tcpcb;
562 void tcp_log_drain(struct tcpcb *tp);
563 int tcp_log_dump_tp_logbuf(struct tcpcb *tp, char *reason, int how, bool force);
564 void tcp_log_dump_tp_bucket_logbufs(struct tcpcb *tp, char *reason);
565 struct tcp_log_buffer *tcp_log_event(struct tcpcb *tp, struct tcphdr *th, struct sockbuf *rxbuf,
[all …]
|
| H A D | tcp_ecn.h | 43 void tcp_ecn_input_syn_sent(struct tcpcb *, uint16_t, int);
44 void tcp_ecn_input_parallel_syn(struct tcpcb *, uint16_t, int);
45 int tcp_ecn_input_segment(struct tcpcb *, uint16_t, int, int, int);
46 uint16_t tcp_ecn_output_syn_sent(struct tcpcb *);
47 int tcp_ecn_output_established(struct tcpcb *, uint16_t *, int, bool);
48 void tcp_ecn_syncache_socket(struct tcpcb *, struct syncache *);
|
| H A D | tcp_ratelimit.h | 97 struct tcpcb;
118 tcp_set_pacing_rate(struct tcpcb *tp, struct ifnet *ifp,
123 struct tcpcb *tp, struct ifnet *ifp,
127 struct tcpcb *tp);
130 tcp_get_pacing_burst_size_w_divisor(struct tcpcb *tp, uint64_t bw, uint32_t segsiz, int can_use_1ms…
141 tcp_set_pacing_rate(struct tcpcb *tp, struct ifnet *ifp, in tcp_set_pacing_rate()
151 struct tcpcb *tp, struct ifnet *ifp, in tcp_chg_pacing_rate()
161 struct tcpcb *tp) in tcp_rel_pacing_rate()
179 tcp_get_pacing_burst_size_w_divisor(struct tcpcb *tp, uint64_t bw, uint32_t segsiz, int can_use_1ms… in tcp_get_pacing_burst_size_w_divisor()
241 tcp_get_pacing_burst_size(struct tcpcb *tp, uint64_t bw, uint32_t segsiz, int can_use_1mss, in tcp_get_pacing_burst_size()
|
| H A D | tcp_fastopen.h | 82 struct tcpcb;
90 void tcp_fastopen_connect(struct tcpcb *);
91 void tcp_fastopen_disable_path(struct tcpcb *);
92 void tcp_fastopen_update_cache(struct tcpcb *, uint16_t, uint8_t,
124 tcp_fastopen_connect(struct tcpcb *_tp) in tcp_fastopen_connect()
129 tcp_fastopen_disable_path(struct tcpcb *_tp) in tcp_fastopen_disable_path()
134 tcp_fastopen_update_cache(struct tcpcb *_tp, uint16_t _mss, uint8_t _cookie_len, in tcp_fastopen_update_cache()
|
| H A D | tcp_offload.c | 113 tcp_offload_listen_start(struct tcpcb *tp) in tcp_offload_listen_start()
122 tcp_offload_listen_stop(struct tcpcb *tp) in tcp_offload_listen_stop()
131 tcp_offload_input(struct tcpcb *tp, struct mbuf *m) in tcp_offload_input()
142 tcp_offload_output(struct tcpcb *tp) in tcp_offload_output()
167 tcp_offload_rcvd(struct tcpcb *tp) in tcp_offload_rcvd()
178 tcp_offload_ctloutput(struct tcpcb *tp, int sopt_dir, int sopt_name) in tcp_offload_ctloutput()
189 tcp_offload_tcp_info(const struct tcpcb *tp, struct tcp_info *ti) in tcp_offload_tcp_info()
200 tcp_offload_alloc_tls_session(struct tcpcb *tp, struct ktls_session *tls, in tcp_offload_alloc_tls_session()
212 tcp_offload_detach(struct tcpcb *tp) in tcp_offload_detach()
223 tcp_offload_pmtu_update(struct tcpcb *tp, tcp_seq seq, int mtu) in tcp_offload_pmtu_update()
|
| H A D | toecore.c | 86 toedev_listen_start(struct toedev *tod __unused, struct tcpcb *tp __unused) in toedev_listen_start()
93 toedev_listen_stop(struct toedev *tod __unused, struct tcpcb *tp __unused) in toedev_listen_stop()
100 toedev_input(struct toedev *tod __unused, struct tcpcb *tp __unused, in toedev_input()
109 toedev_rcvd(struct toedev *tod __unused, struct tcpcb *tp __unused) in toedev_rcvd()
116 toedev_output(struct toedev *tod __unused, struct tcpcb *tp __unused) in toedev_output()
123 toedev_pcb_detach(struct toedev *tod __unused, struct tcpcb *tp __unused) in toedev_pcb_detach()
178 toedev_ctloutput(struct toedev *tod __unused, struct tcpcb *tp __unused, in toedev_ctloutput()
186 toedev_tcp_info(struct toedev *tod __unused, const struct tcpcb *tp __unused, in toedev_tcp_info()
194 toedev_alloc_tls_session(struct toedev *tod __unused, struct tcpcb *tp __unused, in toedev_alloc_tls_session()
202 toedev_pmtu_update(struct toedev *tod __unused, struct tcpcb *tp __unused, in toedev_pmtu_update()
[all …]
|
| H A D | tcp_hpts.h | 113 void tcp_hpts_init(struct tcpcb *);
114 void tcp_hpts_remove(struct tcpcb *);
116 tcp_in_hpts(struct tcpcb *tp) in tcp_in_hpts()
147 uint32_t tcp_hpts_insert_diag(struct tcpcb *tp, uint32_t slot, int32_t line,
152 void __tcp_set_hpts(struct tcpcb *tp, int32_t line);
|
| H A D | tcp_timer.c | 270 typedef bool tcp_timer_t(struct tcpcb *);
292 tcp_output_locked(struct tcpcb *tp) in tcp_output_locked()
309 tcp_timer_delack(struct tcpcb *tp) in tcp_timer_delack()
331 tcp_timer_2msl(struct tcpcb *tp) in tcp_timer_2msl()
380 tcp_timer_keep(struct tcpcb *tp) in tcp_timer_keep()
465 tcp_maxunacktime_check(struct tcpcb *tp) in tcp_maxunacktime_check()
486 tcp_timer_persist(struct tcpcb *tp) in tcp_timer_persist()
551 tcp_timer_rexmt(struct tcpcb *tp) in tcp_timer_rexmt()
825 tcp_bblog_timer(struct tcpcb *tp, tt_which which, tt_what what, uint32_t ticks) in tcp_bblog_timer()
854 tcp_timer_next(struct tcpcb *tp, sbintime_t *precision) in tcp_timer_next()
[all …]
|
| H A D | tcp_usrreq.c | 117 static int tcp_connect(struct tcpcb *, struct sockaddr_in *,
121 static int tcp6_connect(struct tcpcb *, struct sockaddr_in6 *,
124 static void tcp_disconnect(struct tcpcb *);
125 static void tcp_usrclosed(struct tcpcb *);
126 static void tcp_fill_info(const struct tcpcb *, struct tcp_info *);
128 static int tcp_pru_options_support(struct tcpcb *tp, int flags);
131 tcp_bblog_pru(struct tcpcb *tp, uint32_t pru, int error) in tcp_bblog_pru()
159 struct tcpcb *tp = NULL; in tcp_usr_attach()
200 struct tcpcb *tp; in tcp_usr_detach()
227 struct tcpcb *tp; in tcp_usr_bind()
[all …]
|
| H A D | tcp_sack.c | 161 tcp_dsack_block_exists(struct tcpcb *tp) in tcp_dsack_block_exists()
176 tcp_update_dsack_list(struct tcpcb *tp, tcp_seq rcv_start, tcp_seq rcv_end) in tcp_update_dsack_list()
272 tcp_update_sack_list(struct tcpcb *tp, tcp_seq rcv_start, tcp_seq rcv_end) in tcp_update_sack_list()
409 tcp_clean_dsack_blocks(struct tcpcb *tp) in tcp_clean_dsack_blocks()
451 tcp_clean_sackreport(struct tcpcb *tp) in tcp_clean_sackreport()
465 tcp_sackhole_alloc(struct tcpcb *tp, tcp_seq start, tcp_seq end) in tcp_sackhole_alloc()
493 tcp_sackhole_free(struct tcpcb *tp, struct sackhole *hole) in tcp_sackhole_free()
509 tcp_sackhole_insert(struct tcpcb *tp, tcp_seq start, tcp_seq end, in tcp_sackhole_insert()
536 tcp_sackhole_remove(struct tcpcb *tp, struct sackhole *hole) in tcp_sackhole_remove()
559 tcp_sack_doack(struct tcpcb *tp, struct tcpopt *to, tcp_seq th_ack) in tcp_sack_doack()
[all …]
|
| H A D | tcp_ecn.c | 120 tcp_ecn_input_syn_sent(struct tcpcb *tp, uint16_t thflags, int iptos) in tcp_ecn_input_syn_sent()
226 tcp_ecn_input_parallel_syn(struct tcpcb *tp, uint16_t thflags, int iptos) in tcp_ecn_input_parallel_syn()
294 tcp_ecn_input_segment(struct tcpcb *tp, uint16_t thflags, int tlen, int pkts, int iptos) in tcp_ecn_input_segment()
374 tcp_ecn_output_syn_sent(struct tcpcb *tp) in tcp_ecn_output_syn_sent()
404 tcp_ecn_output_established(struct tcpcb *tp, uint16_t *thflags, int len, bool rxmit) in tcp_ecn_output_established()
463 tcp_ecn_syncache_socket(struct tcpcb *tp, struct syncache *sc) in tcp_ecn_syncache_socket()
|
| H A D | tcp_subr.c | 337 static int tcp_default_fb_init(struct tcpcb *tp, void **ptr);
338 static void tcp_default_fb_fini(struct tcpcb *tp, int tcb_is_purged);
339 static int tcp_default_handoff_ok(struct tcpcb *tp);
346 static void tcp_default_switch_failed(struct tcpcb *tp);
368 tcp_record_dsack(struct tcpcb *tp, tcp_seq start, tcp_seq end, int tlp) in tcp_record_dsack()
496 tcp_switch_back_to_default(struct tcpcb *tp) in tcp_switch_back_to_default()
1013 tcp_default_handoff_ok(struct tcpcb *tp) in tcp_default_handoff_ok()
1029 tcp_default_fb_init(struct tcpcb *tp, void **ptr) in tcp_default_fb_init()
1113 tcp_default_fb_fini(struct tcpcb *tp, int tcb_is_purged) in tcp_default_fb_fini()
1134 INPCBSTORAGE_DEFINE(tcpcbstor, tcpcb, "tcpinp", "tcp_inpcb", "tcp", "tcphash");
[all …]
|
| H A D | tcp_log_buf.c | 306 struct tcpcb *tln_tp;
471 tcp_log_remove_id_node(struct inpcb *inp, struct tcpcb *tp, in tcp_log_remove_id_node()
521 tcp_log_grow_tlb(char *tlb_id, struct tcpcb *tp) in tcp_log_grow_tlb()
540 tcp_log_apply_ratio(struct tcpcb *tp, int ratio) in tcp_log_apply_ratio()
603 tcp_log_set_tag(struct tcpcb *tp, char *tag) in tcp_log_set_tag()
642 tcp_log_set_id(struct tcpcb *tp, char *id) in tcp_log_set_id()
1025 tcp_log_get_id(struct tcpcb *tp, char *buf) in tcp_log_get_id()
1049 tcp_log_get_tag(struct tcpcb *tp, char *buf) in tcp_log_get_tag()
1095 tcp_log_get_id_cnt(struct tcpcb *tp) in tcp_log_get_id_cnt()
1174 tcp_log_remove_log_cleanup(struct tcpcb *tp, struct tcp_log_mem *log_entry) in tcp_log_remove_log_cleanup()
[all …]
|
| H A D | tcp_lro_hpts.c | 145 tcp_lro_check_wake_status(struct tcpcb *tp) in tcp_lro_check_wake_status()
155 tcp_lro_log(struct tcpcb *tp, const struct lro_ctrl *lc, in tcp_lro_log()
207 struct tcpcb *tp, int32_t *new_m, bool can_append_old_cmp) in tcp_lro_get_last_if_ackcmp()
253 do_bpf_strip_and_compress(struct tcpcb *tp, struct lro_ctrl *lc, in do_bpf_strip_and_compress()
465 tcp_queue_pkts(struct tcpcb *tp, struct lro_entry *le) in tcp_queue_pkts()
477 static struct tcpcb *
516 struct tcpcb *tp; in _tcp_lro_flush_tcphpts()
|
| H A D | tcp_hpts.c | 202 TAILQ_HEAD(, tcpcb) head;
433 tcp_hpts_log(struct tcp_hpts_entry *hpts, struct tcpcb *tp, struct timeval *tv, in tcp_hpts_log()
495 tcp_hpts_insert_internal(struct tcpcb *tp, struct tcp_hpts_entry *hpts) in tcp_hpts_insert_internal()
522 tcp_hpts_lock(struct tcpcb *tp) in tcp_hpts_lock()
535 tcp_hpts_release(struct tcpcb *tp) in tcp_hpts_release()
555 tcp_hpts_init(struct tcpcb *tp) in tcp_hpts_init()
571 tcp_hpts_remove(struct tcpcb *tp) in tcp_hpts_remove()
595 struct tcpcb *tmp; in tcp_hpts_remove()
783 check_if_slot_would_be_wrong(struct tcp_hpts_entry *hpts, struct tcpcb *tp, in check_if_slot_would_be_wrong()
816 tcp_hpts_insert_diag(struct tcpcb *tp, uint32_t slot, int32_t line, struct hpts_diag *diag) in tcp_hpts_insert_diag()
[all …]
|
| H A D | tcp_reass.c | 195 tcp_log_reassm(struct tcpcb *tp, struct tseg_qent *q, struct tseg_qent *p, in tcp_log_reassm()
233 tcp_reass_log_dump(struct tcpcb *tp) in tcp_reass_log_dump()
245 tcp_reass_log_new_in(struct tcpcb *tp, tcp_seq seq, int len, struct mbuf *m, in tcp_reass_log_new_in()
295 tcp_reass_flush(struct tcpcb *tp) in tcp_reass_flush()
314 tcp_reass_append(struct tcpcb *tp, struct tseg_qent *last, in tcp_reass_append()
340 tcp_reass_prepend(struct tcpcb *tp, struct tseg_qent *first, struct mbuf *m, struct tcphdr *th, in tcp_reass_prepend()
376 tcp_reass_replace(struct tcpcb *tp, struct tseg_qent *q, struct mbuf *m, in tcp_reass_replace()
411 tcp_reass_merge_into(struct tcpcb *tp, struct tseg_qent *ent, in tcp_reass_merge_into()
436 tcp_reass_merge_forward(struct tcpcb *tp, struct tseg_qent *ent) in tcp_reass_merge_forward()
516 tcp_reass(struct tcpcb *tp, struct tcphdr *th, tcp_seq *seq_start, in tcp_reass()
|
| /freebsd/sys/netinet/tcp_stacks/ |
| H A D | rack_bbr_common.h | 88 int ctf_do_queued_segments(struct tcpcb *tp, int have_pkt);
89 uint32_t ctf_outstanding(struct tcpcb *tp);
90 uint32_t ctf_flight_size(struct tcpcb *tp, uint32_t rc_sacked);
93 struct tcpcb *tp, int32_t *tlenp,
95 void ctf_ack_war_checks(struct tcpcb *tp);
98 ctf_do_dropafterack(struct mbuf *m, struct tcpcb *tp,
103 ctf_do_dropwithreset(struct mbuf *m, struct tcpcb *tp,
106 ctf_do_drop(struct mbuf *m, struct tcpcb *tp);
110 struct socket *so, struct tcpcb *tp);
114 struct tcpcb *tp, uint8_t iptos, int32_t * ret_val);
[all …]
|
| H A D | rack_bbr_common.c | 325 ctf_process_inbound_raw(struct tcpcb *tp, struct mbuf *m, int has_pkt) in ctf_process_inbound_raw()
470 ctf_do_queued_segments(struct tcpcb *tp, int have_pkt) in ctf_do_queued_segments()
486 ctf_outstanding(struct tcpcb *tp) in ctf_outstanding()
499 ctf_flight_size(struct tcpcb *tp, uint32_t rc_sacked) in ctf_flight_size()
509 ctf_do_dropwithreset(struct mbuf *m, struct tcpcb *tp, struct tcphdr *th, in ctf_do_dropwithreset()
520 ctf_ack_war_checks(struct tcpcb *tp) in ctf_ack_war_checks()
548 struct tcpcb *tp, int32_t *tlenp, in ctf_drop_checks()
655 ctf_do_dropafterack(struct mbuf *m, struct tcpcb *tp, struct tcphdr *th, int32_t thflags, int32_t t… in ctf_do_dropafterack()
685 ctf_do_drop(struct mbuf *m, struct tcpcb *tp) in ctf_do_drop()
699 struct tcpcb *tp) in ctf_process_rst()
[all …]
|
| /freebsd/sys/dev/cxgbe/tom/ |
| H A D | t4_tom.h | 482 void t4_pcb_detach(struct toedev *, struct tcpcb *);
494 int t4_listen_start(struct toedev *, struct tcpcb *);
495 int t4_listen_stop(struct toedev *, struct tcpcb *);
516 void send_flowc_wr(struct toepcb *, struct tcpcb *);
521 void t4_rcvd(struct toedev *, struct tcpcb *);
522 void t4_rcvd_locked(struct toedev *, struct tcpcb *);
523 int t4_tod_output(struct toedev *, struct tcpcb *);
524 int t4_send_fin(struct toedev *, struct tcpcb *);
525 int t4_send_rst(struct toedev *, struct tcpcb *);
558 void handle_ddp_close(struct toepcb *, struct tcpcb *, uint32_t);
|
| /freebsd/sbin/ipf/ipsend/ |
| H A D | sock.c | 149 struct tcpcb *
152 struct tcpcb *t; in find_tcp()
220 t = (struct tcpcb *)calloc(1, sizeof(*t)); in find_tcp()
227 return (struct tcpcb *)i->inp_ppcb; in find_tcp()
247 struct tcpcb *t, tcb; in do_socket()
|
| /freebsd/sys/netinet/cc/ |
| H A D | cc.h | 95 struct tcpcb *tp; /* Pointer to tcpcb */
244 void cc_attach(struct tcpcb *, struct cc_algo *);
246 void cc_detach(struct tcpcb *);
|
| /freebsd/usr.bin/systat/ |
| H A D | netstat.c | 174 struct tcpcb tcpcb; in fetchnetstat_kvm() local
198 KREAD(inpcb, &tcpcb, istcp ? sizeof(tcpcb) : sizeof(inpcb)); in fetchnetstat_kvm()
199 inpcb = (struct inpcb *)&tcpcb; in fetchnetstat_kvm()
219 enter_kvm(inpcb, &sockb, tcpcb.t_state, "tcp"); in fetchnetstat_kvm()
|