Commit 4a9305c3 authored by martin hou's avatar martin hou

fix: 异常时恢复接收

parent 8f1869ac
......@@ -443,8 +443,10 @@ function Jensen(log, conn) {
// console.log(pid + '-Receive', new Date().toLocaleString(), r?.data);
receive(r);
}).catch((e) => {
console.log('tryReceive error', e)
// console.log('tryReceive error', e)
// if (!channelHealthy) self.onerror?.(e);
Logger.error('jensen', 'receive', String(e));
tryReceive();
});
};
......@@ -471,9 +473,7 @@ function Jensen(log, conn) {
tryDecode();
}, self.timewait);
if (self.onreceive) {
try {
self.onreceive(totalBytes);
} catch (e) {}
try { self.onreceive(totalBytes); } catch (e) {}
}
};
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment