From eaf17ddbb97cbfe60197991e0e4627714b1c2bbe Mon Sep 17 00:00:00 2001 From: Abhishek Kumar Date: Mon, 21 Oct 2024 17:04:03 +0530 Subject: [PATCH] renamed storage.pool.host.connect.workers Signed-off-by: Abhishek Kumar --- .../src/main/java/com/cloud/storage/StorageManager.java | 4 ++-- .../src/main/java/com/cloud/storage/StorageManagerImpl.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/engine/components-api/src/main/java/com/cloud/storage/StorageManager.java b/engine/components-api/src/main/java/com/cloud/storage/StorageManager.java index 8f06c0af4e8..acdd891fc22 100644 --- a/engine/components-api/src/main/java/com/cloud/storage/StorageManager.java +++ b/engine/components-api/src/main/java/com/cloud/storage/StorageManager.java @@ -213,8 +213,8 @@ public interface StorageManager extends StorageService { "when resize a volume upto resize capacity disable threshold (pool.storage.allocated.resize.capacity.disablethreshold)", true, ConfigKey.Scope.Zone); - ConfigKey PrimaryStorageHostConnectWorkers = new ConfigKey<>("Storage", Integer.class, - "primary.storage.host.connect.workers", "1", + ConfigKey StoragePoolHostConnectWorkers = new ConfigKey<>("Storage", Integer.class, + "storage.pool.host.connect.workers", "1", "Number of worker threads to be used to connect hosts to a primary storage", true); /** diff --git a/server/src/main/java/com/cloud/storage/StorageManagerImpl.java b/server/src/main/java/com/cloud/storage/StorageManagerImpl.java index f4edc35b784..eaedd9fced7 100644 --- a/server/src/main/java/com/cloud/storage/StorageManagerImpl.java +++ b/server/src/main/java/com/cloud/storage/StorageManagerImpl.java @@ -1171,7 +1171,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C boolean handleStorageConflictException, boolean errorOnNoUpHost) throws CloudRuntimeException { CopyOnWriteArrayList poolHostIds = new CopyOnWriteArrayList<>(); ExecutorService executorService = Executors.newFixedThreadPool(Math.max(1, Math.min(hostIds.size(), - PrimaryStorageHostConnectWorkers.value()))); + StoragePoolHostConnectWorkers.value()))); List> futures = new ArrayList<>(); AtomicBoolean conflictSeen = new AtomicBoolean(false); for (Long hostId : hostIds) { @@ -3610,7 +3610,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C VmwareAllowParallelExecution, DataStoreDownloadFollowRedirects, AllowVolumeReSizeBeyondAllocation, - PrimaryStorageHostConnectWorkers + StoragePoolHostConnectWorkers }; }