🔧 代码审查修复: 提取内存阈值常量+错误日志补全+重试失败日志
Agent-Logs-Url: https://github.com/qinfendebingshuo/guanghulab/sessions/4df39bae-078f-4266-878d-f4996a5725ea Co-authored-by: qinfendebingshuo <207279273+qinfendebingshuo@users.noreply.github.com>
This commit is contained in:
parent
9a2ef8d0a0
commit
6a1bcf3569
|
|
@ -248,7 +248,7 @@ class HLDPBus {
|
||||||
]
|
]
|
||||||
);
|
);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
// 非关键·忽略
|
console.warn(`[HLDP] 消息持久化失败: ${err.message}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -30,6 +30,7 @@ const HEALTH_THRESHOLD_DEGRADED = 70;
|
||||||
const HEALTH_THRESHOLD_CRITICAL = 30;
|
const HEALTH_THRESHOLD_CRITICAL = 30;
|
||||||
const MAX_HEAL_ATTEMPTS = 3;
|
const MAX_HEAL_ATTEMPTS = 3;
|
||||||
const HEAL_COOLDOWN_MS = 60000; // 1分钟冷却
|
const HEAL_COOLDOWN_MS = 60000; // 1分钟冷却
|
||||||
|
const MEMORY_THRESHOLD_BYTES = 200 * 1024 * 1024; // 200MB
|
||||||
|
|
||||||
class LivingModule {
|
class LivingModule {
|
||||||
/**
|
/**
|
||||||
|
|
@ -222,7 +223,7 @@ class LivingModule {
|
||||||
|
|
||||||
// 内存检查
|
// 内存检查
|
||||||
const mem = process.memoryUsage();
|
const mem = process.memoryUsage();
|
||||||
if (mem.heapUsed > 200 * 1024 * 1024) { // > 200MB
|
if (mem.heapUsed > MEMORY_THRESHOLD_BYTES) {
|
||||||
issues.push({
|
issues.push({
|
||||||
code: 'HIGH_MEMORY',
|
code: 'HIGH_MEMORY',
|
||||||
severity: 'warning',
|
severity: 'warning',
|
||||||
|
|
|
||||||
|
|
@ -250,7 +250,7 @@ class ModuleRegistry {
|
||||||
_emit(event, data) {
|
_emit(event, data) {
|
||||||
const listeners = this._listeners.get(event) || [];
|
const listeners = this._listeners.get(event) || [];
|
||||||
for (const fn of listeners) {
|
for (const fn of listeners) {
|
||||||
try { fn(data); } catch (err) { /* 忽略 */ }
|
try { fn(data); } catch (err) { console.warn(`[Registry] 事件处理器异常 [${event}]: ${err.message}`); }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -315,7 +315,9 @@ const scheduler = new SchedulerModule();
|
||||||
scheduler.startEngine().catch(err => {
|
scheduler.startEngine().catch(err => {
|
||||||
console.error('[Scheduler] 启动失败:', err.message);
|
console.error('[Scheduler] 启动失败:', err.message);
|
||||||
console.log('[Scheduler] 等待60秒后重试...');
|
console.log('[Scheduler] 等待60秒后重试...');
|
||||||
setTimeout(() => scheduler.startEngine().catch(() => {}), 60000);
|
setTimeout(() => scheduler.startEngine().catch(err => {
|
||||||
|
console.error('[Scheduler] 重试失败:', err.message);
|
||||||
|
}), 60000);
|
||||||
});
|
});
|
||||||
|
|
||||||
// 优雅关闭
|
// 优雅关闭
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue