arc: Move platform2/arc/network/ to platform2/patchpanel
Next step in the arc-networkd -> patchpanel rename, this patch moves the
location of the code.
BUG=b:151879931
TEST=units,flashed image to atlas
TEST=tasts arc.PlayStore, crostini.LaunchTerminal.download
Change-Id: I1b5cf8d670e1631d46f6449b725395157bf88dde
Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/platform2/+/2115863
Tested-by: Garrick Evans <garrick@chromium.org>
Commit-Queue: Garrick Evans <garrick@chromium.org>
Reviewed-by: Hidehiko Abe <hidehiko@chromium.org>
Reviewed-by: Eric Caruso <ejcaruso@chromium.org>
Reviewed-by: Chirantan Ekbote <chirantan@chromium.org>
Reviewed-by: Hugo Benichi <hugobenichi@google.com>
diff --git a/patchpanel/net_util_test.cc b/patchpanel/net_util_test.cc
new file mode 100644
index 0000000..938fac6
--- /dev/null
+++ b/patchpanel/net_util_test.cc
@@ -0,0 +1,340 @@
+// Copyright 2019 The Chromium OS Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "patchpanel/net_util.h"
+
+#include <arpa/inet.h>
+#include <byteswap.h>
+#include <net/ethernet.h>
+
+#include <gtest/gtest.h>
+
+namespace patchpanel {
+
+const uint8_t ping_frame[] =
+ "\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x86\xdd\x60\x0b"
+ "\x8d\xb4\x00\x40\x3a\x40\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00"
+ "\x00\x00\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00"
+ "\x00\x00\x00\x00\x00\x01\x80\x00\xb9\x3c\x13\x8f\x00\x09\xde\x6a"
+ "\x78\x5d\x00\x00\x00\x00\x8e\x13\x0f\x00\x00\x00\x00\x00\x10\x11"
+ "\x12\x13\x14\x15\x16\x17\x18\x19\x1a\x1b\x1c\x1d\x1e\x1f\x20\x21"
+ "\x22\x23\x24\x25\x26\x27\x28\x29\x2a\x2b\x2c\x2d\x2e\x2f\x30\x31"
+ "\x32\x33\x34\x35\x36\x37";
+
+const uint8_t rs_frame[] =
+ "\x33\x33\x00\x00\x00\x02\x1a\x9b\x82\xbd\xc0\xa0\x86\xdd\x60\x00"
+ "\x00\x00\x00\x10\x3a\xff\xfe\x80\x00\x00\x00\x00\x00\x00\x2d\x75"
+ "\xb2\x80\x97\x83\x76\xbf\xff\x02\x00\x00\x00\x00\x00\x00\x00\x00"
+ "\x00\x00\x00\x00\x00\x02\x85\x00\x2f\xfc\x00\x00\x00\x00\x01\x01"
+ "\x1a\x9b\x82\xbd\xc0\xa0";
+
+const uint8_t ip_header[] =
+ "\x45\x00\x00\x3d\x7c\x8e\x40\x00\x40\x11\x3d\x36\x64\x73\x5c\x02"
+ "\x64\x73\x5c\x03";
+
+const uint8_t udp_packet[] =
+ "\x45\x00\x00\x65\x44\xf7\x40\x00\x3f\x11\x7d\x62\x64\x57\x54\x5a"
+ "\x64\x73\x5c\x0a\x9d\x6c\x09\xa4\x00\x51\x58\xfb\x70\x72\x6f\x74"
+ "\x6f\x63\x6f\x6c\x20\x20\x61\x73\x73\x75\x6d\x65\x73\x20\x20\x74"
+ "\x68\x61\x74\x20\x74\x68\x65\x20\x49\x6e\x74\x65\x72\x6e\x65\x74"
+ "\x20\x20\x50\x72\x6f\x74\x6f\x63\x6f\x6c\x20\x20\x28\x49\x50\x29"
+ "\x20\x20\x5b\x31\x5d\x20\x69\x73\x20\x75\x73\x65\x64\x20\x61\x73"
+ "\x20\x74\x68\x65\x0a";
+
+TEST(Byteswap, 16bits) {
+ uint32_t test_cases[] = {
+ 0x0000, 0x0001, 0x1000, 0xffff, 0x2244, 0xfffe,
+ };
+
+ for (uint32_t value : test_cases) {
+ EXPECT_EQ(Byteswap16(value), bswap_16(value));
+ EXPECT_EQ(ntohs(value), Ntohs(value));
+ EXPECT_EQ(htons(value), Htons(value));
+ }
+}
+
+TEST(Byteswap, 32bits) {
+ uint32_t test_cases[] = {
+ 0x00000000, 0x00000001, 0x10000000, 0xffffffff, 0x11335577, 0xdeadbeef,
+ };
+
+ for (uint32_t value : test_cases) {
+ EXPECT_EQ(Byteswap32(value), bswap_32(value));
+ EXPECT_EQ(ntohl(value), Ntohl(value));
+ EXPECT_EQ(htonl(value), Htonl(value));
+ }
+}
+
+TEST(Ipv4, CreationAndStringConversion) {
+ struct {
+ std::string literal_address;
+ uint8_t bytes[4];
+ } test_cases[] = {
+ {"0.0.0.0", {0, 0, 0, 0}},
+ {"8.8.8.8", {8, 8, 8, 8}},
+ {"8.8.4.4", {8, 8, 4, 4}},
+ {"192.168.0.0", {192, 168, 0, 0}},
+ {"100.115.92.5", {100, 115, 92, 5}},
+ {"100.115.92.6", {100, 115, 92, 6}},
+ {"224.0.0.251", {224, 0, 0, 251}},
+ {"255.255.255.255", {255, 255, 255, 255}},
+ };
+
+ for (auto const& test_case : test_cases) {
+ uint32_t addr = Ipv4Addr(test_case.bytes[0], test_case.bytes[1],
+ test_case.bytes[2], test_case.bytes[3]);
+ EXPECT_EQ(test_case.literal_address, IPv4AddressToString(addr));
+ }
+}
+
+TEST(Ipv4, CreationAndCidrStringConversion) {
+ struct {
+ std::string literal_address;
+ uint8_t bytes[4];
+ uint32_t prefix_length;
+ } test_cases[] = {
+ {"0.0.0.0/0", {0, 0, 0, 0}, 0},
+ {"192.168.0.0/24", {192, 168, 0, 0}, 24},
+ {"100.115.92.5/30", {100, 115, 92, 5}, 30},
+ {"100.115.92.6/30", {100, 115, 92, 6}, 30},
+ };
+
+ for (auto const& test_case : test_cases) {
+ uint32_t addr = Ipv4Addr(test_case.bytes[0], test_case.bytes[1],
+ test_case.bytes[2], test_case.bytes[3]);
+ EXPECT_EQ(test_case.literal_address,
+ IPv4AddressToCidrString(addr, test_case.prefix_length));
+ }
+}
+
+TEST(Ipv4, IpChecksum) {
+ alignas(4) uint8_t buffer[IP_MAXPACKET];
+
+ iphdr* ip = reinterpret_cast<iphdr*>(buffer);
+
+ memcpy(buffer, ip_header, sizeof(ip_header));
+ uint16_t ori_cksum = ip->check;
+ ip->check = 0;
+ EXPECT_EQ(ori_cksum, Ipv4Checksum(ip));
+}
+
+TEST(Ipv4, UdpChecksum) {
+ alignas(4) uint8_t buffer[IP_MAXPACKET];
+
+ iphdr* ip = reinterpret_cast<iphdr*>(buffer);
+ udphdr* udp = reinterpret_cast<udphdr*>(buffer + sizeof(iphdr));
+
+ memcpy(buffer, udp_packet, sizeof(udp_packet));
+ uint16_t ori_cksum = udp->check;
+ udp->check = 0;
+ EXPECT_EQ(ori_cksum, Udpv4Checksum(ip, udp));
+}
+
+TEST(Ipv6, IcmpChecksum) {
+ alignas(4) uint8_t buffer_extended[IP_MAXPACKET + ETHER_HDR_LEN + 2];
+ uint8_t* buffer = buffer_extended + 2;
+
+ ip6_hdr* ip6 = reinterpret_cast<ip6_hdr*>(buffer + ETHER_HDR_LEN);
+ icmp6_hdr* icmp6 =
+ reinterpret_cast<icmp6_hdr*>(buffer + ETHER_HDR_LEN + sizeof(ip6_hdr));
+
+ memcpy(buffer, ping_frame, sizeof(ping_frame));
+ uint16_t ori_cksum = icmp6->icmp6_cksum;
+ icmp6->icmp6_cksum = 0;
+ EXPECT_EQ(ori_cksum, Icmpv6Checksum(ip6, icmp6));
+
+ memcpy(buffer, rs_frame, sizeof(rs_frame));
+ ori_cksum = icmp6->icmp6_cksum;
+ icmp6->icmp6_cksum = 0;
+ EXPECT_EQ(ori_cksum, Icmpv6Checksum(ip6, icmp6));
+}
+
+TEST(Ipv4, BroadcastAddr) {
+ uint32_t base = Ipv4Addr(100, 115, 92, 0);
+ struct {
+ uint32_t prefix_len;
+ uint32_t want;
+ } test_cases[] = {
+ {24, Ipv4Addr(100, 115, 92, 255)},
+ {29, Ipv4Addr(100, 115, 92, 7)},
+ {30, Ipv4Addr(100, 115, 92, 3)},
+ {31, Ipv4Addr(100, 115, 92, 1)},
+ };
+
+ for (const auto& t : test_cases) {
+ EXPECT_EQ(Ipv4BroadcastAddr(base, t.prefix_len), t.want);
+ }
+}
+
+TEST(IPv4, SetSockaddrIn) {
+ struct sockaddr_storage sockaddr = {};
+ std::ostringstream stream;
+
+ SetSockaddrIn((struct sockaddr*)&sockaddr, 0);
+ stream << sockaddr;
+ EXPECT_EQ("{family: AF_INET, port: 0, addr: 0.0.0.0}", stream.str());
+
+ stream.str("");
+ SetSockaddrIn((struct sockaddr*)&sockaddr, Ipv4Addr(192, 168, 1, 37));
+ stream << sockaddr;
+ EXPECT_EQ("{family: AF_INET, port: 0, addr: 192.168.1.37}", stream.str());
+}
+
+TEST(PrettyPrint, SocketAddrIn) {
+ struct sockaddr_in ipv4_sockaddr = {};
+ std::ostringstream stream;
+
+ stream << ipv4_sockaddr;
+ EXPECT_EQ("{family: AF_INET, port: 0, addr: 0.0.0.0}", stream.str());
+
+ ipv4_sockaddr.sin_family = AF_INET;
+ ipv4_sockaddr.sin_port = htons(1234);
+ ipv4_sockaddr.sin_addr.s_addr = Ipv4Addr(100, 115, 92, 10);
+ std::string expected_output =
+ "{family: AF_INET, port: 1234, addr: 100.115.92.10}";
+
+ stream.str("");
+ stream << ipv4_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ stream.str("");
+ stream << (const struct sockaddr&)ipv4_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ struct sockaddr_storage sockaddr_storage = {};
+ memcpy(&sockaddr_storage, &ipv4_sockaddr, sizeof(ipv4_sockaddr));
+
+ stream.str("");
+ stream << sockaddr_storage;
+ EXPECT_EQ(expected_output, stream.str());
+}
+
+TEST(PrettyPrint, SocketAddrIn6) {
+ struct sockaddr_in6 ipv6_sockaddr = {};
+ std::ostringstream stream;
+
+ stream << ipv6_sockaddr;
+ EXPECT_EQ("{family: AF_INET6, port: 0, addr: ::}", stream.str());
+
+ ipv6_sockaddr.sin6_family = AF_INET6;
+ ipv6_sockaddr.sin6_port = htons(2345);
+ unsigned char addr[16] = {0x20, 0x01, 0xd, 0xb1, 0, 0, 0, 0,
+ 0xab, 0xcd, 0x12, 0x34, 0x56, 0x78, 0xfe, 0xaa};
+ memcpy(ipv6_sockaddr.sin6_addr.s6_addr, addr, sizeof(addr));
+ std::string expected_output =
+ "{family: AF_INET6, port: 2345, addr: 2001:db1::abcd:1234:5678:feaa}";
+
+ stream.str("");
+ stream << ipv6_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ stream.str("");
+ stream << (const struct sockaddr&)ipv6_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ struct sockaddr_storage sockaddr_storage = {};
+ memcpy(&sockaddr_storage, &ipv6_sockaddr, sizeof(ipv6_sockaddr));
+
+ stream.str("");
+ stream << sockaddr_storage;
+ EXPECT_EQ(expected_output, stream.str());
+}
+
+TEST(PrettyPrint, SocketAddrVsock) {
+ struct sockaddr_vm vm_sockaddr = {};
+ std::ostringstream stream;
+
+ stream << vm_sockaddr;
+ EXPECT_EQ("{family: AF_VSOCK, port: 0, cid: 0}", stream.str());
+
+ vm_sockaddr.svm_family = AF_VSOCK;
+ vm_sockaddr.svm_port = 5555;
+ vm_sockaddr.svm_cid = 4;
+ std::string expected_output = "{family: AF_VSOCK, port: 5555, cid: 4}";
+
+ stream.str("");
+ stream << vm_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ stream.str("");
+ stream << (const struct sockaddr&)vm_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ struct sockaddr_storage sockaddr_storage = {};
+ memcpy(&sockaddr_storage, &vm_sockaddr, sizeof(vm_sockaddr));
+
+ stream.str("");
+ stream << sockaddr_storage;
+ EXPECT_EQ(expected_output, stream.str());
+}
+
+TEST(PrettyPrint, SocketAddrUnix) {
+ struct sockaddr_un unix_sockaddr = {};
+ std::ostringstream stream;
+
+ stream << unix_sockaddr;
+ EXPECT_EQ("{family: AF_UNIX, path: @}", stream.str());
+
+ // Fill |sun_path| with an invalid non-null-terminated c string.
+ std::string bogus_output = "{family: AF_UNIX, path: ";
+ for (size_t i = 0; i < sizeof(unix_sockaddr.sun_path); i++) {
+ unix_sockaddr.sun_path[i] = 'a';
+ bogus_output += 'a';
+ }
+ bogus_output += '}';
+ stream.str("");
+ stream << unix_sockaddr;
+ EXPECT_EQ(bogus_output, stream.str());
+
+ memset(&unix_sockaddr, 0, sizeof(unix_sockaddr));
+ unix_sockaddr.sun_family = AF_UNIX;
+ std::string sun_path = "/run/arc/adb";
+ memcpy(&unix_sockaddr.sun_path, sun_path.c_str(), strlen(sun_path.c_str()));
+ std::string expected_output = "{family: AF_UNIX, path: /run/arc/adb}";
+
+ stream.str("");
+ stream << unix_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ stream.str("");
+ stream << (const struct sockaddr&)unix_sockaddr;
+ EXPECT_EQ(expected_output, stream.str());
+
+ struct sockaddr_storage sockaddr_storage = {};
+ memcpy(&sockaddr_storage, &unix_sockaddr, sizeof(unix_sockaddr));
+
+ stream.str("");
+ stream << sockaddr_storage;
+ EXPECT_EQ(expected_output, stream.str());
+}
+
+TEST(PrettyPrint, Rtentry) {
+ struct rtentry route;
+ memset(&route, 0, sizeof(route));
+ std::ostringstream stream;
+
+ stream << route;
+ EXPECT_EQ(
+ "{rt_dst: {unset}, rt_genmask: {unset}, rt_gateway: {unset}, rt_dev: "
+ "null, rt_flags: 0}",
+ stream.str());
+
+ SetSockaddrIn(&route.rt_dst, Ipv4Addr(100, 115, 92, 128));
+ SetSockaddrIn(&route.rt_genmask, Ipv4Addr(255, 255, 255, 252));
+ SetSockaddrIn(&route.rt_gateway, Ipv4Addr(192, 168, 1, 1));
+ std::string rt_dev = "eth0";
+ route.rt_dev = (char*)rt_dev.c_str();
+ route.rt_flags =
+ RTF_UP | RTF_GATEWAY | RTF_DYNAMIC | RTF_MODIFIED | RTF_REJECT;
+ stream.str("");
+ stream << route;
+ EXPECT_EQ(
+ "{rt_dst: {family: AF_INET, port: 0, addr: 100.115.92.128}, rt_genmask: "
+ "{family: AF_INET, port: 0, addr: 255.255.255.252}, rt_gateway: {family: "
+ "AF_INET, port: 0, addr: 192.168.1.1}, rt_dev: eth0, rt_flags: RTF_UP | "
+ "RTF_GATEWAY | RTF_DYNAMIC | RTF_MODIFIED | RTF_REJECT}",
+ stream.str());
+}
+
+} // namespace patchpanel