jianf/HomeAgent
1
0
Fork 0
mirror of https://gitcode.com/JianFeeeee/HomeAgent.git synced 2026-10-03 15:53:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(stop): 修自伤——interceptLoop 里 takeStop() 被 || 短路提前消费

Browse Source 
上一版把 stop 标记在 interceptLoop 里消费掉了一部分：
`if n := armStop(); n > 0 || takeStop() { ... }`，queued=0 时短路到
takeStop()，标记先被吃掉，stepLLM 永远看不到 → 取消后照样重跑一轮。
实测：日志正确打出 stop requested ... queued=0，但生成仍跑到自然结束（5000+ 字全文落库）。

改为只 arm 不 take（takeStop 只由 stepLLM 消费），并补一条**经真实
interceptLoop** 的用例：它必须 a.Start()（第一版测试只调 New()，
interceptLoop 根本没跑，假绿）。已验证该用例在注入此 bug 时失败、修复后通过。
This commit is contained in:
JianFeeeee
2026-09-18 11:32:20 +08:00
parent f340adb1e1
commit 2022875642
2 changed files with 75 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
internal/agent/core/eventloop.go
View File

@ -44,10 +44,18 @@ func (a *Agent) interceptLoop() {
}
if stop {
// 停止：①立即结束当前 LLM 推理；②登记短路配额。
if n := a.sched.armStop(); n > 0 || a.sched.takeStop() {
log.Printf("[agent] stop requested by %s/%s (queued=%d will be short-circuited at pre-action)",
evt.Source, evt.OutputChannel, n)
}
//
// 注意这里**只 arm、不 take**：takeStop 必须由 stepLLM 去消费，
// 它才是决定“取消后不重跑”的那个人。曾经写成
//
// if n := armStop(); n > 0 || takeStop() { ... }
//
// 这个 `||` 在 queued=0 时会短路到 takeStop()，把标记先消费掉，
// 于是 stepLLM 永远看不到它 → 取消后照样重跑一轮。
// 实测：停止被正确记录（`stop requested ... queued=0`）但生成仍跑到自然结束。
n := a.sched.armStop()
log.Printf("[agent] stop requested by %s/%s (queued=%d will be short-circuited at pre-action)",
evt.Source, evt.OutputChannel, n)
a.cancelCurrentLLM()
if text == "" {
// 纯停止：不进中断队列、不产生新任务。旧实现把空停止当成一条