opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(mcp): improve error handling during MCP server connection initialization and reconnection attempts

Browse source
This commit is contained in:
tong3jie 2026-03-20 13:59:26 +08:00
parent 651fe4f04d
commit 82addc2f91
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
pkg/mcp/manager.go
View file

@ -143,6 +143,8 @@ func (m *Manager) LoadFromMCPConfig(
"failed": len(allErrors), "failed": len(allErrors),
"total": enabledCount, "total": enabledCount,
}) })
// only all mcp servers was failed, then return
return fmt.Errorf("all MCP servers failed to connect: %w", err) return fmt.Errorf("all MCP servers failed to connect: %w", err)
} }
@ -150,8 +152,8 @@ func (m *Manager) LoadFromMCPConfig(
"failed": len(allErrors), "failed": len(allErrors),
"connected": connectedCount, "connected": connectedCount,
"total": enabledCount, "total": enabledCount,
"error": err.Error(),
}) })
return fmt.Errorf("partial MCP initialization failure: %w", err)
} }
logger.InfoCF(logModule, "MCP server initialization complete", map[string]any{ logger.InfoCF(logModule, "MCP server initialization complete", map[string]any{
@ -410,6 +412,9 @@ func (m *Manager) handleServerOffline(name string) {
logger.DebugCF("mcp", "Reconnection attempt", map[string]any{"server": name, "attempt": attempt}) logger.DebugCF("mcp", "Reconnection attempt", map[string]any{"server": name, "attempt": attempt})
if m.closed.Load() {
return
}
err := m.ConnectServer(context.Background(), name, conn.Config) err := m.ConnectServer(context.Background(), name, conn.Config)
if err == nil { if err == nil {
logger.InfoCF("mcp", "Reconnection successful", map[string]any{"server": name}) logger.InfoCF("mcp", "Reconnection successful", map[string]any{"server": name})