| /net/rxrpc/ |
| D | call_event.c | 31 unsigned long now = jiffies; in rxrpc_propose_ping() local
32 unsigned long ping_at = now + rxrpc_idle_ack_delay; in rxrpc_propose_ping()
36 rxrpc_reduce_call_timer(call, ping_at, now, in rxrpc_propose_ping()
112 unsigned long now = jiffies, ack_at; in __rxrpc_propose_ACK() local
120 ack_at += now; in __rxrpc_propose_ACK()
123 rxrpc_reduce_call_timer(call, ack_at, now, in __rxrpc_propose_ACK()
162 ktime_t now, max_age, oldest, ack_ts; in rxrpc_resend() local
168 now = ktime_get_real(); in rxrpc_resend()
169 max_age = ktime_sub_us(now, jiffies_to_usecs(call->peer->rto_j)); in rxrpc_resend()
184 oldest = now; in rxrpc_resend()
[all …]
|
| D | conn_object.c | 385 unsigned long expire_at, earliest, idle_timestamp, now; in rxrpc_service_connection_reaper() local
391 now = jiffies; in rxrpc_service_connection_reaper()
392 earliest = now + MAX_JIFFY_OFFSET; in rxrpc_service_connection_reaper()
410 (long)expire_at - (long)now); in rxrpc_service_connection_reaper()
412 if (time_before(now, expire_at)) { in rxrpc_service_connection_reaper()
435 if (earliest != now + MAX_JIFFY_OFFSET) { in rxrpc_service_connection_reaper()
436 _debug("reschedule reaper %ld", (long)earliest - (long)now); in rxrpc_service_connection_reaper()
437 ASSERT(time_after(earliest, now)); in rxrpc_service_connection_reaper()
|
| D | sendmsg.c | 196 unsigned long now; in rxrpc_queue_packet() local
234 now = jiffies; in rxrpc_queue_packet()
235 WRITE_ONCE(call->ack_at, now + MAX_JIFFY_OFFSET); in rxrpc_queue_packet()
238 trace_rxrpc_timer(call, rxrpc_timer_init_for_send_reply, now); in rxrpc_queue_packet()
268 unsigned long now = jiffies; in rxrpc_queue_packet() local
269 unsigned long resend_at = now + call->peer->rto_j; in rxrpc_queue_packet()
272 rxrpc_reduce_call_timer(call, resend_at, now, in rxrpc_queue_packet()
652 unsigned long now, j; in rxrpc_do_sendmsg() local
740 now = jiffies; in rxrpc_do_sendmsg()
741 j += now; in rxrpc_do_sendmsg()
[all …]
|
| D | call_object.c | 64 unsigned long now, in rxrpc_reduce_call_timer() argument
68 trace_rxrpc_timer(call, why, now); in rxrpc_reduce_call_timer()
200 ktime_t now; in rxrpc_alloc_client_call() local
210 now = ktime_get_real(); in rxrpc_alloc_client_call()
211 call->acks_latest_ts = now; in rxrpc_alloc_client_call()
212 call->cong_tstamp = now; in rxrpc_alloc_client_call()
223 unsigned long now = jiffies; in rxrpc_start_call_timer() local
224 unsigned long j = now + MAX_JIFFY_OFFSET; in rxrpc_start_call_timer()
233 call->timer.expires = now; in rxrpc_start_call_timer()
|
| D | peer_event.c | 580 time64_t base, now, delay; in rxrpc_peer_keepalive_worker() local
584 now = ktime_get_seconds(); in rxrpc_peer_keepalive_worker()
587 _enter("%lld,%u", base - now, cursor); in rxrpc_peer_keepalive_worker()
603 while (base <= now && (s8)(cursor - stop) < 0) { in rxrpc_peer_keepalive_worker()
610 base = now; in rxrpc_peer_keepalive_worker()
627 now = ktime_get_seconds(); in rxrpc_peer_keepalive_worker()
628 delay = base - now; in rxrpc_peer_keepalive_worker()
|
| /net/dccp/ccids/ |
| D | ccid3.c | 95 static u32 ccid3_hc_tx_idle_rtt(struct ccid3_hc_tx_sock *hc, ktime_t now) in ccid3_hc_tx_idle_rtt() argument
97 u32 delta = ktime_us_delta(now, hc->tx_t_last_win_count); in ccid3_hc_tx_idle_rtt()
119 ktime_t now = stamp ? *stamp : ktime_get_real(); in ccid3_hc_tx_update_x() local
127 if (ccid3_hc_tx_idle_rtt(hc, now) >= 2) { in ccid3_hc_tx_update_x()
137 } else if (ktime_us_delta(now, hc->tx_t_ld) - (s64)hc->tx_rtt >= 0) { in ccid3_hc_tx_update_x()
142 hc->tx_t_ld = now; in ccid3_hc_tx_update_x()
177 ktime_t now) in ccid3_hc_tx_update_win_count() argument
179 u32 delta = ktime_us_delta(now, hc->tx_t_last_win_count), in ccid3_hc_tx_update_win_count()
183 hc->tx_t_last_win_count = now; in ccid3_hc_tx_update_win_count()
276 ktime_t now = ktime_get_real(); in ccid3_hc_tx_send_packet() local
[all …]
|
| D | ccid2.c | 198 static void ccid2_cwnd_application_limited(struct sock *sk, const u32 now) in ccid2_cwnd_application_limited() argument
211 hc->tx_cwnd_stamp = now; in ccid2_cwnd_application_limited()
217 static void ccid2_cwnd_restart(struct sock *sk, const u32 now) in ccid2_cwnd_restart() argument
222 s32 delta = now - hc->tx_lsndtime; in ccid2_cwnd_restart()
232 hc->tx_cwnd_stamp = now; in ccid2_cwnd_restart()
242 const u32 now = ccid2_jiffies32; in ccid2_hc_tx_packet_sent() local
247 (s32)(now - hc->tx_lsndtime) >= hc->tx_rto) in ccid2_hc_tx_packet_sent()
248 ccid2_cwnd_restart(sk, now); in ccid2_hc_tx_packet_sent()
250 hc->tx_lsndtime = now; in ccid2_hc_tx_packet_sent()
257 hc->tx_cwnd_stamp = now; in ccid2_hc_tx_packet_sent()
[all …]
|
| /net/netfilter/ |
| D | xt_IDLETIMER.c | 172 unsigned long now = jiffies; in idletimer_tg_show() local
184 time_diff = jiffies_to_msecs(expires - now) / 1000; in idletimer_tg_show()
190 if (time_after(expires, now) || ktimespec.tv_sec > 0) in idletimer_tg_show()
195 jiffies_to_msecs(now - expires) / 1000); in idletimer_tg_show()
228 unsigned long time_diff, now = jiffies; in idletimer_resume() local
252 if (time_after(timer->timer.expires, now)) { in idletimer_resume()
256 if (timer->timer.expires > (time_diff + now)) { in idletimer_resume()
276 ktime_t now) in idletimer_tg_alarmproc() argument
449 unsigned long now = jiffies; in reset_timer() local
456 if (!timer_prev || time_before(info_timer->timer.expires, now)) { in reset_timer()
[all …]
|
| D | xt_limit.c | 67 unsigned long now; in limit_mt() local
76 now = jiffies; in limit_mt()
77 credit_increase += (now - xchg(&priv->prev, now)) * CREDITS_PER_JIFFY; in limit_mt()
|
| /net/sunrpc/auth_gss/ |
| D | gss_krb5_unseal.c | 82 s32 now; in gss_verify_mic_v1() local
127 now = ktime_get_real_seconds(); in gss_verify_mic_v1()
129 if (now > ctx->endtime) in gss_verify_mic_v1()
152 time64_t now; in gss_verify_mic_v2() local
197 now = ktime_get_real_seconds(); in gss_verify_mic_v2()
198 if (now > ctx->endtime) in gss_verify_mic_v2()
|
| D | gss_krb5_seal.c | 134 time64_t now; in gss_get_mic_v1() local
141 now = ktime_get_real_seconds(); in gss_get_mic_v1()
162 return (ctx->endtime < now) ? GSS_S_CONTEXT_EXPIRED : GSS_S_COMPLETE; in gss_get_mic_v1()
173 time64_t now; in gss_get_mic_v2() local
201 now = ktime_get_real_seconds(); in gss_get_mic_v2()
203 return (ctx->endtime < now) ? GSS_S_CONTEXT_EXPIRED : GSS_S_COMPLETE; in gss_get_mic_v2()
|
| D | gss_krb5_wrap.c | 166 time64_t now; in gss_wrap_kerberos_v1() local
175 now = ktime_get_real_seconds(); in gss_wrap_kerberos_v1()
243 return (kctx->endtime < now) ? GSS_S_CONTEXT_EXPIRED : GSS_S_COMPLETE; in gss_wrap_kerberos_v1()
256 time64_t now; in gss_unwrap_kerberos_v1() local
321 now = ktime_get_real_seconds(); in gss_unwrap_kerberos_v1()
323 if (now > kctx->endtime) in gss_unwrap_kerberos_v1()
413 time64_t now; in gss_wrap_kerberos_v2() local
455 now = ktime_get_real_seconds(); in gss_wrap_kerberos_v2()
456 return (kctx->endtime < now) ? GSS_S_CONTEXT_EXPIRED : GSS_S_COMPLETE; in gss_wrap_kerberos_v2()
464 time64_t now; in gss_unwrap_kerberos_v2() local
[all …]
|
| /net/sched/ |
| D | sch_cake.c | 294 ktime_t now) in cobalt_set_enqueue_time() argument
296 get_cobalt_cb(skb)->enqueue_time = now; in cobalt_set_enqueue_time()
450 ktime_t now) in cobalt_queue_full() argument
454 if (ktime_to_ns(ktime_sub(now, vars->blue_timer)) > p->target) { in cobalt_queue_full()
459 vars->blue_timer = now; in cobalt_queue_full()
462 vars->drop_next = now; in cobalt_queue_full()
474 ktime_t now) in cobalt_queue_empty() argument
479 ktime_to_ns(ktime_sub(now, vars->blue_timer)) > p->target) { in cobalt_queue_empty()
484 vars->blue_timer = now; in cobalt_queue_empty()
489 if (vars->count && ktime_to_ns(ktime_sub(now, vars->drop_next)) >= 0) { in cobalt_queue_empty()
[all …]
|
| D | sch_etf.c | 80 ktime_t now; in is_packet_valid() local
101 now = q->get_time(); in is_packet_valid()
102 if (ktime_before(txtime, now) || ktime_before(txtime, q->last)) in is_packet_valid()
201 ktime_t now) in timesortedlist_drop() argument
208 if (ktime_after(skb->tstamp, now)) in timesortedlist_drop()
257 ktime_t now, next; in etf_dequeue_timesortedlist() local
263 now = q->get_time(); in etf_dequeue_timesortedlist()
266 if (ktime_before(skb->tstamp, now)) { in etf_dequeue_timesortedlist()
267 timesortedlist_drop(sch, skb, now); in etf_dequeue_timesortedlist()
277 skb->tstamp = now; in etf_dequeue_timesortedlist()
[all …]
|
| D | sch_hhf.c | 185 u32 now = hhf_time_stamp(); in seek_list() local
193 if (hhf_time_before(prev, now)) { in seek_list()
216 u32 now = hhf_time_stamp(); in alloc_new_hh() local
223 if (hhf_time_before(prev, now)) in alloc_new_hh()
256 u32 now = hhf_time_stamp(); in hhf_classify() local
260 if (hhf_time_before(prev, now)) { in hhf_classify()
263 q->hhf_arrays_reset_timestamp = now; in hhf_classify()
273 flow->hit_timestamp = now; in hhf_classify()
311 flow->hit_timestamp = now; in hhf_classify()
|
| D | sch_cbs.c | 180 s64 now = ktime_get_ns(); in cbs_dequeue_soft() local
186 if (now < q->last) { in cbs_dequeue_soft()
191 credits = timediff_to_credits(now - q->last, q->idleslope); in cbs_dequeue_soft()
200 qdisc_watchdog_schedule_ns(&q->watchdog, now + delay); in cbs_dequeue_soft()
202 q->last = now; in cbs_dequeue_soft()
223 q->last = now; in cbs_dequeue_soft()
225 q->last = now + div64_s64(len * NSEC_PER_SEC, in cbs_dequeue_soft()
|
| D | act_gate.c | 38 ktime_t now, base, cycle; in gate_get_start_time() local
42 now = gate_get_time(gact); in gate_get_start_time()
44 if (ktime_after(base, now)) { in gate_get_start_time()
51 n = div64_u64(ktime_sub_ns(now, base), cycle); in gate_get_start_time()
74 ktime_t close_time, now; in gate_timer_func() local
96 now = gate_get_time(gact); in gate_timer_func()
98 if (ktime_after(now, close_time)) { in gate_timer_func()
104 n = div64_u64(ktime_sub_ns(now, base), cycle); in gate_timer_func()
|
| /net/atm/ |
| D | mpoa_caches.c | 229 time64_t now; in clear_count_and_expired() local
231 now = ktime_get_seconds(); in clear_count_and_expired()
238 if ((now - entry->time) > entry->ctrl_info.holding_time) { in clear_count_and_expired()
254 time64_t now; in check_resolving_entries() local
257 now = ktime_get_seconds(); in check_resolving_entries()
264 if ((now - entry->hold_down) in check_resolving_entries()
269 if ((now - entry->reply_wait) > entry->retry_time) { in check_resolving_entries()
301 time64_t now; in refresh_entries() local
305 now = ktime_get_seconds(); in refresh_entries()
312 if ((now - entry->reply_wait) > in refresh_entries()
[all …]
|
| D | mpoa_proc.c | 137 time64_t now; in mpc_show() local
147 now = ktime_get_seconds(); in mpc_show()
150 unsigned long seconds_delta = now - in_entry->time; in mpc_show()
170 unsigned long seconds_delta = now - eg_entry->time; in mpc_show()
|
| /net/ipv4/ |
| D | tcp_cubic.c | 144 u32 now = tcp_jiffies32; in cubictcp_cwnd_event() local
147 delta = now - tcp_sk(sk)->lsndtime; in cubictcp_cwnd_event()
154 if (after(ca->epoch_start, now)) in cubictcp_cwnd_event()
155 ca->epoch_start = now; in cubictcp_cwnd_event()
394 u32 now = bictcp_clock_us(sk); in hystart_update() local
397 if ((s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update()
398 ca->last_ack = now; in hystart_update()
410 if ((s32)(now - ca->round_start) > threshold) { in hystart_update()
413 now - ca->round_start, threshold, in hystart_update()
|
| D | tcp_htcp.c | 107 u32 now = tcp_jiffies32; in measure_achieved_throughput() local
121 ca->lasttime = now; in measure_achieved_throughput()
128 now - ca->lasttime >= ca->minRTT && in measure_achieved_throughput()
130 __u32 cur_Bi = ca->packetcount * HZ / (now - ca->lasttime); in measure_achieved_throughput()
143 ca->lasttime = now; in measure_achieved_throughput()
|
| D | tcp_lp.c | 275 u32 now = tcp_time_stamp(tp); in tcp_lp_pkts_acked() local
282 delta = now - tp->rx_opt.rcv_tsecr; in tcp_lp_pkts_acked()
287 if (lp->last_drop && (now - lp->last_drop < lp->inference)) in tcp_lp_pkts_acked()
324 lp->last_drop = now; in tcp_lp_pkts_acked()
|
| D | inetpeer.c | 272 unsigned long now, token; in inet_peer_xrlim_allow() local
279 now = jiffies; in inet_peer_xrlim_allow()
280 token += now - peer->rate_last; in inet_peer_xrlim_allow()
281 peer->rate_last = now; in inet_peer_xrlim_allow()
|
| /net/mac80211/ |
| D | offchannel.c | 193 unsigned long now) in ieee80211_end_finished_rocs() argument
208 now; in ieee80211_end_finished_rocs()
224 unsigned long now) in ieee80211_recalc_sw_work() argument
226 long dur = ieee80211_end_finished_rocs(local, now); in ieee80211_recalc_sw_work()
492 unsigned long now = jiffies; in ieee80211_coalesce_hw_started_roc() local
506 now; in ieee80211_coalesce_hw_started_roc()
521 ieee80211_handle_roc_started(new_roc, now); in ieee80211_coalesce_hw_started_roc()
635 unsigned long now = jiffies; in ieee80211_start_roc_work() local
636 u32 elapsed = jiffies_to_msecs(now - tmp->start_time); in ieee80211_start_roc_work()
648 ieee80211_handle_roc_started(roc, now); in ieee80211_start_roc_work()
[all …]
|
| /net/bridge/netfilter/ |
| D | ebt_limit.c | 39 unsigned long now = jiffies; in ebt_limit_mt() local
42 info->credit += (now - xchg(&info->prev, now)) * CREDITS_PER_JIFFY; in ebt_limit_mt()
|