mirror of
https://github.com/OpenNebula/one.git
synced 2025-03-28 14:50:08 +03:00
M #-: Added exceptions and exit codes (#3891)
This commit is contained in:
Angel Luis Moya Gonzalez
Tino Vázquez
parent
5f240d9d42
commit
0a7b1be152
@ -41,6 +41,21 @@ require 'vcenter_driver'
|
||||
require 'base64'
|
||||
require 'nsx_driver'
|
||||
|
||||
# Exceptions
|
||||
class DeleteNetworkError < StandardError; end
|
||||
class DeletePortgroupError < StandardError; end
|
||||
|
||||
# FUNCTIONS
|
||||
def update_net(vnet, content)
|
||||
vnet.unlock
|
||||
rc = vnet.update(content, true)
|
||||
vnet.lock(1)
|
||||
return unless OpenNebula.is_error?(rc)
|
||||
|
||||
err_msg = "Could not update the virtual network: #{rc.message}"
|
||||
raise UpdateNetworkError, err_msg
|
||||
end
|
||||
|
||||
SUCCESS_XPATH = '//PARAMETER[TYPE="OUT" and POSITION="1"]/VALUE'
|
||||
ERROR_XPATH = '//PARAMETER[TYPE="OUT" and POSITION="2"]/VALUE'
|
||||
VNET_XPATH = '//EXTRA/VNET'
|
||||
@ -50,10 +65,9 @@ arguments_raw = Base64.decode64(STDIN.read)
|
||||
arguments_xml = Nokogiri::XML(arguments_raw)
|
||||
success = arguments_xml.xpath(SUCCESS_XPATH).text
|
||||
|
||||
if success == 'false'
|
||||
error = arguments_xml.xpath(ERROR_XPATH).text
|
||||
STDERR.puts error
|
||||
exit(-1)
|
||||
unless success
|
||||
err_msg = arguments_xml.xpath(ERROR_XPATH).text
|
||||
raise DeleteNetworkError, err_msg
|
||||
end
|
||||
|
||||
vnet_xml = arguments_xml.xpath(VNET_XPATH).to_s
|
||||
@ -66,105 +80,138 @@ error = template['TEMPLATE/VCENTER_NET_STATE'] == 'ERROR'
|
||||
|
||||
begin
|
||||
# Step 0. Only execute for vcenter network driver
|
||||
if template['VN_MAD'] == 'vcenter' && managed && !error && imported.nil?
|
||||
# Step 1. Extract vnet settings
|
||||
host_id = template['TEMPLATE/VCENTER_ONE_HOST_ID']
|
||||
raise 'Missing VCENTER_ONE_HOST_ID' unless host_id
|
||||
unless template['VN_MAD'] == 'vcenter' && managed && !error && imported.nil?
|
||||
msg = 'Nothing to do. Network is not a vcenter network or is not ' \
|
||||
'managed or is an imported network'
|
||||
STDOUT.puts msg
|
||||
exit(0)
|
||||
end
|
||||
|
||||
pg_name = template['TEMPLATE/BRIDGE']
|
||||
pg_type = template['TEMPLATE/VCENTER_PORTGROUP_TYPE']
|
||||
sw_name = template['TEMPLATE/VCENTER_SWITCH_NAME']
|
||||
# Step 1. Extract vnet settings
|
||||
host_id = template['TEMPLATE/VCENTER_ONE_HOST_ID']
|
||||
raise 'Missing VCENTER_ONE_HOST_ID' unless host_id
|
||||
|
||||
# Step 2. Contact cluster and extract cluster's info
|
||||
vi_client = VCenterDriver::VIClient.new_from_host(host_id)
|
||||
one_client = OpenNebula::Client.new
|
||||
one_host = OpenNebula::Host.new_with_id(host_id, one_client)
|
||||
rc = one_host.info
|
||||
raise rc.message if OpenNebula.is_error? rc
|
||||
network_id = template['ID']
|
||||
pg_name = template['TEMPLATE/BRIDGE']
|
||||
pg_type = template['TEMPLATE/VCENTER_PORTGROUP_TYPE']
|
||||
sw_name = template['TEMPLATE/VCENTER_SWITCH_NAME']
|
||||
|
||||
ccr_ref = one_host['TEMPLATE/VCENTER_CCR_REF']
|
||||
cluster = VCenterDriver::ClusterComputeResource
|
||||
.new_from_ref(ccr_ref, vi_client)
|
||||
dc = cluster.get_dc
|
||||
# Step 2. Get vnet, contact cluster and extract cluster's info
|
||||
vi_client = VCenterDriver::VIClient.new_from_host(host_id)
|
||||
one_client = OpenNebula::Client.new
|
||||
one_vnet = OpenNebula::VirtualNetwork.new_with_id(network_id, one_client)
|
||||
one_host = OpenNebula::Host.new_with_id(host_id, one_client)
|
||||
rc = one_host.info
|
||||
raise rc.message if OpenNebula.is_error? rc
|
||||
|
||||
# NSX
|
||||
ls_id = template['TEMPLATE/NSX_ID']
|
||||
# NSX
|
||||
ccr_ref = one_host['TEMPLATE/VCENTER_CCR_REF']
|
||||
cluster = VCenterDriver::ClusterComputeResource
|
||||
.new_from_ref(ccr_ref, vi_client)
|
||||
dc = cluster.get_dc
|
||||
|
||||
# NSX
|
||||
ls_id = template['TEMPLATE/NSX_ID']
|
||||
# NSX
|
||||
|
||||
# With DVS we have to work at datacenter level and then for each host
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_DPG
|
||||
begin
|
||||
dc.lock
|
||||
|
||||
# Explore network folder in search of dpg and dvs
|
||||
net_folder = dc.network_folder
|
||||
net_folder.fetch!
|
||||
|
||||
# Get distributed port group and dvs if they exists
|
||||
dvs = dc.dvs_exists(sw_name, net_folder)
|
||||
dpg = dc.dpg_exists(pg_name, net_folder)
|
||||
dc.remove_dpg(dpg) if dpg
|
||||
|
||||
# Only remove switch if the port group being removed is
|
||||
# the last and only port group in the switch
|
||||
|
||||
if dvs && dvs.item.summary.portgroupName.size == 1 &&
|
||||
dvs.item.summary.portgroupName[0] == "#{sw_name}-uplink-pg"
|
||||
dc.remove_dvs(dvs)
|
||||
end
|
||||
rescue StandardError => e
|
||||
err_msg = e.message
|
||||
raise DeletePortgroupError, err_msg
|
||||
ensure
|
||||
dc.unlock if dc
|
||||
end
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_PG
|
||||
cluster['host'].each do |host|
|
||||
# Step 3. Loop through hosts in clusters
|
||||
esx_host = VCenterDriver::ESXHost
|
||||
.new_from_ref(host._ref, vi_client)
|
||||
|
||||
# With DVS we have to work at datacenter level and then for each host
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_DPG
|
||||
begin
|
||||
dc.lock
|
||||
esx_host.lock # Exclusive lock for ESX host operation
|
||||
|
||||
# Explore network folder in search of dpg and dvs
|
||||
net_folder = dc.network_folder
|
||||
net_folder.fetch!
|
||||
next unless esx_host.pg_exists(pg_name)
|
||||
|
||||
# Get distributed port group and dvs if they exists
|
||||
dvs = dc.dvs_exists(sw_name, net_folder)
|
||||
dpg = dc.dpg_exists(pg_name, net_folder)
|
||||
dc.remove_dpg(dpg) if dpg
|
||||
swname = esx_host.remove_pg(pg_name)
|
||||
next if !swname || sw_name != swname
|
||||
|
||||
vswitch = esx_host.vss_exists(sw_name)
|
||||
next unless vswitch
|
||||
|
||||
# Only remove switch if the port group being removed is
|
||||
# the last and only port group in the switch
|
||||
|
||||
if dvs && dvs.item.summary.portgroupName.size == 1 &&
|
||||
dvs.item.summary.portgroupName[0] == "#{sw_name}-uplink-pg"
|
||||
dc.remove_dvs(dvs)
|
||||
if vswitch.portgroup.empty?
|
||||
esx_host.remove_vss(sw_name)
|
||||
end
|
||||
rescue StandardError => e
|
||||
raise e
|
||||
err_msg = e.message
|
||||
raise DeletePortgroupError, err_msg
|
||||
ensure
|
||||
dc.unlock if dc
|
||||
esx_host.unlock if esx_host # Remove host lock
|
||||
end
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_PG
|
||||
cluster['host'].each do |host|
|
||||
# Step 3. Loop through hosts in clusters
|
||||
esx_host = VCenterDriver::ESXHost
|
||||
.new_from_ref(host._ref, vi_client)
|
||||
|
||||
begin
|
||||
esx_host.lock # Exclusive lock for ESX host operation
|
||||
|
||||
next unless esx_host.pg_exists(pg_name)
|
||||
|
||||
swname = esx_host.remove_pg(pg_name)
|
||||
next if !swname || sw_name != swname
|
||||
|
||||
vswitch = esx_host.vss_exists(sw_name)
|
||||
next unless vswitch
|
||||
|
||||
# Only remove switch if the port group being removed is
|
||||
# the last and only port group in the switch
|
||||
if vswitch.portgroup.empty?
|
||||
esx_host.remove_vss(sw_name)
|
||||
end
|
||||
rescue StandardError => e
|
||||
raise e
|
||||
ensure
|
||||
esx_host.unlock if esx_host # Remove host lock
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_NSXV
|
||||
nsx_client = NSXDriver::NSXClient.new_from_id(host_id)
|
||||
logical_switch = NSXDriver::VirtualWire
|
||||
.new(nsx_client, ls_id, nil, nil)
|
||||
logical_switch.delete_logical_switch
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_NSXT
|
||||
nsx_client = NSXDriver::NSXClient.new_from_id(host_id)
|
||||
logical_switch = NSXDriver::OpaqueNetwork
|
||||
.new(nsx_client, ls_id, nil, nil)
|
||||
logical_switch.delete_logical_switch
|
||||
end
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_NSXV
|
||||
begin
|
||||
nsx_client = NSXDriver::NSXClient.new_from_id(host_id)
|
||||
logical_switch = NSXDriver::VirtualWire
|
||||
.new(nsx_client, ls_id, nil, nil)
|
||||
logical_switch.delete_logical_switch
|
||||
rescue StandardError => e
|
||||
err_msg = e.message
|
||||
raise DeletePortgroupError, err_msg
|
||||
end
|
||||
end
|
||||
|
||||
if pg_type == VCenterDriver::Network::NETWORK_TYPE_NSXT
|
||||
begin
|
||||
nsx_client = NSXDriver::NSXClient.new_from_id(host_id)
|
||||
logical_switch = NSXDriver::OpaqueNetwork
|
||||
.new(nsx_client, ls_id, nil, nil)
|
||||
logical_switch.delete_logical_switch
|
||||
rescue StandardError => e
|
||||
err_msg = e.message
|
||||
raise DeletePortgroupError, err_msg
|
||||
end
|
||||
end
|
||||
|
||||
rescue DeleteNetworkError => e
|
||||
STDERR.puts e.message
|
||||
STDERR.puts e.backtrace if VCenterDriver::CONFIG[:debug_information]
|
||||
net_info << "VCENTER_NET_STATE=\"ERROR\"\n"
|
||||
net_info << "VCENTER_NET_ERROR=\"#{e.message}\"\n"
|
||||
update_net(one_vnet, net_info)
|
||||
one_vnet.lock(1)
|
||||
exit(-1)
|
||||
rescue DeletePortgroupError => e
|
||||
STDERR.puts e.message
|
||||
STDERR.puts e.backtrace if VCenterDriver::CONFIG[:debug_information]
|
||||
exit(-1)
|
||||
rescue StandardError => e
|
||||
STDERR.puts("#{e.message}/#{e.backtrace}")
|
||||
STDERR.puts e.message
|
||||
STDERR.puts e.backtrace if VCenterDriver::CONFIG[:debug_information]
|
||||
exit(-1)
|
||||
ensure
|
||||
vi_client.close_connection if vi_client
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user