diff options
Diffstat (limited to 'net/sched')
-rw-r--r-- | net/sched/sch_htb.c | 38 |
1 files changed, 29 insertions, 9 deletions
diff --git a/net/sched/sch_htb.c b/net/sched/sch_htb.c index fcd06e29e8b3..f89fd71ce92f 100644 --- a/net/sched/sch_htb.c +++ b/net/sched/sch_htb.c | |||
@@ -577,6 +577,32 @@ static int htb_enqueue(struct sk_buff *skb, struct Qdisc *sch) | |||
577 | return NET_XMIT_SUCCESS; | 577 | return NET_XMIT_SUCCESS; |
578 | } | 578 | } |
579 | 579 | ||
580 | static inline void htb_accnt_tokens(struct htb_class *cl, int bytes, long diff) | ||
581 | { | ||
582 | long toks = diff + cl->tokens; | ||
583 | |||
584 | if (toks > cl->buffer) | ||
585 | toks = cl->buffer; | ||
586 | toks -= (long) qdisc_l2t(cl->rate, bytes); | ||
587 | if (toks <= -cl->mbuffer) | ||
588 | toks = 1 - cl->mbuffer; | ||
589 | |||
590 | cl->tokens = toks; | ||
591 | } | ||
592 | |||
593 | static inline void htb_accnt_ctokens(struct htb_class *cl, int bytes, long diff) | ||
594 | { | ||
595 | long toks = diff + cl->ctokens; | ||
596 | |||
597 | if (toks > cl->cbuffer) | ||
598 | toks = cl->cbuffer; | ||
599 | toks -= (long) qdisc_l2t(cl->ceil, bytes); | ||
600 | if (toks <= -cl->mbuffer) | ||
601 | toks = 1 - cl->mbuffer; | ||
602 | |||
603 | cl->ctokens = toks; | ||
604 | } | ||
605 | |||
580 | /** | 606 | /** |
581 | * htb_charge_class - charges amount "bytes" to leaf and ancestors | 607 | * htb_charge_class - charges amount "bytes" to leaf and ancestors |
582 | * | 608 | * |
@@ -592,26 +618,20 @@ static void htb_charge_class(struct htb_sched *q, struct htb_class *cl, | |||
592 | int level, struct sk_buff *skb) | 618 | int level, struct sk_buff *skb) |
593 | { | 619 | { |
594 | int bytes = qdisc_pkt_len(skb); | 620 | int bytes = qdisc_pkt_len(skb); |
595 | long toks, diff; | ||
596 | enum htb_cmode old_mode; | 621 | enum htb_cmode old_mode; |
597 | 622 | long diff; | |
598 | #define HTB_ACCNT(T,B,R) toks = diff + cl->T; \ | ||
599 | if (toks > cl->B) toks = cl->B; \ | ||
600 | toks -= (long) qdisc_l2t(cl->R, bytes); \ | ||
601 | if (toks <= -cl->mbuffer) toks = 1-cl->mbuffer; \ | ||
602 | cl->T = toks | ||
603 | 623 | ||
604 | while (cl) { | 624 | while (cl) { |
605 | diff = psched_tdiff_bounded(q->now, cl->t_c, cl->mbuffer); | 625 | diff = psched_tdiff_bounded(q->now, cl->t_c, cl->mbuffer); |
606 | if (cl->level >= level) { | 626 | if (cl->level >= level) { |
607 | if (cl->level == level) | 627 | if (cl->level == level) |
608 | cl->xstats.lends++; | 628 | cl->xstats.lends++; |
609 | HTB_ACCNT(tokens, buffer, rate); | 629 | htb_accnt_tokens(cl, bytes, diff); |
610 | } else { | 630 | } else { |
611 | cl->xstats.borrows++; | 631 | cl->xstats.borrows++; |
612 | cl->tokens += diff; /* we moved t_c; update tokens */ | 632 | cl->tokens += diff; /* we moved t_c; update tokens */ |
613 | } | 633 | } |
614 | HTB_ACCNT(ctokens, cbuffer, ceil); | 634 | htb_accnt_ctokens(cl, bytes, diff); |
615 | cl->t_c = q->now; | 635 | cl->t_c = q->now; |
616 | 636 | ||
617 | old_mode = cl->cmode; | 637 | old_mode = cl->cmode; |