@@ -1143,7 +1143,7 @@ def __init__(self, content, dc_name=None):
1143
1143
self .esx_hosts = {}
1144
1144
self .parent_datacenters = {}
1145
1145
1146
- def find_obj (self , content , types , name , confine_to_datacenter = True ):
1146
+ def find_obj_wrapper (self , content , types , name , confine_to_datacenter = True ):
1147
1147
""" Wrapper around find_obj to set datacenter context """
1148
1148
result = find_obj (content , types , name )
1149
1149
if result and confine_to_datacenter :
@@ -1180,19 +1180,19 @@ def get_network(self, network_name):
1180
1180
if len (networks ) == 1 :
1181
1181
self .networks [network_name ] = networks [0 ]
1182
1182
else :
1183
- self .networks [network_name ] = self .find_obj (self .content , [vim .Network ], network_name )
1183
+ self .networks [network_name ] = self .find_obj_wrapper (self .content , [vim .Network ], network_name )
1184
1184
1185
1185
return self .networks [network_name ]
1186
1186
1187
1187
def get_cluster (self , cluster ):
1188
1188
if cluster not in self .clusters :
1189
- self .clusters [cluster ] = self .find_obj (self .content , [vim .ClusterComputeResource ], cluster )
1189
+ self .clusters [cluster ] = self .find_obj_wrapper (self .content , [vim .ClusterComputeResource ], cluster )
1190
1190
1191
1191
return self .clusters [cluster ]
1192
1192
1193
1193
def get_esx_host (self , host ):
1194
1194
if host not in self .esx_hosts :
1195
- self .esx_hosts [host ] = self .find_obj (self .content , [vim .HostSystem ], host )
1195
+ self .esx_hosts [host ] = self .find_obj_wrapper (self .content , [vim .HostSystem ], host )
1196
1196
1197
1197
return self .esx_hosts [host ]
1198
1198
@@ -1996,7 +1996,7 @@ def configure_network(self, vm_obj):
1996
1996
if len (networks ) == 1 :
1997
1997
pg_obj = networks [0 ]
1998
1998
else :
1999
- pg_obj = self .cache .find_obj (self .content , [vim .dvs .DistributedVirtualPortgroup ], network_name )
1999
+ pg_obj = self .cache .find_obj_wrapper (self .content , [vim .dvs .DistributedVirtualPortgroup ], network_name )
2000
2000
2001
2001
# TODO: (akasurde) There is no way to find association between resource pool and distributed virtual portgroup
2002
2002
# For now, check if we are able to find distributed virtual switch
@@ -2781,13 +2781,13 @@ def select_datastore(self, vm_obj=None):
2781
2781
for host in cluster .host :
2782
2782
for mi in host .configManager .storageSystem .fileSystemVolumeInfo .mountInfo :
2783
2783
if mi .volume .type == "VMFS" or mi .volume .type == "NFS" :
2784
- datastores .append (self .cache .find_obj (self .content , [vim .Datastore ], mi .volume .name ))
2784
+ datastores .append (self .cache .find_obj_wrapper (self .content , [vim .Datastore ], mi .volume .name ))
2785
2785
elif self .params ['esxi_hostname' ]:
2786
2786
host = self .find_hostsystem_by_name (self .params ['esxi_hostname' ])
2787
2787
2788
2788
for mi in host .configManager .storageSystem .fileSystemVolumeInfo .mountInfo :
2789
2789
if mi .volume .type == "VMFS" or mi .volume .type == "NFS" :
2790
- datastores .append (self .cache .find_obj (self .content , [vim .Datastore ], mi .volume .name ))
2790
+ datastores .append (self .cache .find_obj_wrapper (self .content , [vim .Datastore ], mi .volume .name ))
2791
2791
else :
2792
2792
datastores = self .cache .get_all_objs (self .content , [vim .Datastore ])
2793
2793
datastores = [x for x in datastores if self .cache .get_parent_datacenter (x ).name == self .params ['datacenter' ]]
@@ -2809,12 +2809,12 @@ def select_datastore(self, vm_obj=None):
2809
2809
elif self .params ['disk' ][0 ]['datastore' ]:
2810
2810
datastore_name = self .params ['disk' ][0 ]['datastore' ]
2811
2811
# Check if user has provided datastore cluster first
2812
- datastore_cluster = self .cache .find_obj (self .content , [vim .StoragePod ], datastore_name )
2812
+ datastore_cluster = self .cache .find_obj_wrapper (self .content , [vim .StoragePod ], datastore_name )
2813
2813
if datastore_cluster :
2814
2814
# If user specified datastore cluster so get recommended datastore
2815
2815
datastore_name = self .get_recommended_datastore (datastore_cluster_obj = datastore_cluster )
2816
2816
# Check if get_recommended_datastore or user specified datastore exists or not
2817
- datastore = self .cache .find_obj (self .content , [vim .Datastore ], datastore_name )
2817
+ datastore = self .cache .find_obj_wrapper (self .content , [vim .Datastore ], datastore_name )
2818
2818
else :
2819
2819
self .module .fail_json (msg = "Either datastore or autoselect_datastore should be provided to select datastore" )
2820
2820
@@ -2906,26 +2906,26 @@ def get_resource_pool(self, cluster=None, host=None, resource_pool=None):
2906
2906
resource_pool_name = resource_pool or self .params .get ('resource_pool' , None )
2907
2907
2908
2908
# get the datacenter object
2909
- datacenter = find_obj (self .content , [vim .Datacenter ], self .params ['datacenter' ])
2909
+ datacenter = find_obj_wrapper (self .content , [vim .Datacenter ], self .params ['datacenter' ])
2910
2910
if not datacenter :
2911
2911
self .module .fail_json (msg = 'Unable to find datacenter "%s"' % self .params ['datacenter' ])
2912
2912
2913
2913
# if cluster is given, get the cluster object
2914
2914
if cluster_name :
2915
- cluster = find_obj (self .content , [vim .ComputeResource ], cluster_name , folder = datacenter )
2915
+ cluster = find_obj_wrapper (self .content , [vim .ComputeResource ], cluster_name , folder = datacenter )
2916
2916
if not cluster :
2917
2917
self .module .fail_json (msg = 'Unable to find cluster "%s"' % cluster_name )
2918
2918
# if host is given, get the cluster object using the host
2919
2919
elif host_name :
2920
- host = find_obj (self .content , [vim .HostSystem ], host_name , folder = datacenter )
2920
+ host = find_obj_wrapper (self .content , [vim .HostSystem ], host_name , folder = datacenter )
2921
2921
if not host :
2922
2922
self .module .fail_json (msg = 'Unable to find host "%s"' % host_name )
2923
2923
cluster = host .parent
2924
2924
else :
2925
2925
cluster = None
2926
2926
2927
2927
# get resource pools limiting search to cluster or datacenter
2928
- resource_pool = find_obj (self .content , [vim .ResourcePool ], resource_pool_name , folder = cluster or datacenter )
2928
+ resource_pool = find_obj_wrapper (self .content , [vim .ResourcePool ], resource_pool_name , folder = cluster or datacenter )
2929
2929
if not resource_pool :
2930
2930
if resource_pool_name :
2931
2931
self .module .fail_json (msg = 'Unable to find resource_pool "%s"' % resource_pool_name )
@@ -2951,7 +2951,7 @@ def deploy_vm(self):
2951
2951
self .folder = '/%(folder)s' % self .params
2952
2952
self .folder = self .folder .rstrip ('/' )
2953
2953
2954
- datacenter = self .cache .find_obj (self .content , [vim .Datacenter ], self .params ['datacenter' ])
2954
+ datacenter = self .cache .find_obj_wrapper (self .content , [vim .Datacenter ], self .params ['datacenter' ])
2955
2955
if datacenter is None :
2956
2956
self .module .fail_json (msg = 'No datacenter named %(datacenter)s was found' % self .params )
2957
2957
@@ -3013,12 +3013,12 @@ def deploy_vm(self):
3013
3013
# User may want to deploy VM to specific datastore.
3014
3014
datastore_name = self .params ['datastore' ]
3015
3015
# Check if user has provided datastore cluster first
3016
- datastore_cluster = self .cache .find_obj (self .content , [vim .StoragePod ], datastore_name )
3016
+ datastore_cluster = self .cache .find_obj_wrapper (self .content , [vim .StoragePod ], datastore_name )
3017
3017
if datastore_cluster :
3018
3018
# If user specified datastore cluster so get recommended datastore
3019
3019
datastore_name = self .get_recommended_datastore (datastore_cluster_obj = datastore_cluster )
3020
3020
# Check if get_recommended_datastore or user specified datastore exists or not
3021
- datastore = self .cache .find_obj (self .content , [vim .Datastore ], datastore_name )
3021
+ datastore = self .cache .find_obj_wrapper (self .content , [vim .Datastore ], datastore_name )
3022
3022
else :
3023
3023
(datastore , datastore_name ) = self .select_datastore (vm_obj )
3024
3024
0 commit comments