Maor Lipchuk has uploaded a new change for review.

Change subject: webadmin: Add query calls to AsyncDataProvider
......................................................................

webadmin: Add query calls to AsyncDataProvider

Adding calls to the attached Storage Domains' queries

Change-Id: Ie1cac201f0688f81ac84a4ae1aee3bf483504c0f
Bug-Url: https://bugzilla.redhat.com/1138115
Signed-off-by: Maor Lipchuk <[email protected]>
---
M 
frontend/webadmin/modules/uicommonweb/src/main/java/org/ovirt/engine/ui/uicommonweb/dataprovider/AsyncDataProvider.java
1 file changed, 43 insertions(+), 0 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/44/36544/1

diff --git 
a/frontend/webadmin/modules/uicommonweb/src/main/java/org/ovirt/engine/ui/uicommonweb/dataprovider/AsyncDataProvider.java
 
b/frontend/webadmin/modules/uicommonweb/src/main/java/org/ovirt/engine/ui/uicommonweb/dataprovider/AsyncDataProvider.java
index 0260e3f..13854ca 100644
--- 
a/frontend/webadmin/modules/uicommonweb/src/main/java/org/ovirt/engine/ui/uicommonweb/dataprovider/AsyncDataProvider.java
+++ 
b/frontend/webadmin/modules/uicommonweb/src/main/java/org/ovirt/engine/ui/uicommonweb/dataprovider/AsyncDataProvider.java
@@ -123,6 +123,7 @@
 import org.ovirt.engine.core.common.queries.ProviderQueryParameters;
 import org.ovirt.engine.core.common.queries.SearchParameters;
 import org.ovirt.engine.core.common.queries.ServerParameters;
+import 
org.ovirt.engine.core.common.queries.StorageDomainsAndStoragePoolIdQueryParameters;
 import 
org.ovirt.engine.core.common.queries.StorageServerConnectionQueryParametersBase;
 import org.ovirt.engine.core.common.queries.VdcQueryParametersBase;
 import org.ovirt.engine.core.common.queries.VdcQueryReturnValue;
@@ -313,6 +314,48 @@
                 OsRepositoryVerb.GetDefaultOSes), callback);
     }
 
+    public static void getStorageDomainsWithAttachedStoragePoolGuid(
+            AsyncQuery aQuery, StoragePool storagePool, List<StorageDomain> 
storageDomains) {
+        aQuery.converterCallback = new IAsyncConverter() {
+            @Override
+            public Object Convert(Object source, AsyncQuery _asyncQuery) {
+                return source == null ?
+                        new ArrayList<StorageDomain>() : 
(ArrayList<StorageDomain>) source;
+            }
+        };
+        StorageDomainsAndStoragePoolIdQueryParameters parameters =
+                new 
StorageDomainsAndStoragePoolIdQueryParameters(storageDomains, 
storagePool.getId());
+        
Frontend.getInstance().runQuery(VdcQueryType.GetStorageDomainsWithAttachedStoragePoolGuid,
+                parameters, aQuery);
+    }
+
+    public static void getStorageDomainsWithAttachedStoragePoolGuid(
+            AsyncQuery aQuery, StoragePool storagePool,
+            List<StorageDomain> storageDomains, StorageServerConnections 
storageServerConnection, Guid vdsId) {
+        aQuery.converterCallback = new IAsyncConverter() {
+            @Override
+            public Object Convert(Object source, AsyncQuery _asyncQuery) {
+                return source == null ?
+                        new ArrayList<StorageDomain>() : 
(ArrayList<StorageDomain>) source;
+            }
+        };
+
+        if (storageDomains != null) {
+            // Get file storage domains
+            StorageDomainsAndStoragePoolIdQueryParameters parameters =
+                    new 
StorageDomainsAndStoragePoolIdQueryParameters(storageDomains, 
storagePool.getId(), vdsId);
+            
Frontend.getInstance().runQuery(VdcQueryType.GetBlockStorageDomainsWithAttachedStoragePoolGuid,
+                    parameters, aQuery);
+        }
+        else {
+            // Get block storage domains
+            StorageDomainsAndStoragePoolIdQueryParameters parameters =
+                    new 
StorageDomainsAndStoragePoolIdQueryParameters(storageServerConnection, 
storagePool.getId(), vdsId);
+            
Frontend.getInstance().runQuery(VdcQueryType.GetFileStorageDomainsWithAttachedStoragePoolGuid,
+                    parameters, aQuery);
+        }
+    }
+
     public static Boolean isMigrationSupported(ArchitectureType architecture, 
Version version) {
         return migrationSupport.get(architecture).get(version);
     }


-- 
To view, visit http://gerrit.ovirt.org/36544
To unsubscribe, visit http://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: Ie1cac201f0688f81ac84a4ae1aee3bf483504c0f
Gerrit-PatchSet: 1
Gerrit-Project: ovirt-engine
Gerrit-Branch: ovirt-engine-3.5
Gerrit-Owner: Maor Lipchuk <[email protected]>
_______________________________________________
Engine-patches mailing list
[email protected]
http://lists.ovirt.org/mailman/listinfo/engine-patches

Reply via email to