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

Merge "Send message to add/remove NAT-T keepalive packet filter."

Browse Source 
am: 29df9e7e8f

Change-Id: I3e35d73a38cfbd0a29ad3f1f859b2d6fdb514ff1
This commit is contained in:
Aaron Huang
2019-05-10 07:19:27 -07:00
committed by android-build-merger
parent e3950cf24a 29df9e7e8f
commit c72bc8eea1
1 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
services/core/java/com/android/server/connectivity/KeepaliveTracker.java
View File

@@ -327,6 +327,8 @@ public class KeepaliveTracker {
Log.d(TAG, "Starting keepalive " + mSlot + " on " + mNai.name()); Log.d(TAG, "Starting keepalive " + mSlot + " on " + mNai.name());
switch (mType) { switch (mType) {
case TYPE_NATT: case TYPE_NATT:
mNai.asyncChannel.sendMessage(
CMD_ADD_KEEPALIVE_PACKET_FILTER, slot, 0 /* Unused */, mPacket);
mNai.asyncChannel mNai.asyncChannel
.sendMessage(CMD_START_SOCKET_KEEPALIVE, slot, mInterval, mPacket); .sendMessage(CMD_START_SOCKET_KEEPALIVE, slot, mInterval, mPacket);
break; break;
@@ -337,9 +339,8 @@ public class KeepaliveTracker {
handleStopKeepalive(mNai, mSlot, ERROR_INVALID_SOCKET); handleStopKeepalive(mNai, mSlot, ERROR_INVALID_SOCKET);
return; return;
} }
mNai.asyncChannel mNai.asyncChannel.sendMessage(
.sendMessage(CMD_ADD_KEEPALIVE_PACKET_FILTER, slot, 0 /* Unused */, CMD_ADD_KEEPALIVE_PACKET_FILTER, slot, 0 /* Unused */, mPacket);
mPacket);
// TODO: check result from apf and notify of failure as needed. // TODO: check result from apf and notify of failure as needed.
mNai.asyncChannel mNai.asyncChannel
.sendMessage(CMD_START_SOCKET_KEEPALIVE, slot, mInterval, mPacket); .sendMessage(CMD_START_SOCKET_KEEPALIVE, slot, mInterval, mPacket);
@@ -375,14 +376,17 @@ public class KeepaliveTracker {
return; return;
default: default:
mStartedState = STOPPING; mStartedState = STOPPING;
if (mType == TYPE_NATT) { switch (mType) {
mNai.asyncChannel.sendMessage(CMD_STOP_SOCKET_KEEPALIVE, mSlot); case TYPE_TCP:
} else if (mType == TYPE_TCP) { mTcpController.stopSocketMonitor(mSlot);
mNai.asyncChannel.sendMessage(CMD_STOP_SOCKET_KEEPALIVE, mSlot); // fall through
mNai.asyncChannel.sendMessage(CMD_REMOVE_KEEPALIVE_PACKET_FILTER, mSlot); case TYPE_NATT:
mTcpController.stopSocketMonitor(mSlot); mNai.asyncChannel.sendMessage(CMD_STOP_SOCKET_KEEPALIVE, mSlot);
} else { mNai.asyncChannel.sendMessage(CMD_REMOVE_KEEPALIVE_PACKET_FILTER,
Log.wtf(TAG, "Stopping keepalive with unknown type: " + mType); mSlot);
break;
default:
Log.wtf(TAG, "Stopping keepalive with unknown type: " + mType);
} }
} }