blob: 845696a98bb3365c065cec517d85a0aa36add9cf [file] [log] [blame]
// Copyright (c) PLUMgrid, Inc.
// Licensed under the Apache License, Version 2.0 (the "License")
BPF_TABLE("prog", int, int, jump, 64);
BPF_TABLE("array", int, u64, stats, 64);
enum states {
S_EOP = 1,
S_ETHER,
S_ARP,
S_IP
};
int parse_ether(struct __sk_buff *skb) {
size_t cur = 0;
size_t next = cur + 14;
int key = S_ETHER;
u64 *leaf = stats.lookup(&key);
if (leaf) (*leaf)++;
switch (bpf_dext_pkt(skb, cur + 12, 0, 16)) {
case 0x0800: jump.call(skb, S_IP);
case 0x0806: jump.call(skb, S_ARP);
}
jump.call(skb, S_EOP);
return 1;
}
int parse_arp(struct __sk_buff *skb) {
size_t cur = 14; // TODO: get from ctx
size_t next = cur + 28;
int key = S_ARP;
u64 *leaf = stats.lookup(&key);
if (leaf) (*leaf)++;
jump.call(skb, S_EOP);
return 1;
}
int parse_ip(struct __sk_buff *skb) {
size_t cur = 14; // TODO: get from ctx
size_t next = cur + 20;
int key = S_IP;
u64 *leaf = stats.lookup(&key);
if (leaf) (*leaf)++;
jump.call(skb, S_EOP);
return 1;
}
int eop(struct __sk_buff *skb) {
int key = S_EOP;
u64 *leaf = stats.lookup(&key);
if (leaf) (*leaf)++;
return 1;
}