blob: 8af1797a9dd75edc1d969cabcc58fd87042bcab4 [file] [log] [blame]
Christopher Wileyd2896662016-05-19 11:54:54 -07001/*
2 * Copyright (C) 2016 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
Erik Kline7a4ccc62018-08-27 17:26:47 +090017package android.net.ip;
Christopher Wileyd2896662016-05-19 11:54:54 -070018
markchien986750b2019-12-06 15:24:53 +080019import static android.net.RouteInfo.RTN_UNICAST;
Treehugger Robot86d212b2020-03-30 04:23:55 +000020import static android.net.TetheringManager.TetheringRequest.checkStaticAddressConfiguration;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +090021import static android.net.dhcp.IDhcpServer.STATUS_SUCCESS;
Erik Kline94ae4c92017-06-13 21:32:10 +090022import static android.net.util.NetworkConstants.RFC7421_PREFIX_LENGTH;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +090023import static android.net.util.NetworkConstants.asByte;
Mark Chiendb6befb2020-05-29 22:07:37 +000024import static android.net.util.PrefixUtils.asIpPrefix;
markchien986750b2019-12-06 15:24:53 +080025import static android.net.util.TetheringMessageBase.BASE_IPSERVER;
Automerger Merge Worker3d330ff2020-03-16 04:06:46 +000026import static android.system.OsConstants.RT_SCOPE_UNIVERSE;
Erik Kline94ae4c92017-06-13 21:32:10 +090027
Remi NGUYEN VANeee629f2020-06-08 15:40:06 +090028import static com.android.net.module.util.Inet4AddressUtils.intToInet4AddressHTH;
29
Erik Kline94ae4c92017-06-13 21:32:10 +090030import android.net.INetd;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +090031import android.net.INetworkStackStatusCallback;
Erik Kline94ae4c92017-06-13 21:32:10 +090032import android.net.IpPrefix;
Christopher Wileyd2896662016-05-19 11:54:54 -070033import android.net.LinkAddress;
Erik Kline1eb8c692016-07-08 17:21:26 +090034import android.net.LinkProperties;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090035import android.net.MacAddress;
Erik Kline94ae4c92017-06-13 21:32:10 +090036import android.net.RouteInfo;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090037import android.net.TetheredClient;
markchien9e44cde2019-12-25 19:40:32 +080038import android.net.TetheringManager;
Automerger Merge Worker37a22752020-03-17 16:59:57 +000039import android.net.TetheringRequestParcel;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090040import android.net.dhcp.DhcpLeaseParcelable;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +090041import android.net.dhcp.DhcpServerCallbacks;
42import android.net.dhcp.DhcpServingParamsParcel;
43import android.net.dhcp.DhcpServingParamsParcelExt;
Xiao Ma3eab4922020-04-06 11:24:48 +000044import android.net.dhcp.IDhcpEventCallbacks;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +090045import android.net.dhcp.IDhcpServer;
Lorenzo Colittifb19f492020-02-14 01:06:35 +090046import android.net.ip.IpNeighborMonitor.NeighborEvent;
Erik Kline94ae4c92017-06-13 21:32:10 +090047import android.net.ip.RouterAdvertisementDaemon.RaParams;
markchien92b8e7f2020-01-07 14:43:17 +080048import android.net.shared.NetdUtils;
49import android.net.shared.RouteUtils;
Erik Kline8bd00d52017-12-08 17:47:50 +090050import android.net.util.InterfaceParams;
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +090051import android.net.util.InterfaceSet;
Xiao Ma5a428f52020-05-14 06:52:59 +000052import android.net.util.PrefixUtils;
Erik Kline7747fd42017-05-12 16:52:48 +090053import android.net.util.SharedLog;
Lorenzo Colittifb19f492020-02-14 01:06:35 +090054import android.os.Handler;
Christopher Wileyd2896662016-05-19 11:54:54 -070055import android.os.Looper;
56import android.os.Message;
Erik Kline94ae4c92017-06-13 21:32:10 +090057import android.os.RemoteException;
58import android.os.ServiceSpecificException;
Christopher Wileyd2896662016-05-19 11:54:54 -070059import android.util.Log;
60import android.util.SparseArray;
61
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090062import androidx.annotation.NonNull;
Xiao Ma5a428f52020-05-14 06:52:59 +000063import androidx.annotation.Nullable;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090064
Christopher Wileyd2896662016-05-19 11:54:54 -070065import com.android.internal.util.MessageUtils;
Christopher Wileyd2896662016-05-19 11:54:54 -070066import com.android.internal.util.State;
67import com.android.internal.util.StateMachine;
Hungming Chenbe4827d2020-06-02 00:13:26 +000068import com.android.networkstack.tethering.BpfCoordinator;
Hungming Chen39869f02020-06-02 00:13:45 +000069import com.android.networkstack.tethering.BpfCoordinator.Ipv6ForwardingRule;
Mark Chiendb6befb2020-05-29 22:07:37 +000070import com.android.networkstack.tethering.PrivateAddressCoordinator;
Christopher Wileyd2896662016-05-19 11:54:54 -070071
Lorenzo Colittifb19f492020-02-14 01:06:35 +090072import java.io.IOException;
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +090073import java.net.Inet4Address;
Erik Kline94ae4c92017-06-13 21:32:10 +090074import java.net.Inet6Address;
Lorenzo Colittifb19f492020-02-14 01:06:35 +090075import java.net.NetworkInterface;
Erik Kline94ae4c92017-06-13 21:32:10 +090076import java.net.UnknownHostException;
77import java.util.ArrayList;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090078import java.util.Arrays;
79import java.util.Collections;
Erik Kline94ae4c92017-06-13 21:32:10 +090080import java.util.HashSet;
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +090081import java.util.List;
Erik Kline94ae4c92017-06-13 21:32:10 +090082import java.util.Objects;
83import java.util.Random;
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +090084import java.util.Set;
Christopher Wileyd2896662016-05-19 11:54:54 -070085
86/**
Erik Klinedd4d5822017-06-12 18:20:08 +090087 * Provides the interface to IP-layer serving functionality for a given network
88 * interface, e.g. for tethering or "local-only hotspot" mode.
Christopher Wileyd2896662016-05-19 11:54:54 -070089 *
Erik Klinedd4d5822017-06-12 18:20:08 +090090 * @hide
Christopher Wileyd2896662016-05-19 11:54:54 -070091 */
Erik Kline7a4ccc62018-08-27 17:26:47 +090092public class IpServer extends StateMachine {
93 public static final int STATE_UNAVAILABLE = 0;
94 public static final int STATE_AVAILABLE = 1;
95 public static final int STATE_TETHERED = 2;
96 public static final int STATE_LOCAL_ONLY = 3;
97
markchien08cc0302019-09-09 20:50:49 +080098 /** Get string name of |state|.*/
Erik Kline7a4ccc62018-08-27 17:26:47 +090099 public static String getStateString(int state) {
100 switch (state) {
101 case STATE_UNAVAILABLE: return "UNAVAILABLE";
102 case STATE_AVAILABLE: return "AVAILABLE";
103 case STATE_TETHERED: return "TETHERED";
104 case STATE_LOCAL_ONLY: return "LOCAL_ONLY";
105 }
106 return "UNKNOWN: " + state;
107 }
108
Erik Kline0f27eed2018-05-29 19:24:43 +0900109 private static final byte DOUG_ADAMS = (byte) 42;
Erik Kline94ae4c92017-06-13 21:32:10 +0900110
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900111 // TODO: have PanService use some visible version of this constant
Mark Chiendb6befb2020-05-29 22:07:37 +0000112 private static final String BLUETOOTH_IFACE_ADDR = "192.168.44.1/24";
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900113
114 // TODO: have this configurable
115 private static final int DHCP_LEASE_TIME_SECS = 3600;
116
Lorenzo Colitti8bc1e542020-04-14 09:21:19 +0000117 private static final MacAddress NULL_MAC_ADDRESS = MacAddress.fromString("00:00:00:00:00:00");
118
markchien08cc0302019-09-09 20:50:49 +0800119 private static final String TAG = "IpServer";
120 private static final boolean DBG = false;
121 private static final boolean VDBG = false;
122 private static final Class[] sMessageClasses = {
Erik Kline7a4ccc62018-08-27 17:26:47 +0900123 IpServer.class
Christopher Wileyd2896662016-05-19 11:54:54 -0700124 };
125 private static final SparseArray<String> sMagicDecoderRing =
markchien08cc0302019-09-09 20:50:49 +0800126 MessageUtils.findMessageNames(sMessageClasses);
Christopher Wileyd2896662016-05-19 11:54:54 -0700127
markchien08cc0302019-09-09 20:50:49 +0800128 /** IpServer callback. */
Erik Kline7a4ccc62018-08-27 17:26:47 +0900129 public static class Callback {
130 /**
131 * Notify that |who| has changed its tethering state.
132 *
133 * @param who the calling instance of IpServer
134 * @param state one of STATE_*
markchien9e44cde2019-12-25 19:40:32 +0800135 * @param lastError one of TetheringManager.TETHER_ERROR_*
Erik Kline7a4ccc62018-08-27 17:26:47 +0900136 */
markchien6d06f6d2019-12-16 20:15:20 +0800137 public void updateInterfaceState(IpServer who, int state, int lastError) { }
Erik Kline7a4ccc62018-08-27 17:26:47 +0900138
139 /**
140 * Notify that |who| has new LinkProperties.
141 *
142 * @param who the calling instance of IpServer
143 * @param newLp the new LinkProperties to report
144 */
markchien6d06f6d2019-12-16 20:15:20 +0800145 public void updateLinkProperties(IpServer who, LinkProperties newLp) { }
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900146
147 /**
148 * Notify that the DHCP leases changed in one of the IpServers.
149 */
150 public void dhcpLeasesChanged() { }
Mark Chiendb6befb2020-05-29 22:07:37 +0000151
152 /**
153 * Request Tethering change.
154 *
155 * @param tetheringType the downstream type of this IpServer.
156 * @param enabled enable or disable tethering.
157 */
158 public void requestEnableTethering(int tetheringType, boolean enabled) { }
Erik Kline7a4ccc62018-08-27 17:26:47 +0900159 }
160
markchien08cc0302019-09-09 20:50:49 +0800161 /** Capture IpServer dependencies, for injection. */
markchien6d06f6d2019-12-16 20:15:20 +0800162 public abstract static class Dependencies {
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900163 /** Create an IpNeighborMonitor to be used by this IpServer */
164 public IpNeighborMonitor getIpNeighborMonitor(Handler handler, SharedLog log,
165 IpNeighborMonitor.NeighborEventConsumer consumer) {
166 return new IpNeighborMonitor(handler, log, consumer);
167 }
168
markchien08cc0302019-09-09 20:50:49 +0800169 /** Create a RouterAdvertisementDaemon instance to be used by IpServer.*/
Erik Kline7a4ccc62018-08-27 17:26:47 +0900170 public RouterAdvertisementDaemon getRouterAdvertisementDaemon(InterfaceParams ifParams) {
171 return new RouterAdvertisementDaemon(ifParams);
172 }
173
markchien08cc0302019-09-09 20:50:49 +0800174 /** Get |ifName|'s interface information.*/
Erik Kline7a4ccc62018-08-27 17:26:47 +0900175 public InterfaceParams getInterfaceParams(String ifName) {
176 return InterfaceParams.getByName(ifName);
177 }
178
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900179 /** Get |ifName|'s interface index. */
180 public int getIfindex(String ifName) {
181 try {
182 return NetworkInterface.getByName(ifName).getIndex();
183 } catch (IOException | NullPointerException e) {
184 Log.e(TAG, "Can't determine interface index for interface " + ifName);
185 return 0;
186 }
187 }
Mark Chiendb6befb2020-05-29 22:07:37 +0000188
markchien6d06f6d2019-12-16 20:15:20 +0800189 /** Create a DhcpServer instance to be used by IpServer. */
190 public abstract void makeDhcpServer(String ifName, DhcpServingParamsParcel params,
191 DhcpServerCallbacks cb);
Erik Kline7a4ccc62018-08-27 17:26:47 +0900192 }
193
Christopher Wileyd2896662016-05-19 11:54:54 -0700194 // request from the user that it wants to tether
markchien986750b2019-12-06 15:24:53 +0800195 public static final int CMD_TETHER_REQUESTED = BASE_IPSERVER + 1;
Christopher Wileyd2896662016-05-19 11:54:54 -0700196 // request from the user that it wants to untether
markchien986750b2019-12-06 15:24:53 +0800197 public static final int CMD_TETHER_UNREQUESTED = BASE_IPSERVER + 2;
Christopher Wileyd2896662016-05-19 11:54:54 -0700198 // notification that this interface is down
markchien986750b2019-12-06 15:24:53 +0800199 public static final int CMD_INTERFACE_DOWN = BASE_IPSERVER + 3;
Christopher Wileyd2896662016-05-19 11:54:54 -0700200 // notification from the master SM that it had trouble enabling IP Forwarding
markchien986750b2019-12-06 15:24:53 +0800201 public static final int CMD_IP_FORWARDING_ENABLE_ERROR = BASE_IPSERVER + 4;
Christopher Wileyd2896662016-05-19 11:54:54 -0700202 // notification from the master SM that it had trouble disabling IP Forwarding
markchien986750b2019-12-06 15:24:53 +0800203 public static final int CMD_IP_FORWARDING_DISABLE_ERROR = BASE_IPSERVER + 5;
Christopher Wileyd2896662016-05-19 11:54:54 -0700204 // notification from the master SM that it had trouble starting tethering
markchien986750b2019-12-06 15:24:53 +0800205 public static final int CMD_START_TETHERING_ERROR = BASE_IPSERVER + 6;
Christopher Wileyd2896662016-05-19 11:54:54 -0700206 // notification from the master SM that it had trouble stopping tethering
markchien986750b2019-12-06 15:24:53 +0800207 public static final int CMD_STOP_TETHERING_ERROR = BASE_IPSERVER + 7;
Christopher Wileyd2896662016-05-19 11:54:54 -0700208 // notification from the master SM that it had trouble setting the DNS forwarders
markchien986750b2019-12-06 15:24:53 +0800209 public static final int CMD_SET_DNS_FORWARDERS_ERROR = BASE_IPSERVER + 8;
Christopher Wileyd2896662016-05-19 11:54:54 -0700210 // the upstream connection has changed
markchien986750b2019-12-06 15:24:53 +0800211 public static final int CMD_TETHER_CONNECTION_CHANGED = BASE_IPSERVER + 9;
Erik Kline1eb8c692016-07-08 17:21:26 +0900212 // new IPv6 tethering parameters need to be processed
markchien986750b2019-12-06 15:24:53 +0800213 public static final int CMD_IPV6_TETHER_UPDATE = BASE_IPSERVER + 10;
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900214 // new neighbor cache entry on our interface
215 public static final int CMD_NEIGHBOR_EVENT = BASE_IPSERVER + 11;
Xiao Ma5a428f52020-05-14 06:52:59 +0000216 // request from DHCP server that it wants to have a new prefix
217 public static final int CMD_NEW_PREFIX_REQUEST = BASE_IPSERVER + 12;
Mark Chiendb6befb2020-05-29 22:07:37 +0000218 // request from PrivateAddressCoordinator to restart tethering.
219 public static final int CMD_NOTIFY_PREFIX_CONFLICT = BASE_IPSERVER + 13;
Christopher Wileyd2896662016-05-19 11:54:54 -0700220
221 private final State mInitialState;
Erik Klineea9cc482017-03-10 19:35:34 +0900222 private final State mLocalHotspotState;
Christopher Wileyd2896662016-05-19 11:54:54 -0700223 private final State mTetheredState;
224 private final State mUnavailableState;
Mark Chiendb6befb2020-05-29 22:07:37 +0000225 private final State mWaitingForRestartState;
Christopher Wileyd2896662016-05-19 11:54:54 -0700226
Erik Kline7747fd42017-05-12 16:52:48 +0900227 private final SharedLog mLog;
Erik Klined3c0b5e2017-09-03 20:38:29 +0900228 private final INetd mNetd;
Hungming Chenbe4827d2020-06-02 00:13:26 +0000229 @NonNull
230 private final BpfCoordinator mBpfCoordinator;
Erik Kline7a4ccc62018-08-27 17:26:47 +0900231 private final Callback mCallback;
Erik Klined3c0b5e2017-09-03 20:38:29 +0900232 private final InterfaceController mInterfaceCtrl;
Mark Chiendb6befb2020-05-29 22:07:37 +0000233 private final PrivateAddressCoordinator mPrivateAddressCoordinator;
Christopher Wileyd2896662016-05-19 11:54:54 -0700234
Christopher Wileyd2896662016-05-19 11:54:54 -0700235 private final String mIfaceName;
Christopher Wiley5c0b10a2016-05-31 14:43:08 -0700236 private final int mInterfaceType;
Erik Klineab6439b2017-06-06 19:24:21 +0900237 private final LinkProperties mLinkProperties;
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900238 private final boolean mUsingLegacyDhcp;
Nucca Chen95e0bac2020-05-12 11:34:28 +0000239 private final boolean mUsingBpfOffload;
Christopher Wileyd2896662016-05-19 11:54:54 -0700240
Erik Kline7a4ccc62018-08-27 17:26:47 +0900241 private final Dependencies mDeps;
Remi NGUYEN VANa911e842018-03-15 11:57:14 +0900242
Christopher Wileyd2896662016-05-19 11:54:54 -0700243 private int mLastError;
Erik Klineb3bb26e2017-07-06 19:49:35 +0900244 private int mServingMode;
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +0900245 private InterfaceSet mUpstreamIfaceSet; // may change over time
Erik Kline8bd00d52017-12-08 17:47:50 +0900246 private InterfaceParams mInterfaceParams;
Erik Klinedd4d5822017-06-12 18:20:08 +0900247 // TODO: De-duplicate this with mLinkProperties above. Currently, these link
248 // properties are those selected by the IPv6TetheringCoordinator and relayed
249 // to us. By comparison, mLinkProperties contains the addresses and directly
250 // connected routes that have been formed from these properties iff. we have
251 // succeeded in configuring them and are able to announce them within Router
252 // Advertisements (otherwise, we do not add them to mLinkProperties at all).
Erik Kline94ae4c92017-06-13 21:32:10 +0900253 private LinkProperties mLastIPv6LinkProperties;
254 private RouterAdvertisementDaemon mRaDaemon;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900255
256 // To be accessed only on the handler thread
257 private int mDhcpServerStartIndex = 0;
258 private IDhcpServer mDhcpServer;
Erik Kline94ae4c92017-06-13 21:32:10 +0900259 private RaParams mLastRaParams;
Automerger Merge Worker37a22752020-03-17 16:59:57 +0000260
261 private LinkAddress mStaticIpv4ServerAddr;
262 private LinkAddress mStaticIpv4ClientAddr;
263
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900264 @NonNull
265 private List<TetheredClient> mDhcpLeases = Collections.emptyList();
Christopher Wileyd2896662016-05-19 11:54:54 -0700266
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900267 private int mLastIPv6UpstreamIfindex = 0;
268
269 private class MyNeighborEventConsumer implements IpNeighborMonitor.NeighborEventConsumer {
270 public void accept(NeighborEvent e) {
271 sendMessage(CMD_NEIGHBOR_EVENT, e);
272 }
273 }
274
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900275 private final IpNeighborMonitor mIpNeighborMonitor;
276
Mark Chiendb6befb2020-05-29 22:07:37 +0000277 private LinkAddress mIpv4Address;
278
Maciej Żenczykowski61d59a72020-05-12 19:04:39 +0000279 // TODO: Add a dependency object to pass the data members or variables from the tethering
280 // object. It helps to reduce the arguments of the constructor.
Erik Kline7a4ccc62018-08-27 17:26:47 +0900281 public IpServer(
Erik Kline7747fd42017-05-12 16:52:48 +0900282 String ifaceName, Looper looper, int interfaceType, SharedLog log,
Hungming Chenbe4827d2020-06-02 00:13:26 +0000283 INetd netd, @NonNull BpfCoordinator coordinator, Callback callback,
284 boolean usingLegacyDhcp, boolean usingBpfOffload,
Mark Chiendb6befb2020-05-29 22:07:37 +0000285 PrivateAddressCoordinator addressCoordinator, Dependencies deps) {
Christopher Wileyd2896662016-05-19 11:54:54 -0700286 super(ifaceName, looper);
Erik Kline7747fd42017-05-12 16:52:48 +0900287 mLog = log.forSubComponent(ifaceName);
markchien92b8e7f2020-01-07 14:43:17 +0800288 mNetd = netd;
Hungming Chenbe4827d2020-06-02 00:13:26 +0000289 mBpfCoordinator = coordinator;
Erik Kline7a4ccc62018-08-27 17:26:47 +0900290 mCallback = callback;
Remi NGUYEN VANd1b51a32019-01-22 16:13:57 +0900291 mInterfaceCtrl = new InterfaceController(ifaceName, mNetd, mLog);
Christopher Wileyd2896662016-05-19 11:54:54 -0700292 mIfaceName = ifaceName;
Christopher Wiley5c0b10a2016-05-31 14:43:08 -0700293 mInterfaceType = interfaceType;
Erik Klineab6439b2017-06-06 19:24:21 +0900294 mLinkProperties = new LinkProperties();
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900295 mUsingLegacyDhcp = usingLegacyDhcp;
Nucca Chen95e0bac2020-05-12 11:34:28 +0000296 mUsingBpfOffload = usingBpfOffload;
Mark Chiendb6befb2020-05-29 22:07:37 +0000297 mPrivateAddressCoordinator = addressCoordinator;
Remi NGUYEN VANa911e842018-03-15 11:57:14 +0900298 mDeps = deps;
Erik Klinedd4d5822017-06-12 18:20:08 +0900299 resetLinkProperties();
markchien9e44cde2019-12-25 19:40:32 +0800300 mLastError = TetheringManager.TETHER_ERROR_NO_ERROR;
Erik Kline7a4ccc62018-08-27 17:26:47 +0900301 mServingMode = STATE_AVAILABLE;
Christopher Wileyd2896662016-05-19 11:54:54 -0700302
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900303 mIpNeighborMonitor = mDeps.getIpNeighborMonitor(getHandler(), mLog,
304 new MyNeighborEventConsumer());
Nucca Chen95e0bac2020-05-12 11:34:28 +0000305
Maciej Żenczykowski61d59a72020-05-12 19:04:39 +0000306 // IP neighbor monitor monitors the neighbor events for adding/removing offload
Nucca Chen95e0bac2020-05-12 11:34:28 +0000307 // forwarding rules per client. If BPF offload is not supported, don't start listening
Maciej Żenczykowski61d59a72020-05-12 19:04:39 +0000308 // for neighbor events. See updateIpv6ForwardingRules, addIpv6ForwardingRule,
Nucca Chen95e0bac2020-05-12 11:34:28 +0000309 // removeIpv6ForwardingRule.
Maciej Żenczykowski61d59a72020-05-12 19:04:39 +0000310 if (mUsingBpfOffload && !mIpNeighborMonitor.start()) {
311 mLog.e("Failed to create IpNeighborMonitor on " + mIfaceName);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900312 }
313
Christopher Wileyd2896662016-05-19 11:54:54 -0700314 mInitialState = new InitialState();
Erik Klineea9cc482017-03-10 19:35:34 +0900315 mLocalHotspotState = new LocalHotspotState();
Christopher Wileyd2896662016-05-19 11:54:54 -0700316 mTetheredState = new TetheredState();
Christopher Wileyd2896662016-05-19 11:54:54 -0700317 mUnavailableState = new UnavailableState();
Mark Chiendb6befb2020-05-29 22:07:37 +0000318 mWaitingForRestartState = new WaitingForRestartState();
Erik Klineea9cc482017-03-10 19:35:34 +0900319 addState(mInitialState);
Erik Klinef79a34d2017-04-13 22:54:34 +0900320 addState(mLocalHotspotState);
321 addState(mTetheredState);
Mark Chiendb6befb2020-05-29 22:07:37 +0000322 addState(mWaitingForRestartState, mTetheredState);
Christopher Wileyd2896662016-05-19 11:54:54 -0700323 addState(mUnavailableState);
324
325 setInitialState(mInitialState);
326 }
327
markchien08cc0302019-09-09 20:50:49 +0800328 /** Interface name which IpServer served.*/
329 public String interfaceName() {
330 return mIfaceName;
331 }
Erik Kline218c2262017-06-09 16:36:29 +0900332
Erik Kline94ae4c92017-06-13 21:32:10 +0900333 /**
markchien9e44cde2019-12-25 19:40:32 +0800334 * Tethering downstream type. It would be one of TetheringManager#TETHERING_*.
Erik Kline94ae4c92017-06-13 21:32:10 +0900335 */
markchien08cc0302019-09-09 20:50:49 +0800336 public int interfaceType() {
337 return mInterfaceType;
338 }
Erik Kline94ae4c92017-06-13 21:32:10 +0900339
markchien08cc0302019-09-09 20:50:49 +0800340 /** Last error from this IpServer. */
341 public int lastError() {
342 return mLastError;
343 }
344
345 /** Serving mode is the current state of IpServer state machine. */
346 public int servingMode() {
347 return mServingMode;
348 }
349
350 /** The properties of the network link which IpServer is serving. */
351 public LinkProperties linkProperties() {
352 return new LinkProperties(mLinkProperties);
353 }
354
Mark Chiendb6befb2020-05-29 22:07:37 +0000355 /** The address which IpServer is using. */
356 public LinkAddress getAddress() {
357 return mIpv4Address;
358 }
359
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900360 /**
361 * Get the latest list of DHCP leases that was reported. Must be called on the IpServer looper
362 * thread.
363 */
364 public List<TetheredClient> getAllLeases() {
365 return Collections.unmodifiableList(mDhcpLeases);
366 }
367
markchien08cc0302019-09-09 20:50:49 +0800368 /** Stop this IpServer. After this is called this IpServer should not be used any more. */
369 public void stop() {
370 sendMessage(CMD_INTERFACE_DOWN);
371 }
372
373 /**
374 * Tethering is canceled. IpServer state machine will be available and wait for
375 * next tethering request.
376 */
377 public void unwanted() {
378 sendMessage(CMD_TETHER_UNREQUESTED);
379 }
380
381 /** Internals. */
382
383 private boolean startIPv4() {
384 return configureIPv4(true);
385 }
Christopher Wiley5c0b10a2016-05-31 14:43:08 -0700386
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900387 /**
388 * Convenience wrapper around INetworkStackStatusCallback to run callbacks on the IpServer
389 * handler.
390 *
391 * <p>Different instances of this class can be created for each call to IDhcpServer methods,
392 * with different implementations of the callback, to differentiate handling of success/error in
393 * each call.
394 */
395 private abstract class OnHandlerStatusCallback extends INetworkStackStatusCallback.Stub {
396 @Override
397 public void onStatusAvailable(int statusCode) {
398 getHandler().post(() -> callback(statusCode));
399 }
400
401 public abstract void callback(int statusCode);
Remi NGUYEN VAN1232fe32019-04-05 15:15:48 +0900402
403 @Override
404 public int getInterfaceVersion() {
405 return this.VERSION;
406 }
Paul Trautrime01ea252020-01-23 14:55:57 +0900407
408 @Override
409 public String getInterfaceHash() {
410 return this.HASH;
411 }
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900412 }
413
414 private class DhcpServerCallbacksImpl extends DhcpServerCallbacks {
415 private final int mStartIndex;
416
417 private DhcpServerCallbacksImpl(int startIndex) {
418 mStartIndex = startIndex;
419 }
420
421 @Override
422 public void onDhcpServerCreated(int statusCode, IDhcpServer server) throws RemoteException {
423 getHandler().post(() -> {
424 // We are on the handler thread: mDhcpServerStartIndex can be read safely.
425 if (mStartIndex != mDhcpServerStartIndex) {
426 // This start request is obsolete. When the |server| binder token goes out of
427 // scope, the garbage collector will finalize it, which causes the network stack
428 // process garbage collector to collect the server itself.
429 return;
430 }
431
432 if (statusCode != STATUS_SUCCESS) {
433 mLog.e("Error obtaining DHCP server: " + statusCode);
434 handleError();
435 return;
436 }
437
438 mDhcpServer = server;
439 try {
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900440 mDhcpServer.startWithCallbacks(new OnHandlerStatusCallback() {
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900441 @Override
442 public void callback(int startStatusCode) {
443 if (startStatusCode != STATUS_SUCCESS) {
444 mLog.e("Error starting DHCP server: " + startStatusCode);
445 handleError();
446 }
447 }
Xiao Ma5a428f52020-05-14 06:52:59 +0000448 }, new DhcpEventCallback());
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900449 } catch (RemoteException e) {
markchien92b8e7f2020-01-07 14:43:17 +0800450 throw new IllegalStateException(e);
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900451 }
452 });
453 }
454
455 private void handleError() {
markchien9e44cde2019-12-25 19:40:32 +0800456 mLastError = TetheringManager.TETHER_ERROR_DHCPSERVER_ERROR;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900457 transitionTo(mInitialState);
458 }
459 }
460
Xiao Ma5a428f52020-05-14 06:52:59 +0000461 private class DhcpEventCallback extends IDhcpEventCallbacks.Stub {
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900462 @Override
463 public void onLeasesChanged(List<DhcpLeaseParcelable> leaseParcelables) {
464 final ArrayList<TetheredClient> leases = new ArrayList<>();
465 for (DhcpLeaseParcelable lease : leaseParcelables) {
466 final LinkAddress address = new LinkAddress(
Automerger Merge Worker3d330ff2020-03-16 04:06:46 +0000467 intToInet4AddressHTH(lease.netAddr), lease.prefixLength,
468 0 /* flags */, RT_SCOPE_UNIVERSE /* as per RFC6724#3.2 */,
469 lease.expTime /* deprecationTime */, lease.expTime /* expirationTime */);
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900470
471 final MacAddress macAddress;
472 try {
473 macAddress = MacAddress.fromBytes(lease.hwAddr);
474 } catch (IllegalArgumentException e) {
475 Log.wtf(TAG, "Invalid address received from DhcpServer: "
476 + Arrays.toString(lease.hwAddr));
477 return;
478 }
479
480 final TetheredClient.AddressInfo addressInfo = new TetheredClient.AddressInfo(
Automerger Merge Worker3d330ff2020-03-16 04:06:46 +0000481 address, lease.hostname);
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900482 leases.add(new TetheredClient(
483 macAddress,
484 Collections.singletonList(addressInfo),
485 mInterfaceType));
486 }
487
488 getHandler().post(() -> {
489 mDhcpLeases = leases;
490 mCallback.dhcpLeasesChanged();
491 });
492 }
493
494 @Override
Xiao Ma5a428f52020-05-14 06:52:59 +0000495 public void onNewPrefixRequest(@NonNull final IpPrefix currentPrefix) {
496 Objects.requireNonNull(currentPrefix);
497 sendMessage(CMD_NEW_PREFIX_REQUEST, currentPrefix);
Xiao Ma3eab4922020-04-06 11:24:48 +0000498 }
499
500 @Override
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900501 public int getInterfaceVersion() {
502 return this.VERSION;
503 }
504
505 @Override
506 public String getInterfaceHash() throws RemoteException {
507 return this.HASH;
508 }
509 }
510
Xiao Ma5a428f52020-05-14 06:52:59 +0000511 private RouteInfo getDirectConnectedRoute(@NonNull final LinkAddress ipv4Address) {
512 Objects.requireNonNull(ipv4Address);
513 return new RouteInfo(PrefixUtils.asIpPrefix(ipv4Address), null, mIfaceName, RTN_UNICAST);
514 }
515
516 private DhcpServingParamsParcel makeServingParams(@NonNull final Inet4Address defaultRouter,
517 @NonNull final Inet4Address dnsServer, @NonNull LinkAddress serverAddr,
518 @Nullable Inet4Address clientAddr) {
519 final boolean changePrefixOnDecline =
520 (mInterfaceType == TetheringManager.TETHERING_NCM && clientAddr == null);
521 return new DhcpServingParamsParcelExt()
522 .setDefaultRouters(defaultRouter)
523 .setDhcpLeaseTimeSecs(DHCP_LEASE_TIME_SECS)
524 .setDnsServers(dnsServer)
525 .setServerAddr(serverAddr)
526 .setMetered(true)
527 .setSingleClientAddr(clientAddr)
528 .setChangePrefixOnDecline(changePrefixOnDecline);
529 // TODO: also advertise link MTU
530 }
531
Treehugger Robot86d212b2020-03-30 04:23:55 +0000532 private boolean startDhcp(final LinkAddress serverLinkAddr, final LinkAddress clientLinkAddr) {
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900533 if (mUsingLegacyDhcp) {
534 return true;
535 }
Treehugger Robot86d212b2020-03-30 04:23:55 +0000536
537 final Inet4Address addr = (Inet4Address) serverLinkAddr.getAddress();
Treehugger Robot86d212b2020-03-30 04:23:55 +0000538 final Inet4Address clientAddr = clientLinkAddr == null ? null :
539 (Inet4Address) clientLinkAddr.getAddress();
540
Xiao Ma5a428f52020-05-14 06:52:59 +0000541 final DhcpServingParamsParcel params = makeServingParams(addr /* defaultRouter */,
542 addr /* dnsServer */, serverLinkAddr, clientAddr);
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900543 mDhcpServerStartIndex++;
544 mDeps.makeDhcpServer(
545 mIfaceName, params, new DhcpServerCallbacksImpl(mDhcpServerStartIndex));
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900546 return true;
547 }
548
549 private void stopDhcp() {
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900550 // Make all previous start requests obsolete so servers are not started later
551 mDhcpServerStartIndex++;
552
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900553 if (mDhcpServer != null) {
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900554 try {
555 mDhcpServer.stop(new OnHandlerStatusCallback() {
556 @Override
557 public void callback(int statusCode) {
558 if (statusCode != STATUS_SUCCESS) {
559 mLog.e("Error stopping DHCP server: " + statusCode);
markchien9e44cde2019-12-25 19:40:32 +0800560 mLastError = TetheringManager.TETHER_ERROR_DHCPSERVER_ERROR;
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900561 // Not much more we can do here
562 }
Remi NGUYEN VANdb5594d2020-02-13 09:16:19 +0900563 mDhcpLeases.clear();
564 getHandler().post(mCallback::dhcpLeasesChanged);
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900565 }
566 });
567 mDhcpServer = null;
568 } catch (RemoteException e) {
Xiao Ma5a428f52020-05-14 06:52:59 +0000569 mLog.e("Error stopping DHCP server", e);
markchien92b8e7f2020-01-07 14:43:17 +0800570 // Not much more we can do here
Remi NGUYEN VAN0e3d09232018-12-04 12:13:09 +0900571 }
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900572 }
573 }
574
Treehugger Robot86d212b2020-03-30 04:23:55 +0000575 private boolean configureDhcp(boolean enable, final LinkAddress serverAddr,
576 final LinkAddress clientAddr) {
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900577 if (enable) {
Treehugger Robot86d212b2020-03-30 04:23:55 +0000578 return startDhcp(serverAddr, clientAddr);
Remi NGUYEN VANe3bb5c52018-06-12 15:57:04 +0900579 } else {
580 stopDhcp();
581 return true;
582 }
583 }
584
Erik Klinef8bba5b2018-05-18 16:09:24 +0900585 private void stopIPv4() {
586 configureIPv4(false);
587 // NOTE: All of configureIPv4() will be refactored out of existence
588 // into calls to InterfaceController, shared with startIPv4().
589 mInterfaceCtrl.clearIPv4Address();
Mark Chiendb6befb2020-05-29 22:07:37 +0000590 mPrivateAddressCoordinator.releaseDownstream(this);
markchien92b8e7f2020-01-07 14:43:17 +0800591 mIpv4Address = null;
Automerger Merge Worker37a22752020-03-17 16:59:57 +0000592 mStaticIpv4ServerAddr = null;
593 mStaticIpv4ClientAddr = null;
Erik Klinef8bba5b2018-05-18 16:09:24 +0900594 }
Erik Klinedd4d5822017-06-12 18:20:08 +0900595
596 private boolean configureIPv4(boolean enabled) {
597 if (VDBG) Log.d(TAG, "configureIPv4(" + enabled + ")");
598
Mark Chiendb6befb2020-05-29 22:07:37 +0000599 if (enabled) {
600 mIpv4Address = requestIpv4Address();
601 }
602
603 if (mIpv4Address == null) {
604 mLog.e("No available ipv4 address");
markchien92b8e7f2020-01-07 14:43:17 +0800605 return false;
Christopher Wiley5c0b10a2016-05-31 14:43:08 -0700606 }
Christopher Wileyd2896662016-05-19 11:54:54 -0700607
Mark Chiendb6befb2020-05-29 22:07:37 +0000608 if (mInterfaceType == TetheringManager.TETHERING_BLUETOOTH) {
609 // BT configures the interface elsewhere: only start DHCP.
610 // TODO: make all tethering types behave the same way, and delete the bluetooth
611 // code that calls into NetworkManagementService directly.
612 return configureDhcp(enabled, mIpv4Address, null /* clientAddress */);
613 }
614
615 final IpPrefix ipv4Prefix = asIpPrefix(mIpv4Address);
616
markchien92b8e7f2020-01-07 14:43:17 +0800617 final Boolean setIfaceUp;
Jimmy Chen151384d2019-12-03 11:37:09 +0800618 if (mInterfaceType == TetheringManager.TETHERING_WIFI
Mark Chience7403c2020-06-19 06:25:12 +0000619 || mInterfaceType == TetheringManager.TETHERING_WIFI_P2P
Dedy Lansky04bef3c2019-11-21 00:36:14 +0200620 || mInterfaceType == TetheringManager.TETHERING_ETHERNET
621 || mInterfaceType == TetheringManager.TETHERING_WIGIG) {
Mark Chience7403c2020-06-19 06:25:12 +0000622 // The WiFi and Ethernet stack has ownership of the interface up/down state.
markchien92b8e7f2020-01-07 14:43:17 +0800623 // It is unclear whether the Bluetooth or USB stacks will manage their own
624 // state.
625 setIfaceUp = null;
626 } else {
627 setIfaceUp = enabled;
628 }
629 if (!mInterfaceCtrl.setInterfaceConfiguration(mIpv4Address, setIfaceUp)) {
630 mLog.e("Error configuring interface");
631 if (!enabled) stopDhcp();
632 return false;
633 }
Erik Klinedd4d5822017-06-12 18:20:08 +0900634
Erik Klinedd4d5822017-06-12 18:20:08 +0900635 if (enabled) {
markchien92b8e7f2020-01-07 14:43:17 +0800636 mLinkProperties.addLinkAddress(mIpv4Address);
Xiao Ma5a428f52020-05-14 06:52:59 +0000637 mLinkProperties.addRoute(getDirectConnectedRoute(mIpv4Address));
Erik Klinedd4d5822017-06-12 18:20:08 +0900638 } else {
markchien92b8e7f2020-01-07 14:43:17 +0800639 mLinkProperties.removeLinkAddress(mIpv4Address);
Xiao Ma5a428f52020-05-14 06:52:59 +0000640 mLinkProperties.removeRoute(getDirectConnectedRoute(mIpv4Address));
Erik Klinedd4d5822017-06-12 18:20:08 +0900641 }
Treehugger Robot86d212b2020-03-30 04:23:55 +0000642 return configureDhcp(enabled, mIpv4Address, mStaticIpv4ClientAddr);
Christopher Wileyd2896662016-05-19 11:54:54 -0700643 }
644
Mark Chiendb6befb2020-05-29 22:07:37 +0000645 private LinkAddress requestIpv4Address() {
646 if (mStaticIpv4ServerAddr != null) return mStaticIpv4ServerAddr;
Erik Kline0f27eed2018-05-29 19:24:43 +0900647
Mark Chiendb6befb2020-05-29 22:07:37 +0000648 if (mInterfaceType == TetheringManager.TETHERING_BLUETOOTH) {
649 return new LinkAddress(BLUETOOTH_IFACE_ADDR);
650 }
651
652 return mPrivateAddressCoordinator.requestDownstreamAddress(this);
Xiao Ma5a428f52020-05-14 06:52:59 +0000653 }
654
Erik Kline94ae4c92017-06-13 21:32:10 +0900655 private boolean startIPv6() {
Remi NGUYEN VANa911e842018-03-15 11:57:14 +0900656 mInterfaceParams = mDeps.getInterfaceParams(mIfaceName);
Erik Kline8bd00d52017-12-08 17:47:50 +0900657 if (mInterfaceParams == null) {
658 mLog.e("Failed to find InterfaceParams");
Erik Kline94ae4c92017-06-13 21:32:10 +0900659 stopIPv6();
660 return false;
661 }
662
Remi NGUYEN VANa911e842018-03-15 11:57:14 +0900663 mRaDaemon = mDeps.getRouterAdvertisementDaemon(mInterfaceParams);
Erik Kline94ae4c92017-06-13 21:32:10 +0900664 if (!mRaDaemon.start()) {
665 stopIPv6();
666 return false;
667 }
668
669 return true;
670 }
671
672 private void stopIPv6() {
Erik Kline8bd00d52017-12-08 17:47:50 +0900673 mInterfaceParams = null;
Erik Kline94ae4c92017-06-13 21:32:10 +0900674 setRaParams(null);
675
676 if (mRaDaemon != null) {
677 mRaDaemon.stop();
678 mRaDaemon = null;
679 }
680 }
681
682 // IPv6TetheringCoordinator sends updates with carefully curated IPv6-only
683 // LinkProperties. These have extraneous data filtered out and only the
684 // necessary prefixes included (per its prefix distribution policy).
685 //
686 // TODO: Evaluate using a data structure than is more directly suited to
687 // communicating only the relevant information.
Mark Chien9c5e7ea2020-05-25 02:04:59 +0000688 private void updateUpstreamIPv6LinkProperties(LinkProperties v6only, int ttlAdjustment) {
Erik Kline94ae4c92017-06-13 21:32:10 +0900689 if (mRaDaemon == null) return;
690
691 // Avoid unnecessary work on spurious updates.
692 if (Objects.equals(mLastIPv6LinkProperties, v6only)) {
693 return;
694 }
695
696 RaParams params = null;
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900697 int upstreamIfindex = 0;
Erik Kline94ae4c92017-06-13 21:32:10 +0900698
699 if (v6only != null) {
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900700 final String upstreamIface = v6only.getInterfaceName();
701
Erik Kline94ae4c92017-06-13 21:32:10 +0900702 params = new RaParams();
Maciej Żenczykowski7ed764d2020-05-28 03:21:31 -0700703 params.mtu = v6only.getMtu();
paulhud9736de2019-03-08 16:35:20 +0800704 params.hasDefaultRoute = v6only.hasIpv6DefaultRoute();
Erik Kline94ae4c92017-06-13 21:32:10 +0900705
Mark Chien9c5e7ea2020-05-25 02:04:59 +0000706 if (params.hasDefaultRoute) params.hopLimit = getHopLimit(upstreamIface, ttlAdjustment);
Erik Kline8e492f82018-09-14 16:25:54 +0900707
Erik Kline94ae4c92017-06-13 21:32:10 +0900708 for (LinkAddress linkAddr : v6only.getLinkAddresses()) {
709 if (linkAddr.getPrefixLength() != RFC7421_PREFIX_LENGTH) continue;
710
711 final IpPrefix prefix = new IpPrefix(
712 linkAddr.getAddress(), linkAddr.getPrefixLength());
713 params.prefixes.add(prefix);
714
715 final Inet6Address dnsServer = getLocalDnsIpFor(prefix);
716 if (dnsServer != null) {
717 params.dnses.add(dnsServer);
718 }
719 }
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900720
721 upstreamIfindex = mDeps.getIfindex(upstreamIface);
Hungming Chenbe4827d2020-06-02 00:13:26 +0000722
723 // Add upstream index to name mapping for the tether stats usage in the coordinator.
724 // Although this mapping could be added by both class Tethering and IpServer, adding
725 // mapping from IpServer guarantees that the mapping is added before the adding
726 // forwarding rules. That is because there are different state machines in both
727 // classes. It is hard to guarantee the link property update order between multiple
728 // state machines.
729 mBpfCoordinator.addUpstreamNameToLookupTable(upstreamIfindex, upstreamIface);
Erik Kline94ae4c92017-06-13 21:32:10 +0900730 }
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900731
Erik Kline94ae4c92017-06-13 21:32:10 +0900732 // If v6only is null, we pass in null to setRaParams(), which handles
733 // deprecation of any existing RA data.
734
735 setRaParams(params);
736 mLastIPv6LinkProperties = v6only;
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900737
738 updateIpv6ForwardingRules(mLastIPv6UpstreamIfindex, upstreamIfindex, null);
739 mLastIPv6UpstreamIfindex = upstreamIfindex;
Erik Kline94ae4c92017-06-13 21:32:10 +0900740 }
741
Xiao Ma5a428f52020-05-14 06:52:59 +0000742 private void removeRoutesFromLocalNetwork(@NonNull final List<RouteInfo> toBeRemoved) {
743 final int removalFailures = RouteUtils.removeRoutesFromLocalNetwork(
744 mNetd, toBeRemoved);
745 if (removalFailures > 0) {
746 mLog.e(String.format("Failed to remove %d IPv6 routes from local table.",
747 removalFailures));
748 }
749
750 for (RouteInfo route : toBeRemoved) mLinkProperties.removeRoute(route);
751 }
752
753 private void addRoutesToLocalNetwork(@NonNull final List<RouteInfo> toBeAdded) {
754 try {
755 // It's safe to call networkAddInterface() even if
756 // the interface is already in the local_network.
757 mNetd.networkAddInterface(INetd.LOCAL_NET_ID, mIfaceName);
758 try {
759 // Add routes from local network. Note that adding routes that
760 // already exist does not cause an error (EEXIST is silently ignored).
761 RouteUtils.addRoutesToLocalNetwork(mNetd, mIfaceName, toBeAdded);
762 } catch (IllegalStateException e) {
763 mLog.e("Failed to add IPv4/v6 routes to local table: " + e);
764 return;
765 }
766 } catch (ServiceSpecificException | RemoteException e) {
767 mLog.e("Failed to add " + mIfaceName + " to local table: ", e);
768 return;
769 }
770
771 for (RouteInfo route : toBeAdded) mLinkProperties.addRoute(route);
772 }
773
Erik Klinedd4d5822017-06-12 18:20:08 +0900774 private void configureLocalIPv6Routes(
Erik Kline94ae4c92017-06-13 21:32:10 +0900775 HashSet<IpPrefix> deprecatedPrefixes, HashSet<IpPrefix> newPrefixes) {
776 // [1] Remove the routes that are deprecated.
777 if (!deprecatedPrefixes.isEmpty()) {
Xiao Ma5a428f52020-05-14 06:52:59 +0000778 removeRoutesFromLocalNetwork(getLocalRoutesFor(mIfaceName, deprecatedPrefixes));
Erik Kline94ae4c92017-06-13 21:32:10 +0900779 }
780
781 // [2] Add only the routes that have not previously been added.
782 if (newPrefixes != null && !newPrefixes.isEmpty()) {
783 HashSet<IpPrefix> addedPrefixes = (HashSet) newPrefixes.clone();
784 if (mLastRaParams != null) {
785 addedPrefixes.removeAll(mLastRaParams.prefixes);
786 }
787
Erik Kline94ae4c92017-06-13 21:32:10 +0900788 if (!addedPrefixes.isEmpty()) {
Xiao Ma5a428f52020-05-14 06:52:59 +0000789 addRoutesToLocalNetwork(getLocalRoutesFor(mIfaceName, addedPrefixes));
Erik Kline94ae4c92017-06-13 21:32:10 +0900790 }
791 }
792 }
793
Erik Klinedd4d5822017-06-12 18:20:08 +0900794 private void configureLocalIPv6Dns(
Erik Kline94ae4c92017-06-13 21:32:10 +0900795 HashSet<Inet6Address> deprecatedDnses, HashSet<Inet6Address> newDnses) {
Erik Klined3c0b5e2017-09-03 20:38:29 +0900796 // TODO: Is this really necessary? Can we not fail earlier if INetd cannot be located?
797 if (mNetd == null) {
Erik Kline94ae4c92017-06-13 21:32:10 +0900798 if (newDnses != null) newDnses.clear();
799 mLog.e("No netd service instance available; not setting local IPv6 addresses");
800 return;
801 }
802
803 // [1] Remove deprecated local DNS IP addresses.
804 if (!deprecatedDnses.isEmpty()) {
805 for (Inet6Address dns : deprecatedDnses) {
Erik Klined3c0b5e2017-09-03 20:38:29 +0900806 if (!mInterfaceCtrl.removeAddress(dns, RFC7421_PREFIX_LENGTH)) {
807 mLog.e("Failed to remove local dns IP " + dns);
Erik Kline94ae4c92017-06-13 21:32:10 +0900808 }
Erik Klinedd4d5822017-06-12 18:20:08 +0900809
810 mLinkProperties.removeLinkAddress(new LinkAddress(dns, RFC7421_PREFIX_LENGTH));
Erik Kline94ae4c92017-06-13 21:32:10 +0900811 }
812 }
813
814 // [2] Add only the local DNS IP addresses that have not previously been added.
815 if (newDnses != null && !newDnses.isEmpty()) {
816 final HashSet<Inet6Address> addedDnses = (HashSet) newDnses.clone();
817 if (mLastRaParams != null) {
818 addedDnses.removeAll(mLastRaParams.dnses);
819 }
820
821 for (Inet6Address dns : addedDnses) {
Erik Klined3c0b5e2017-09-03 20:38:29 +0900822 if (!mInterfaceCtrl.addAddress(dns, RFC7421_PREFIX_LENGTH)) {
823 mLog.e("Failed to add local dns IP " + dns);
Erik Kline94ae4c92017-06-13 21:32:10 +0900824 newDnses.remove(dns);
825 }
Erik Klinedd4d5822017-06-12 18:20:08 +0900826
827 mLinkProperties.addLinkAddress(new LinkAddress(dns, RFC7421_PREFIX_LENGTH));
Erik Kline94ae4c92017-06-13 21:32:10 +0900828 }
829 }
830
831 try {
Erik Klined3c0b5e2017-09-03 20:38:29 +0900832 mNetd.tetherApplyDnsInterfaces();
Erik Kline94ae4c92017-06-13 21:32:10 +0900833 } catch (ServiceSpecificException | RemoteException e) {
834 mLog.e("Failed to update local DNS caching server");
835 if (newDnses != null) newDnses.clear();
836 }
837 }
838
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900839 private void addIpv6ForwardingRule(Ipv6ForwardingRule rule) {
Nucca Chen95e0bac2020-05-12 11:34:28 +0000840 // Theoretically, we don't need this check because IP neighbor monitor doesn't start if BPF
841 // offload is disabled. Add this check just in case.
842 // TODO: Perhaps remove this protection check.
843 if (!mUsingBpfOffload) return;
844
Treehugger Robot96895192020-06-09 13:28:38 +0000845 mBpfCoordinator.tetherOffloadRuleAdd(this, rule);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900846 }
847
Treehugger Robot96895192020-06-09 13:28:38 +0000848 private void removeIpv6ForwardingRule(Ipv6ForwardingRule rule) {
Nucca Chen95e0bac2020-05-12 11:34:28 +0000849 // TODO: Perhaps remove this protection check.
Treehugger Robot96895192020-06-09 13:28:38 +0000850 // See the related comment in #addIpv6ForwardingRule.
Nucca Chen95e0bac2020-05-12 11:34:28 +0000851 if (!mUsingBpfOffload) return;
852
Treehugger Robot96895192020-06-09 13:28:38 +0000853 mBpfCoordinator.tetherOffloadRuleRemove(this, rule);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900854 }
855
Automerger Merge Worker43c671d2020-02-25 04:04:44 +0000856 private void clearIpv6ForwardingRules() {
Treehugger Robot96895192020-06-09 13:28:38 +0000857 if (!mUsingBpfOffload) return;
858
859 mBpfCoordinator.tetherOffloadRuleClear(this);
Automerger Merge Worker43c671d2020-02-25 04:04:44 +0000860 }
861
Treehugger Robot96895192020-06-09 13:28:38 +0000862 private void updateIpv6ForwardingRule(int newIfindex) {
863 // TODO: Perhaps remove this protection check.
864 // See the related comment in #addIpv6ForwardingRule.
865 if (!mUsingBpfOffload) return;
866
867 mBpfCoordinator.tetherOffloadRuleUpdate(this, newIfindex);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900868 }
869
870 // Handles all updates to IPv6 forwarding rules. These can currently change only if the upstream
871 // changes or if a neighbor event is received.
872 private void updateIpv6ForwardingRules(int prevUpstreamIfindex, int upstreamIfindex,
873 NeighborEvent e) {
Automerger Merge Worker43c671d2020-02-25 04:04:44 +0000874 // If we no longer have an upstream, clear forwarding rules and do nothing else.
875 if (upstreamIfindex == 0) {
876 clearIpv6ForwardingRules();
877 return;
878 }
879
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900880 // If the upstream interface has changed, remove all rules and re-add them with the new
881 // upstream interface.
882 if (prevUpstreamIfindex != upstreamIfindex) {
Treehugger Robot96895192020-06-09 13:28:38 +0000883 updateIpv6ForwardingRule(upstreamIfindex);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900884 }
885
886 // If we're here to process a NeighborEvent, do so now.
Automerger Merge Worker43c671d2020-02-25 04:04:44 +0000887 // mInterfaceParams must be non-null or the event would not have arrived.
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900888 if (e == null) return;
889 if (!(e.ip instanceof Inet6Address) || e.ip.isMulticastAddress()
890 || e.ip.isLoopbackAddress() || e.ip.isLinkLocalAddress()) {
891 return;
892 }
893
Lorenzo Colitti8bc1e542020-04-14 09:21:19 +0000894 // When deleting rules, we still need to pass a non-null MAC, even though it's ignored.
895 // Do this here instead of in the Ipv6ForwardingRule constructor to ensure that we never
896 // add rules with a null MAC, only delete them.
897 MacAddress dstMac = e.isValid() ? e.macAddr : NULL_MAC_ADDRESS;
Automerger Merge Worker43c671d2020-02-25 04:04:44 +0000898 Ipv6ForwardingRule rule = new Ipv6ForwardingRule(upstreamIfindex,
Lorenzo Colitti8bc1e542020-04-14 09:21:19 +0000899 mInterfaceParams.index, (Inet6Address) e.ip, mInterfaceParams.macAddr, dstMac);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900900 if (e.isValid()) {
901 addIpv6ForwardingRule(rule);
902 } else {
Treehugger Robot96895192020-06-09 13:28:38 +0000903 removeIpv6ForwardingRule(rule);
Lorenzo Colittifb19f492020-02-14 01:06:35 +0900904 }
905 }
906
907 private void handleNeighborEvent(NeighborEvent e) {
908 if (mInterfaceParams != null
909 && mInterfaceParams.index == e.ifindex
910 && mInterfaceParams.hasMacAddress) {
911 updateIpv6ForwardingRules(mLastIPv6UpstreamIfindex, mLastIPv6UpstreamIfindex, e);
912 }
913 }
914
Xiao Ma5a428f52020-05-14 06:52:59 +0000915 private void handleNewPrefixRequest(@NonNull final IpPrefix currentPrefix) {
916 if (!currentPrefix.contains(mIpv4Address.getAddress())
917 || currentPrefix.getPrefixLength() != mIpv4Address.getPrefixLength()) {
918 Log.e(TAG, "Invalid prefix: " + currentPrefix);
919 return;
920 }
921
922 final LinkAddress deprecatedLinkAddress = mIpv4Address;
Mark Chiendb6befb2020-05-29 22:07:37 +0000923 mIpv4Address = requestIpv4Address();
924 if (mIpv4Address == null) {
Xiao Ma5a428f52020-05-14 06:52:59 +0000925 mLog.e("Fail to request a new downstream prefix");
926 return;
927 }
Mark Chiendb6befb2020-05-29 22:07:37 +0000928 final Inet4Address srvAddr = (Inet4Address) mIpv4Address.getAddress();
Xiao Ma5a428f52020-05-14 06:52:59 +0000929
930 // Add new IPv4 address on the interface.
931 if (!mInterfaceCtrl.addAddress(srvAddr, currentPrefix.getPrefixLength())) {
932 mLog.e("Failed to add new IP " + srvAddr);
933 return;
934 }
935
936 // Remove deprecated routes from local network.
937 removeRoutesFromLocalNetwork(
938 Collections.singletonList(getDirectConnectedRoute(deprecatedLinkAddress)));
939 mLinkProperties.removeLinkAddress(deprecatedLinkAddress);
940
941 // Add new routes to local network.
942 addRoutesToLocalNetwork(
943 Collections.singletonList(getDirectConnectedRoute(mIpv4Address)));
944 mLinkProperties.addLinkAddress(mIpv4Address);
945
946 // Update local DNS caching server with new IPv4 address, otherwise, dnsmasq doesn't
947 // listen on the interface configured with new IPv4 address, that results DNS validation
948 // failure of downstream client even if appropriate routes have been configured.
949 try {
950 mNetd.tetherApplyDnsInterfaces();
951 } catch (ServiceSpecificException | RemoteException e) {
952 mLog.e("Failed to update local DNS caching server");
953 return;
954 }
955 sendLinkProperties();
956
957 // Notify DHCP server that new prefix/route has been applied on IpServer.
958 final Inet4Address clientAddr = mStaticIpv4ClientAddr == null ? null :
959 (Inet4Address) mStaticIpv4ClientAddr.getAddress();
960 final DhcpServingParamsParcel params = makeServingParams(srvAddr /* defaultRouter */,
961 srvAddr /* dnsServer */, mIpv4Address /* serverLinkAddress */, clientAddr);
962 try {
963 mDhcpServer.updateParams(params, new OnHandlerStatusCallback() {
964 @Override
965 public void callback(int statusCode) {
966 if (statusCode != STATUS_SUCCESS) {
967 mLog.e("Error updating DHCP serving params: " + statusCode);
968 }
969 }
970 });
971 } catch (RemoteException e) {
972 mLog.e("Error updating DHCP serving params", e);
973 }
974 }
975
Mark Chien9c5e7ea2020-05-25 02:04:59 +0000976 private byte getHopLimit(String upstreamIface, int adjustTTL) {
Erik Kline8e492f82018-09-14 16:25:54 +0900977 try {
978 int upstreamHopLimit = Integer.parseUnsignedInt(
979 mNetd.getProcSysNet(INetd.IPV6, INetd.CONF, upstreamIface, "hop_limit"));
Mark Chien9c5e7ea2020-05-25 02:04:59 +0000980 upstreamHopLimit = upstreamHopLimit + adjustTTL;
Erik Kline8e492f82018-09-14 16:25:54 +0900981 // Cap the hop limit to 255.
982 return (byte) Integer.min(upstreamHopLimit, 255);
983 } catch (Exception e) {
984 mLog.e("Failed to find upstream interface hop limit", e);
985 }
986 return RaParams.DEFAULT_HOPLIMIT;
987 }
988
Erik Kline94ae4c92017-06-13 21:32:10 +0900989 private void setRaParams(RaParams newParams) {
990 if (mRaDaemon != null) {
991 final RaParams deprecatedParams =
992 RaParams.getDeprecatedRaParams(mLastRaParams, newParams);
993
Erik Klinedd4d5822017-06-12 18:20:08 +0900994 configureLocalIPv6Routes(deprecatedParams.prefixes,
Erik Kline94ae4c92017-06-13 21:32:10 +0900995 (newParams != null) ? newParams.prefixes : null);
996
Erik Klinedd4d5822017-06-12 18:20:08 +0900997 configureLocalIPv6Dns(deprecatedParams.dnses,
Erik Kline94ae4c92017-06-13 21:32:10 +0900998 (newParams != null) ? newParams.dnses : null);
999
1000 mRaDaemon.buildNewRa(deprecatedParams, newParams);
1001 }
1002
1003 mLastRaParams = newParams;
1004 }
1005
Erik Klineb4df3f42017-07-06 16:40:06 +09001006 private void logMessage(State state, int what) {
1007 mLog.log(state.getName() + " got " + sMagicDecoderRing.get(what, Integer.toString(what)));
Christopher Wileyd2896662016-05-19 11:54:54 -07001008 }
1009
Erik Klineea9cc482017-03-10 19:35:34 +09001010 private void sendInterfaceState(int newInterfaceState) {
Erik Klineb3bb26e2017-07-06 19:49:35 +09001011 mServingMode = newInterfaceState;
Erik Kline7a4ccc62018-08-27 17:26:47 +09001012 mCallback.updateInterfaceState(this, newInterfaceState, mLastError);
Erik Klinedd4d5822017-06-12 18:20:08 +09001013 sendLinkProperties();
1014 }
1015
1016 private void sendLinkProperties() {
Erik Kline7a4ccc62018-08-27 17:26:47 +09001017 mCallback.updateLinkProperties(this, new LinkProperties(mLinkProperties));
Erik Klineea9cc482017-03-10 19:35:34 +09001018 }
1019
Erik Klinedd4d5822017-06-12 18:20:08 +09001020 private void resetLinkProperties() {
1021 mLinkProperties.clear();
1022 mLinkProperties.setInterfaceName(mIfaceName);
1023 }
1024
Automerger Merge Worker37a22752020-03-17 16:59:57 +00001025 private void maybeConfigureStaticIp(final TetheringRequestParcel request) {
Treehugger Robot86d212b2020-03-30 04:23:55 +00001026 // Ignore static address configuration if they are invalid or null. In theory, static
1027 // addresses should not be invalid here because TetheringManager do not allow caller to
1028 // specify invalid static address configuration.
1029 if (request == null || request.localIPv4Address == null
1030 || request.staticClientAddress == null || !checkStaticAddressConfiguration(
1031 request.localIPv4Address, request.staticClientAddress)) {
1032 return;
1033 }
Automerger Merge Worker37a22752020-03-17 16:59:57 +00001034
1035 mStaticIpv4ServerAddr = request.localIPv4Address;
1036 mStaticIpv4ClientAddr = request.staticClientAddress;
1037 }
1038
Christopher Wileyd2896662016-05-19 11:54:54 -07001039 class InitialState extends State {
1040 @Override
1041 public void enter() {
Erik Kline7a4ccc62018-08-27 17:26:47 +09001042 sendInterfaceState(STATE_AVAILABLE);
Christopher Wileyd2896662016-05-19 11:54:54 -07001043 }
1044
1045 @Override
1046 public boolean processMessage(Message message) {
Erik Klineb4df3f42017-07-06 16:40:06 +09001047 logMessage(this, message.what);
Christopher Wileyd2896662016-05-19 11:54:54 -07001048 switch (message.what) {
1049 case CMD_TETHER_REQUESTED:
markchien9e44cde2019-12-25 19:40:32 +08001050 mLastError = TetheringManager.TETHER_ERROR_NO_ERROR;
Erik Klineea9cc482017-03-10 19:35:34 +09001051 switch (message.arg1) {
Erik Kline7a4ccc62018-08-27 17:26:47 +09001052 case STATE_LOCAL_ONLY:
Automerger Merge Worker37a22752020-03-17 16:59:57 +00001053 maybeConfigureStaticIp((TetheringRequestParcel) message.obj);
Erik Klineea9cc482017-03-10 19:35:34 +09001054 transitionTo(mLocalHotspotState);
1055 break;
Erik Kline7a4ccc62018-08-27 17:26:47 +09001056 case STATE_TETHERED:
Automerger Merge Worker37a22752020-03-17 16:59:57 +00001057 maybeConfigureStaticIp((TetheringRequestParcel) message.obj);
Erik Klineea9cc482017-03-10 19:35:34 +09001058 transitionTo(mTetheredState);
1059 break;
1060 default:
Erik Kline7747fd42017-05-12 16:52:48 +09001061 mLog.e("Invalid tethering interface serving state specified.");
Erik Klineea9cc482017-03-10 19:35:34 +09001062 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001063 break;
1064 case CMD_INTERFACE_DOWN:
1065 transitionTo(mUnavailableState);
1066 break;
Erik Kline1eb8c692016-07-08 17:21:26 +09001067 case CMD_IPV6_TETHER_UPDATE:
Mark Chien9c5e7ea2020-05-25 02:04:59 +00001068 updateUpstreamIPv6LinkProperties((LinkProperties) message.obj, message.arg1);
Erik Kline1eb8c692016-07-08 17:21:26 +09001069 break;
Christopher Wileyd2896662016-05-19 11:54:54 -07001070 default:
Erik Klineab6439b2017-06-06 19:24:21 +09001071 return NOT_HANDLED;
Christopher Wileyd2896662016-05-19 11:54:54 -07001072 }
Erik Klineab6439b2017-06-06 19:24:21 +09001073 return HANDLED;
Christopher Wileyd2896662016-05-19 11:54:54 -07001074 }
1075 }
1076
Erik Klinef79a34d2017-04-13 22:54:34 +09001077 class BaseServingState extends State {
Christopher Wileyd2896662016-05-19 11:54:54 -07001078 @Override
1079 public void enter() {
Erik Klinedd4d5822017-06-12 18:20:08 +09001080 if (!startIPv4()) {
markchien9e44cde2019-12-25 19:40:32 +08001081 mLastError = TetheringManager.TETHER_ERROR_IFACE_CFG_ERROR;
Christopher Wiley5c0b10a2016-05-31 14:43:08 -07001082 return;
Christopher Wileyd2896662016-05-19 11:54:54 -07001083 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001084
Christopher Wileyd2896662016-05-19 11:54:54 -07001085 try {
Mark Chiendb6befb2020-05-29 22:07:37 +00001086 NetdUtils.tetherInterface(mNetd, mIfaceName, asIpPrefix(mIpv4Address));
markchiend72cf2c2020-02-15 11:35:00 +08001087 } catch (RemoteException | ServiceSpecificException | IllegalStateException e) {
Xiao Ma5a428f52020-05-14 06:52:59 +00001088 mLog.e("Error Tethering", e);
markchien9e44cde2019-12-25 19:40:32 +08001089 mLastError = TetheringManager.TETHER_ERROR_TETHER_IFACE_ERROR;
Christopher Wileyd2896662016-05-19 11:54:54 -07001090 return;
1091 }
Erik Kline1eb8c692016-07-08 17:21:26 +09001092
Erik Kline94ae4c92017-06-13 21:32:10 +09001093 if (!startIPv6()) {
1094 mLog.e("Failed to startIPv6");
Erik Klinef79a34d2017-04-13 22:54:34 +09001095 // TODO: Make this a fatal error once Bluetooth IPv6 is sorted.
1096 return;
Erik Kline1eb8c692016-07-08 17:21:26 +09001097 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001098 }
1099
Christopher Wileye10bfc02016-05-23 16:17:30 -07001100 @Override
1101 public void exit() {
Christopher Wileye10bfc02016-05-23 16:17:30 -07001102 // Note that at this point, we're leaving the tethered state. We can fail any
1103 // of these operations, but it doesn't really change that we have to try them
1104 // all in sequence.
Erik Kline94ae4c92017-06-13 21:32:10 +09001105 stopIPv6();
Christopher Wileye10bfc02016-05-23 16:17:30 -07001106
1107 try {
markchien92b8e7f2020-01-07 14:43:17 +08001108 NetdUtils.untetherInterface(mNetd, mIfaceName);
1109 } catch (RemoteException | ServiceSpecificException e) {
markchien9e44cde2019-12-25 19:40:32 +08001110 mLastError = TetheringManager.TETHER_ERROR_UNTETHER_IFACE_ERROR;
Erik Kline7747fd42017-05-12 16:52:48 +09001111 mLog.e("Failed to untether interface: " + e);
Christopher Wileye10bfc02016-05-23 16:17:30 -07001112 }
1113
Erik Klinedd4d5822017-06-12 18:20:08 +09001114 stopIPv4();
1115
1116 resetLinkProperties();
Christopher Wileye10bfc02016-05-23 16:17:30 -07001117 }
1118
Erik Klineea9cc482017-03-10 19:35:34 +09001119 @Override
1120 public boolean processMessage(Message message) {
Erik Klineb4df3f42017-07-06 16:40:06 +09001121 logMessage(this, message.what);
Erik Klineea9cc482017-03-10 19:35:34 +09001122 switch (message.what) {
1123 case CMD_TETHER_UNREQUESTED:
1124 transitionTo(mInitialState);
1125 if (DBG) Log.d(TAG, "Untethered (unrequested)" + mIfaceName);
1126 break;
1127 case CMD_INTERFACE_DOWN:
1128 transitionTo(mUnavailableState);
1129 if (DBG) Log.d(TAG, "Untethered (ifdown)" + mIfaceName);
1130 break;
1131 case CMD_IPV6_TETHER_UPDATE:
Mark Chien9c5e7ea2020-05-25 02:04:59 +00001132 updateUpstreamIPv6LinkProperties((LinkProperties) message.obj, message.arg1);
Erik Klinedd4d5822017-06-12 18:20:08 +09001133 sendLinkProperties();
Erik Klineea9cc482017-03-10 19:35:34 +09001134 break;
1135 case CMD_IP_FORWARDING_ENABLE_ERROR:
1136 case CMD_IP_FORWARDING_DISABLE_ERROR:
1137 case CMD_START_TETHERING_ERROR:
1138 case CMD_STOP_TETHERING_ERROR:
1139 case CMD_SET_DNS_FORWARDERS_ERROR:
markchien62a625d2020-03-19 13:37:43 +08001140 mLastError = TetheringManager.TETHER_ERROR_INTERNAL_ERROR;
Erik Klineea9cc482017-03-10 19:35:34 +09001141 transitionTo(mInitialState);
1142 break;
Xiao Ma5a428f52020-05-14 06:52:59 +00001143 case CMD_NEW_PREFIX_REQUEST:
1144 handleNewPrefixRequest((IpPrefix) message.obj);
1145 break;
Mark Chiendb6befb2020-05-29 22:07:37 +00001146 case CMD_NOTIFY_PREFIX_CONFLICT:
1147 mLog.i("restart tethering: " + mInterfaceType);
1148 mCallback.requestEnableTethering(mInterfaceType, false /* enabled */);
1149 transitionTo(mWaitingForRestartState);
1150 break;
Erik Klineea9cc482017-03-10 19:35:34 +09001151 default:
1152 return false;
1153 }
1154 return true;
1155 }
1156 }
1157
Erik Klinef79a34d2017-04-13 22:54:34 +09001158 // Handling errors in BaseServingState.enter() by transitioning is
1159 // problematic because transitioning during a multi-state jump yields
1160 // a Log.wtf(). Ultimately, there should be only one ServingState,
1161 // and forwarding and NAT rules should be handled by a coordinating
Erik Kline7a4ccc62018-08-27 17:26:47 +09001162 // functional element outside of IpServer.
Erik Klinef79a34d2017-04-13 22:54:34 +09001163 class LocalHotspotState extends BaseServingState {
Erik Klineea9cc482017-03-10 19:35:34 +09001164 @Override
1165 public void enter() {
Erik Klinef79a34d2017-04-13 22:54:34 +09001166 super.enter();
markchien9e44cde2019-12-25 19:40:32 +08001167 if (mLastError != TetheringManager.TETHER_ERROR_NO_ERROR) {
Erik Klinef79a34d2017-04-13 22:54:34 +09001168 transitionTo(mInitialState);
1169 }
1170
Erik Klineea9cc482017-03-10 19:35:34 +09001171 if (DBG) Log.d(TAG, "Local hotspot " + mIfaceName);
Erik Kline7a4ccc62018-08-27 17:26:47 +09001172 sendInterfaceState(STATE_LOCAL_ONLY);
Erik Klineea9cc482017-03-10 19:35:34 +09001173 }
1174
1175 @Override
1176 public boolean processMessage(Message message) {
Erik Klinef79a34d2017-04-13 22:54:34 +09001177 if (super.processMessage(message)) return true;
1178
Erik Klineb4df3f42017-07-06 16:40:06 +09001179 logMessage(this, message.what);
Erik Klineea9cc482017-03-10 19:35:34 +09001180 switch (message.what) {
1181 case CMD_TETHER_REQUESTED:
Erik Kline7747fd42017-05-12 16:52:48 +09001182 mLog.e("CMD_TETHER_REQUESTED while in local-only hotspot mode.");
Erik Klineea9cc482017-03-10 19:35:34 +09001183 break;
1184 case CMD_TETHER_CONNECTION_CHANGED:
1185 // Ignored in local hotspot state.
1186 break;
1187 default:
1188 return false;
1189 }
1190 return true;
1191 }
1192 }
1193
Erik Klinef79a34d2017-04-13 22:54:34 +09001194 // Handling errors in BaseServingState.enter() by transitioning is
1195 // problematic because transitioning during a multi-state jump yields
1196 // a Log.wtf(). Ultimately, there should be only one ServingState,
1197 // and forwarding and NAT rules should be handled by a coordinating
Erik Kline7a4ccc62018-08-27 17:26:47 +09001198 // functional element outside of IpServer.
Erik Klinef79a34d2017-04-13 22:54:34 +09001199 class TetheredState extends BaseServingState {
Erik Klineea9cc482017-03-10 19:35:34 +09001200 @Override
1201 public void enter() {
Erik Klinef79a34d2017-04-13 22:54:34 +09001202 super.enter();
markchien9e44cde2019-12-25 19:40:32 +08001203 if (mLastError != TetheringManager.TETHER_ERROR_NO_ERROR) {
Erik Klinef79a34d2017-04-13 22:54:34 +09001204 transitionTo(mInitialState);
1205 }
1206
Erik Klineea9cc482017-03-10 19:35:34 +09001207 if (DBG) Log.d(TAG, "Tethered " + mIfaceName);
Erik Kline7a4ccc62018-08-27 17:26:47 +09001208 sendInterfaceState(STATE_TETHERED);
Erik Klineea9cc482017-03-10 19:35:34 +09001209 }
1210
1211 @Override
1212 public void exit() {
1213 cleanupUpstream();
Erik Klinef79a34d2017-04-13 22:54:34 +09001214 super.exit();
Erik Klineea9cc482017-03-10 19:35:34 +09001215 }
1216
Christopher Wileyd2896662016-05-19 11:54:54 -07001217 private void cleanupUpstream() {
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001218 if (mUpstreamIfaceSet == null) return;
Erik Kline8ea45482017-02-13 17:28:53 +09001219
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001220 for (String ifname : mUpstreamIfaceSet.ifnames) cleanupUpstreamInterface(ifname);
1221 mUpstreamIfaceSet = null;
Automerger Merge Worker43c671d2020-02-25 04:04:44 +00001222 clearIpv6ForwardingRules();
Erik Kline8ea45482017-02-13 17:28:53 +09001223 }
1224
1225 private void cleanupUpstreamInterface(String upstreamIface) {
1226 // Note that we don't care about errors here.
1227 // Sometimes interfaces are gone before we get
1228 // to remove their rules, which generates errors.
1229 // Just do the best we can.
1230 try {
markchien92b8e7f2020-01-07 14:43:17 +08001231 mNetd.ipfwdRemoveInterfaceForward(mIfaceName, upstreamIface);
1232 } catch (RemoteException | ServiceSpecificException e) {
1233 mLog.e("Exception in ipfwdRemoveInterfaceForward: " + e.toString());
Erik Kline8ea45482017-02-13 17:28:53 +09001234 }
1235 try {
markchien92b8e7f2020-01-07 14:43:17 +08001236 mNetd.tetherRemoveForward(mIfaceName, upstreamIface);
1237 } catch (RemoteException | ServiceSpecificException e) {
1238 mLog.e("Exception in disableNat: " + e.toString());
Erik Kline8ea45482017-02-13 17:28:53 +09001239 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001240 }
1241
1242 @Override
1243 public boolean processMessage(Message message) {
Erik Klinef79a34d2017-04-13 22:54:34 +09001244 if (super.processMessage(message)) return true;
1245
Erik Klineb4df3f42017-07-06 16:40:06 +09001246 logMessage(this, message.what);
Christopher Wileyd2896662016-05-19 11:54:54 -07001247 switch (message.what) {
Erik Klineea9cc482017-03-10 19:35:34 +09001248 case CMD_TETHER_REQUESTED:
Erik Kline7747fd42017-05-12 16:52:48 +09001249 mLog.e("CMD_TETHER_REQUESTED while already tethering.");
Christopher Wileyd2896662016-05-19 11:54:54 -07001250 break;
1251 case CMD_TETHER_CONNECTION_CHANGED:
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001252 final InterfaceSet newUpstreamIfaceSet = (InterfaceSet) message.obj;
1253 if (noChangeInUpstreamIfaceSet(newUpstreamIfaceSet)) {
Christopher Wileyd2896662016-05-19 11:54:54 -07001254 if (VDBG) Log.d(TAG, "Connection changed noop - dropping");
1255 break;
1256 }
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001257
1258 if (newUpstreamIfaceSet == null) {
1259 cleanupUpstream();
1260 break;
1261 }
1262
1263 for (String removed : upstreamInterfacesRemoved(newUpstreamIfaceSet)) {
1264 cleanupUpstreamInterface(removed);
1265 }
1266
1267 final Set<String> added = upstreamInterfacesAdd(newUpstreamIfaceSet);
1268 // This makes the call to cleanupUpstream() in the error
1269 // path for any interface neatly cleanup all the interfaces.
1270 mUpstreamIfaceSet = newUpstreamIfaceSet;
1271
1272 for (String ifname : added) {
Christopher Wileyd2896662016-05-19 11:54:54 -07001273 try {
markchien92b8e7f2020-01-07 14:43:17 +08001274 mNetd.tetherAddForward(mIfaceName, ifname);
1275 mNetd.ipfwdAddInterfaceForward(mIfaceName, ifname);
1276 } catch (RemoteException | ServiceSpecificException e) {
1277 mLog.e("Exception enabling NAT: " + e.toString());
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001278 cleanupUpstream();
markchien62a625d2020-03-19 13:37:43 +08001279 mLastError = TetheringManager.TETHER_ERROR_ENABLE_FORWARDING_ERROR;
Christopher Wileyd2896662016-05-19 11:54:54 -07001280 transitionTo(mInitialState);
1281 return true;
1282 }
1283 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001284 break;
Lorenzo Colittifb19f492020-02-14 01:06:35 +09001285 case CMD_NEIGHBOR_EVENT:
1286 handleNeighborEvent((NeighborEvent) message.obj);
1287 break;
Christopher Wileyd2896662016-05-19 11:54:54 -07001288 default:
Erik Klinedd4d5822017-06-12 18:20:08 +09001289 return false;
Christopher Wileyd2896662016-05-19 11:54:54 -07001290 }
Erik Klinedd4d5822017-06-12 18:20:08 +09001291 return true;
Christopher Wileyd2896662016-05-19 11:54:54 -07001292 }
Remi NGUYEN VAN25a7e4f2018-03-09 14:07:18 +09001293
1294 private boolean noChangeInUpstreamIfaceSet(InterfaceSet newIfaces) {
1295 if (mUpstreamIfaceSet == null && newIfaces == null) return true;
1296 if (mUpstreamIfaceSet != null && newIfaces != null) {
1297 return mUpstreamIfaceSet.equals(newIfaces);
1298 }
1299 return false;
1300 }
1301
1302 private Set<String> upstreamInterfacesRemoved(InterfaceSet newIfaces) {
1303 if (mUpstreamIfaceSet == null) return new HashSet<>();
1304
1305 final HashSet<String> removed = new HashSet<>(mUpstreamIfaceSet.ifnames);
1306 removed.removeAll(newIfaces.ifnames);
1307 return removed;
1308 }
1309
1310 private Set<String> upstreamInterfacesAdd(InterfaceSet newIfaces) {
1311 final HashSet<String> added = new HashSet<>(newIfaces.ifnames);
1312 if (mUpstreamIfaceSet != null) added.removeAll(mUpstreamIfaceSet.ifnames);
1313 return added;
1314 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001315 }
1316
Christopher Wiley9ad83ab2016-05-20 17:51:27 -07001317 /**
1318 * This state is terminal for the per interface state machine. At this
1319 * point, the master state machine should have removed this interface
1320 * specific state machine from its list of possible recipients of
1321 * tethering requests. The state machine itself will hang around until
1322 * the garbage collector finds it.
1323 */
Christopher Wileyd2896662016-05-19 11:54:54 -07001324 class UnavailableState extends State {
1325 @Override
1326 public void enter() {
Lorenzo Colitti8bcf1982020-06-18 16:36:32 +00001327 mIpNeighborMonitor.stop();
markchien9e44cde2019-12-25 19:40:32 +08001328 mLastError = TetheringManager.TETHER_ERROR_NO_ERROR;
Erik Kline7a4ccc62018-08-27 17:26:47 +09001329 sendInterfaceState(STATE_UNAVAILABLE);
Christopher Wileyd2896662016-05-19 11:54:54 -07001330 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001331 }
Erik Kline94ae4c92017-06-13 21:32:10 +09001332
Mark Chiendb6befb2020-05-29 22:07:37 +00001333 class WaitingForRestartState extends State {
1334 @Override
1335 public boolean processMessage(Message message) {
1336 logMessage(this, message.what);
1337 switch (message.what) {
1338 case CMD_TETHER_UNREQUESTED:
1339 transitionTo(mInitialState);
1340 mLog.i("Untethered (unrequested) and restarting " + mIfaceName);
1341 mCallback.requestEnableTethering(mInterfaceType, true /* enabled */);
1342 break;
1343 case CMD_INTERFACE_DOWN:
1344 transitionTo(mUnavailableState);
1345 mLog.i("Untethered (interface down) and restarting" + mIfaceName);
1346 mCallback.requestEnableTethering(mInterfaceType, true /* enabled */);
1347 break;
1348 default:
1349 return false;
1350 }
1351 return true;
1352 }
1353 }
1354
Erik Kline94ae4c92017-06-13 21:32:10 +09001355 // Accumulate routes representing "prefixes to be assigned to the local
1356 // interface", for subsequent modification of local_network routing.
1357 private static ArrayList<RouteInfo> getLocalRoutesFor(
1358 String ifname, HashSet<IpPrefix> prefixes) {
1359 final ArrayList<RouteInfo> localRoutes = new ArrayList<RouteInfo>();
1360 for (IpPrefix ipp : prefixes) {
markchien986750b2019-12-06 15:24:53 +08001361 localRoutes.add(new RouteInfo(ipp, null, ifname, RTN_UNICAST));
Erik Kline94ae4c92017-06-13 21:32:10 +09001362 }
1363 return localRoutes;
1364 }
1365
1366 // Given a prefix like 2001:db8::/64 return an address like 2001:db8::1.
1367 private static Inet6Address getLocalDnsIpFor(IpPrefix localPrefix) {
1368 final byte[] dnsBytes = localPrefix.getRawAddress();
Erik Kline0f27eed2018-05-29 19:24:43 +09001369 dnsBytes[dnsBytes.length - 1] = getRandomSanitizedByte(DOUG_ADAMS, asByte(0), asByte(1));
Erik Kline94ae4c92017-06-13 21:32:10 +09001370 try {
1371 return Inet6Address.getByAddress(null, dnsBytes, 0);
1372 } catch (UnknownHostException e) {
markchien986750b2019-12-06 15:24:53 +08001373 Log.wtf(TAG, "Failed to construct Inet6Address from: " + localPrefix);
Erik Kline94ae4c92017-06-13 21:32:10 +09001374 return null;
1375 }
1376 }
1377
Erik Kline0f27eed2018-05-29 19:24:43 +09001378 private static byte getRandomSanitizedByte(byte dflt, byte... excluded) {
Erik Kline94ae4c92017-06-13 21:32:10 +09001379 final byte random = (byte) (new Random()).nextInt();
Erik Kline0f27eed2018-05-29 19:24:43 +09001380 for (int value : excluded) {
1381 if (random == value) return dflt;
1382 }
1383 return random;
Erik Kline94ae4c92017-06-13 21:32:10 +09001384 }
Christopher Wileyd2896662016-05-19 11:54:54 -07001385}