blob: 7f952ca39bfac093a1f737fde25baa335f83a5e0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/* 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/.
*/
/*
* Uses host:version service to detect if ADB is running
* Modified from adb-file-transfer from original ADB
*/
"use strict";
const client = require("resource://devtools/client/shared/remote-debugging/adb/adb-client.js");
const { dumpn } = require("resource://devtools/shared/DevToolsUtils.js");
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
// stuck (bug 1481963), to avoid the stuck, we do forcibly fail the
// 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 (event) {
dumpn("running checker onerror");
finish(false);
};
socket.s.onopen = function (event) {
dumpn("running checker onopen");
state = "start";
runFSM();
};
socket.s.onclose = function (event) {
dumpn("running checker onclose");
};
socket.s.ondata = function (event) {
dumpn("running checker ondata");
runFSM(event.data);
};
};
socket = client.connect();
setupSocket();
});
};
|
