<fix>[host]: avoid stale context timeout for capacity checks

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Author: littleya

compute/src/main/java/org/zstack/compute/host/HostAfterConnectHookExtensionPoint.java

@@ -4,6 +4,15 @@
 import org.zstack.header.host.ConnectHostInfo;
 import org.zstack.header.host.HostInventory;
 
+/**
+ * Runs after the hypervisor connect hook and before pre-connect extensions.
+ */
 public interface HostAfterConnectHookExtensionPoint {
+    /**
+     * Returns a flow to run after host connection.
+     *
+     * @param reconnect whether this connect was triggered by host reconnect
+     * @return null to skip, or a flow to join the connect chain
+     */
     Flow createAfterConnectHookFlow(HostInventory host, ConnectHostInfo info, boolean reconnect);
 }

compute/src/main/java/org/zstack/compute/host/HostManagerImpl.java

@@ -14,7 +14,6 @@
 import org.zstack.core.defer.Deferred;
 import org.zstack.core.errorcode.ErrorFacade;
 import org.zstack.core.thread.*;
-import org.zstack.core.timeout.ApiTimeoutManager;
 import org.zstack.core.workflow.FlowChainBuilder;
 import org.zstack.header.AbstractService;
 import org.zstack.header.allocator.HostAllocatorConstant;
@@ -93,8 +92,6 @@ public class HostManagerImpl extends AbstractService implements HostManager, Man
     private ResourceConfigFacade rcf;
     @Autowired
     private ClusterResourceConfigInitializer crci;
-    @Autowired
-    private ApiTimeoutManager timeoutMgr;
 
     private Map<Class, HostBaseExtensionFactory> hostBaseExtensionFactories = new HashMap<>();
     private List<HostExtensionManager> hostExtensionManagers = new ArrayList<>();
@@ -821,7 +818,7 @@ private void reportHostCapacity() {
         new While<>(hostUuids).step((hostUuid, completion) -> {
             CheckHostCapacityMsg msg = new CheckHostCapacityMsg();
             msg.setHostUuid(hostUuid);
-            timeoutMgr.setMessageTimeout(msg);
+            msg.setTimeout(HostConstant.CHECK_HOST_CAPACITY_TIMEOUT);
             bus.makeTargetServiceIdByResourceUuid(msg, HostConstant.SERVICE_ID, hostUuid);
             bus.send(msg, new CloudBusCallBack(completion) {
                 @Override

header/src/main/java/org/zstack/header/host/HostConstant.java

@@ -1,11 +1,14 @@
 package org.zstack.header.host;
 
+import java.util.concurrent.TimeUnit;
 
 public interface HostConstant {
     public static final String SERVICE_ID = "host";
 
     public static final String ACTION_CATEGORY = "host";
 
+    long CHECK_HOST_CAPACITY_TIMEOUT = TimeUnit.MINUTES.toMillis(30);
+
     String HOST_SYNC_SIGNATURE_PREFIX = "Host-";
 
     String HOST_ARCHITECTURE_X86_64 = "x86_64";

plugin/kvm/src/main/java/org/zstack/kvm/KVMHostCapacityExtension.java

@@ -4,7 +4,6 @@
 import org.zstack.core.cloudbus.CloudBus;
 import org.zstack.core.cloudbus.CloudBusCallBack;
 import org.zstack.core.errorcode.ErrorFacade;
-import org.zstack.core.timeout.ApiTimeoutManager;
 import org.zstack.header.core.Completion;
 import org.zstack.header.core.NopeCompletion;
 import org.zstack.header.core.workflow.Flow;
@@ -24,14 +23,12 @@ public class KVMHostCapacityExtension implements KVMHostConnectExtensionPoint, H
     @Autowired
     private ErrorFacade errf;
     @Autowired
-    private ApiTimeoutManager timeoutMgr;
-    @Autowired
     private ResourceConfigFacade rcf;
 
     public void reportCapacity(HostInventory host, Completion completion) {
         CheckHostCapacityMsg msg = new CheckHostCapacityMsg();
         msg.setHostUuid(host.getUuid());
-        timeoutMgr.setMessageTimeout(msg);
+        msg.setTimeout(HostConstant.CHECK_HOST_CAPACITY_TIMEOUT);
         bus.makeTargetServiceIdByResourceUuid(msg, HostConstant.SERVICE_ID, host.getUuid());
         bus.send(msg, new CloudBusCallBack(completion) {
             @Override