opensource/mateclaw
2
0
Fork 0
mirror of https://gitee.com/mateos/mateclaw.git synced 2026-09-15 11:58:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(chat): reset stale stopRequested flag on new stream register

Browse Source
This commit is contained in:
matevip 2026-04-16 18:13:34 +08:00
parent ba086d75f2
commit 8a25d723f0
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
mateclaw-server/src/main/java/vip/mate/channel/web/ChatStreamTracker.java
View File

@ -144,6 +144,18 @@ public class ChatStreamTracker {
if (state != null && state.done) { if (state != null && state.done) {
stopHeartbeat(conversationId); stopHeartbeat(conversationId);
runs.put(conversationId, new RunState(conversationId)); runs.put(conversationId, new RunState(conversationId));
} else if (state != null) {
// Reuse path: when complete() early-returns due to activeFluxCount > 0
// (approval replay / interrupt / any leaked flux increment), the RunState
// is kept with stopRequested still true from the previous turn. Left alone,
// the next register() would reuse it and ReasoningNode would instantly
// abort every new message with "Stop requested before LLM call".
// Reset the flag here — new registration means new user intent, and any
// still-live prior flux has already been cancelled via requestStop()'s
// disposable.dispose(), so the flag is redundant for it.
if (state.stopRequested.compareAndSet(true, false)) {
log.info("[ChatStreamTracker] Reset stale stopRequested on register: {}", conversationId);
}
} }
startHeartbeat(conversationId); startHeartbeat(conversationId);
log.debug("Stream registered: {}", conversationId); log.debug("Stream registered: {}", conversationId);