mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-10-30 05:35:31 +00:00
387 lines
13 KiB
JavaScript
387 lines
13 KiB
JavaScript
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
"use strict";
|
|
|
|
const {classes: Cc, interfaces: Ci, utils: Cu, results: Cr} = Components;
|
|
|
|
Cu.import("resource://gre/modules/XPCOMUtils.jsm");
|
|
Cu.import("resource://gre/modules/Services.jsm");
|
|
|
|
const NETWORKSERVICE_CONTRACTID = "@mozilla.org/network/service;1";
|
|
const NETWORKSERVICE_CID = Components.ID("{a6c58260-46df-11e3-8f96-0800200c9a66}");
|
|
|
|
// 1xx - Requested action is proceeding
|
|
const NETD_COMMAND_PROCEEDING = 100;
|
|
// 2xx - Requested action has been successfully completed
|
|
const NETD_COMMAND_OKAY = 200;
|
|
// 4xx - The command is accepted but the requested action didn't
|
|
// take place.
|
|
const NETD_COMMAND_FAIL = 400;
|
|
// 5xx - The command syntax or parameters error
|
|
const NETD_COMMAND_ERROR = 500;
|
|
// 6xx - Unsolicited broadcasts
|
|
const NETD_COMMAND_UNSOLICITED = 600;
|
|
|
|
const WIFI_CTRL_INTERFACE = "wl0.1";
|
|
|
|
const MANUAL_PROXY_CONFIGURATION = 1;
|
|
|
|
const DEBUG = false;
|
|
|
|
function netdResponseType(code) {
|
|
return Math.floor(code / 100) * 100;
|
|
}
|
|
|
|
function isError(code) {
|
|
let type = netdResponseType(code);
|
|
return (type !== NETD_COMMAND_PROCEEDING && type !== NETD_COMMAND_OKAY);
|
|
}
|
|
|
|
function debug(msg) {
|
|
dump("-*- NetworkService: " + msg + "\n");
|
|
}
|
|
|
|
/**
|
|
* This component watches for network interfaces changing state and then
|
|
* adjusts routes etc. accordingly.
|
|
*/
|
|
function NetworkService() {
|
|
if(DEBUG) debug("Starting net_worker.");
|
|
this.worker = new ChromeWorker("resource://gre/modules/net_worker.js");
|
|
this.worker.onmessage = this.handleWorkerMessage.bind(this);
|
|
this.worker.onerror = function onerror(event) {
|
|
if(DEBUG) debug("Received error from worker: " + event.filename +
|
|
":" + event.lineno + ": " + event.message + "\n");
|
|
// Prevent the event from bubbling any further.
|
|
event.preventDefault();
|
|
};
|
|
|
|
// Callbacks to invoke when a reply arrives from the net_worker.
|
|
this.controlCallbacks = Object.create(null);
|
|
}
|
|
|
|
NetworkService.prototype = {
|
|
classID: NETWORKSERVICE_CID,
|
|
classInfo: XPCOMUtils.generateCI({classID: NETWORKSERVICE_CID,
|
|
contractID: NETWORKSERVICE_CONTRACTID,
|
|
classDescription: "Network Service",
|
|
interfaces: [Ci.nsINetworkService]}),
|
|
QueryInterface: XPCOMUtils.generateQI([Ci.nsINetworkService,
|
|
Ci.nsISupportsWeakReference,
|
|
Ci.nsIWorkerHolder]),
|
|
|
|
// nsIWorkerHolder
|
|
|
|
worker: null,
|
|
|
|
// Helpers
|
|
|
|
idgen: 0,
|
|
controlMessage: function controlMessage(params, callback) {
|
|
if (callback) {
|
|
let id = this.idgen++;
|
|
params.id = id;
|
|
this.controlCallbacks[id] = callback;
|
|
}
|
|
this.worker.postMessage(params);
|
|
},
|
|
|
|
handleWorkerMessage: function handleWorkerMessage(e) {
|
|
if(DEBUG) debug("NetworkManager received message from worker: " + JSON.stringify(e.data));
|
|
let response = e.data;
|
|
let id = response.id;
|
|
if (id === 'broadcast') {
|
|
Services.obs.notifyObservers(null, response.topic, response.reason);
|
|
return;
|
|
}
|
|
let callback = this.controlCallbacks[id];
|
|
if (callback) {
|
|
callback.call(this, response);
|
|
delete this.controlCallbacks[id];
|
|
}
|
|
},
|
|
|
|
// nsINetworkService
|
|
|
|
getNetworkInterfaceStats: function getNetworkInterfaceStats(networkName, callback) {
|
|
if(DEBUG) debug("getNetworkInterfaceStats for " + networkName);
|
|
|
|
let params = {
|
|
cmd: "getNetworkInterfaceStats",
|
|
ifname: networkName
|
|
};
|
|
|
|
params.report = true;
|
|
params.isAsync = true;
|
|
|
|
this.controlMessage(params, function(result) {
|
|
let success = result.resultCode >= NETD_COMMAND_OKAY &&
|
|
result.resultCode < NETD_COMMAND_ERROR;
|
|
callback.networkStatsAvailable(success, result.rxBytes,
|
|
result.txBytes, result.date);
|
|
});
|
|
},
|
|
|
|
setWifiOperationMode: function setWifiOperationMode(interfaceName, mode, callback) {
|
|
if(DEBUG) debug("setWifiOperationMode on " + interfaceName + " to " + mode);
|
|
|
|
let params = {
|
|
cmd: "setWifiOperationMode",
|
|
ifname: interfaceName,
|
|
mode: mode
|
|
};
|
|
|
|
params.report = true;
|
|
params.isAsync = true;
|
|
|
|
this.controlMessage(params, function(result) {
|
|
if (isError(result.resultCode)) {
|
|
callback.wifiOperationModeResult("netd command error");
|
|
} else {
|
|
callback.wifiOperationModeResult(null);
|
|
}
|
|
});
|
|
},
|
|
|
|
resetRoutingTable: function resetRoutingTable(network) {
|
|
if (!network.ip || !network.netmask) {
|
|
if(DEBUG) debug("Either ip or netmask is null. Cannot reset routing table.");
|
|
return;
|
|
}
|
|
let options = {
|
|
cmd: "removeNetworkRoute",
|
|
ifname: network.name,
|
|
ip: network.ip,
|
|
netmask: network.netmask
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
setDNS: function setDNS(networkInterface) {
|
|
if(DEBUG) debug("Going DNS to " + networkInterface.name);
|
|
let options = {
|
|
cmd: "setDNS",
|
|
ifname: networkInterface.name,
|
|
dns1_str: networkInterface.dns1,
|
|
dns2_str: networkInterface.dns2
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
setDefaultRouteAndDNS: function setDefaultRouteAndDNS(network, oldInterface) {
|
|
if(DEBUG) debug("Going to change route and DNS to " + network.name);
|
|
let options = {
|
|
cmd: "setDefaultRouteAndDNS",
|
|
ifname: network.name,
|
|
oldIfname: (oldInterface && oldInterface !== network) ? oldInterface.name : null,
|
|
gateway_str: network.gateway,
|
|
dns1_str: network.dns1,
|
|
dns2_str: network.dns2
|
|
};
|
|
this.worker.postMessage(options);
|
|
this.setNetworkProxy(network);
|
|
},
|
|
|
|
removeDefaultRoute: function removeDefaultRoute(ifname) {
|
|
if(DEBUG) debug("Remove default route for " + ifname);
|
|
let options = {
|
|
cmd: "removeDefaultRoute",
|
|
ifname: ifname
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
addHostRoute: function addHostRoute(network) {
|
|
if(DEBUG) debug("Going to add host route on " + network.name);
|
|
let options = {
|
|
cmd: "addHostRoute",
|
|
ifname: network.name,
|
|
gateway: network.gateway,
|
|
hostnames: [network.dns1, network.dns2, network.httpProxyHost]
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
removeHostRoute: function removeHostRoute(network) {
|
|
if(DEBUG) debug("Going to remove host route on " + network.name);
|
|
let options = {
|
|
cmd: "removeHostRoute",
|
|
ifname: network.name,
|
|
gateway: network.gateway,
|
|
hostnames: [network.dns1, network.dns2, network.httpProxyHost]
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
removeHostRoutes: function removeHostRoutes(ifname) {
|
|
if(DEBUG) debug("Going to remove all host routes on " + ifname);
|
|
let options = {
|
|
cmd: "removeHostRoutes",
|
|
ifname: ifname,
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
addHostRouteWithResolve: function addHostRouteWithResolve(network, hosts) {
|
|
if(DEBUG) debug("Going to add host route after dns resolution on " + network.name);
|
|
let options = {
|
|
cmd: "addHostRoute",
|
|
ifname: network.name,
|
|
gateway: network.gateway,
|
|
hostnames: hosts
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
removeHostRouteWithResolve: function removeHostRouteWithResolve(network, hosts) {
|
|
if(DEBUG) debug("Going to remove host route after dns resolution on " + network.name);
|
|
let options = {
|
|
cmd: "removeHostRoute",
|
|
ifname: network.name,
|
|
gateway: network.gateway,
|
|
hostnames: hosts
|
|
};
|
|
this.worker.postMessage(options);
|
|
},
|
|
|
|
setNetworkProxy: function setNetworkProxy(network) {
|
|
try {
|
|
if (!network.httpProxyHost || network.httpProxyHost === "") {
|
|
// Sets direct connection to internet.
|
|
Services.prefs.clearUserPref("network.proxy.type");
|
|
Services.prefs.clearUserPref("network.proxy.share_proxy_settings");
|
|
Services.prefs.clearUserPref("network.proxy.http");
|
|
Services.prefs.clearUserPref("network.proxy.http_port");
|
|
Services.prefs.clearUserPref("network.proxy.ssl");
|
|
Services.prefs.clearUserPref("network.proxy.ssl_port");
|
|
if(DEBUG) debug("No proxy support for " + network.name + " network interface.");
|
|
return;
|
|
}
|
|
|
|
if(DEBUG) debug("Going to set proxy settings for " + network.name + " network interface.");
|
|
// Sets manual proxy configuration.
|
|
Services.prefs.setIntPref("network.proxy.type", MANUAL_PROXY_CONFIGURATION);
|
|
// Do not use this proxy server for all protocols.
|
|
Services.prefs.setBoolPref("network.proxy.share_proxy_settings", false);
|
|
Services.prefs.setCharPref("network.proxy.http", network.httpProxyHost);
|
|
Services.prefs.setCharPref("network.proxy.ssl", network.httpProxyHost);
|
|
let port = network.httpProxyPort === 0 ? 8080 : network.httpProxyPort;
|
|
Services.prefs.setIntPref("network.proxy.http_port", port);
|
|
Services.prefs.setIntPref("network.proxy.ssl_port", port);
|
|
} catch(ex) {
|
|
if(DEBUG) debug("Exception " + ex + ". Unable to set proxy setting for " +
|
|
network.name + " network interface.");
|
|
}
|
|
},
|
|
|
|
// Enable/Disable DHCP server.
|
|
setDhcpServer: function setDhcpServer(enabled, config, callback) {
|
|
if (null === config) {
|
|
config = {};
|
|
}
|
|
|
|
config.cmd = "setDhcpServer";
|
|
config.isAsync = true;
|
|
config.enabled = enabled;
|
|
|
|
this.controlMessage(config, function setDhcpServerResult(response) {
|
|
if (!response.success) {
|
|
callback.dhcpServerResult('Set DHCP server error');
|
|
return;
|
|
}
|
|
callback.dhcpServerResult(null);
|
|
});
|
|
},
|
|
|
|
// Enable/disable WiFi tethering by sending commands to netd.
|
|
setWifiTethering: function setWifiTethering(enable, config, callback) {
|
|
// config should've already contained:
|
|
// .ifname
|
|
// .internalIfname
|
|
// .externalIfname
|
|
config.wifictrlinterfacename = WIFI_CTRL_INTERFACE;
|
|
config.cmd = "setWifiTethering";
|
|
|
|
// The callback function in controlMessage may not be fired immediately.
|
|
config.isAsync = true;
|
|
this.controlMessage(config, function setWifiTetheringResult(data) {
|
|
let code = data.resultCode;
|
|
let reason = data.resultReason;
|
|
let enable = data.enable;
|
|
let enableString = enable ? "Enable" : "Disable";
|
|
|
|
if(DEBUG) debug(enableString + " Wifi tethering result: Code " + code + " reason " + reason);
|
|
|
|
if (isError(code)) {
|
|
callback.wifiTetheringEnabledChange("netd command error");
|
|
} else {
|
|
callback.wifiTetheringEnabledChange(null);
|
|
}
|
|
});
|
|
},
|
|
|
|
// Enable/disable USB tethering by sending commands to netd.
|
|
setUSBTethering: function setUSBTethering(enable, config, callback) {
|
|
config.cmd = "setUSBTethering";
|
|
// The callback function in controlMessage may not be fired immediately.
|
|
config.isAsync = true;
|
|
this.controlMessage(config, function setUsbTetheringResult(data) {
|
|
let code = data.resultCode;
|
|
let reason = data.resultReason;
|
|
let enable = data.enable;
|
|
let enableString = enable ? "Enable" : "Disable";
|
|
|
|
if(DEBUG) debug(enableString + " USB tethering result: Code " + code + " reason " + reason);
|
|
|
|
if (isError(code)) {
|
|
callback.usbTetheringEnabledChange("netd command error");
|
|
} else {
|
|
callback.usbTetheringEnabledChange(null);
|
|
}
|
|
});
|
|
},
|
|
|
|
// Switch usb function by modifying property of persist.sys.usb.config.
|
|
enableUsbRndis: function enableUsbRndis(enable, callback) {
|
|
if(DEBUG) debug("enableUsbRndis: " + enable);
|
|
|
|
let params = {
|
|
cmd: "enableUsbRndis",
|
|
enable: enable
|
|
};
|
|
// Ask net work to report the result when this value is set to true.
|
|
if (callback) {
|
|
params.report = true;
|
|
} else {
|
|
params.report = false;
|
|
}
|
|
|
|
// The callback function in controlMessage may not be fired immediately.
|
|
params.isAsync = true;
|
|
//this._usbTetheringAction = TETHERING_STATE_ONGOING;
|
|
this.controlMessage(params, function (data) {
|
|
callback.enableUsbRndisResult(data.result, data.enable);
|
|
});
|
|
},
|
|
|
|
updateUpStream: function updateUpStream(previous, current, callback) {
|
|
let params = {
|
|
cmd: "updateUpStream",
|
|
isAsync: true,
|
|
previous: previous,
|
|
current: current
|
|
};
|
|
|
|
this.controlMessage(params, function (data) {
|
|
let code = data.resultCode;
|
|
let reason = data.resultReason;
|
|
if(DEBUG) debug("updateUpStream result: Code " + code + " reason " + reason);
|
|
callback.updateUpStreamResult(!isError(code), data.current.externalIfname);
|
|
});
|
|
},
|
|
};
|
|
|
|
this.NSGetFactory = XPCOMUtils.generateNSGetFactory([NetworkService]);
|