162306a36Sopenharmony_ci/* Copyright (c) 2017 Facebook
262306a36Sopenharmony_ci *
362306a36Sopenharmony_ci * This program is free software; you can redistribute it and/or
462306a36Sopenharmony_ci * modify it under the terms of version 2 of the GNU General Public
562306a36Sopenharmony_ci * License as published by the Free Software Foundation.
662306a36Sopenharmony_ci *
762306a36Sopenharmony_ci * BPF program to set base_rtt to 80us when host is running TCP-NV and
862306a36Sopenharmony_ci * both hosts are in the same datacenter (as determined by IPv6 prefix).
962306a36Sopenharmony_ci *
1062306a36Sopenharmony_ci * Use "bpftool cgroup attach $cg sock_ops $prog" to load this BPF program.
1162306a36Sopenharmony_ci */
1262306a36Sopenharmony_ci
1362306a36Sopenharmony_ci#include <uapi/linux/bpf.h>
1462306a36Sopenharmony_ci#include <uapi/linux/tcp.h>
1562306a36Sopenharmony_ci#include <uapi/linux/if_ether.h>
1662306a36Sopenharmony_ci#include <uapi/linux/if_packet.h>
1762306a36Sopenharmony_ci#include <uapi/linux/ip.h>
1862306a36Sopenharmony_ci#include <linux/socket.h>
1962306a36Sopenharmony_ci#include <bpf/bpf_helpers.h>
2062306a36Sopenharmony_ci#include <bpf/bpf_endian.h>
2162306a36Sopenharmony_ci
2262306a36Sopenharmony_ci#define DEBUG 1
2362306a36Sopenharmony_ci
2462306a36Sopenharmony_ciSEC("sockops")
2562306a36Sopenharmony_ciint bpf_basertt(struct bpf_sock_ops *skops)
2662306a36Sopenharmony_ci{
2762306a36Sopenharmony_ci	char cong[20];
2862306a36Sopenharmony_ci	char nv[] = "nv";
2962306a36Sopenharmony_ci	int rv = 0, n;
3062306a36Sopenharmony_ci	int op;
3162306a36Sopenharmony_ci
3262306a36Sopenharmony_ci	op = (int) skops->op;
3362306a36Sopenharmony_ci
3462306a36Sopenharmony_ci#ifdef DEBUG
3562306a36Sopenharmony_ci	bpf_printk("BPF command: %d\n", op);
3662306a36Sopenharmony_ci#endif
3762306a36Sopenharmony_ci
3862306a36Sopenharmony_ci	/* Check if both hosts are in the same datacenter. For this
3962306a36Sopenharmony_ci	 * example they are if the 1st 5.5 bytes in the IPv6 address
4062306a36Sopenharmony_ci	 * are the same.
4162306a36Sopenharmony_ci	 */
4262306a36Sopenharmony_ci	if (skops->family == AF_INET6 &&
4362306a36Sopenharmony_ci	    skops->local_ip6[0] == skops->remote_ip6[0] &&
4462306a36Sopenharmony_ci	    (bpf_ntohl(skops->local_ip6[1]) & 0xfff00000) ==
4562306a36Sopenharmony_ci	    (bpf_ntohl(skops->remote_ip6[1]) & 0xfff00000)) {
4662306a36Sopenharmony_ci		switch (op) {
4762306a36Sopenharmony_ci		case BPF_SOCK_OPS_BASE_RTT:
4862306a36Sopenharmony_ci			n = bpf_getsockopt(skops, SOL_TCP, TCP_CONGESTION,
4962306a36Sopenharmony_ci					   cong, sizeof(cong));
5062306a36Sopenharmony_ci			if (!n && !__builtin_memcmp(cong, nv, sizeof(nv))) {
5162306a36Sopenharmony_ci				/* Set base_rtt to 80us */
5262306a36Sopenharmony_ci				rv = 80;
5362306a36Sopenharmony_ci			} else if (n) {
5462306a36Sopenharmony_ci				rv = n;
5562306a36Sopenharmony_ci			} else {
5662306a36Sopenharmony_ci				rv = -1;
5762306a36Sopenharmony_ci			}
5862306a36Sopenharmony_ci			break;
5962306a36Sopenharmony_ci		default:
6062306a36Sopenharmony_ci			rv = -1;
6162306a36Sopenharmony_ci		}
6262306a36Sopenharmony_ci	} else {
6362306a36Sopenharmony_ci		rv = -1;
6462306a36Sopenharmony_ci	}
6562306a36Sopenharmony_ci#ifdef DEBUG
6662306a36Sopenharmony_ci	bpf_printk("Returning %d\n", rv);
6762306a36Sopenharmony_ci#endif
6862306a36Sopenharmony_ci	skops->reply = rv;
6962306a36Sopenharmony_ci	return 1;
7062306a36Sopenharmony_ci}
7162306a36Sopenharmony_cichar _license[] SEC("license") = "GPL";
72