core: allow trying to select new SPM when network problems with current SPM

For now there is some cases when SPM can be safely transited to another host when there is network problems with the current SPM.
But some checks not allow to start this process.
With this change we allow to start process to select new SPM.
If this process not safe, selection process will be stopped on next steps.

Signed-off-by: Stanislav Melnichuk <[email protected]>

Author: 0ffer

backend/manager/modules/vdsbroker/src/main/java/org/ovirt/engine/core/vdsbroker/irsbroker/IrsProxyImpl.java

@@ -89,7 +89,6 @@
 import org.ovirt.engine.core.vdsbroker.ResourceManager;
 import org.ovirt.engine.core.vdsbroker.TransportFactory;
 import org.ovirt.engine.core.vdsbroker.storage.StoragePoolDomainHelper;
-import org.ovirt.engine.core.vdsbroker.vdsbroker.VDSNetworkException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -299,6 +298,7 @@ private void proceedStoragePoolStats(StoragePool storagePool) {
                     new SpmStatusVDSCommandParameters(curVdsId, storagePoolId));
         }
 
+        // if spm status didn't work or not spm then cause failover with attempts
         if (result == null
                 || !result.getSucceeded()
                 || result.getSucceeded() && ((SpmStatusResult) result.getReturnValue()).getSpmStatus() != SpmStatus.SPM) {
@@ -316,10 +316,7 @@ private void proceedStoragePoolStats(StoragePool storagePool) {
                 }
             }
 
-            // if spm status didn't work or not spm and NOT NETWORK
-            // PROBLEM
-            // then cause failover with attempts
-            if (result != null && !(result.getExceptionObject() instanceof VDSNetworkException)) {
+            if (curVdsId != null) { // If there was already SPM host, then we can start failover process
                 Map<Guid, AsyncTaskStatus> tasksList =
                         (Map<Guid, AsyncTaskStatus>) resourceManager
                                 .runVdsCommand(VDSCommandType.HSMGetAllTasksStatuses,
@@ -336,7 +333,7 @@ private void proceedStoragePoolStats(StoragePool storagePool) {
                 if (tasksList == null || allTasksFinished) {
                     nullifyInternalProxies();
                 } else {
-                    if (_errorAttempts < Config.<Integer> getValue(ConfigValues.SPMFailOverAttempts)) {
+                    if (_errorAttempts < Config.<Integer>getValue(ConfigValues.SPMFailOverAttempts)) {
                         _errorAttempts++;
                         log.warn("failed getting spm status for pool '{}' ({}), attempt number: {}",
                                 storagePoolId, storagePool.getName(), _errorAttempts);