Change-Id: I70fc4382f832d1a2bded8a5ee7d9b96fac77879b
This commit is contained in:
Jean-Baptiste Queru
2011-05-19 07:54:53 -07:00
4 changed files with 106 additions and 169 deletions

View File

@@ -38,32 +38,6 @@ public class NetworkUtils {
/** Bring the named network interface down. */ /** Bring the named network interface down. */
public native static int disableInterface(String interfaceName); public native static int disableInterface(String interfaceName);
/**
* Add a route to the routing table.
*
* @param interfaceName the interface to route through.
* @param dst the network or host to route to. May be IPv4 or IPv6, e.g.
* "0.0.0.0" or "2001:4860::".
* @param prefixLength the prefix length of the route.
* @param gw the gateway to use, e.g., "192.168.251.1". If null,
* indicates a directly-connected route.
*/
public native static int addRoute(String interfaceName, String dst,
int prefixLength, String gw);
/** Return the gateway address for the default route for the named interface. */
public static InetAddress getDefaultRoute(String interfaceName) {
int addr = getDefaultRouteNative(interfaceName);
return intToInetAddress(addr);
}
private native static int getDefaultRouteNative(String interfaceName);
/** Remove host routes that uses the named interface. */
public native static int removeHostRoutes(String interfaceName);
/** Remove the default route for the named interface. */
public native static int removeDefaultRoute(String interfaceName);
/** Reset any sockets that are connected via the named interface. */ /** Reset any sockets that are connected via the named interface. */
public native static int resetConnections(String interfaceName); public native static int resetConnections(String interfaceName);
@@ -159,6 +133,15 @@ public class NetworkUtils {
return Integer.reverseBytes(value); return Integer.reverseBytes(value);
} }
/**
* Convert a IPv4 netmask integer to a prefix length
* @param netmask as an integer in network byte order
* @return the network prefix length
*/
public static int netmaskIntToPrefixLength(int netmask) {
return Integer.bitCount(netmask);
}
/** /**
* Create an InetAddress from a string where the string must be a standard * Create an InetAddress from a string where the string must be a standard
* representation of a V4 or V6 address. Avoids doing a DNS lookup on failure * representation of a V4 or V6 address. Avoids doing a DNS lookup on failure
@@ -172,60 +155,6 @@ public class NetworkUtils {
return InetAddress.parseNumericAddress(addrString); return InetAddress.parseNumericAddress(addrString);
} }
/**
* Add a default route through the specified gateway.
* @param interfaceName interface on which the route should be added
* @param gw the IP address of the gateway to which the route is desired,
* @return {@code true} on success, {@code false} on failure
*/
public static boolean addDefaultRoute(String interfaceName, InetAddress gw) {
String dstStr;
String gwStr = gw.getHostAddress();
if (gw instanceof Inet4Address) {
dstStr = "0.0.0.0";
} else if (gw instanceof Inet6Address) {
dstStr = "::";
} else {
Log.w(TAG, "addDefaultRoute failure: address is neither IPv4 nor IPv6" +
"(" + gwStr + ")");
return false;
}
return addRoute(interfaceName, dstStr, 0, gwStr) == 0;
}
/**
* Add a host route.
* @param interfaceName interface on which the route should be added
* @param dst the IP address of the host to which the route is desired,
* this should not be null.
* @param gw the IP address of the gateway to which the route is desired,
* if null, indicates a directly-connected route.
* @return {@code true} on success, {@code false} on failure
*/
public static boolean addHostRoute(String interfaceName, InetAddress dst,
InetAddress gw) {
if (dst == null) {
Log.w(TAG, "addHostRoute: dst should not be null");
return false;
}
int prefixLength;
String dstStr = dst.getHostAddress();
String gwStr = (gw != null) ? gw.getHostAddress() : null;
if (dst instanceof Inet4Address) {
prefixLength = 32;
} else if (dst instanceof Inet6Address) {
prefixLength = 128;
} else {
Log.w(TAG, "addHostRoute failure: address is neither IPv4 nor IPv6" +
"(" + dst + ")");
return false;
}
return addRoute(interfaceName, dstStr, prefixLength, gwStr) == 0;
}
/** /**
* Get InetAddress masked with prefixLength. Will never return null. * Get InetAddress masked with prefixLength. Will never return null.
* @param IP address which will be masked with specified prefixLength * @param IP address which will be masked with specified prefixLength
@@ -271,4 +200,25 @@ public class NetworkUtils {
return (((left instanceof Inet4Address) && (right instanceof Inet4Address)) || return (((left instanceof Inet4Address) && (right instanceof Inet4Address)) ||
((left instanceof Inet6Address) && (right instanceof Inet6Address))); ((left instanceof Inet6Address) && (right instanceof Inet6Address)));
} }
/**
* Convert a 32 char hex string into a Inet6Address.
* throws a runtime exception if the string isn't 32 chars, isn't hex or can't be
* made into an Inet6Address
* @param addrHexString a 32 character hex string representing an IPv6 addr
* @return addr an InetAddress representation for the string
*/
public static InetAddress hexToInet6Address(String addrHexString)
throws IllegalArgumentException {
try {
return numericToInetAddress(String.format("%s:%s:%s:%s:%s:%s:%s:%s",
addrHexString.substring(0,4), addrHexString.substring(4,8),
addrHexString.substring(8,12), addrHexString.substring(12,16),
addrHexString.substring(16,20), addrHexString.substring(20,24),
addrHexString.substring(24,28), addrHexString.substring(28,32)));
} catch (Exception e) {
Log.e("NetworkUtils", "error in hexToInet6Address(" + addrHexString + "): " + e);
throw new IllegalArgumentException(e);
}
}
} }

View File

@@ -46,18 +46,16 @@ public class RouteInfo implements Parcelable {
public RouteInfo(LinkAddress destination, InetAddress gateway) { public RouteInfo(LinkAddress destination, InetAddress gateway) {
if (destination == null) { if (destination == null) {
try { if (gateway != null) {
if (gateway != null) { if (gateway instanceof Inet4Address) {
if (gateway instanceof Inet4Address) { destination = new LinkAddress(Inet4Address.ANY, 0);
destination = new LinkAddress(Inet4Address.ANY, 0);
} else {
destination = new LinkAddress(Inet6Address.ANY, 0);
}
} else { } else {
// no destination, no gateway. invalid. destination = new LinkAddress(Inet6Address.ANY, 0);
throw new RuntimeException("Invalid arguments passed in.");
} }
} catch (Exception e) {} } else {
// no destination, no gateway. invalid.
throw new RuntimeException("Invalid arguments passed in.");
}
} }
if (gateway == null) { if (gateway == null) {
if (destination.getAddress() instanceof Inet4Address) { if (destination.getAddress() instanceof Inet4Address) {
@@ -76,6 +74,20 @@ public class RouteInfo implements Parcelable {
this(null, gateway); this(null, gateway);
} }
public static RouteInfo makeHostRoute(InetAddress host) {
return makeHostRoute(host, null);
}
public static RouteInfo makeHostRoute(InetAddress host, InetAddress gateway) {
if (host == null) return null;
if (host instanceof Inet4Address) {
return new RouteInfo(new LinkAddress(host, 32), gateway);
} else {
return new RouteInfo(new LinkAddress(host, 128), gateway);
}
}
private boolean isDefault() { private boolean isDefault() {
boolean val = false; boolean val = false;
if (mGateway != null) { if (mGateway != null) {

View File

@@ -26,10 +26,6 @@
extern "C" { extern "C" {
int ifc_enable(const char *ifname); int ifc_enable(const char *ifname);
int ifc_disable(const char *ifname); int ifc_disable(const char *ifname);
int ifc_add_route(const char *ifname, const char *destStr, uint32_t prefixLen, const char *gwStr);
int ifc_remove_host_routes(const char *ifname);
int ifc_get_default_route(const char *ifname);
int ifc_remove_default_route(const char *ifname);
int ifc_reset_connections(const char *ifname); int ifc_reset_connections(const char *ifname);
int dhcp_do_request(const char *ifname, int dhcp_do_request(const char *ifname,
@@ -94,56 +90,6 @@ static jint android_net_utils_disableInterface(JNIEnv* env, jobject clazz, jstri
return (jint)result; return (jint)result;
} }
static jint android_net_utils_addRoute(JNIEnv* env, jobject clazz, jstring ifname,
jstring dst, jint prefixLength, jstring gw)
{
int result;
const char *nameStr = env->GetStringUTFChars(ifname, NULL);
const char *dstStr = env->GetStringUTFChars(dst, NULL);
const char *gwStr = NULL;
if (gw != NULL) {
gwStr = env->GetStringUTFChars(gw, NULL);
}
result = ::ifc_add_route(nameStr, dstStr, prefixLength, gwStr);
env->ReleaseStringUTFChars(ifname, nameStr);
env->ReleaseStringUTFChars(dst, dstStr);
if (gw != NULL) {
env->ReleaseStringUTFChars(gw, gwStr);
}
return (jint)result;
}
static jint android_net_utils_removeHostRoutes(JNIEnv* env, jobject clazz, jstring ifname)
{
int result;
const char *nameStr = env->GetStringUTFChars(ifname, NULL);
result = ::ifc_remove_host_routes(nameStr);
env->ReleaseStringUTFChars(ifname, nameStr);
return (jint)result;
}
static jint android_net_utils_getDefaultRoute(JNIEnv* env, jobject clazz, jstring ifname)
{
int result;
const char *nameStr = env->GetStringUTFChars(ifname, NULL);
result = ::ifc_get_default_route(nameStr);
env->ReleaseStringUTFChars(ifname, nameStr);
return (jint)result;
}
static jint android_net_utils_removeDefaultRoute(JNIEnv* env, jobject clazz, jstring ifname)
{
int result;
const char *nameStr = env->GetStringUTFChars(ifname, NULL);
result = ::ifc_remove_default_route(nameStr);
env->ReleaseStringUTFChars(ifname, nameStr);
return (jint)result;
}
static jint android_net_utils_resetConnections(JNIEnv* env, jobject clazz, jstring ifname) static jint android_net_utils_resetConnections(JNIEnv* env, jobject clazz, jstring ifname)
{ {
int result; int result;
@@ -260,12 +206,6 @@ static JNINativeMethod gNetworkUtilMethods[] = {
{ "enableInterface", "(Ljava/lang/String;)I", (void *)android_net_utils_enableInterface }, { "enableInterface", "(Ljava/lang/String;)I", (void *)android_net_utils_enableInterface },
{ "disableInterface", "(Ljava/lang/String;)I", (void *)android_net_utils_disableInterface }, { "disableInterface", "(Ljava/lang/String;)I", (void *)android_net_utils_disableInterface },
{ "addRoute", "(Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;)I",
(void *)android_net_utils_addRoute },
{ "removeHostRoutes", "(Ljava/lang/String;)I", (void *)android_net_utils_removeHostRoutes },
{ "getDefaultRouteNative", "(Ljava/lang/String;)I",
(void *)android_net_utils_getDefaultRoute },
{ "removeDefaultRoute", "(Ljava/lang/String;)I", (void *)android_net_utils_removeDefaultRoute },
{ "resetConnections", "(Ljava/lang/String;)I", (void *)android_net_utils_resetConnections }, { "resetConnections", "(Ljava/lang/String;)I", (void *)android_net_utils_resetConnections },
{ "runDhcp", "(Ljava/lang/String;Landroid/net/DhcpInfoInternal;)Z", (void *)android_net_utils_runDhcp }, { "runDhcp", "(Ljava/lang/String;Landroid/net/DhcpInfoInternal;)Z", (void *)android_net_utils_runDhcp },
{ "runDhcpRenew", "(Ljava/lang/String;Landroid/net/DhcpInfoInternal;)Z", (void *)android_net_utils_runDhcpRenew }, { "runDhcpRenew", "(Ljava/lang/String;Landroid/net/DhcpInfoInternal;)Z", (void *)android_net_utils_runDhcpRenew },

View File

@@ -26,6 +26,7 @@ import android.net.ConnectivityManager;
import android.net.DummyDataStateTracker; import android.net.DummyDataStateTracker;
import android.net.EthernetDataTracker; import android.net.EthernetDataTracker;
import android.net.IConnectivityManager; import android.net.IConnectivityManager;
import android.net.LinkAddress;
import android.net.LinkProperties; import android.net.LinkProperties;
import android.net.MobileDataStateTracker; import android.net.MobileDataStateTracker;
import android.net.NetworkConfig; import android.net.NetworkConfig;
@@ -61,6 +62,7 @@ import java.io.FileWriter;
import java.io.IOException; import java.io.IOException;
import java.io.PrintWriter; import java.io.PrintWriter;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.Inet4Address;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
@@ -125,6 +127,8 @@ public class ConnectivityService extends IConnectivityManager.Stub {
private AtomicBoolean mBackgroundDataEnabled = new AtomicBoolean(true); private AtomicBoolean mBackgroundDataEnabled = new AtomicBoolean(true);
private INetworkManagementService mNetd;
private static final int ENABLED = 1; private static final int ENABLED = 1;
private static final int DISABLED = 0; private static final int DISABLED = 0;
@@ -933,10 +937,6 @@ public class ConnectivityService extends IConnectivityManager.Stub {
* @return {@code true} on success, {@code false} on failure * @return {@code true} on success, {@code false} on failure
*/ */
private boolean addHostRoute(NetworkStateTracker nt, InetAddress hostAddress, int cycleCount) { private boolean addHostRoute(NetworkStateTracker nt, InetAddress hostAddress, int cycleCount) {
if (nt.getNetworkInfo().getType() == ConnectivityManager.TYPE_WIFI) {
return false;
}
LinkProperties lp = nt.getLinkProperties(); LinkProperties lp = nt.getLinkProperties();
if ((lp == null) || (hostAddress == null)) return false; if ((lp == null) || (hostAddress == null)) return false;
@@ -951,20 +951,28 @@ public class ConnectivityService extends IConnectivityManager.Stub {
} }
RouteInfo bestRoute = RouteInfo.selectBestRoute(lp.getRoutes(), hostAddress); RouteInfo bestRoute = RouteInfo.selectBestRoute(lp.getRoutes(), hostAddress);
InetAddress gateway = null; InetAddress gatewayAddress = null;
if (bestRoute != null) { if (bestRoute != null) {
gateway = bestRoute.getGateway(); gatewayAddress = bestRoute.getGateway();
// if the best route is ourself, don't relf-reference, just add the host route // if the best route is ourself, don't relf-reference, just add the host route
if (hostAddress.equals(gateway)) gateway = null; if (hostAddress.equals(gatewayAddress)) gatewayAddress = null;
} }
if (gateway != null) { if (gatewayAddress != null) {
if (cycleCount > MAX_HOSTROUTE_CYCLE_COUNT) { if (cycleCount > MAX_HOSTROUTE_CYCLE_COUNT) {
loge("Error adding hostroute - too much recursion"); loge("Error adding hostroute - too much recursion");
return false; return false;
} }
if (!addHostRoute(nt, gateway, cycleCount+1)) return false; if (!addHostRoute(nt, gatewayAddress, cycleCount+1)) return false;
}
RouteInfo route = RouteInfo.makeHostRoute(hostAddress, gatewayAddress);
try {
mNetd.addRoute(interfaceName, route);
return true;
} catch (Exception ex) {
return false;
} }
return NetworkUtils.addHostRoute(interfaceName, hostAddress, gateway);
} }
// TODO support the removal of single host routes. Keep a ref count of them so we // TODO support the removal of single host routes. Keep a ref count of them so we
@@ -1291,6 +1299,9 @@ public class ConnectivityService extends IConnectivityManager.Stub {
} }
void systemReady() { void systemReady() {
IBinder b = ServiceManager.getService(Context.NETWORKMANAGEMENT_SERVICE);
mNetd = INetworkManagementService.Stub.asInterface(b);
synchronized(this) { synchronized(this) {
mSystemReady = true; mSystemReady = true;
if (mInitialBroadcast != null) { if (mInitialBroadcast != null) {
@@ -1427,7 +1438,6 @@ public class ConnectivityService extends IConnectivityManager.Stub {
if (interfaceName != null && !privateDnsRouteSet) { if (interfaceName != null && !privateDnsRouteSet) {
Collection<InetAddress> dnsList = p.getDnses(); Collection<InetAddress> dnsList = p.getDnses();
for (InetAddress dns : dnsList) { for (InetAddress dns : dnsList) {
if (DBG) log(" adding " + dns);
addHostRoute(nt, dns, 0); addHostRoute(nt, dns, 0);
} }
nt.privateDnsRouteSet(true); nt.privateDnsRouteSet(true);
@@ -1435,8 +1445,6 @@ public class ConnectivityService extends IConnectivityManager.Stub {
} }
private void removePrivateDnsRoutes(NetworkStateTracker nt) { private void removePrivateDnsRoutes(NetworkStateTracker nt) {
// TODO - we should do this explicitly but the NetUtils api doesnt
// support this yet - must remove all. No worse than before
LinkProperties p = nt.getLinkProperties(); LinkProperties p = nt.getLinkProperties();
if (p == null) return; if (p == null) return;
String interfaceName = p.getInterfaceName(); String interfaceName = p.getInterfaceName();
@@ -1446,7 +1454,17 @@ public class ConnectivityService extends IConnectivityManager.Stub {
log("removePrivateDnsRoutes for " + nt.getNetworkInfo().getTypeName() + log("removePrivateDnsRoutes for " + nt.getNetworkInfo().getTypeName() +
" (" + interfaceName + ")"); " (" + interfaceName + ")");
} }
NetworkUtils.removeHostRoutes(interfaceName);
Collection<InetAddress> dnsList = p.getDnses();
for (InetAddress dns : dnsList) {
if (DBG) log(" removing " + dns);
RouteInfo route = RouteInfo.makeHostRoute(dns);
try {
mNetd.removeRoute(interfaceName, route);
} catch (Exception ex) {
loge("error (" + ex + ") removing dns route " + route);
}
}
nt.privateDnsRouteSet(false); nt.privateDnsRouteSet(false);
} }
} }
@@ -1457,19 +1475,27 @@ public class ConnectivityService extends IConnectivityManager.Stub {
if (p == null) return; if (p == null) return;
String interfaceName = p.getInterfaceName(); String interfaceName = p.getInterfaceName();
if (TextUtils.isEmpty(interfaceName)) return; if (TextUtils.isEmpty(interfaceName)) return;
for (RouteInfo route : p.getRoutes()) {
for (RouteInfo route : p.getRoutes()) {
//TODO - handle non-default routes //TODO - handle non-default routes
if (route.isDefaultRoute()) { if (route.isDefaultRoute()) {
if (DBG) log("adding default route " + route);
InetAddress gateway = route.getGateway(); InetAddress gateway = route.getGateway();
if (addHostRoute(nt, gateway, 0) && if (addHostRoute(nt, gateway, 0)) {
NetworkUtils.addDefaultRoute(interfaceName, gateway)) { try {
mNetd.addRoute(interfaceName, route);
} catch (Exception e) {
loge("error adding default route " + route);
continue;
}
if (DBG) { if (DBG) {
NetworkInfo networkInfo = nt.getNetworkInfo(); NetworkInfo networkInfo = nt.getNetworkInfo();
log("addDefaultRoute for " + networkInfo.getTypeName() + log("addDefaultRoute for " + networkInfo.getTypeName() +
" (" + interfaceName + "), GatewayAddr=" + " (" + interfaceName + "), GatewayAddr=" +
gateway.getHostAddress()); gateway.getHostAddress());
} }
} else {
loge("error adding host route for default route " + route);
} }
} }
} }
@@ -1481,8 +1507,17 @@ public class ConnectivityService extends IConnectivityManager.Stub {
if (p == null) return; if (p == null) return;
String interfaceName = p.getInterfaceName(); String interfaceName = p.getInterfaceName();
if (interfaceName != null) { if (interfaceName == null) return;
if (NetworkUtils.removeDefaultRoute(interfaceName) >= 0) {
for (RouteInfo route : p.getRoutes()) {
//TODO - handle non-default routes
if (route.isDefaultRoute()) {
try {
mNetd.removeRoute(interfaceName, route);
} catch (Exception ex) {
loge("error (" + ex + ") removing default route " + route);
continue;
}
if (DBG) { if (DBG) {
NetworkInfo networkInfo = nt.getNetworkInfo(); NetworkInfo networkInfo = nt.getNetworkInfo();
log("removeDefaultRoute for " + networkInfo.getTypeName() + " (" + log("removeDefaultRoute for " + networkInfo.getTypeName() + " (" +