| /net/netfilter/ |
| D | xt_rateest.c | 18 struct gnet_stats_rate_est64 sample = {0}; in xt_rateest_mt() local
22 gen_estimator_read(&info->est1->rate_est, &sample); in xt_rateest_mt()
25 bps1 = info->bps1 >= sample.bps ? info->bps1 - sample.bps : 0; in xt_rateest_mt()
26 pps1 = info->pps1 >= sample.pps ? info->pps1 - sample.pps : 0; in xt_rateest_mt()
28 bps1 = sample.bps; in xt_rateest_mt()
29 pps1 = sample.pps; in xt_rateest_mt()
36 gen_estimator_read(&info->est2->rate_est, &sample); in xt_rateest_mt()
39 bps2 = info->bps2 >= sample.bps ? info->bps2 - sample.bps : 0; in xt_rateest_mt()
40 pps2 = info->pps2 >= sample.pps ? info->pps2 - sample.pps : 0; in xt_rateest_mt()
42 bps2 = sample.bps; in xt_rateest_mt()
[all …]
|
| /net/dccp/ccids/lib/ |
| D | packet_history.c | 396 u32 sample = 0, in tfrc_rx_hist_sample_rtt() local
402 sample = SUB16(tfrc_rx_hist_rtt_prev_s(h)->tfrchrx_ccval, in tfrc_rx_hist_sample_rtt()
404 if (sample) in tfrc_rx_hist_sample_rtt()
405 sample = 4 / sample * in tfrc_rx_hist_sample_rtt()
424 sample = ktime_to_us(net_timedelta(tfrc_rx_hist_rtt_last_s(h)->tfrchrx_tstamp)); in tfrc_rx_hist_sample_rtt()
430 if (unlikely(sample > DCCP_SANE_RTT_MAX)) { in tfrc_rx_hist_sample_rtt()
431 DCCP_WARN("RTT sample %u too large, using max\n", sample); in tfrc_rx_hist_sample_rtt()
432 sample = DCCP_SANE_RTT_MAX; in tfrc_rx_hist_sample_rtt()
438 return sample; in tfrc_rx_hist_sample_rtt()
|
| /net/ipv4/ |
| D | tcp_nv.c | 239 static void tcpnv_acked(struct sock *sk, const struct ack_sample *sample) in tcpnv_acked() argument
251 if (sample->rtt_us < 0) in tcpnv_acked()
268 if (sample->in_flight == 0) in tcpnv_acked()
274 avg_rtt = (((u64)sample->rtt_us) * nv_rtt_factor + in tcpnv_acked()
278 avg_rtt = sample->rtt_us; in tcpnv_acked()
283 avg_rtt = sample->rtt_us; in tcpnv_acked()
287 rate64 = ((u64)sample->in_flight) * 80000; in tcpnv_acked()
|
| D | tcp_cdg.c | 299 static void tcp_cdg_acked(struct sock *sk, const struct ack_sample *sample) in tcp_cdg_acked() argument
304 if (sample->rtt_us <= 0) in tcp_cdg_acked()
312 if (sample->pkts_acked == 1 && ca->delack) { in tcp_cdg_acked()
316 ca->rtt.min = min(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked()
319 } else if (sample->pkts_acked > 1 && ca->delack < 5) { in tcp_cdg_acked()
324 ca->rtt.min = min_not_zero(ca->rtt.min, sample->rtt_us); in tcp_cdg_acked()
325 ca->rtt.max = max(ca->rtt.max, sample->rtt_us); in tcp_cdg_acked()
|
| D | tcp_htcp.c | 102 const struct ack_sample *sample) in measure_achieved_throughput() argument
110 ca->pkts_acked = sample->pkts_acked; in measure_achieved_throughput()
112 if (sample->rtt_us > 0) in measure_achieved_throughput()
113 measure_rtt(sk, usecs_to_jiffies(sample->rtt_us)); in measure_achieved_throughput()
125 ca->packetcount += sample->pkts_acked; in measure_achieved_throughput()
|
| D | tcp_veno.c | 74 const struct ack_sample *sample) in tcp_veno_pkts_acked() argument
79 if (sample->rtt_us < 0) in tcp_veno_pkts_acked()
83 vrtt = sample->rtt_us + 1; in tcp_veno_pkts_acked()
|
| D | tcp_vegas.c | 111 void tcp_vegas_pkts_acked(struct sock *sk, const struct ack_sample *sample) in tcp_vegas_pkts_acked() argument
116 if (sample->rtt_us < 0) in tcp_vegas_pkts_acked()
120 vrtt = sample->rtt_us + 1; in tcp_vegas_pkts_acked()
|
| D | tcp_westwood.c | 104 const struct ack_sample *sample) in tcp_westwood_pkts_acked() argument
108 if (sample->rtt_us > 0) in tcp_westwood_pkts_acked()
109 w->rtt = usecs_to_jiffies(sample->rtt_us); in tcp_westwood_pkts_acked()
|
| D | tcp_lp.c | 271 static void tcp_lp_pkts_acked(struct sock *sk, const struct ack_sample *sample) in tcp_lp_pkts_acked() argument
278 if (sample->rtt_us > 0) in tcp_lp_pkts_acked()
279 tcp_lp_rtt_sample(sk, sample->rtt_us); in tcp_lp_pkts_acked()
|
| D | tcp_illinois.c | 86 static void tcp_illinois_acked(struct sock *sk, const struct ack_sample *sample) in tcp_illinois_acked() argument
89 s32 rtt_us = sample->rtt_us; in tcp_illinois_acked()
91 ca->acked = sample->pkts_acked; in tcp_illinois_acked()
|
| D | tcp_bic.c | 190 static void bictcp_acked(struct sock *sk, const struct ack_sample *sample) in bictcp_acked() argument
197 ca->delayed_ack += sample->pkts_acked - in bictcp_acked()
|
| D | tcp_cubic.c | 448 __bpf_kfunc static void cubictcp_acked(struct sock *sk, const struct ack_sample *sample) in cubictcp_acked() argument
455 if (sample->rtt_us < 0) in cubictcp_acked()
462 delay = sample->rtt_us; in cubictcp_acked()
|
| D | tcp_vegas.h | 21 void tcp_vegas_pkts_acked(struct sock *sk, const struct ack_sample *sample);
|
| D | tcp_input.c | 653 static void tcp_rcv_rtt_update(struct tcp_sock *tp, u32 sample, int win_dep) in tcp_rcv_rtt_update() argument
656 long m = sample; in tcp_rcv_rtt_update()
3467 struct ack_sample sample = { .pkts_acked = pkts_acked, in tcp_clean_rtx_queue() local
3470 sample.in_flight = tp->mss_cache * in tcp_clean_rtx_queue()
3472 icsk->icsk_ca_ops->pkts_acked(sk, &sample); in tcp_clean_rtx_queue()
|
| /net/core/ |
| D | gen_stats.c | 311 struct gnet_stats_rate_est64 sample; in gnet_stats_copy_rate_est() local
315 if (!gen_estimator_read(rate_est, &sample)) in gnet_stats_copy_rate_est()
317 est.bps = min_t(u64, UINT_MAX, sample.bps); in gnet_stats_copy_rate_est()
319 est.pps = sample.pps; in gnet_stats_copy_rate_est()
329 if (res < 0 || est.bps == sample.bps) in gnet_stats_copy_rate_est()
332 return gnet_stats_copy(d, TCA_STATS_RATE_EST64, &sample, in gnet_stats_copy_rate_est()
333 sizeof(sample), TCA_STATS_PAD); in gnet_stats_copy_rate_est()
|
| D | gen_estimator.c | 257 struct gnet_stats_rate_est64 *sample) in gen_estimator_read() argument
271 sample->bps = est->avbps >> 8; in gen_estimator_read()
272 sample->pps = est->avpps >> 8; in gen_estimator_read()
|
| /net/sched/ |
| D | act_sample.c | 279 entry->sample.psample_group = in tcf_offload_sample_get_group()
281 entry->destructor_priv = entry->sample.psample_group; in tcf_offload_sample_get_group()
292 entry->sample.trunc_size = tcf_sample_trunc_size(act); in tcf_sample_offload_act_setup()
293 entry->sample.truncate = tcf_sample_truncate(act); in tcf_sample_offload_act_setup()
294 entry->sample.rate = tcf_sample_rate(act); in tcf_sample_offload_act_setup()
|
| D | act_police.c | 263 struct gnet_stats_rate_est64 sample; in tcf_police_act() local
265 if (!gen_estimator_read(&police->tcf_rate_est, &sample) || in tcf_police_act()
266 sample.bps >= p->tcfp_ewma_rate) in tcf_police_act()
|
| D | sch_fq.c | 501 unsigned long sample; in fq_check_throttled() local
510 sample = (unsigned long)(now - q->time_next_delayed_flow); in fq_check_throttled()
512 q->unthrottle_latency_ns += sample >> 3; in fq_check_throttled()
|
| /net/mac80211/ |
| D | rc80211_minstrel_ht.c | 704 u16 *rates = mi->sample[type].sample_rates; in __minstrel_ht_get_sample_rate()
791 u16 cur = mi->sample[type].sample_rates[i]; in minstrel_ht_find_sample_rate()
807 u16 *rates = mi->sample[type].sample_rates; in minstrel_ht_move_sample_rates()
881 group = mi->sample[type].sample_group; in minstrel_ht_next_inc_rate()
897 mi->sample[type].sample_group = group; in minstrel_ht_next_inc_rate()
951 slow_rates = mi->sample[MINSTREL_SAMPLE_TYPE_SLOW].sample_rates; in minstrel_ht_next_jump_rate()
952 group = mi->sample[MINSTREL_SAMPLE_TYPE_JUMP].sample_group; in minstrel_ht_next_jump_rate()
1002 mi->sample[MINSTREL_SAMPLE_TYPE_JUMP].sample_group = group; in minstrel_ht_next_jump_rate()
1018 rates = mi->sample[MINSTREL_SAMPLE_TYPE_INC].sample_rates; in minstrel_ht_refill_sample_rates()
1029 rates = mi->sample[MINSTREL_SAMPLE_TYPE_JUMP].sample_rates; in minstrel_ht_refill_sample_rates()
[all …]
|
| D | rc80211_minstrel_ht_debugfs.c | 40 for (type = 0; type < ARRAY_SIZE(mi->sample); type++) in minstrel_ht_is_sample_rate()
42 if (mi->sample[type].cur_sample_rates[i] == idx) in minstrel_ht_is_sample_rate()
|
| D | rc80211_minstrel_ht.h | 189 struct minstrel_sample_category sample[__MINSTREL_SAMPLE_TYPE_MAX]; member
|
| /net/dccp/ |
| D | input.c | 523 u32 sample = dp->dccps_options_received.dccpor_timestamp_echo; in dccp_rcv_respond_partopen_state_process() local
550 if (likely(sample)) { in dccp_rcv_respond_partopen_state_process()
551 long delta = dccp_timestamp() - sample; in dccp_rcv_respond_partopen_state_process()
|
| /net/dccp/ccids/ |
| D | ccid3.c | 760 const u32 sample = tfrc_rx_hist_sample_rtt(&hc->rx_hist, skb); in ccid3_hc_rx_packet_recv() local
766 if (sample != 0) in ccid3_hc_rx_packet_recv()
767 hc->rx_rtt = tfrc_ewma(hc->rx_rtt, sample, 9); in ccid3_hc_rx_packet_recv()
|
| /net/openvswitch/ |
| D | actions.c | 1031 static int sample(struct datapath *dp, struct sk_buff *skb, in sample() function
1414 err = sample(dp, skb, key, a, last); in do_execute_actions()
|