11d9c037aSJohn Fastabend // SPDX-License-Identifier: GPL-2.0
21d9c037aSJohn Fastabend // Copyright (c) 2020 Isovalent, Inc.
31d9c037aSJohn Fastabend #include "vmlinux.h"
41d9c037aSJohn Fastabend #include <bpf/bpf_helpers.h>
51d9c037aSJohn Fastabend
61d9c037aSJohn Fastabend struct {
71d9c037aSJohn Fastabend __uint(type, BPF_MAP_TYPE_SOCKMAP);
81d9c037aSJohn Fastabend __uint(max_entries, 2);
91d9c037aSJohn Fastabend __type(key, __u32);
101d9c037aSJohn Fastabend __type(value, __u64);
111d9c037aSJohn Fastabend } sock_map SEC(".maps");
121d9c037aSJohn Fastabend
131d9c037aSJohn Fastabend struct {
141d9c037aSJohn Fastabend __uint(type, BPF_MAP_TYPE_SOCKHASH);
151d9c037aSJohn Fastabend __uint(max_entries, 2);
161d9c037aSJohn Fastabend __type(key, __u32);
171d9c037aSJohn Fastabend __type(value, __u64);
181d9c037aSJohn Fastabend } sock_hash SEC(".maps");
191d9c037aSJohn Fastabend
201d9c037aSJohn Fastabend struct {
211d9c037aSJohn Fastabend __uint(type, BPF_MAP_TYPE_SK_STORAGE);
221d9c037aSJohn Fastabend __uint(map_flags, BPF_F_NO_PREALLOC);
231d9c037aSJohn Fastabend __type(key, __u32);
241d9c037aSJohn Fastabend __type(value, __u64);
251d9c037aSJohn Fastabend } socket_storage SEC(".maps");
261d9c037aSJohn Fastabend
271d9c037aSJohn Fastabend SEC("sk_msg")
prog_msg_verdict(struct sk_msg_md * msg)281d9c037aSJohn Fastabend int prog_msg_verdict(struct sk_msg_md *msg)
291d9c037aSJohn Fastabend {
301d9c037aSJohn Fastabend struct task_struct *task = (struct task_struct *)bpf_get_current_task();
311d9c037aSJohn Fastabend int verdict = SK_PASS;
321d9c037aSJohn Fastabend __u32 pid, tpid;
331d9c037aSJohn Fastabend __u64 *sk_stg;
341d9c037aSJohn Fastabend
351d9c037aSJohn Fastabend pid = bpf_get_current_pid_tgid() >> 32;
361d9c037aSJohn Fastabend sk_stg = bpf_sk_storage_get(&socket_storage, msg->sk, 0, BPF_SK_STORAGE_GET_F_CREATE);
371d9c037aSJohn Fastabend if (!sk_stg)
381d9c037aSJohn Fastabend return SK_DROP;
391d9c037aSJohn Fastabend *sk_stg = pid;
401d9c037aSJohn Fastabend bpf_probe_read_kernel(&tpid , sizeof(tpid), &task->tgid);
411d9c037aSJohn Fastabend if (pid != tpid)
421d9c037aSJohn Fastabend verdict = SK_DROP;
431d9c037aSJohn Fastabend bpf_sk_storage_delete(&socket_storage, (void *)msg->sk);
441d9c037aSJohn Fastabend return verdict;
451d9c037aSJohn Fastabend }
461d9c037aSJohn Fastabend
471d9c037aSJohn Fastabend char _license[] SEC("license") = "GPL";
48