Fetch the repository succeeded.
This action will force synchronization from 大菜卵/Aircontroller-scrcpy, which will overwrite any changes that you have made since you forked the repository, and can not be recovered!!!
Synchronous operation will process in the background and will refresh the page when finishing processing. Please be patient.
exports.connectDeviceCommon = function (app, deviceId) {
if (app.connectMap[deviceId]) {
try {
app.connectMap[deviceId + "_tc"].terminate();
app.connectMap[deviceId].end();
} catch (error) {
console.error(error);
}
}
try {
var _client = net.connect(
{
port: app.devices[deviceId].port
}, function (err) {
app.connectMap[deviceId] = _client;
if (err) {
console.log('connect socket server error');
app.connectMap[deviceId] = null;
return;
}
var count = 1;
var readBannerBytes = 0;
var bannerLength = 2;
var readFrameBytes = 0;
var frameBodyLength = 0;
var frameBody = new Buffer(0);
var tempFrame;
var tempTimer;
var banner = {
version: 0
, length: 0
, pid: 0
, realWidth: 0
, realHeight: 0
, virtualWidth: 0
, virtualHeight: 0
, orientation: 0
, quirks: 0
};
function tryRead() {
for (var chunk; (chunk = _client.read());) {
// console.info('chunk(length=%d)', chunk.length)
for (var cursor = 0, len = chunk.length; cursor < len;) {
if (readBannerBytes < bannerLength) {
switch (readBannerBytes) {
case 0:
// version
banner.version = chunk[cursor]
break;
case 1:
// length
banner.length = bannerLength = chunk[cursor]
break;
case 2:
case 3:
case 4:
case 5:
// pid
banner.pid +=
(chunk[cursor] << ((readBannerBytes - 2) * 8)) >>> 0
break;
case 6:
case 7:
case 8:
case 9:
// real width
banner.realWidth +=
(chunk[cursor] << ((readBannerBytes - 6) * 8)) >>> 0
break;
case 10:
case 11:
case 12:
case 13:
// real height
banner.realHeight +=
(chunk[cursor] << ((readBannerBytes - 10) * 8)) >>> 0
break;
case 14:
case 15:
case 16:
case 17:
// virtual width
banner.virtualWidth +=
(chunk[cursor] << ((readBannerBytes - 14) * 8)) >>> 0
break;
case 18:
case 19:
case 20:
case 21:
// virtual height
banner.virtualHeight +=
(chunk[cursor] << ((readBannerBytes - 18) * 8)) >>> 0
break;
case 22:
// orientation
banner.orientation += chunk[cursor] * 90
break;
case 23:
// quirks
banner.quirks = chunk[cursor];
break;
}
cursor += 1;
readBannerBytes += 1;
if (readBannerBytes === bannerLength) {
if (!app.renameMap[deviceId]) {
app.renameMap[deviceId] = deviceId;
}
var item = document.getElementById(deviceId + "_check");
if (app.accessToken.clientNum <= app.linkDeviceCount && item == null) {
_client.end();
return;
}
if (item == null) {
app.linkDeviceCount++;
app.screens.push({ name: deviceId, source: '', wm: app.devices[deviceId].wm });
app.screensMap[deviceId] = app.screens.length - 1;
}
}
}
else if (readFrameBytes < 4) {
frameBodyLength += (chunk[cursor] << (readFrameBytes * 8)) >>> 0;
cursor += 1;
readFrameBytes += 1;
// console.info('headerbyte%d(val=%d)', readFrameBytes, frameBodyLength)
}
else {
if (len - cursor >= frameBodyLength) {
// console.info('bodyfin(len=%d,cursor=%d)', frameBodyLength, cursor)
frameBody = Buffer.concat([
frameBody
, chunk.slice(cursor, cursor + frameBodyLength)
])
// Sanity check for JPG header, only here for debugging purposes.
if (frameBody[0] !== 0xFF || frameBody[1] !== 0xD8) {
console.error(
'Frame body does not start with JPG header', frameBody);
process.exit(1);
}
// ws.send(frameBody, {
// binary: true
// })
var canvas = document.getElementById(deviceId + "_t");
if (canvas) {
loadMainImg(frameBody, canvas);
} else {
let rd = Math.random() * 10;
tempFrame = null;
tempFrame = frameBody;
try {
clearTimeout(tempTimer);
} catch (error) { }
if (rd <= app.frameNum) {
canvas = document.getElementById(deviceId);
loadImg(frameBody, canvas);
} else {
tempTimer = setTimeout(() => {
let canvas = document.getElementById(deviceId);
loadImg(tempFrame, canvas);
}, 150);
}
}
frameBody = null;
cursor += frameBodyLength;
frameBodyLength = readFrameBytes = 0;
frameBody = new Buffer(0);
}
else {
// console.info('body(len=%d)', len - cursor)
frameBody = Buffer.concat([
frameBody
, chunk.slice(cursor, len)
]);
frameBodyLength -= len - cursor;
readFrameBytes += len - cursor;
cursor = len;
}
}
}
}
}
_client.on('readable', tryRead)
_client.on('timeout', function (err) {
console.error("连接超时:重试");
// setTimeout(() => {
// if (app.devices[deviceId]) {
// connectDevice(deviceId);
// } else {
// app.connectMap[deviceId] = null;
// }
// }, 10000);
})
_client.on('connect', function (err) {
console.log("连接设备成功");
app.connectMap[deviceId] = _client;
})
});
_client.on('error', function (err) {
console.error("连接失败:重试");
})
} catch (error) {
console.error(error);
console.error("连接失败:重试");
}
app.connectMap[deviceId + "_tc"] = new Worker('deviceTouchWorker.js');
app.connectMap[deviceId + "_tc"].postMessage({ event: 'connect', data: app.devices[deviceId] });
}
exports.connectDeviceByThread = function (app, deviceId) {
if (app.connectMap[deviceId]) {
try {
app.connectMap[deviceId].terminate();
app.connectMap[deviceId + "_tc"].terminate();
} catch (error) {
console.error(error);
}
}
var count = 1;
var tempFrame;
var tempTimer;
app.connectMap[deviceId] = new Worker('deviceConnectWorker.js');
app.connectMap[deviceId].postMessage(app.devices[deviceId]);
app.connectMap[deviceId].onmessage = (event) => {
try {
var canvas = document.getElementById(event.data.device + "_t");
if (canvas) {
loadMainImg(event.data.buf, canvas);
} else {
let rd = Math.random() * 10;
// if (rd <= app.frameNum) {
// canvas = document.getElementById(event.data.device);
// loadImg(event.data.buf, canvas);
// count++;
// }
tempFrame = null;
tempFrame = event.data.buf;
try {
clearTimeout(tempTimer);
} catch (error) { }
if (rd <= app.frameNum) {
canvas = document.getElementById(deviceId);
loadImg(event.data.buf, canvas);
} else {
tempTimer = setTimeout(() => {
let canvas = document.getElementById(deviceId);
console.debug(1);
loadImg(tempFrame, canvas);
}, 150);
}
}
delete event.data;
event = null;
} catch (error) {
console.error(error);
}
};
app.connectMap[deviceId + "_tc"] = new Worker('deviceTouchWorker.js');
app.connectMap[deviceId + "_tc"].postMessage({ event: 'connect', data: app.devices[deviceId] });
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。