commit 66ce72dad011b1c6ee6e1adc5c19dbcbb659ee71
author Maciej Żenczykowski <maze@google.com> Wed Feb 12 05:05:00 2020 -0800
committer Maciej Żenczykowski <maze@google.com> Sat Feb 15 02:47:04 2020 +0000
tree f3d36d1b6cd351a3eae4e6e31c7eaf27c86cd254
parent adff5426c9a389c7bd92dde680cbff19c915010c

OffloadUtils - implement getTetherStatsMapFd()

Test: build, atest
Signed-off-by: Maciej Żenczykowski <maze@google.com>
Change-Id: Ibc2d96000a712eee6d64006b063dc50bfbab15c0

server/OffloadUtils.h

diff --git a/server/OffloadUtils.h b/server/OffloadUtils.h
index f2a4dc2..1fb482b 100644
--- a/server/OffloadUtils.h
+++ b/server/OffloadUtils.h
@@ -64,6 +64,11 @@
     return (fd == -1) ? -errno : fd;
 }
 
+inline int getTetherStatsMapFd(void) {
+    const int fd = bpf::bpfFdGet(TETHER_STATS_MAP_PATH, 0);
+    return (fd == -1) ? -errno : fd;
+}
+
 int openNetlinkSocket(void);
 
 int doTcQdiscClsact(int fd, int ifIndex, uint16_t nlMsgType, uint16_t nlMsgFlags);

server/OffloadUtilsTest.cpp

diff --git a/server/OffloadUtilsTest.cpp b/server/OffloadUtilsTest.cpp
index e4316a7..8179563 100644
--- a/server/OffloadUtilsTest.cpp
+++ b/server/OffloadUtilsTest.cpp
@@ -141,6 +141,14 @@
     close(fd);
 }
 
+TEST_F(OffloadUtilsTest, GetTetherStatsMapFd) {
+    SKIP_IF_BPF_NOT_SUPPORTED;
+
+    int fd = getTetherStatsMapFd();
+    ASSERT_LE(3, fd);  // 0,1,2 - stdin/out/err, thus 3 <= fd
+    close(fd);
+}
+
 TEST_F(OffloadUtilsTest, TryOpeningNetlinkSocket) {
     int fd = openNetlinkSocket();
     ASSERT_LE(3, fd);