/kernel/linux/linux-5.10/net/ipv4/ |
H A D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument 26 acked = tcp_slow_start(tp, acked); in tcp_scalable_cong_avoid() 27 if (!acked) in tcp_scalable_cong_avoid() 31 acked); in tcp_scalable_cong_avoid()
|
H A D | tcp_veno.c | 119 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument 125 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid() 138 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid() 157 acked = tcp_slow_start(tp, acked); in tcp_veno_cong_avoid() 158 if (!acked) in tcp_veno_cong_avoid() 167 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_veno_cong_avoid() 181 tp->snd_cwnd_cnt += acked; in tcp_veno_cong_avoid()
|
H A D | tcp_yeah.c | 58 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument 67 acked = tcp_slow_start(tp, acked); in tcp_yeah_cong_avoid() 68 if (!acked) in tcp_yeah_cong_avoid() 75 acked); in tcp_yeah_cong_avoid() 78 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_yeah_cong_avoid()
|
H A D | tcp_cong.c | 390 * something better;) a packet is only considered (s)acked in its entirety to 396 u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument 398 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start() 400 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start() 403 return acked; in tcp_slow_start() 410 void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument 418 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai() 436 void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument 445 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid() [all...] |
H A D | tcp_bic.c | 140 static void bictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in bictcp_cong_avoid() argument 149 acked = tcp_slow_start(tp, acked); in bictcp_cong_avoid() 150 if (!acked) in bictcp_cong_avoid() 154 tcp_cong_avoid_ai(tp, ca->cnt, acked); in bictcp_cong_avoid()
|
H A D | tcp_illinois.c | 52 u16 acked; /* # packets acked by current ACK */ member 78 ca->acked = 0; in tcp_illinois_init() 91 ca->acked = sample->pkts_acked; in tcp_illinois_acked() 260 static void tcp_illinois_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_illinois_cong_avoid() argument 274 tcp_slow_start(tp, acked); in tcp_illinois_cong_avoid() 280 tp->snd_cwnd_cnt += ca->acked; in tcp_illinois_cong_avoid() 281 ca->acked = 1; in tcp_illinois_cong_avoid()
|
H A D | tcp_cubic.c | 221 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked) in bictcp_update() argument 226 ca->ack_cnt += acked; /* count the number of ACKed packets */ in bictcp_update() 244 ca->ack_cnt = acked; /* start counting */ in bictcp_update() 331 static void bictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in bictcp_cong_avoid() argument 340 acked = tcp_slow_start(tp, acked); in bictcp_cong_avoid() 341 if (!acked) in bictcp_cong_avoid() 344 bictcp_update(ca, tp->snd_cwnd, acked); in bictcp_cong_avoid() 345 tcp_cong_avoid_ai(tp, ca->cnt, acked); in bictcp_cong_avoid()
|
H A D | tcp_vegas.c | 165 static void tcp_vegas_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_vegas_cong_avoid() argument 171 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid() 196 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid() 246 tcp_slow_start(tp, acked); in tcp_vegas_cong_avoid() 286 tcp_slow_start(tp, acked); in tcp_vegas_cong_avoid()
|
H A D | tcp_nv.c | 114 * used to determine bytes acked since last 181 static void tcpnv_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcpnv_cong_avoid() argument 195 acked = tcp_slow_start(tp, acked); in tcpnv_cong_avoid() 196 if (!acked) in tcpnv_cong_avoid() 202 tcp_cong_avoid_ai(tp, cnt, acked); in tcpnv_cong_avoid() 205 tcp_cong_avoid_ai(tp, cnt, acked); in tcpnv_cong_avoid()
|
/kernel/linux/linux-6.6/net/ipv4/ |
H A D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument 26 acked = tcp_slow_start(tp, acked); in tcp_scalable_cong_avoid() 27 if (!acked) in tcp_scalable_cong_avoid() 31 acked); in tcp_scalable_cong_avoid()
|
H A D | tcp_veno.c | 119 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument 125 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid() 138 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid() 157 acked = tcp_slow_start(tp, acked); in tcp_veno_cong_avoid() 158 if (!acked) in tcp_veno_cong_avoid() 167 tcp_cong_avoid_ai(tp, tcp_snd_cwnd(tp), acked); in tcp_veno_cong_avoid() 181 tp->snd_cwnd_cnt += acked; in tcp_veno_cong_avoid()
|
H A D | tcp_yeah.c | 58 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument 67 acked = tcp_slow_start(tp, acked); in tcp_yeah_cong_avoid() 68 if (!acked) in tcp_yeah_cong_avoid() 75 acked); in tcp_yeah_cong_avoid() 78 tcp_cong_avoid_ai(tp, tcp_snd_cwnd(tp), acked); in tcp_yeah_cong_avoid()
|
H A D | tcp_cong.c | 452 * something better;) a packet is only considered (s)acked in its entirety to 458 __bpf_kfunc u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument 460 u32 cwnd = min(tcp_snd_cwnd(tp) + acked, tp->snd_ssthresh); in tcp_slow_start() 462 acked -= cwnd - tcp_snd_cwnd(tp); in tcp_slow_start() 465 return acked; in tcp_slow_start() 472 __bpf_kfunc void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument 480 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai() 498 __bpf_kfunc void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument 507 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid() [all...] |
H A D | tcp_bic.c | 140 static void bictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in bictcp_cong_avoid() argument 149 acked = tcp_slow_start(tp, acked); in bictcp_cong_avoid() 150 if (!acked) in bictcp_cong_avoid() 154 tcp_cong_avoid_ai(tp, ca->cnt, acked); in bictcp_cong_avoid()
|
H A D | tcp_illinois.c | 52 u16 acked; /* # packets acked by current ACK */ member 78 ca->acked = 0; in tcp_illinois_init() 91 ca->acked = sample->pkts_acked; in tcp_illinois_acked() 260 static void tcp_illinois_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_illinois_cong_avoid() argument 274 tcp_slow_start(tp, acked); in tcp_illinois_cong_avoid() 280 tp->snd_cwnd_cnt += ca->acked; in tcp_illinois_cong_avoid() 281 ca->acked = 1; in tcp_illinois_cong_avoid()
|
H A D | tcp_cubic.c | 214 static inline void bictcp_update(struct bictcp *ca, u32 cwnd, u32 acked) in bictcp_update() argument 219 ca->ack_cnt += acked; /* count the number of ACKed packets */ in bictcp_update() 237 ca->ack_cnt = acked; /* start counting */ in bictcp_update() 324 __bpf_kfunc static void cubictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in cubictcp_cong_avoid() argument 333 acked = tcp_slow_start(tp, acked); in cubictcp_cong_avoid() 334 if (!acked) in cubictcp_cong_avoid() 337 bictcp_update(ca, tcp_snd_cwnd(tp), acked); in cubictcp_cong_avoid() 338 tcp_cong_avoid_ai(tp, ca->cnt, acked); in cubictcp_cong_avoid()
|
H A D | tcp_vegas.c | 165 static void tcp_vegas_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_vegas_cong_avoid() argument 171 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid() 196 tcp_reno_cong_avoid(sk, ack, acked); in tcp_vegas_cong_avoid() 247 tcp_slow_start(tp, acked); in tcp_vegas_cong_avoid() 287 tcp_slow_start(tp, acked); in tcp_vegas_cong_avoid()
|
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/ |
H A D | bpf_tcp_helpers.h | 70 syn_data_acked:1,/* data in SYN is acked by SYN-ACK */ 160 void (*cong_avoid)(struct sock *sk, __u32 ack, __u32 acked); 188 static __always_inline __u32 tcp_slow_start(struct tcp_sock *tp, __u32 acked) in tcp_slow_start() argument 190 __u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start() 192 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start() 195 return acked; in tcp_slow_start() 214 static __always_inline void tcp_cong_avoid_ai(struct tcp_sock *tp, __u32 w, __u32 acked) in tcp_cong_avoid_ai() argument 222 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai()
|
/kernel/linux/linux-6.6/net/mac80211/ |
H A D | status.c | 628 bool acked, bool dropped, in ieee80211_report_ack_skb() 652 .ack = acked, in ieee80211_report_ack_skb() 671 acked, in ieee80211_report_ack_skb() 675 cookie, acked, in ieee80211_report_ack_skb() 694 skb_complete_wifi_ack(skb, acked); in ieee80211_report_ack_skb() 705 bool acked = info->flags & IEEE80211_TX_STAT_ACK; in ieee80211_report_used_skb() local 708 acked = false; in ieee80211_report_used_skb() 743 if (!acked) { in ieee80211_report_used_skb() 757 acked); in ieee80211_report_used_skb() 763 ieee80211_report_ack_skb(local, skb, acked, droppe in ieee80211_report_used_skb() 626 ieee80211_report_ack_skb(struct ieee80211_local *local, struct sk_buff *orig_skb, bool acked, bool dropped, ktime_t ack_hwtstamp) ieee80211_report_ack_skb() argument 932 bool acked; __ieee80211_tx_status() local 955 ieee80211_get_qos_ctl(hdr), sta, true, acked); __ieee80211_tx_status() local 1114 bool acked, noack_success, ack_signal_valid; ieee80211_tx_status_ext() local 1158 acked, info->status.tx_time); ieee80211_tx_status_ext() local [all...] |
/kernel/linux/linux-5.10/net/mac80211/ |
H A D | status.c | 615 bool acked, bool dropped) in ieee80211_report_ack_skb() 645 acked, in ieee80211_report_ack_skb() 649 cookie, acked, in ieee80211_report_ack_skb() 656 acked, GFP_ATOMIC); in ieee80211_report_ack_skb() 668 skb_complete_wifi_ack(skb, acked); in ieee80211_report_ack_skb() 678 bool acked = info->flags & IEEE80211_TX_STAT_ACK; in ieee80211_report_used_skb() local 681 acked = false; in ieee80211_report_used_skb() 718 acked); in ieee80211_report_used_skb() 723 ieee80211_report_ack_skb(local, info, acked, dropped); in ieee80211_report_used_skb() 728 skb->wifi_acked = acked; in ieee80211_report_used_skb() 613 ieee80211_report_ack_skb(struct ieee80211_local *local, struct ieee80211_tx_info *info, bool acked, bool dropped) ieee80211_report_ack_skb() argument 893 bool acked; __ieee80211_tx_status() local 917 ieee80211_get_qos_ctl(hdr), sta, true, acked); __ieee80211_tx_status() local 1078 bool acked, noack_success; ieee80211_tx_status_ext() local 1121 acked, info->status.tx_time); ieee80211_tx_status_ext() local [all...] |
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
H A D | bpf_cubic.c | 273 __u32 acked) in bictcp_update() 278 ca->ack_cnt += acked; /* count the number of ACKed packets */ in bictcp_update() 296 ca->ack_cnt = acked; /* start counting */ in bictcp_update() 387 void BPF_STRUCT_OPS(bictcp_cong_avoid, struct sock *sk, __u32 ack, __u32 acked) in BPF_STRUCT_OPS() argument 398 acked = tcp_slow_start(tp, acked); in BPF_STRUCT_OPS() 399 if (!acked) in BPF_STRUCT_OPS() 402 bictcp_update(ca, tp->snd_cwnd, acked); in BPF_STRUCT_OPS() 403 tcp_cong_avoid_ai(tp, ca->cnt, acked); in BPF_STRUCT_OPS() 272 bictcp_update(struct bictcp *ca, __u32 cwnd, __u32 acked) bictcp_update() argument
|
H A D | bpf_dctcp.c | 198 void BPF_PROG(tcp_reno_cong_avoid, struct sock *sk, __u32 ack, __u32 acked) in BPF_PROG() argument 207 acked = tcp_slow_start(tp, acked); in BPF_PROG() 208 if (!acked) in BPF_PROG() 212 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in BPF_PROG()
|
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/ |
H A D | bpf_cubic.c | 267 __u32 acked) in bictcp_update() 272 ca->ack_cnt += acked; /* count the number of ACKed packets */ in bictcp_update() 290 ca->ack_cnt = acked; /* start counting */ in bictcp_update() 381 void BPF_STRUCT_OPS(bpf_cubic_cong_avoid, struct sock *sk, __u32 ack, __u32 acked) in BPF_STRUCT_OPS() argument 392 acked = tcp_slow_start(tp, acked); in BPF_STRUCT_OPS() 393 if (!acked) in BPF_STRUCT_OPS() 396 bictcp_update(ca, tp->snd_cwnd, acked); in BPF_STRUCT_OPS() 397 tcp_cong_avoid_ai(tp, ca->cnt, acked); in BPF_STRUCT_OPS() 266 bictcp_update(struct bictcp *ca, __u32 cwnd, __u32 acked) bictcp_update() argument
|
/kernel/linux/linux-5.10/net/tipc/ |
H A D | link.c | 107 * @transmitq: queue for sent, non-acked messages 111 * @acked: # last packet acked by a certain peer. Used for broadcast. 190 u16 acked; member 253 u16 acked, u16 gap, 364 rcv_l->acked = snd_l->snd_nxt - 1; in tipc_link_add_bc_peer() 433 return l->acked; in tipc_link_acked() 814 u16 bc_acked = l->bc_rcvlink->acked; in tipc_link_timeout() 980 l->acked = 0; in tipc_link_reset() 1201 if (link_is_bc_sndlink(l) && !less(r->acked, msg_seqn in link_retransmit_failure() 1520 tipc_link_advance_transmq(struct tipc_link *l, struct tipc_link *r, u16 acked, u16 gap, struct tipc_gap_ack_blks *ga, struct sk_buff_head *xmitq, bool *retransmitted, int *rc) tipc_link_advance_transmq() argument 2448 tipc_link_bc_ack_rcv(struct tipc_link *r, u16 acked, u16 gap, struct tipc_gap_ack_blks *ga, struct sk_buff_head *xmitq, struct sk_buff_head *retrq) tipc_link_bc_ack_rcv() argument 2488 u16 acked = msg_bcast_ack(hdr); tipc_link_bc_nack_rcv() local [all...] |
/kernel/linux/linux-6.6/net/tipc/ |
H A D | link.c | 107 * @transmitq: queue for sent, non-acked messages 111 * @acked: # last packet acked by a certain peer. Used for broadcast. 136 * @rcv_unacked: # messages read by user, but not yet acked back to peer 150 * @bc_peer_is_up: peer has acked the bcast init msg 218 u16 acked; member 281 u16 acked, u16 gap, 392 rcv_l->acked = snd_l->snd_nxt - 1; in tipc_link_add_bc_peer() 461 return l->acked; in tipc_link_acked() 849 u16 bc_acked = l->bc_rcvlink->acked; in tipc_link_timeout() 1556 tipc_link_advance_transmq(struct tipc_link *l, struct tipc_link *r, u16 acked, u16 gap, struct tipc_gap_ack_blks *ga, struct sk_buff_head *xmitq, bool *retransmitted, int *rc) tipc_link_advance_transmq() argument 2484 tipc_link_bc_ack_rcv(struct tipc_link *r, u16 acked, u16 gap, struct tipc_gap_ack_blks *ga, struct sk_buff_head *xmitq, struct sk_buff_head *retrq) tipc_link_bc_ack_rcv() argument 2524 u16 acked = msg_bcast_ack(hdr); tipc_link_bc_nack_rcv() local [all...] |