| /samples/bpf/ |
| A D | tcbpf1_kern.c | 26 __u8 old_tos = load_byte(skb, TOS_OFF); in set_ip_tos()
56 int bpf_prog1(struct __sk_buff *skb) in bpf_prog1() argument
62 set_ip_tos(skb, 8); in bpf_prog1()
63 set_tcp_ip_src(skb, 0xA010101); in bpf_prog1()
64 set_tcp_dest_port(skb, 5001); in bpf_prog1()
70 int _redirect_xmit(struct __sk_buff *skb) in _redirect_xmit() argument
72 return bpf_redirect(skb->ifindex + 1, 0); in _redirect_xmit()
75 int _redirect_recv(struct __sk_buff *skb) in _redirect_recv() argument
77 return bpf_redirect(skb->ifindex + 1, 1); in _redirect_recv()
82 bpf_clone_redirect(skb, skb->ifindex + 1, 0); in _clone_redirect_xmit()
[all …]
|
| A D | test_lwt_bpf.c | 29 int do_nop(struct __sk_buff *skb) in do_nop() argument
38 skb->cb[0] = CB_MAGIC; in do_test_ctx()
39 printk("len %d hash %d protocol %d", skb->len, skb->hash, in do_test_ctx()
40 skb->protocol); in do_test_ctx()
42 skb->ingress_ifindex, skb->ifindex); in do_test_ctx()
49 int do_test_cb(struct __sk_buff *skb) in do_test_cb() argument
51 printk("cb0: %x cb1: %x cb2: %x", skb->cb[0], skb->cb[1], in do_test_cb()
52 skb->cb[2]); in do_test_cb()
53 printk("cb3: %x cb4: %x", skb->cb[3], skb->cb[4]); in do_test_cb()
223 __fill_garbage(skb); in do_fill_garbage()
[all …]
|
| A D | sockex3_kern.c | 135 skb->cb[0] = nhoff; in parse_ip_proto()
150 update_stats(skb, g); in parse_ip_proto()
166 nhoff = skb->cb[0]; in bpf_func_ip()
181 skb->cb[0] = nhoff; in bpf_func_ip()
195 nhoff = skb->cb[0]; in bpf_func_ipv6()
205 skb->cb[0] = nhoff; in bpf_func_ipv6()
215 nhoff = skb->cb[0]; in bpf_func_vlan()
220 skb->cb[0] = nhoff; in bpf_func_vlan()
232 nhoff = skb->cb[0]; in bpf_func_mpls()
236 skb->cb[0] = nhoff; in bpf_func_mpls()
[all …]
|
| A D | sockex2_kern.c | 88 *ip_proto = load_byte(skb, in parse_ipv6()
90 flow->src = ipv6_addr_hash(skb, in parse_ipv6()
92 flow->dst = ipv6_addr_hash(skb, in parse_ipv6()
104 __u64 proto = load_half(skb, 12); in flow_dissector()
133 __u64 gre_flags = load_half(skb, in flow_dissector()
135 __u64 gre_proto = load_half(skb, in flow_dissector()
151 proto = load_half(skb, in flow_dissector()
179 flow->ports = load_word(skb, nhoff); in flow_dissector()
200 int bpf_prog2(struct __sk_buff *skb) in bpf_prog2() argument
206 if (!flow_dissector(skb, &flow)) in bpf_prog2()
[all …]
|
| A D | tracex1.bpf.c | 28 struct sk_buff *skb; in bpf_prog1() local
31 bpf_core_read(&skb, sizeof(skb), (void *)PT_REGS_PARM1(ctx)); in bpf_prog1()
32 dev = BPF_CORE_READ(skb, dev); in bpf_prog1()
33 len = BPF_CORE_READ(skb, len); in bpf_prog1()
40 bpf_trace_printk(fmt, sizeof(fmt), skb, len); in bpf_prog1()
|
| A D | parse_ldabs.c | 28 int handle_ingress(struct __sk_buff *skb) in handle_ingress() argument
32 if (load_half(skb, offsetof(struct ethhdr, h_proto)) != ETH_P_IP) in handle_ingress()
34 if (load_byte(skb, ETH_HLEN + offsetof(struct iphdr, protocol)) != IPPROTO_UDP || in handle_ingress()
35 load_byte(skb, ETH_HLEN) != 0x45) in handle_ingress()
37 if (ip_is_fragment(skb, ETH_HLEN)) in handle_ingress()
39 if (load_half(skb, troff + offsetof(struct udphdr, dest)) == DEFAULT_PKTGEN_UDP_PORT) in handle_ingress()
|
| A D | sockex1_kern.c | 16 int bpf_prog1(struct __sk_buff *skb) in bpf_prog1() argument
18 int index = load_byte(skb, ETH_HLEN + offsetof(struct iphdr, protocol)); in bpf_prog1()
21 if (skb->pkt_type != PACKET_OUTGOING) in bpf_prog1()
26 __sync_fetch_and_add(value, skb->len); in bpf_prog1()
|
| A D | tc_l2_redirect_kern.c | 59 int _l2_to_iptun_ingress_forward(struct __sk_buff *skb) in _l2_to_iptun_ingress_forward() argument
61 void *data = (void *)(long)skb->data; in _l2_to_iptun_ingress_forward()
63 void *data_end = (void *)(long)skb->data_end; in _l2_to_iptun_ingress_forward()
110 void *data = (void *)(long)skb->data; in _l2_to_iptun_ingress_redirect()
112 void *data_end = (void *)(long)skb->data_end; in _l2_to_iptun_ingress_redirect()
141 bpf_skb_set_tunnel_key(skb, &tkey, sizeof(tkey), 0); in _l2_to_iptun_ingress_redirect()
149 void *data = (void *)(long)skb->data; in _l2_to_ip6tun_ingress_redirect()
151 void *data_end = (void *)(long)skb->data_end; in _l2_to_ip6tun_ingress_redirect()
201 int _drop_non_tun_vip(struct __sk_buff *skb) in _drop_non_tun_vip() argument
203 void *data = (void *)(long)skb->data; in _drop_non_tun_vip()
[all …]
|
| A D | hbm_edt_kern.c | 56 int _hbm_out_cg(struct __sk_buff *skb) in _hbm_out_cg() argument
68 int len = skb->len; in _hbm_out_cg()
74 if (qsp != NULL && !qsp->loopback && (skb->ifindex == 1)) in _hbm_out_cg()
77 hbm_get_pkt_info(skb, &pkti); in _hbm_out_cg()
107 skb->tstamp = sendtime; in _hbm_out_cg()
128 if (bpf_skb_ecn_set_ce(skb)) { in _hbm_out_cg()
|
| A D | parse_simple.c | 27 int handle_ingress(struct __sk_buff *skb) in handle_ingress() argument
29 void *data = (void *)(long)skb->data; in handle_ingress()
33 void *data_end = (void *)(long)skb->data_end; in handle_ingress()
|
| A D | hbm_out_kern.c | 58 int _hbm_out_cg(struct __sk_buff *skb) in _hbm_out_cg() argument
61 int len = skb->len; in _hbm_out_cg()
76 if (qsp != NULL && !qsp->loopback && (skb->ifindex == 1)) in _hbm_out_cg()
79 hbm_get_pkt_info(skb, &pkti); in _hbm_out_cg()
145 if (bpf_skb_ecn_set_ce(skb)) { in _hbm_out_cg()
|
| A D | lwt_len_hist.bpf.c | 47 int do_len_hist(struct __sk_buff *skb) in do_len_hist() argument
51 key = log2l(skb->len); in do_len_hist()
|
| A D | hbm_kern.h | 82 static int get_tcp_info(struct __sk_buff *skb, struct hbm_pkt_info *pkti) in get_tcp_info() argument
87 sk = skb->sk; in get_tcp_info()
108 static void hbm_get_pkt_info(struct __sk_buff *skb, in hbm_get_pkt_info() argument
116 bpf_skb_load_bytes(skb, 0, &iph, 12); in hbm_get_pkt_info()
132 get_tcp_info(skb, pkti); in hbm_get_pkt_info()
|
| A D | parse_varlen.c | 113 int handle_ingress(struct __sk_buff *skb) in handle_ingress() argument
115 void *data = (void *)(long)skb->data; in handle_ingress()
117 void *data_end = (void *)(long)skb->data_end; in handle_ingress()
|
| /samples/connector/ |
| A D | cn_test.c | 45 struct sk_buff *skb;
53 skb = alloc_skb(size, GFP_ATOMIC);
54 if (!skb) {
59 nlh = nlmsg_put(skb, 0, 0x123, NLMSG_DONE, size - sizeof(*nlh), 0);
61 kfree_skb(skb);
104 NETLINK_CB(skb).dst_group = ctl->group;
106 netlink_unicast(nls, skb, 0, 0);
|