Source code
Revision control
Copy as Markdown
Other Tools
/* 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
*/
/*
* Uses host:version service to detect if ADB is running
* Modified from adb-file-transfer from original ADB
*/
"use strict";
exports.check = async function check() {
let socket;
let state;
let timerID;
const TIMEOUT_TIME = 1000;
dumpn("Asking for host:version");
return new Promise(resolve => {
// On MacOSX connecting to a port which is not started listening gets
// connection after |TIMEOUT_TIME| elapsed.
timerID = setTimeout(() => {
socket.close();
resolve(false);
}, TIMEOUT_TIME);
function finish(returnValue) {
clearTimeout(timerID);
resolve(returnValue);
}
const runFSM = function runFSM(packetData) {
dumpn("runFSM " + state);
switch (state) {
case "start":
const req = client.createRequest("host:version");
socket.send(req);
state = "wait-version";
break;
case "wait-version":
// TODO: Actually check the version number to make sure the daemon
// supports the commands we want to use
const { length, data } = client.unpackPacket(packetData);
dumpn("length: ", length, "data: ", data);
socket.close();
const version = parseInt(data, 16);
if (version >= 31) {
finish(true);
} else {
dumpn("killing existing adb as we need version >= 31");
finish(false);
}
break;
default:
dumpn("Unexpected State: " + state);
finish(false);
}
};
const setupSocket = function () {
socket.s.onerror = function () {
dumpn("running checker onerror");
finish(false);
};
socket.s.onopen = function () {
dumpn("running checker onopen");
state = "start";
runFSM();
};
socket.s.onclose = function () {
dumpn("running checker onclose");
};
socket.s.ondata = function (event) {
dumpn("running checker ondata");
runFSM(event.data);
};
};
socket = client.connect();
setupSocket();
});
};