mirror/xdp-project-bpf-examples
1
0
Fork 0
mirror of https://github.com/xdp-project/bpf-examples.git synced 2024-05-06 15:54:53 +00:00
Code Issues Projects Releases Wiki Activity

EDT: implement horizon drop

Browse Source 
FQ-pacing qdisc also have horizon, but cannot use that, because this
BPF-prog will have updated map (t_last) on packet and assumes it got
its part of bandwidth.

Signed-off-by: Jesper Dangaard Brouer <netoptimizer@brouer.com>
This commit is contained in:
Jesper Dangaard Brouer
2020-11-14 12:06:25 +01:00
parent efcd3c81b0
commit 86750f321e
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
traffic-pacing-edt/edt_pacer02.c
View File

@@ -12,6 +12,8 @@ char _license[] SEC("license") = "GPL";
#define RATE_IN_BITS (1000 * 1000 * 1000)
#define RATE_IN_BYTES (RATE_IN_BITS / 8)
#define T_HORIZON_DROP (2000 * 1000 * 1000)
/* FIXME add proper READ_ONCE / WRITE_ONCE macros, for now use for annotation */
#define READ_ONCE(V) (V)
#define WRITE_ONCE(X,V) (X) = (V)
@@ -40,6 +42,7 @@ struct bpf_elf_map SEC("maps") time_delay_map = {
static __always_inline int sched_departure(struct __sk_buff *skb)
{
struct edt_val *edt;
__u64 t_queue_sz;
__u64 t_xmit_ns;
__u64 t_next;
__u64 t_curr;
@@ -76,7 +79,16 @@ static __always_inline int sched_departure(struct __sk_buff *skb)
return BPF_OK;
}
// TODO Add horizon
/* Calc queue size measured in time */
t_queue_sz = t_next - now;
/* FQ-pacing qdisc also have horizon, but cannot use that, because this
* BPF-prog will have updated map (t_last) on packet and assumes it got
* its part of bandwidth.
*/
if (t_queue_sz >= T_HORIZON_DROP /* edt->t_horizon_drop */)
return BPF_DROP;
// TODO Add ECN marking horizon
/* Advance "time queue" */