LineageOS/android_packages_modules_Connectivity
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge "Improve dumping IPv4 map entries." am: 26f799f2d7

Browse Source 
Original change: https://android-review.googlesource.com/c/platform/packages/modules/Connectivity/+/1737394

Change-Id: I9689a3ef866b2d4fd246663bd0909082b86a4624
This commit is contained in:
Nucca Chen
2021-06-15 08:02:33 +00:00
committed by Automerger Merge Worker
parent ddca01a6af 26f799f2d7
commit 7bd9af79a7
1 changed files with 30 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
Tethering/src/com/android/networkstack/tethering/BpfCoordinator.java
View File

@@ -48,6 +48,7 @@ import android.net.util.InterfaceParams;
import android.net.util.SharedLog; import android.net.util.SharedLog;
import android.net.util.TetheringUtils.ForwardedStats; import android.net.util.TetheringUtils.ForwardedStats;
import android.os.Handler; import android.os.Handler;
import android.os.SystemClock;
import android.system.ErrnoException; import android.system.ErrnoException;
import android.text.TextUtils; import android.text.TextUtils;
import android.util.Log; import android.util.Log;
@@ -871,7 +872,7 @@ public class BpfCoordinator {
} }
} }
private String ipv4RuleToString(Tether4Key key, Tether4Value value) { private String ipv4RuleToString(long now, Tether4Key key, Tether4Value value) {
final String private4, public4, dst4; final String private4, public4, dst4;
try { try {
private4 = InetAddress.getByAddress(key.src4).getHostAddress(); private4 = InetAddress.getByAddress(key.src4).getHostAddress();
@@ -880,29 +881,43 @@ public class BpfCoordinator {
} catch (UnknownHostException impossible) { } catch (UnknownHostException impossible) {
throw new AssertionError("4-byte array not valid IPv4 address!"); throw new AssertionError("4-byte array not valid IPv4 address!");
} }
return String.format("[%s] %d(%s) %s:%d -> %d(%s) %s:%d -> %s:%d", long ageMs = (now - value.lastUsed) / 1_000_000;
return String.format("[%s] %d(%s) %s:%d -> %d(%s) %s:%d -> %s:%d %dms",
key.dstMac, key.iif, getIfName(key.iif), private4, key.srcPort, key.dstMac, key.iif, getIfName(key.iif), private4, key.srcPort,
value.oif, getIfName(value.oif), value.oif, getIfName(value.oif),
public4, value.srcPort, dst4, key.dstPort); public4, value.srcPort, dst4, key.dstPort, ageMs);
}
private void dumpIpv4ForwardingRuleMap(long now, BpfMap<Tether4Key, Tether4Value> map,
IndentingPrintWriter pw) throws ErrnoException {
if (map == null) {
pw.println("No IPv4 support");
return;
}
if (map.isEmpty()) {
pw.println("No rules");
return;
}
map.forEach((k, v) -> pw.println(ipv4RuleToString(now, k, v)));
} }
private void dumpIpv4ForwardingRules(IndentingPrintWriter pw) { private void dumpIpv4ForwardingRules(IndentingPrintWriter pw) {
try (BpfMap<Tether4Key, Tether4Value> map = mDeps.getBpfUpstream4Map()) { final long now = SystemClock.elapsedRealtimeNanos();
if (map == null) {
pw.println("No IPv4 support"); try (BpfMap<Tether4Key, Tether4Value> upstreamMap = mDeps.getBpfUpstream4Map();
return; BpfMap<Tether4Key, Tether4Value> downstreamMap = mDeps.getBpfDownstream4Map()) {
} pw.println("IPv4 Upstream: [inDstMac] iif(iface) src -> nat -> dst");
if (map.isEmpty()) {
pw.println("No IPv4 rules");
return;
}
pw.println("IPv4: [inDstMac] iif(iface) src -> nat -> dst");
pw.increaseIndent(); pw.increaseIndent();
map.forEach((k, v) -> pw.println(ipv4RuleToString(k, v))); dumpIpv4ForwardingRuleMap(now, upstreamMap, pw);
pw.decreaseIndent();
pw.println("IPv4 Downstream: [inDstMac] iif(iface) src -> nat -> dst");
pw.increaseIndent();
dumpIpv4ForwardingRuleMap(now, downstreamMap, pw);
pw.decreaseIndent();
} catch (ErrnoException e) { } catch (ErrnoException e) {
pw.println("Error dumping IPv4 map: " + e); pw.println("Error dumping IPv4 map: " + e);
} }
pw.decreaseIndent();
} }
/** /**