Home
last modified time | relevance | path

Searched refs:acked (Results 1 – 25 of 87) sorted by relevance

1234

/openbmc/linux/net/ipv4/
H A Dtcp_scalable.c18 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 Dtcp_veno.c119 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 Dtcp_yeah.c58 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 Dtcp_cong.c457 __bpf_kfunc u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument
459 u32 cwnd = min(tcp_snd_cwnd(tp) + acked, tp->snd_ssthresh); in tcp_slow_start()
461 acked -= cwnd - tcp_snd_cwnd(tp); in tcp_slow_start()
464 return acked; in tcp_slow_start()
471 __bpf_kfunc void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument
479 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai()
497 __bpf_kfunc void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument
506 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid()
507 if (!acked) in tcp_reno_cong_avoid()
511 tcp_cong_avoid_ai(tp, tcp_snd_cwnd(tp), acked); in tcp_reno_cong_avoid()
H A Dtcp_illinois.c52 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 Dtcp_cubic.c214 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 Dtcp_vegas.c165 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()
H A Dtcp_bic.c140 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 Dtcp_nv.c180 static void tcpnv_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcpnv_cong_avoid() argument
194 acked = tcp_slow_start(tp, acked); in tcpnv_cong_avoid()
195 if (!acked) in tcpnv_cong_avoid()
201 tcp_cong_avoid_ai(tp, cnt, acked); in tcpnv_cong_avoid()
204 tcp_cong_avoid_ai(tp, cnt, acked); in tcpnv_cong_avoid()
H A Dtcp_highspeed.c112 static void hstcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in hstcp_cong_avoid() argument
121 tcp_slow_start(tp, acked); in hstcp_cong_avoid()
H A Dtcp_bbr.c480 struct sock *sk, const struct rate_sample *rs, u32 acked, u32 *new_cwnd) in bbr_set_cwnd_to_recover_or_restore() argument
499 cwnd = tcp_packets_in_flight(tp) + acked; in bbr_set_cwnd_to_recover_or_restore()
508 *new_cwnd = max(cwnd, tcp_packets_in_flight(tp) + acked); in bbr_set_cwnd_to_recover_or_restore()
519 u32 acked, u32 bw, int gain) in bbr_set_cwnd() argument
525 if (!acked) in bbr_set_cwnd()
528 if (bbr_set_cwnd_to_recover_or_restore(sk, rs, acked, &cwnd)) in bbr_set_cwnd()
541 cwnd = min(cwnd + acked, target_cwnd); in bbr_set_cwnd()
543 cwnd = cwnd + acked; in bbr_set_cwnd()
H A Dtcp_hybla.c90 static void hybla_cong_avoid(struct sock *sk, u32 ack, u32 acked) in hybla_cong_avoid() argument
107 tcp_reno_cong_avoid(sk, ack, acked); in hybla_cong_avoid()
H A Dtcp_lp.c121 static void tcp_lp_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_lp_cong_avoid() argument
126 tcp_reno_cong_avoid(sk, ack, acked); in tcp_lp_cong_avoid()
/openbmc/linux/net/mac80211/
H A Dstatus.c628 bool acked, bool dropped, in ieee80211_report_ack_skb() argument
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, dropped, in ieee80211_report_used_skb()
[all …]
/openbmc/linux/tools/testing/selftests/bpf/progs/
H A Dbpf_cubic.c267 __u32 acked) in bictcp_update() argument
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()
H A Dbpf_dctcp.c231 extern void tcp_reno_cong_avoid(struct sock *sk, __u32 ack, __u32 acked) __ksym;
234 void BPF_PROG(dctcp_cong_avoid, struct sock *sk, __u32 ack, __u32 acked) in BPF_PROG() argument
236 tcp_reno_cong_avoid(sk, ack, acked); in BPF_PROG()
/openbmc/phosphor-logging/extensions/openpower-pels/
H A Dhost_notifier.cpp109 if ((a.hostState == TransmissionState::acked) || in enqueueRequired()
115 (a.hmcState == TransmissionState::acked)) in enqueueRequired()
145 if (a.hostState == TransmissionState::acked) in notifyRequired()
154 if ((a.hmcState == TransmissionState::acked) || in notifyRequired()
432 _repo.setPELHostTransState(id, TransmissionState::acked); in ackPEL()
H A Dpel_entry.cpp27 (value ? TransmissionState::acked : TransmissionState::newPEL)); in managementSystemAck()
/openbmc/linux/net/tipc/
H A Dlink.c218 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()
1015 l->acked = 0; in tipc_link_reset()
1236 if (link_is_bc_sndlink(l) && !less(r->acked, msg_seqno(hdr))) in link_retransmit_failure()
1557 u16 acked, u16 gap, in tipc_link_advance_transmq() argument
1567 u16 nacked = acked, ngap = gap, gack_cnt = 0; in tipc_link_advance_transmq()
1571 u16 end = r->acked, start = end, offset = r->last_gap; in tipc_link_advance_transmq()
[all …]
/openbmc/phosphor-logging/test/openpower-pels/
H A Drepository_test.cpp352 repo.setPELHostTransState(pel->id(), TransmissionState::acked); in TEST_F()
356 EXPECT_EQ((*a).get().hostState, TransmissionState::acked); in TEST_F()
361 EXPECT_EQ(newPEL.hostTransmissionState(), TransmissionState::acked); in TEST_F()
370 EXPECT_EQ((*a).get().hostState, TransmissionState::acked); in TEST_F()
375 EXPECT_EQ(newPEL.hostTransmissionState(), TransmissionState::acked); in TEST_F()
395 repo.setPELHMCTransState(pel->id(), TransmissionState::acked); in TEST_F()
399 EXPECT_EQ((*a).get().hmcState, TransmissionState::acked); in TEST_F()
404 EXPECT_EQ(newPEL.hmcTransmissionState(), TransmissionState::acked); in TEST_F()
413 EXPECT_EQ((*a).get().hmcState, TransmissionState::acked); in TEST_F()
418 EXPECT_EQ(newPEL.hmcTransmissionState(), TransmissionState::acked); in TEST_F()
[all …]
/openbmc/linux/tools/testing/selftests/bpf/
H A Dbpf_tcp_helpers.h171 void (*cong_avoid)(struct sock *sk, __u32 ack, __u32 acked);
230 extern __u32 tcp_slow_start(struct tcp_sock *tp, __u32 acked) __ksym;
231 extern void tcp_cong_avoid_ai(struct tcp_sock *tp, __u32 w, __u32 acked) __ksym;
/openbmc/linux/drivers/net/arcnet/
H A Dcapmode.c185 static int ack_tx(struct net_device *dev, int acked) in ack_tx() argument
193 lp->outgoing.skb->protocol, acked); in ack_tx()
213 ackpkt->soft.cap.mes.ack = acked; in ack_tx()
/openbmc/linux/drivers/remoteproc/
H A Dqcom_sysmon.c125 bool acked = false; in sysmon_request_shutdown() local
149 acked = true; in sysmon_request_shutdown()
154 return acked; in sysmon_request_shutdown()
334 bool acked = false; in ssctl_request_shutdown() local
360 acked = true; in ssctl_request_shutdown()
366 return acked; in ssctl_request_shutdown()
/openbmc/linux/drivers/net/wireless/ath/wil6210/
H A Dtxrx.h623 static inline void wil_consume_skb(struct sk_buff *skb, bool acked) in wil_consume_skb() argument
626 skb_complete_wifi_ack(skb, acked); in wil_consume_skb()
628 acked ? dev_consume_skb_any(skb) : dev_kfree_skb_any(skb); in wil_consume_skb()
/openbmc/linux/net/dccp/ccids/
H A Dccid3.c362 struct tfrc_tx_hist_entry *acked; in ccid3_hc_tx_packet_recv() local
379 acked = tfrc_tx_hist_find_entry(hc->tx_hist, dccp_hdr_ack_seq(skb)); in ccid3_hc_tx_packet_recv()
380 if (acked == NULL) in ccid3_hc_tx_packet_recv()
383 tfrc_tx_hist_purge(&acked->next); in ccid3_hc_tx_packet_recv()
387 r_sample = dccp_sample_rtt(sk, ktime_us_delta(now, acked->stamp)); in ccid3_hc_tx_packet_recv()

1234