Lines Matching refs:now
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()
505 ktime_t now, in cobalt_should_drop() argument
528 sojourn = ktime_to_ns(ktime_sub(now, cobalt_get_enqueue_time(skb))); in cobalt_should_drop()
529 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
540 vars->drop_next = cobalt_control(now, in cobalt_should_drop()
561 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
569 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
580 vars->drop_next = ktime_add_ns(now, p->interval); in cobalt_should_drop()
582 vars->drop_next = now; in cobalt_should_drop()
1471 ktime_t now, bool drop) in cake_advance_shaper() argument
1483 if (ktime_before(b->time_next_packet, now)) in cake_advance_shaper()
1488 ktime_add_ns(now, tin_dur))) in cake_advance_shaper()
1489 b->time_next_packet = ktime_add_ns(now, tin_dur); in cake_advance_shaper()
1504 ktime_t now = ktime_get(); in cake_drop() local
1533 if (cobalt_queue_full(&flow->cvars, &b->cparams, now)) in cake_drop()
1548 cake_advance_shaper(q, b, skb, now, true); in cake_drop()
1701 ktime_t now = ktime_get(); in cake_enqueue() local
1719 if (ktime_before(b->time_next_packet, now)) in cake_enqueue()
1720 b->time_next_packet = now; in cake_enqueue()
1723 if (ktime_before(q->time_next_packet, now)) { in cake_enqueue()
1724 q->failsafe_next_packet = now; in cake_enqueue()
1725 q->time_next_packet = now; in cake_enqueue()
1726 } else if (ktime_after(q->time_next_packet, now) && in cake_enqueue()
1727 ktime_after(q->failsafe_next_packet, now)) { in cake_enqueue()
1753 cobalt_set_enqueue_time(segs, now); in cake_enqueue()
1776 cobalt_set_enqueue_time(skb, now); in cake_enqueue()
1790 cake_advance_shaper(q, b, ack, now, true); in cake_enqueue()
1814 ktime_to_ns(ktime_sub(now, q->last_packet_time)); in cake_enqueue()
1826 q->last_packet_time = now; in cake_enqueue()
1830 ktime_to_ns(ktime_sub(now, in cake_enqueue()
1839 q->avg_window_begin = now; in cake_enqueue()
1841 if (ktime_after(now, in cake_enqueue()
1850 q->last_packet_time = now; in cake_enqueue()
1950 ktime_t now = ktime_get(); in cake_dequeue() local
1964 if (ktime_after(q->time_next_packet, now) && in cake_dequeue()
1965 ktime_after(q->failsafe_next_packet, now)) { in cake_dequeue()
2018 ktime_sub(b->time_next_packet, now); in cake_dequeue()
2110 if (cobalt_queue_empty(&flow->cvars, &b->cparams, now)) in cake_dequeue()
2114 ktime_before(now, flow->cvars.drop_next)) { in cake_dequeue()
2160 if (!cobalt_should_drop(&flow->cvars, &b->cparams, now, skb, in cake_dequeue()
2170 now, true); in cake_dequeue()
2187 delay = ktime_to_ns(ktime_sub(now, cobalt_get_enqueue_time(skb))); in cake_dequeue()
2194 len = cake_advance_shaper(q, b, skb, now, false); in cake_dequeue()
2198 if (ktime_after(q->time_next_packet, now) && sch->q.qlen) { in cake_dequeue()
2209 ktime_add_ns(now, in cake_dequeue()
3016 ktime_t now = ktime_get(); in cake_dump_class_stats() local
3038 ktime_sub(now, in cake_dump_class_stats()
3044 ktime_sub(now, in cake_dump_class_stats()