hanyu.liang's avatar <fix>[plugin]: add newDriverInstance for isolated drivers

core/src/main/java/org/zstack/core/plugin/PluginManager.java

@@ -25,4 +25,15 @@ public interface PluginManager {
 
     // get plugin class with type
     <T extends PluginDriver> T getPlugin(Class<? extends PluginDriver> pluginClass, String type);
+
+    /**
+     * Create a new independent instance of a plugin driver.
+     * Unlike getPlugin() which returns a shared singleton, this method creates
+     * a fresh instance each time to avoid concurrent state corruption when
+     * multiple callers need isolated driver configurations.
+     *
+     * @param pluginUuid the plugin product key / UUID
+     * @return a new instance of the plugin driver
+     */
+    <T extends PluginDriver> T newDriverInstance(String pluginUuid);
 }

core/src/main/java/org/zstack/core/plugin/PluginManagerImpl.java

@@ -298,6 +298,21 @@ public <T extends PluginDriver> T getPlugin(Class<? extends PluginDriver> plugin
                 .orElse(null);
     }
 
+    @Override
+    public <T extends PluginDriver> T newDriverInstance(String pluginProductKey) {
+        PluginDriver singleton = pluginInstances.get(pluginProductKey);
+        if (singleton == null) {
+            throw new CloudRuntimeException(String.format("Unsupported plugin %s", pluginProductKey));
+        }
+
+        try {
+            return (T) singleton.getClass().getConstructor().newInstance();
+        } catch (Exception e) {
+            throw new CloudRuntimeException(
+                    String.format("Failed to create new instance of plugin %s", pluginProductKey), e);
+        }
+    }
+
     @Override
     public void handleMessage(Message msg) {
         if (msg instanceof APIRefreshPluginDriversMsg) {