Commit 90baeb9d authored by Leslie Monis's avatar Leslie Monis Committed by David S. Miller

pie: use term backlog instead of qlen

Remove ambiguity by using the term backlog instead of qlen when
representing the queue length in bytes.
Signed-off-by: default avatarMohit P. Tahiliani <tahiliani@nitk.edu.in>
Signed-off-by: default avatarGautam Ramakrishnan <gautamramk@gmail.com>
Signed-off-by: default avatarLeslie Monis <lesliemonis@gmail.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent ef710370
...@@ -46,7 +46,7 @@ struct pie_params { ...@@ -46,7 +46,7 @@ struct pie_params {
* @accu_prob: accumulated drop probability * @accu_prob: accumulated drop probability
* @dq_count: number of bytes dequeued in a measurement cycle * @dq_count: number of bytes dequeued in a measurement cycle
* @avg_dq_rate: calculated average dq rate * @avg_dq_rate: calculated average dq rate
* @qlen_old: queue length during previous qdelay calculation * @backlog_old: queue backlog during previous qdelay calculation
* @accu_prob_overflows: number of times accu_prob overflows * @accu_prob_overflows: number of times accu_prob overflows
*/ */
struct pie_vars { struct pie_vars {
...@@ -58,7 +58,7 @@ struct pie_vars { ...@@ -58,7 +58,7 @@ struct pie_vars {
u64 accu_prob; u64 accu_prob;
u64 dq_count; u64 dq_count;
u32 avg_dq_rate; u32 avg_dq_rate;
u32 qlen_old; u32 backlog_old;
u8 accu_prob_overflows; u8 accu_prob_overflows;
}; };
...@@ -127,12 +127,12 @@ static inline void pie_set_enqueue_time(struct sk_buff *skb) ...@@ -127,12 +127,12 @@ static inline void pie_set_enqueue_time(struct sk_buff *skb)
} }
bool pie_drop_early(struct Qdisc *sch, struct pie_params *params, bool pie_drop_early(struct Qdisc *sch, struct pie_params *params,
struct pie_vars *vars, u32 qlen, u32 packet_size); struct pie_vars *vars, u32 backlog, u32 packet_size);
void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
struct pie_vars *vars, u32 qlen); struct pie_vars *vars, u32 backlog);
void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars, void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars,
u32 qlen); u32 backlog);
#endif #endif
...@@ -31,7 +31,7 @@ struct pie_sched_data { ...@@ -31,7 +31,7 @@ struct pie_sched_data {
}; };
bool pie_drop_early(struct Qdisc *sch, struct pie_params *params, bool pie_drop_early(struct Qdisc *sch, struct pie_params *params,
struct pie_vars *vars, u32 qlen, u32 packet_size) struct pie_vars *vars, u32 backlog, u32 packet_size)
{ {
u64 rnd; u64 rnd;
u64 local_prob = vars->prob; u64 local_prob = vars->prob;
...@@ -51,7 +51,7 @@ bool pie_drop_early(struct Qdisc *sch, struct pie_params *params, ...@@ -51,7 +51,7 @@ bool pie_drop_early(struct Qdisc *sch, struct pie_params *params,
/* If we have fewer than 2 mtu-sized packets, disable pie_drop_early, /* If we have fewer than 2 mtu-sized packets, disable pie_drop_early,
* similar to min_th in RED * similar to min_th in RED
*/ */
if (qlen < 2 * mtu) if (backlog < 2 * mtu)
return false; return false;
/* If bytemode is turned on, use packet size to compute new /* If bytemode is turned on, use packet size to compute new
...@@ -215,7 +215,7 @@ static int pie_change(struct Qdisc *sch, struct nlattr *opt, ...@@ -215,7 +215,7 @@ static int pie_change(struct Qdisc *sch, struct nlattr *opt,
} }
void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
struct pie_vars *vars, u32 qlen) struct pie_vars *vars, u32 backlog)
{ {
psched_time_t now = psched_get_time(); psched_time_t now = psched_get_time();
u32 dtime = 0; u32 dtime = 0;
...@@ -231,7 +231,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, ...@@ -231,7 +231,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
vars->dq_tstamp = now; vars->dq_tstamp = now;
if (qlen == 0) if (backlog == 0)
vars->qdelay = 0; vars->qdelay = 0;
if (dtime == 0) if (dtime == 0)
...@@ -244,7 +244,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, ...@@ -244,7 +244,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
* we have enough packets to calculate the drain rate. Save * we have enough packets to calculate the drain rate. Save
* current time as dq_tstamp and start measurement cycle. * current time as dq_tstamp and start measurement cycle.
*/ */
if (qlen >= QUEUE_THRESHOLD && vars->dq_count == DQCOUNT_INVALID) { if (backlog >= QUEUE_THRESHOLD && vars->dq_count == DQCOUNT_INVALID) {
vars->dq_tstamp = psched_get_time(); vars->dq_tstamp = psched_get_time();
vars->dq_count = 0; vars->dq_count = 0;
} }
...@@ -283,7 +283,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, ...@@ -283,7 +283,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
* dq_count to 0 to re-enter the if block when the next * dq_count to 0 to re-enter the if block when the next
* packet is dequeued * packet is dequeued
*/ */
if (qlen < QUEUE_THRESHOLD) { if (backlog < QUEUE_THRESHOLD) {
vars->dq_count = DQCOUNT_INVALID; vars->dq_count = DQCOUNT_INVALID;
} else { } else {
vars->dq_count = 0; vars->dq_count = 0;
...@@ -307,7 +307,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params, ...@@ -307,7 +307,7 @@ void pie_process_dequeue(struct sk_buff *skb, struct pie_params *params,
EXPORT_SYMBOL_GPL(pie_process_dequeue); EXPORT_SYMBOL_GPL(pie_process_dequeue);
void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars, void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars,
u32 qlen) u32 backlog)
{ {
psched_time_t qdelay = 0; /* in pschedtime */ psched_time_t qdelay = 0; /* in pschedtime */
psched_time_t qdelay_old = 0; /* in pschedtime */ psched_time_t qdelay_old = 0; /* in pschedtime */
...@@ -322,7 +322,7 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars, ...@@ -322,7 +322,7 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars,
vars->qdelay_old = vars->qdelay; vars->qdelay_old = vars->qdelay;
if (vars->avg_dq_rate > 0) if (vars->avg_dq_rate > 0)
qdelay = (qlen << PIE_SCALE) / vars->avg_dq_rate; qdelay = (backlog << PIE_SCALE) / vars->avg_dq_rate;
else else
qdelay = 0; qdelay = 0;
} else { } else {
...@@ -330,10 +330,10 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars, ...@@ -330,10 +330,10 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars,
qdelay_old = vars->qdelay_old; qdelay_old = vars->qdelay_old;
} }
/* If qdelay is zero and qlen is not, it means qlen is very small, /* If qdelay is zero and backlog is not, it means backlog is very small,
* so we do not update probabilty in this round. * so we do not update probabilty in this round.
*/ */
if (qdelay == 0 && qlen != 0) if (qdelay == 0 && backlog != 0)
update_prob = false; update_prob = false;
/* In the algorithm, alpha and beta are between 0 and 2 with typical /* In the algorithm, alpha and beta are between 0 and 2 with typical
...@@ -409,7 +409,7 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars, ...@@ -409,7 +409,7 @@ void pie_calculate_probability(struct pie_params *params, struct pie_vars *vars,
vars->prob -= vars->prob / 64; vars->prob -= vars->prob / 64;
vars->qdelay = qdelay; vars->qdelay = qdelay;
vars->qlen_old = qlen; vars->backlog_old = backlog;
/* We restart the measurement cycle if the following conditions are met /* We restart the measurement cycle if the following conditions are met
* 1. If the delay has been low for 2 consecutive Tupdate periods * 1. If the delay has been low for 2 consecutive Tupdate periods
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment