Merge changes from topic "tcp_keepalive_fix" am: eada640d5d
Original change: https://android-review.googlesource.com/c/platform/frameworks/base/+/1494039 MUST ONLY BE SUBMITTED BY AUTOMERGER Change-Id: Ic9e330a2bd8dbb701db0e5b73c1954670d4988fc
This commit is contained in:
@@ -19,12 +19,16 @@ package android.net.util;
|
|||||||
import static android.net.SocketKeepalive.ERROR_INVALID_IP_ADDRESS;
|
import static android.net.SocketKeepalive.ERROR_INVALID_IP_ADDRESS;
|
||||||
|
|
||||||
import android.annotation.NonNull;
|
import android.annotation.NonNull;
|
||||||
|
import android.annotation.Nullable;
|
||||||
import android.net.InvalidPacketException;
|
import android.net.InvalidPacketException;
|
||||||
|
import android.net.KeepalivePacketData;
|
||||||
import android.net.NattKeepalivePacketData;
|
import android.net.NattKeepalivePacketData;
|
||||||
import android.net.NattKeepalivePacketDataParcelable;
|
import android.net.NattKeepalivePacketDataParcelable;
|
||||||
import android.net.TcpKeepalivePacketData;
|
import android.net.TcpKeepalivePacketData;
|
||||||
import android.net.TcpKeepalivePacketDataParcelable;
|
import android.net.TcpKeepalivePacketDataParcelable;
|
||||||
|
import android.os.Build;
|
||||||
import android.system.OsConstants;
|
import android.system.OsConstants;
|
||||||
|
import android.util.Log;
|
||||||
|
|
||||||
import com.android.net.module.util.IpUtils;
|
import com.android.net.module.util.IpUtils;
|
||||||
|
|
||||||
@@ -45,6 +49,8 @@ public final class KeepalivePacketDataUtil {
|
|||||||
private static final int IPV6_HEADER_LENGTH = 40;
|
private static final int IPV6_HEADER_LENGTH = 40;
|
||||||
private static final int TCP_HEADER_LENGTH = 20;
|
private static final int TCP_HEADER_LENGTH = 20;
|
||||||
|
|
||||||
|
private static final String TAG = KeepalivePacketDataUtil.class.getSimpleName();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Convert a NattKeepalivePacketData to a NattKeepalivePacketDataParcelable.
|
* Convert a NattKeepalivePacketData to a NattKeepalivePacketDataParcelable.
|
||||||
*/
|
*/
|
||||||
@@ -151,4 +157,67 @@ public final class KeepalivePacketDataUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// TODO: add buildV6Packet.
|
// TODO: add buildV6Packet.
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Get a {@link TcpKeepalivePacketDataParcelable} from {@link KeepalivePacketData}, if the
|
||||||
|
* generic class actually contains TCP keepalive data.
|
||||||
|
*
|
||||||
|
* @deprecated This method is used on R platforms where android.net.TcpKeepalivePacketData was
|
||||||
|
* not yet system API. Newer platforms should use android.net.TcpKeepalivePacketData directly.
|
||||||
|
*
|
||||||
|
* @param data A {@link KeepalivePacketData} that may contain TCP keepalive data.
|
||||||
|
* @return A parcelable containing TCP keepalive data, or null if the input data does not
|
||||||
|
* contain TCP keepalive data.
|
||||||
|
*/
|
||||||
|
@Deprecated
|
||||||
|
@SuppressWarnings("AndroidFrameworkCompatChange") // API version check used to Log.wtf
|
||||||
|
@Nullable
|
||||||
|
public static TcpKeepalivePacketDataParcelable parseTcpKeepalivePacketData(
|
||||||
|
@Nullable KeepalivePacketData data) {
|
||||||
|
if (data == null) return null;
|
||||||
|
|
||||||
|
if (Build.VERSION.SDK_INT > Build.VERSION_CODES.R) {
|
||||||
|
Log.wtf(TAG, "parseTcpKeepalivePacketData should not be used after R, use "
|
||||||
|
+ "TcpKeepalivePacketData instead.");
|
||||||
|
}
|
||||||
|
|
||||||
|
// Reconstruct TcpKeepalivePacketData from the packet contained in KeepalivePacketData
|
||||||
|
final ByteBuffer buffer = ByteBuffer.wrap(data.getPacket());
|
||||||
|
buffer.order(ByteOrder.BIG_ENDIAN);
|
||||||
|
|
||||||
|
// Most of the fields are accessible from the KeepalivePacketData superclass: instead of
|
||||||
|
// using Struct to parse everything, just extract the extra fields necessary for
|
||||||
|
// TcpKeepalivePacketData.
|
||||||
|
final int tcpSeq;
|
||||||
|
final int tcpAck;
|
||||||
|
final int wndSize;
|
||||||
|
final int ipTos;
|
||||||
|
final int ttl;
|
||||||
|
try {
|
||||||
|
// This only support IPv4, because TcpKeepalivePacketData only supports IPv4 for R and
|
||||||
|
// below, and this method should not be used on newer platforms.
|
||||||
|
tcpSeq = buffer.getInt(IPV4_HEADER_LENGTH + 4);
|
||||||
|
tcpAck = buffer.getInt(IPV4_HEADER_LENGTH + 8);
|
||||||
|
wndSize = buffer.getShort(IPV4_HEADER_LENGTH + 14);
|
||||||
|
ipTos = buffer.get(1);
|
||||||
|
ttl = buffer.get(8);
|
||||||
|
} catch (IndexOutOfBoundsException e) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
final TcpKeepalivePacketDataParcelable p = new TcpKeepalivePacketDataParcelable();
|
||||||
|
p.srcAddress = data.getSrcAddress().getAddress();
|
||||||
|
p.srcPort = data.getSrcPort();
|
||||||
|
p.dstAddress = data.getDstAddress().getAddress();
|
||||||
|
p.dstPort = data.getDstPort();
|
||||||
|
p.seq = tcpSeq;
|
||||||
|
p.ack = tcpAck;
|
||||||
|
// TcpKeepalivePacketData could actually use non-zero wndScale, but this does not affect
|
||||||
|
// actual functionality as generated packets will be the same (no wndScale option added)
|
||||||
|
p.rcvWnd = wndSize;
|
||||||
|
p.rcvWndScale = 0;
|
||||||
|
p.tos = ipTos;
|
||||||
|
p.ttl = ttl;
|
||||||
|
return p;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -20,6 +20,7 @@ import static com.android.testutils.ParcelUtils.assertParcelingIsLossless;
|
|||||||
|
|
||||||
import static org.junit.Assert.assertArrayEquals;
|
import static org.junit.Assert.assertArrayEquals;
|
||||||
import static org.junit.Assert.assertEquals;
|
import static org.junit.Assert.assertEquals;
|
||||||
|
import static org.junit.Assert.assertTrue;
|
||||||
import static org.junit.Assert.fail;
|
import static org.junit.Assert.fail;
|
||||||
|
|
||||||
import android.net.util.KeepalivePacketDataUtil;
|
import android.net.util.KeepalivePacketDataUtil;
|
||||||
@@ -156,4 +157,49 @@ public final class KeepalivePacketDataUtilTest {
|
|||||||
+ " ack: 572662306, rcvWnd: 48000, rcvWndScale: 2, tos: 4, ttl: 64}";
|
+ " ack: 572662306, rcvWnd: 48000, rcvWndScale: 2, tos: 4, ttl: 64}";
|
||||||
assertEquals(expected, resultData.toString());
|
assertEquals(expected, resultData.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testParseTcpKeepalivePacketData() throws Exception {
|
||||||
|
final int srcPort = 1234;
|
||||||
|
final int dstPort = 4321;
|
||||||
|
final int sequence = 0x11111111;
|
||||||
|
final int ack = 0x22222222;
|
||||||
|
final int wnd = 4800;
|
||||||
|
final int wndScale = 2;
|
||||||
|
final int tos = 4;
|
||||||
|
final int ttl = 64;
|
||||||
|
final TcpKeepalivePacketDataParcelable testParcel = new TcpKeepalivePacketDataParcelable();
|
||||||
|
testParcel.srcAddress = IPV4_KEEPALIVE_SRC_ADDR;
|
||||||
|
testParcel.srcPort = srcPort;
|
||||||
|
testParcel.dstAddress = IPV4_KEEPALIVE_DST_ADDR;
|
||||||
|
testParcel.dstPort = dstPort;
|
||||||
|
testParcel.seq = sequence;
|
||||||
|
testParcel.ack = ack;
|
||||||
|
testParcel.rcvWnd = wnd;
|
||||||
|
testParcel.rcvWndScale = wndScale;
|
||||||
|
testParcel.tos = tos;
|
||||||
|
testParcel.ttl = ttl;
|
||||||
|
|
||||||
|
final KeepalivePacketData testData =
|
||||||
|
KeepalivePacketDataUtil.fromStableParcelable(testParcel);
|
||||||
|
final TcpKeepalivePacketDataParcelable parsedParcelable =
|
||||||
|
KeepalivePacketDataUtil.parseTcpKeepalivePacketData(testData);
|
||||||
|
final TcpKeepalivePacketData roundTripData =
|
||||||
|
KeepalivePacketDataUtil.fromStableParcelable(parsedParcelable);
|
||||||
|
|
||||||
|
// Generated packet is the same, but rcvWnd / wndScale will differ if scale is non-zero
|
||||||
|
assertTrue(testData.getPacket().length > 0);
|
||||||
|
assertArrayEquals(testData.getPacket(), roundTripData.getPacket());
|
||||||
|
|
||||||
|
testParcel.rcvWndScale = 0;
|
||||||
|
final KeepalivePacketData noScaleTestData =
|
||||||
|
KeepalivePacketDataUtil.fromStableParcelable(testParcel);
|
||||||
|
final TcpKeepalivePacketDataParcelable noScaleParsedParcelable =
|
||||||
|
KeepalivePacketDataUtil.parseTcpKeepalivePacketData(noScaleTestData);
|
||||||
|
final TcpKeepalivePacketData noScaleRoundTripData =
|
||||||
|
KeepalivePacketDataUtil.fromStableParcelable(noScaleParsedParcelable);
|
||||||
|
assertEquals(noScaleTestData, noScaleRoundTripData);
|
||||||
|
assertTrue(noScaleTestData.getPacket().length > 0);
|
||||||
|
assertArrayEquals(noScaleTestData.getPacket(), noScaleRoundTripData.getPacket());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,6 +21,7 @@ rule android.net.ProvisioningConfigurationParcelable* com.android.wifi.x.@0
|
|||||||
rule android.net.ResolverParamsParcel* com.android.wifi.x.@0
|
rule android.net.ResolverParamsParcel* com.android.wifi.x.@0
|
||||||
rule android.net.RouteInfoParcel* com.android.wifi.x.@0
|
rule android.net.RouteInfoParcel* com.android.wifi.x.@0
|
||||||
rule android.net.ScanResultInfoParcelable* com.android.wifi.x.@0
|
rule android.net.ScanResultInfoParcelable* com.android.wifi.x.@0
|
||||||
|
rule android.net.TcpKeepalivePacketDataParcelable* com.android.wifi.x.@0
|
||||||
rule android.net.TetherConfigParcel* com.android.wifi.x.@0
|
rule android.net.TetherConfigParcel* com.android.wifi.x.@0
|
||||||
rule android.net.TetherOffloadRuleParcel* com.android.wifi.x.@0
|
rule android.net.TetherOffloadRuleParcel* com.android.wifi.x.@0
|
||||||
rule android.net.TetherStatsParcel* com.android.wifi.x.@0
|
rule android.net.TetherStatsParcel* com.android.wifi.x.@0
|
||||||
@@ -43,7 +44,6 @@ rule android.net.DhcpResults* com.android.wifi.x.@0
|
|||||||
rule android.net.InterfaceConfiguration* com.android.wifi.x.@0
|
rule android.net.InterfaceConfiguration* com.android.wifi.x.@0
|
||||||
rule android.net.IpMemoryStore* com.android.wifi.x.@0
|
rule android.net.IpMemoryStore* com.android.wifi.x.@0
|
||||||
rule android.net.NetworkMonitorManager* com.android.wifi.x.@0
|
rule android.net.NetworkMonitorManager* com.android.wifi.x.@0
|
||||||
rule android.net.TcpKeepalivePacketData* com.android.wifi.x.@0
|
|
||||||
rule android.net.NetworkFactory* com.android.wifi.x.@0
|
rule android.net.NetworkFactory* com.android.wifi.x.@0
|
||||||
rule android.net.ip.IpClientCallbacks* com.android.wifi.x.@0
|
rule android.net.ip.IpClientCallbacks* com.android.wifi.x.@0
|
||||||
rule android.net.ip.IpClientManager* com.android.wifi.x.@0
|
rule android.net.ip.IpClientManager* com.android.wifi.x.@0
|
||||||
|
|||||||
Reference in New Issue
Block a user