| /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
601 int (*tfb_tcp_output)(struct tcpcb *);
602 void (*tfb_tcp_do_segment)(struct tcpcb *, struct mbuf *,
604 int (*tfb_do_segment_nounlock)(struct tcpcb *, struct mbuf *,
606 int (*tfb_do_queued_segments)(struct tcpcb *, int);
607 int (*tfb_tcp_ctloutput)(struct tcpcb *, struct sockopt *);
609 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 | 383 tcp_bblogging_on(struct tcpcb *tp) in tcp_bblogging_on()
398 tcp_bblogging_point_on(struct tcpcb *tp, uint8_t bbpoint) in tcp_bblogging_point_on()
411 tcp_set_bblog_state(struct tcpcb *tp, uint8_t ls, uint8_t bbpoint) in tcp_set_bblog_state()
431 tcp_get_bblog_state(struct tcpcb *tp) in tcp_get_bblog_state()
437 tcp_trace_point(struct tcpcb *tp, int num) in tcp_trace_point()
526 struct tcpcb;
552 void tcp_log_drain(struct tcpcb *tp);
553 int tcp_log_dump_tp_logbuf(struct tcpcb *tp, char *reason, int how, bool force);
554 void tcp_log_dump_tp_bucket_logbufs(struct tcpcb *tp, char *reason);
555 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 | 100 void tcp_hpts_init(struct tcpcb *);
101 void tcp_hpts_remove(struct tcpcb *);
104 tcp_in_hpts(struct tcpcb *tp) in tcp_in_hpts()
135 uint32_t tcp_hpts_insert_diag(struct tcpcb *tp, uint32_t slot, int32_t line,
140 void tcp_set_hpts(struct tcpcb *tp);
|
| 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()
824 tcp_bblog_timer(struct tcpcb *tp, tt_which which, tt_what what, uint32_t ticks) in tcp_bblog_timer()
853 tcp_timer_next(struct tcpcb *tp, sbintime_t *precision) in tcp_timer_next()
[all …]
|
| H A D | tcp_usrreq.c | 114 static int tcp_connect(struct tcpcb *, struct sockaddr_in *,
118 static int tcp6_connect(struct tcpcb *, struct sockaddr_in6 *,
121 static void tcp_disconnect(struct tcpcb *);
122 static void tcp_usrclosed(struct tcpcb *);
123 static void tcp_fill_info(const struct tcpcb *, struct tcp_info *);
125 static int tcp_pru_options_support(struct tcpcb *tp, int flags);
128 tcp_bblog_pru(struct tcpcb *tp, uint32_t pru, int error) in tcp_bblog_pru()
156 struct tcpcb *tp = NULL; in tcp_usr_attach()
197 struct tcpcb *tp; in tcp_usr_detach()
224 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 | 335 static int tcp_default_fb_init(struct tcpcb *tp, void **ptr);
336 static void tcp_default_fb_fini(struct tcpcb *tp, int tcb_is_purged);
337 static int tcp_default_handoff_ok(struct tcpcb *tp);
344 static void tcp_default_switch_failed(struct tcpcb *tp);
366 tcp_record_dsack(struct tcpcb *tp, tcp_seq start, tcp_seq end, int tlp) in tcp_record_dsack()
494 tcp_switch_back_to_default(struct tcpcb *tp) in tcp_switch_back_to_default()
1011 tcp_default_handoff_ok(struct tcpcb *tp) in tcp_default_handoff_ok()
1027 tcp_default_fb_init(struct tcpcb *tp, void **ptr) in tcp_default_fb_init()
1108 tcp_default_fb_fini(struct tcpcb *tp, int tcb_is_purged) in tcp_default_fb_fini()
1129 INPCBSTORAGE_DEFINE(tcpcbstor, tcpcb, "tcpinp", "tcp_inpcb", "tcp", "tcphash");
[all …]
|
| H A D | tcp_log_buf.c | 314 struct tcpcb *tln_tp;
479 tcp_log_remove_id_node(struct inpcb *inp, struct tcpcb *tp, in tcp_log_remove_id_node()
529 tcp_log_grow_tlb(char *tlb_id, struct tcpcb *tp) in tcp_log_grow_tlb()
548 tcp_log_apply_ratio(struct tcpcb *tp, int ratio) in tcp_log_apply_ratio()
611 tcp_log_set_tag(struct tcpcb *tp, char *tag) in tcp_log_set_tag()
650 tcp_log_set_id(struct tcpcb *tp, char *id) in tcp_log_set_id()
1033 tcp_log_get_id(struct tcpcb *tp, char *buf) in tcp_log_get_id()
1057 tcp_log_get_tag(struct tcpcb *tp, char *buf) in tcp_log_get_tag()
1103 tcp_log_get_id_cnt(struct tcpcb *tp) in tcp_log_get_id_cnt()
1182 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_timewait.c | 115 tcp_eff_msl(struct tcpcb *tp) in tcp_eff_msl()
147 tcp_twstart(struct tcpcb *tp) in tcp_twstart()
199 struct tcpcb *tp = intotcpcb(inp); in tcp_twcheck()
|
| H A D | tcp_hpts.c | 244 TAILQ_HEAD(, tcpcb) head;
474 tcp_hpts_log(struct tcp_hpts_entry *hpts, struct tcpcb *tp, struct timeval *tv, in tcp_hpts_log()
538 tcp_hpts_insert_internal(struct tcpcb *tp, struct tcp_hpts_entry *hpts) in tcp_hpts_insert_internal()
565 tcp_hpts_lock(struct tcpcb *tp) in tcp_hpts_lock()
578 tcp_hpts_release(struct tcpcb *tp) in tcp_hpts_release()
598 tcp_hpts_init(struct tcpcb *tp) in tcp_hpts_init()
614 tcp_hpts_remove(struct tcpcb *tp) in tcp_hpts_remove()
638 struct tcpcb *tmp; in tcp_hpts_remove()
826 check_if_slot_would_be_wrong(struct tcp_hpts_entry *hpts, struct tcpcb *tp, in check_if_slot_would_be_wrong()
859 tcp_hpts_insert_diag(struct tcpcb *tp, uint32_t slot, int32_t line, struct hpts_diag *diag) in tcp_hpts_insert_diag()
[all …]
|
| /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 | 323 ctf_process_inbound_raw(struct tcpcb *tp, struct mbuf *m, int has_pkt) in ctf_process_inbound_raw()
468 ctf_do_queued_segments(struct tcpcb *tp, int have_pkt) in ctf_do_queued_segments()
484 ctf_outstanding(struct tcpcb *tp) in ctf_outstanding()
497 ctf_flight_size(struct tcpcb *tp, uint32_t rc_sacked) in ctf_flight_size()
507 ctf_do_dropwithreset(struct mbuf *m, struct tcpcb *tp, struct tcphdr *th, in ctf_do_dropwithreset()
516 ctf_ack_war_checks(struct tcpcb *tp) in ctf_ack_war_checks()
544 struct tcpcb *tp, int32_t *tlenp, in ctf_drop_checks()
651 ctf_do_dropafterack(struct mbuf *m, struct tcpcb *tp, struct tcphdr *th, int32_t thflags, int32_t t… in ctf_do_dropafterack()
681 ctf_do_drop(struct mbuf *m, struct tcpcb *tp) in ctf_do_drop()
695 struct tcpcb *tp) in ctf_process_rst()
[all …]
|
| /freebsd/tools/tools/kgdb/ |
| H A D | tcplog.py | 84 def dump_tcpcb(self, tcpcb): argument
85 if tcpcb['t_lognum'] == 0:
86 print("processing {}\t{}\n\tno logs".format(tcpcb.type, tcpcb))
89 print("processing {}\t{}".format(tcpcb.type, tcpcb))
92 tcpcb['_t_logstate'], tcpcb['_t_logpoint'], tcpcb['t_lognum'], tcpcb['t_logsn']))
94 eaddr = (tcpcb['t_logs']['stqh_first'])
101 filename = "{}_tcp_log.bin".format(tcpcb)
104 f.write(self.format_header(tcpcb, eaddr, len(log_buf)))
110 def format_header(self, tcpcb, eaddr, datalen): argument
118 inp = tcpcb.cast(gdb.lookup_type("struct inpcb").pointer())
[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 | 148 struct tcpcb *
151 struct tcpcb *t; in find_tcp()
219 t = (struct tcpcb *)calloc(1, sizeof(*t)); in find_tcp()
226 return (struct tcpcb *)i->inp_ppcb; in find_tcp()
246 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 *);
|