refactor: 拆分大函数路径模块并收紧 nloc 棘轮 / split large-fn modules and tighten nloc ratchet

- chat_job_queue：worker 目录化（stream/json 任务体）
- lib：run_agent_turn 迁至 run_agent_turn.rs 并再导出
- agent_turn：串行工具执行体迁至 serial/exec_serial.rs
- 澄清问卷、markdown_links/check、quality_tools 等目录化（既有拆分）
- 开发文档与 fn-nloc 基线同步

Co-authored-by: Yales Peter <noisystreet@users.noreply.github.com>

Author: cursoragent

docs/开发文档.md

@@ -1 +1 @@
-226
+217

scripts/fn_nloc_max_baseline.txt

@@ -1 +1 @@
-2039
+2006

scripts/fn_nloc_top10_sum_baseline.txt

@@ -0,0 +1,246 @@
+//! 串行工具批执行主循环（从 [`super::`] 拆出以降低 `serial/mod.rs` 行数）。
+
+use std::collections::HashMap;
+use std::time::Instant;
+
+use log::info;
+
+use crate::agent::workflow_tool_dispatch;
+use crate::tool_registry::{self, HandlerId, ToolRuntime};
+
+use super::super::{
+    ExecuteToolsBatchOutcome, ExecuteToolsCommonCtx, abort_tool_batch_if_sse_closed,
+};
+use super::after_dispatch::{
+    serial_bookkeep_run_command_failure, serial_log_web_audit_write_tool_if_needed,
+    serial_maybe_invalidate_codebase_semantic_index, serial_tool_iteration_sse_preface,
+};
+use super::emit::{
+    emit_serial_tool_result, serial_bookkeep_readonly_tool_ttl_cache_after_tool,
+    serial_emit_early_without_dispatch,
+};
+use super::{
+    SerialEmitEarlyWithoutDispatchParams, SerialEmitToolResultParams,
+    SerialToolIterationSsePreface, SerialTtlAfterDispatchParams,
+};
+
+pub(super) async fn execute_tools_serial_impl(
+    ctx: ExecuteToolsCommonCtx<'_>,
+    workspace_changed: &mut bool,
+) -> ExecuteToolsBatchOutcome {
+    let ExecuteToolsCommonCtx {
+        tool_calls,
+        per_coord,
+        messages,
+        cfg,
+        effective_working_dir,
+        workspace_is_set,
+        read_file_turn_cache,
+        workspace_changelist,
+        out,
+        tool_running_hook: _,
+        clarification_questionnaire_hook,
+        echo_terminal_transcript,
+        terminal_tool_display_max_chars,
+        tool_result_envelope_v1,
+        web_tool_ctx,
+        cli_tool_ctx,
+        mcp_session,
+        request_chrome_trace,
+        step_executor_constraint,
+        tools_defs_full,
+        turn_allow,
+        long_term_memory,
+        long_term_memory_scope_id,
+        tracing_chat_turn,
+        request_audit,
+        tool_outcome_recorder,
+        handler_lookup,
+        sync_default_sandbox_backend,
+        readonly_tool_ttl_cache,
+        sse_control_mirror,
+    } = ctx;
+
+    let sse_mirror_for_emit = sse_control_mirror.clone();
+
+    let mut readonly_cache: HashMap<(String, String), String> = HashMap::new();
+    for tc in tool_calls {
+        if abort_tool_batch_if_sse_closed(
+            out,
+            "SSE sender closed during tool execution, aborting remaining tools",
+        )
+        .await
+        {
+            return ExecuteToolsBatchOutcome::AbortedSse;
+        }
+
+        let name = tc.function.name.clone();
+        let args = tc.function.arguments.clone();
+        let id = tc.id.clone();
+        serial_tool_iteration_sse_preface(SerialToolIterationSsePreface {
+            out,
+            sse_mirror: sse_mirror_for_emit.as_ref(),
+            cfg,
+            tracing_chat_turn: tracing_chat_turn.as_ref(),
+            id: id.as_str(),
+            name: &name,
+            args: &args,
+            messages,
+        })
+        .await;
+
+        if serial_emit_early_without_dispatch(SerialEmitEarlyWithoutDispatchParams {
+            messages,
+            per_coord,
+            cfg,
+            tool_outcome_recorder: &tool_outcome_recorder,
+            out,
+            sse_control_mirror: sse_mirror_for_emit.clone(),
+            clarification_questionnaire_hook: clarification_questionnaire_hook.clone(),
+            echo_terminal_transcript,
+            terminal_tool_display_max_chars,
+            tool_result_envelope_v1,
+            effective_working_dir,
+            name: name.as_str(),
+            args: args.as_str(),
+            id: id.as_str(),
+            step_executor_constraint,
+            tools_defs_full,
+            turn_allow,
+            readonly_cache: &mut readonly_cache,
+            readonly_tool_ttl_cache: &readonly_tool_ttl_cache,
+        })
+        .await
+        {
+            continue;
+        }
+
+        let is_readonly = tool_registry::is_readonly_tool(cfg.as_ref(), name.as_str());
+        let cache_key = (name.clone(), args.clone());
+
+        let t_tool = Instant::now();
+        let runtime = if let Some(cctx) = cli_tool_ctx {
+            ToolRuntime::Cli {
+                workspace_changed,
+                ctx: cctx,
+            }
+        } else {
+            ToolRuntime::Web {
+                workspace_changed,
+                ctx: web_tool_ctx,
+            }
+        };
+        let (result, reflection_inject) =
+            if handler_lookup.id_for(name.as_str()) == HandlerId::Workflow {
+                workflow_tool_dispatch::dispatch_workflow_execute_tool(
+                    runtime,
+                    per_coord,
+                    cfg,
+                    effective_working_dir,
+                    workspace_is_set,
+                    args.as_str(),
+                    request_chrome_trace.clone(),
+                )
+                .await
+            } else {
+                tool_registry::dispatch_tool(tool_registry::DispatchToolParams {
+                    runtime,
+                    cfg,
+                    effective_working_dir,
+                    workspace_is_set,
+                    name: &name,
+                    args: &args,
+                    sse_out_tx: out,
+                    sse_control_mirror: sse_mirror_for_emit.as_ref(),
+                    tc,
+                    read_file_turn_cache: read_file_turn_cache.clone(),
+                    workspace_changelist: workspace_changelist.cloned(),
+                    mcp_session,
+                    turn_allow,
+                    long_term_memory: long_term_memory.clone(),
+                    long_term_memory_scope_id: long_term_memory_scope_id.clone(),
+                    handler_lookup: &handler_lookup,
+                    sync_default_sandbox_backend: &sync_default_sandbox_backend,
+                })
+                .await
+            };
+
+        info!(
+            target: super::super::LOG_TARGET,
+            "工具调用完成 tool={} args_preview={} elapsed_ms={}",
+            name,
+            crate::redact::tool_arguments_preview_for_log(&args),
+            t_tool.elapsed().as_millis()
+        );
+
+        serial_log_web_audit_write_tool_if_needed(
+            cfg.as_ref(),
+            is_readonly,
+            request_audit.as_ref(),
+            tracing_chat_turn.as_ref(),
+            long_term_memory_scope_id.as_deref(),
+            name.as_str(),
+            args.as_str(),
+        );
+
+        serial_bookkeep_run_command_failure(
+            per_coord,
+            name.as_str(),
+            args.as_str(),
+            result.as_str(),
+        );
+
+        serial_maybe_invalidate_codebase_semantic_index(
+            cfg,
+            effective_working_dir,
+            workspace_changed,
+            is_readonly,
+            name.as_str(),
+            args.as_str(),
+            result.as_str(),
+        );
+
+        serial_bookkeep_readonly_tool_ttl_cache_after_tool(SerialTtlAfterDispatchParams {
+            cfg: cfg.as_ref(),
+            effective_working_dir,
+            readonly_tool_ttl_cache: &readonly_tool_ttl_cache,
+            name: name.as_str(),
+            args: args.as_str(),
+            result: result.as_str(),
+            workspace_changed: *workspace_changed,
+        });
+
+        if (!is_readonly || *workspace_changed)
+            && let Some(c) = read_file_turn_cache.as_ref()
+        {
+            c.clear();
+        }
+
+        if is_readonly {
+            readonly_cache.insert(cache_key, result.clone());
+        } else {
+            readonly_cache.clear();
+        }
+
+        emit_serial_tool_result(SerialEmitToolResultParams {
+            messages,
+            per_coord,
+            cfg,
+            tool_outcome_recorder: &tool_outcome_recorder,
+            out,
+            sse_control_mirror: sse_mirror_for_emit.clone(),
+            clarification_questionnaire_hook: clarification_questionnaire_hook.clone(),
+            echo_terminal_transcript,
+            terminal_tool_display_max_chars,
+            tool_result_envelope_v1,
+            name: name.as_str(),
+            args: args.as_str(),
+            id: id.as_str(),
+            result,
+            reflection_inject,
+        })
+        .await;
+    }
+
+    ExecuteToolsBatchOutcome::Finished
+}