lkml.org 
[lkml]   [2011]   [Feb]   [27]   [last100]   RSS Feed
Views: [wrap][no wrap]   [headers]  [forward] 
 
Messages in this thread
/
Date
From
SubjectRe: txqueuelen has wrong units; should be time
/*
* sch_fifo_timeout.c Simple FIFO queue with per packet timeout.
*
* This program is free software; you can redistribute it and/or modify it under
* the terms of the GNU General Public License as published by the Free Software
* Foundation; either version 2 of the License, or (at your option) any later
* version.
*
*/

#include <linux/module.h>
#include <linux/slab.h>
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/errno.h>
#include <linux/skbuff.h>
#include <net/pkt_sched.h>
#include <net/inet_ecn.h>

#define DEFAULT_TIMEOUT_PKT_MS 10
#define DEFAULT_TIMEOUT_PKT PSCHED_NS2TICKS((u64)NSEC_PER_SEC * \
DEFAULT_TIMEOUT_PKT_MS / 1000)

struct tc_fifo_timeout_qopt {
__u64 timeout; /* Max time packet may stay in buffer */
__u32 limit; /* Queue length: bytes for bfifo, packets for pfifo */
};

struct fifo_timeout_skb_cb {
psched_time_t time_queued;
};

struct fifo_timeout_sched_data {
psched_tdiff_t timeout;
u32 limit;
};

static inline
struct fifo_timeout_skb_cb *fifo_timeout_skb_cb(struct sk_buff *skb)
{
BUILD_BUG_ON(sizeof(skb->cb) <
sizeof(struct qdisc_skb_cb) +
sizeof(struct fifo_timeout_skb_cb));
return (struct fifo_timeout_skb_cb *)qdisc_skb_cb(skb)->data;
}

static void pfifo_timeout_drop_timedout_packets(struct Qdisc *sch,
psched_time_t now)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);
struct sk_buff *skb;

check_next:
skb = qdisc_peek_head(sch);
if (likely(!skb))
return;

if (likely(fifo_timeout_skb_cb(skb)->time_queued + q->timeout > now))
return;

__qdisc_queue_drop_head(sch, &sch->q);
sch->qstats.drops++;

goto check_next;
}

static int pfifo_tail_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);

if (likely(skb_queue_len(&sch->q) < q->limit))
return qdisc_enqueue_tail(skb, sch);

/* queue full, remove one skb to fulfill the limit */
__qdisc_queue_drop_head(sch, &sch->q);
sch->qstats.drops++;
qdisc_enqueue_tail(skb, sch);

return NET_XMIT_CN;
}

static int bfifo_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);

if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= q->limit))
return qdisc_enqueue_tail(skb, sch);

return qdisc_reshape_fail(skb, sch);
}

static int pfifo_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);

if (likely(skb_queue_len(&sch->q) < q->limit))
return qdisc_enqueue_tail(skb, sch);

return qdisc_reshape_fail(skb, sch);
}

static int pfifo_timeout_tail_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
psched_time_t now = psched_get_time();

fifo_timeout_skb_cb(skb)->time_queued = now;
pfifo_timeout_drop_timedout_packets(sch, now);

return pfifo_tail_enqueue(skb, sch);
}

static int bfifo_timeout_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
psched_time_t now = psched_get_time();

fifo_timeout_skb_cb(skb)->time_queued = now;
pfifo_timeout_drop_timedout_packets(sch, now);

return bfifo_enqueue(skb, sch);
}

static int pfifo_timeout_enqueue(struct sk_buff *skb, struct Qdisc* sch)
{
psched_time_t now = psched_get_time();

fifo_timeout_skb_cb(skb)->time_queued = now;
pfifo_timeout_drop_timedout_packets(sch, now);

return pfifo_enqueue(skb, sch);
}

static int fifo_timeout_init(struct Qdisc *sch, struct nlattr *opt)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);

if (opt == NULL) {
u32 limit = qdisc_dev(sch)->tx_queue_len ? : 1;

q->limit = limit;
q->timeout = DEFAULT_TIMEOUT_PKT;
} else {
struct tc_fifo_timeout_qopt *ctl = nla_data(opt);

if (nla_len(opt) < sizeof(*ctl))
return -EINVAL;

q->limit = ctl->limit;
q->timeout = ctl->timeout ? : DEFAULT_TIMEOUT_PKT;
}

return 0;
}

static int fifo_timeout_dump(struct Qdisc *sch, struct sk_buff *skb)
{
struct fifo_timeout_sched_data *q = qdisc_priv(sch);
struct tc_fifo_timeout_qopt opt = {
.limit = q->limit,
.timeout = q->timeout
};

NLA_PUT(skb, TCA_OPTIONS, sizeof(opt), &opt);
return skb->len;

nla_put_failure:
return -1;
}

static struct Qdisc_ops pfifo_timeout_qdisc_ops __read_mostly = {
.id = "pfifo_timeout",
.priv_size = sizeof(struct fifo_timeout_sched_data),
.enqueue = pfifo_timeout_enqueue,
.dequeue = qdisc_dequeue_head,
.peek = qdisc_peek_head,
.drop = qdisc_queue_drop,
.init = fifo_timeout_init,
.reset = qdisc_reset_queue,
.change = fifo_timeout_init,
.dump = fifo_timeout_dump,
.owner = THIS_MODULE,
};

static struct Qdisc_ops bfifo_timeout_qdisc_ops __read_mostly = {
.id = "bfifo_timeout",
.priv_size = sizeof(struct fifo_timeout_sched_data),
.enqueue = bfifo_timeout_enqueue,
.dequeue = qdisc_dequeue_head,
.peek = qdisc_peek_head,
.drop = qdisc_queue_drop,
.init = fifo_timeout_init,
.reset = qdisc_reset_queue,
.change = fifo_timeout_init,
.dump = fifo_timeout_dump,
.owner = THIS_MODULE,
};

static struct Qdisc_ops pfifo_head_drop_timeout_qdisc_ops __read_mostly = {
.id = "pfifo_hd_tout",
.priv_size = sizeof(struct fifo_timeout_sched_data),
.enqueue = pfifo_timeout_tail_enqueue,
.dequeue = qdisc_dequeue_head,
.peek = qdisc_peek_head,
.drop = qdisc_queue_drop_head,
.init = fifo_timeout_init,
.reset = qdisc_reset_queue,
.change = fifo_timeout_init,
.dump = fifo_timeout_dump,
.owner = THIS_MODULE,
};

static int __init fifo_timeout_module_init(void)
{
int retval;

retval = register_qdisc(&pfifo_timeout_qdisc_ops);
if (retval)
goto cleanup;
retval = register_qdisc(&bfifo_timeout_qdisc_ops);
if (retval)
goto cleanup;
retval = register_qdisc(&pfifo_head_drop_timeout_qdisc_ops);
if (retval)
goto cleanup;

return 0;

cleanup:
unregister_qdisc(&pfifo_timeout_qdisc_ops);
unregister_qdisc(&bfifo_timeout_qdisc_ops);
unregister_qdisc(&pfifo_head_drop_timeout_qdisc_ops);
return retval;
}
static void __exit fifo_timeout_module_exit(void)
{
unregister_qdisc(&pfifo_timeout_qdisc_ops);
unregister_qdisc(&bfifo_timeout_qdisc_ops);
unregister_qdisc(&pfifo_head_drop_timeout_qdisc_ops);
}

module_init(fifo_timeout_module_init)
module_exit(fifo_timeout_module_exit)
MODULE_LICENSE("GPL");

\
 
 \ /
  Last update: 2011-02-27 12:05    [W:0.675 / U:0.224 seconds]
©2003-2020 Jasper Spaans|hosted at Digital Ocean and TransIP|Read the blog|Advertise on this site