test debug

lib/device.js

@@ -224,6 +224,10 @@ class Device extends EventEmitter {
 				} else {
 					break;
 				}
+				if (mboxMessages.length > 1000) {
+					this._log.error('mbox over 1000 messages !?');
+					break;
+				}
 			} catch (err) {
 				break;
 			}
@@ -480,18 +484,34 @@ class Device extends EventEmitter {
 	}
 
 	async _close() {
+		let timeoutAt = Date.now() + DEVICE_OPEN_TIMEOUT;
 		const canClose = () => (!this._opening && !this._closing);
 		while (!canClose()) {
 			const p = new Promise(resolve => {
+				let timer = null;
 				const onChange = () => {
 					if (canClose()) {
 						this.off('_opening', onChange);
 						this.off('_closing', onChange);
 						resolve();
 					}
 				};
+				const onTimeout = async () => {
+					this._log.error('Timeout while _closing_ the device, attempt to force close');
+					this.off('_opening', onChange);
+					this.off('_closing', onChange);
+					if (this._usbDev) {
+						try {
+							await this._usbDev.close({ processPendingRequests: false });
+						} catch (e) {
+							this._log.error('Failed to force-close the device', e);
+						}
+					}
+					reject(new Error('Timeout while _closing_ the device'));
+				};
 				this.on('_opening', onChange);
 				this.on('_closing', onChange);
+				timer = setTimeout(onTimeout, Math.max(0, timeoutAt - Date.now()));
 			});
 			await p;
 		}

lib/index.js

@@ -5,8 +5,68 @@ const { Logger } = require('./logger');
 const { RunMode, initConfig, showUsage, config } = require('./config');
 const { isInternalError } = require('./error');
 const { version: PACKAGE_VERSION } = require('../package.json');
+const async_hooks = require('async_hooks');
+
+let hook = null;
+let hookMap = new Map();
 
 async function run() {
+	hook = async_hooks.createHook({
+		init: (asyncId, type, triggerAsyncId, resource) => {
+			if (resource && resource._timerArgs && resource._timerArgs[0] == 'notrack') {
+				return;
+			}
+			const error = {};
+			Error.captureStackTrace(error);
+			const stack = error.stack.split("\n").map(line => line.trim()).slice(1);
+			hookMap.set(asyncId, {
+				type,
+				triggerAsyncId,
+				resource,
+				stack,
+				count: 0,
+				timer: type == 'PROMISE' ? setInterval(() => {
+					console.log('================================================================');
+					const m = hookMap.get(asyncId);
+					m.count++;
+					console.log(`async op=${asyncId} stalled for over ${10 * m.count} mins`);
+					console.log(type);
+					console.log(resource);
+					console.log('stack:');
+					console.log(stack);
+					let parentId = triggerAsyncId;
+					while (parentId) {
+						const parent = hookMap.get(parentId);
+						if (!parent) {
+							break;
+						}
+						parentId = parent.triggerAsyncId;
+						console.log(`Parent ${parentId}`);
+						console.log(type);
+						console.log(resource);
+						console.log('stack:');
+						console.log(parent.stack);
+					}
+					console.log('done=============================================================\r\n\r\n');
+				}, 10 * 60 * 1000, 'notrack') : null
+			});
+		},
+		destroy: (asyncId) => {
+			const task = hookMap.get(asyncId);
+			if (task && task.timer) {
+				clearInterval(task.timer);
+			}
+			hookMap.delete(asyncId);
+		},
+		promiseResolve: (asyncId) => {
+			const task = hookMap.get(asyncId);
+			if (task && task.timer) {
+				clearInterval(task.timer);
+			}
+			hookMap.delete(asyncId);
+		},
+	});
+	hook.enable();
 	let ok = true;
 	let runner = null;
 	try {