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