• Home
  • Raw
  • Download

Lines Matching refs:now

295 				    ktime_t now)  in cobalt_set_enqueue_time()  argument
297 get_cobalt_cb(skb)->enqueue_time = now; in cobalt_set_enqueue_time()
451 ktime_t now) in cobalt_queue_full() argument
455 if (ktime_to_ns(ktime_sub(now, vars->blue_timer)) > p->target) { in cobalt_queue_full()
460 vars->blue_timer = now; in cobalt_queue_full()
463 vars->drop_next = now; in cobalt_queue_full()
475 ktime_t now) in cobalt_queue_empty() argument
480 ktime_to_ns(ktime_sub(now, vars->blue_timer)) > p->target) { in cobalt_queue_empty()
485 vars->blue_timer = now; in cobalt_queue_empty()
490 if (vars->count && ktime_to_ns(ktime_sub(now, vars->drop_next)) >= 0) { in cobalt_queue_empty()
506 ktime_t now, in cobalt_should_drop() argument
529 sojourn = ktime_to_ns(ktime_sub(now, cobalt_get_enqueue_time(skb))); in cobalt_should_drop()
530 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
541 vars->drop_next = cobalt_control(now, in cobalt_should_drop()
562 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
570 schedule = ktime_sub(now, vars->drop_next); in cobalt_should_drop()
581 vars->drop_next = ktime_add_ns(now, p->interval); in cobalt_should_drop()
583 vars->drop_next = now; in cobalt_should_drop()
1472 ktime_t now, bool drop) in cake_advance_shaper() argument
1484 if (ktime_before(b->time_next_packet, now)) in cake_advance_shaper()
1489 ktime_add_ns(now, tin_dur))) in cake_advance_shaper()
1490 b->time_next_packet = ktime_add_ns(now, tin_dur); in cake_advance_shaper()
1505 ktime_t now = ktime_get(); in cake_drop() local
1534 if (cobalt_queue_full(&flow->cvars, &b->cparams, now)) in cake_drop()
1549 cake_advance_shaper(q, b, skb, now, true); in cake_drop()
1702 ktime_t now = ktime_get(); in cake_enqueue() local
1720 if (ktime_before(b->time_next_packet, now)) in cake_enqueue()
1721 b->time_next_packet = now; in cake_enqueue()
1724 if (ktime_before(q->time_next_packet, now)) { in cake_enqueue()
1725 q->failsafe_next_packet = now; in cake_enqueue()
1726 q->time_next_packet = now; in cake_enqueue()
1727 } else if (ktime_after(q->time_next_packet, now) && in cake_enqueue()
1728 ktime_after(q->failsafe_next_packet, now)) { in cake_enqueue()
1754 cobalt_set_enqueue_time(segs, now); in cake_enqueue()
1777 cobalt_set_enqueue_time(skb, now); in cake_enqueue()
1791 cake_advance_shaper(q, b, ack, now, true); in cake_enqueue()
1815 ktime_to_ns(ktime_sub(now, q->last_packet_time)); in cake_enqueue()
1827 q->last_packet_time = now; in cake_enqueue()
1831 ktime_to_ns(ktime_sub(now, in cake_enqueue()
1840 q->avg_window_begin = now; in cake_enqueue()
1842 if (ktime_after(now, in cake_enqueue()
1851 q->last_packet_time = now; in cake_enqueue()
1951 ktime_t now = ktime_get(); in cake_dequeue() local
1965 if (ktime_after(q->time_next_packet, now) && in cake_dequeue()
1966 ktime_after(q->failsafe_next_packet, now)) { in cake_dequeue()
2019 ktime_sub(b->time_next_packet, now); in cake_dequeue()
2111 if (cobalt_queue_empty(&flow->cvars, &b->cparams, now)) in cake_dequeue()
2115 ktime_before(now, flow->cvars.drop_next)) { in cake_dequeue()
2161 if (!cobalt_should_drop(&flow->cvars, &b->cparams, now, skb, in cake_dequeue()
2171 now, true); in cake_dequeue()
2188 delay = ktime_to_ns(ktime_sub(now, cobalt_get_enqueue_time(skb))); in cake_dequeue()
2195 len = cake_advance_shaper(q, b, skb, now, false); in cake_dequeue()
2199 if (ktime_after(q->time_next_packet, now) && sch->q.qlen) { in cake_dequeue()
2210 ktime_add_ns(now, in cake_dequeue()
3014 ktime_t now = ktime_get(); in cake_dump_class_stats() local
3036 ktime_sub(now, in cake_dump_class_stats()
3042 ktime_sub(now, in cake_dump_class_stats()