From 6c6fd3f47d531b0f81d8f58193e792d483cef664 Mon Sep 17 00:00:00 2001 From: Vijay Date: Fri, 20 Jul 2012 14:25:19 +0530 Subject: [PATCH] AutoScale. Apply mutiple nitro logins only to autoscale netscaler --- .../network/resource/NetscalerResource.java | 179 ++++++++---------- 1 file changed, 84 insertions(+), 95 deletions(-) diff --git a/core/src/com/cloud/network/resource/NetscalerResource.java b/core/src/com/cloud/network/resource/NetscalerResource.java index 652a567af0b..06b33849077 100644 --- a/core/src/com/cloud/network/resource/NetscalerResource.java +++ b/core/src/com/cloud/network/resource/NetscalerResource.java @@ -12,8 +12,6 @@ // Automatically generated by addcopyright.py at 04/03/2012 package com.cloud.network.resource; -import java.io.FileInputStream; -import java.io.ObjectInputStream; import java.util.ArrayList; import java.util.Collections; import java.util.Formatter; @@ -231,21 +229,24 @@ public class NetscalerResource implements ServerResource { } private ArrayList netscalerServices = new ArrayList(); - private com.citrix.netscaler.nitro.service.nitro_service login_get_service() throws ExecutionException { + private com.citrix.netscaler.nitro.service.nitro_service login_get_service(Boolean forAutoScale) throws ExecutionException { + if(forAutoScale == null) { + return _netscalerService; + } com.citrix.netscaler.nitro.service.nitro_service _netscalerService = null; try { _netscalerService = new com.citrix.netscaler.nitro.service.nitro_service(_ip, "https"); _netscalerService.set_credential(_username, _password); _netscalerService.set_timeout(_timeout); - apiCallResult = _netscalerService.login(); + base_response apiCallResult = _netscalerService.login(); if (apiCallResult.errorcode != 0) { - throw new ExecutionException ("VJ Failed to log in to Netscaler device at " + _ip + " due to error " + apiCallResult.errorcode + " and message " + apiCallResult.message); + throw new ExecutionException ("AuotoScale Failed to log in to Netscaler device at " + _ip + " due to error " + apiCallResult.errorcode + " and message " + apiCallResult.message); } } catch(ExecutionException ee) { throw ee; } catch(Exception ee) { - throw new ExecutionException ("VJ Exception happend during login" + ee.getMessage()); + throw new ExecutionException ("AutoScale Exception happend during login" + ee.getMessage()); } netscalerServices.add(_netscalerService); return _netscalerService; @@ -307,8 +308,8 @@ public class NetscalerResource implements ServerResource { private void validateInterfaces(String publicInterface, String privateInterface) throws ExecutionException { try { if (!_isSdx && !_cloudManaged) { - Interface publicIf = Interface.get(login_get_service(), publicInterface); - Interface privateIf = Interface.get(login_get_service(), privateInterface); + Interface publicIf = Interface.get(login_get_service(true), publicInterface); + Interface privateIf = Interface.get(login_get_service(true), privateInterface); if (publicIf != null || privateIf != null) { return; } else { @@ -329,7 +330,7 @@ public class NetscalerResource implements ServerResource { private void validateDeviceType(String deviceType) throws ExecutionException { try { if (!_isSdx && !_cloudManaged) { - nshardware nsHw = com.citrix.netscaler.nitro.resource.config.ns.nshardware.get(login_get_service()); + nshardware nsHw = com.citrix.netscaler.nitro.resource.config.ns.nshardware.get(login_get_service(true)); if (nsHw == null) { throw new ExecutionException("Failed to get the hardware description of the Netscaler device at " + _ip); } else { @@ -495,7 +496,7 @@ public class NetscalerResource implements ServerResource { try { vserver_servicegroup_binding.set_name(nsVirtualServerName); vserver_servicegroup_binding.set_servicegroupname(serviceGroupName); - vserver_servicegroup_binding.delete(login_get_service(), vserver_servicegroup_binding); + vserver_servicegroup_binding.delete(login_get_service(true), vserver_servicegroup_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -505,7 +506,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.basic.servicegroup serviceGroup = new com.citrix.netscaler.nitro.resource.config.basic.servicegroup(); try { serviceGroup.set_servicegroupname(serviceGroupName); - serviceGroup.delete(login_get_service(), serviceGroup); + serviceGroup.delete(login_get_service(true), serviceGroup); } catch (Exception e) { // Ignore Exception throw e; @@ -518,7 +519,7 @@ public class NetscalerResource implements ServerResource { // lbvserver.set_name(nsVirtualServerName); // lbvserver.set_minautoscalemembers(0); // lbvserver.set_maxautoscalemembers(0); - // lbvserver.update(login_get_service(), lbvserver); + // lbvserver.update(login_get_service(true), lbvserver); // } catch (Exception e) { // // Ignore Exception // throw e; @@ -563,7 +564,7 @@ public class NetscalerResource implements ServerResource { try { timer_policy_binding.set_name(timerName); timer_policy_binding.set_policyname(policyName); - timer_policy_binding.delete(login_get_service(), timer_policy_binding); + timer_policy_binding.delete(login_get_service(true), timer_policy_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -573,7 +574,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.timer.timerpolicy timerPolicy = new com.citrix.netscaler.nitro.resource.config.timer.timerpolicy(); try { timerPolicy.set_name(policyName); - timerPolicy.delete(login_get_service(), timerPolicy); + timerPolicy.delete(login_get_service(true), timerPolicy); } catch (Exception e) { // Ignore Exception throw e; @@ -585,7 +586,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleaction scaleDownAction = new com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleaction(); try { scaleDownAction.set_name(scaleDownActionName); - scaleDownAction.delete(login_get_service(), scaleDownAction); + scaleDownAction.delete(login_get_service(true), scaleDownAction); } catch (Exception e) { // Ignore Exception throw e; @@ -595,7 +596,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleaction scaleUpAction = new com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleaction(); try { scaleUpAction.set_name(scaleUpActionName); - scaleUpAction.delete(login_get_service(), scaleUpAction); + scaleUpAction.delete(login_get_service(true), scaleUpAction); } catch (Exception e) { // Ignore Exception throw e; @@ -605,7 +606,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.timer.timertrigger timer = new com.citrix.netscaler.nitro.resource.config.timer.timertrigger(); try { timer.set_name(timerName); - timer.delete(login_get_service(), timer); + timer.delete(login_get_service(true), timer); } catch (Exception e) { // Ignore Exception throw e; @@ -615,7 +616,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleprofile autoscaleProfile = new com.citrix.netscaler.nitro.resource.config.autoscale.autoscaleprofile(); try { autoscaleProfile.set_name(profileName); - autoscaleProfile.delete(login_get_service(), autoscaleProfile); + autoscaleProfile.delete(login_get_service(true), autoscaleProfile); } catch (Exception e) { // Ignore Exception throw e; @@ -627,7 +628,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.lb.lbmonitor monitor = new com.citrix.netscaler.nitro.resource.config.lb.lbmonitor(); try { monitor.set_monitorname(monitorName); - monitor.delete(login_get_service(), monitor); + monitor.delete(login_get_service(true), monitor); } catch (Exception e) { // Ignore Exception throw e; @@ -637,7 +638,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.lb.lbmetrictable metricTable = new com.citrix.netscaler.nitro.resource.config.lb.lbmetrictable(); try { metricTable.set_metric(mtName); - metricTable.delete(login_get_service(), metricTable); + metricTable.delete(login_get_service(true), metricTable); } catch (Exception e) { // Ignore Exception throw e; @@ -671,7 +672,7 @@ public class NetscalerResource implements ServerResource { serviceGroup.set_servicetype(lbProtocol); serviceGroup.set_autoscale("POLICY"); // TODO: Values not displayed in API serviceGroup.set_memberport(memberPort); - serviceGroup.add(login_get_service(), serviceGroup); + serviceGroup.add(login_get_service(true), serviceGroup); } catch (Exception e) { // Ignore Exception throw e; @@ -684,7 +685,7 @@ public class NetscalerResource implements ServerResource { try { vserver_servicegroup_binding.set_name(nsVirtualServerName); vserver_servicegroup_binding.set_servicegroupname(serviceGroupName); - vserver_servicegroup_binding.add(login_get_service(), vserver_servicegroup_binding); + vserver_servicegroup_binding.add(login_get_service(true), vserver_servicegroup_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -726,7 +727,7 @@ public class NetscalerResource implements ServerResource { lbvserver.set_name(nsVirtualServerName); lbvserver.set_minautoscalemembers(minAutoScaleMembers); lbvserver.set_maxautoscalemembers(maxAutoScaleMembers); - lbvserver.update(login_get_service(), lbvserver); + lbvserver.update(login_get_service(true), lbvserver); } catch (Exception e) { // Ignore Exception throw e; @@ -748,11 +749,11 @@ public class NetscalerResource implements ServerResource { autoscaleProfile.set_apikey(apiKey); autoscaleProfile.set_sharedsecret(secretKey); autoscaleProfile.set_url(url); - autoscaleProfile.add(login_get_service(), autoscaleProfile); + autoscaleProfile.add(login_get_service(true), autoscaleProfile); } catch (Exception e) { // Ignore Exception - throw e; + // throw e; } // Add Timer @@ -760,7 +761,7 @@ public class NetscalerResource implements ServerResource { try { timer.set_name(timerName); timer.set_interval(interval); - timer.add(login_get_service(), timer); + timer.add(login_get_service(true), timer); } catch (Exception e) { // Ignore Exception throw e; @@ -806,7 +807,7 @@ public class NetscalerResource implements ServerResource { ((profileTO.getOtherDeployParams() == null)? "" : (profileTO.getOtherDeployParams() + "&")) + "lbRuleId=" + loadBalancerTO.getId(); scaleUpAction.set_parameters(scaleUpParameters); - scaleUpAction.add(login_get_service(), scaleUpAction); + scaleUpAction.add(login_get_service(true), scaleUpAction); } catch (Exception e) { // Ignore Exception throw e; @@ -825,7 +826,7 @@ public class NetscalerResource implements ServerResource { "lbRuleId=" + loadBalancerTO.getId(); scaleDownAction.set_parameters(scaleDownParameters); scaleDownAction.set_vmdestroygraceperiod(destroyVmGracePeriod); - scaleDownAction.add(login_get_service(), scaleDownAction); + scaleDownAction.add(login_get_service(true), scaleDownAction); } catch (Exception e) { // Ignore Exception throw e; @@ -856,7 +857,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.lb.lbmetrictable metricTable = new com.citrix.netscaler.nitro.resource.config.lb.lbmetrictable(); try { metricTable.set_metrictable(mtName); - metricTable.add(login_get_service(), metricTable); + metricTable.add(login_get_service(true), metricTable); } catch (Exception e) { // Ignore Exception throw e; @@ -873,7 +874,7 @@ public class NetscalerResource implements ServerResource { monitor.set_snmpcommunity(snmpCommunity); monitor.set_metrictable(mtName); monitor.set_interval((int)(interval * 0.8)); - monitor.add(login_get_service(), monitor); + monitor.add(login_get_service(true), monitor); } catch (Exception e) { // Ignore Exception throw e; @@ -887,7 +888,7 @@ public class NetscalerResource implements ServerResource { monitor_servicegroup_binding.set_servicegroupname(serviceGroupName); monitor_servicegroup_binding.set_passive(true); // Mark the monitor to do only collect // metrics, basically use it for autoscaling purpose only. - monitor_servicegroup_binding.add(login_get_service(), monitor_servicegroup_binding); + monitor_servicegroup_binding.add(login_get_service(true), monitor_servicegroup_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -908,7 +909,7 @@ public class NetscalerResource implements ServerResource { metrictable_metric_binding.set_metrictable(mtName); metrictable_metric_binding.set_metric(counterName); metrictable_metric_binding.set_Snmpoid(counterOid); - metrictable_metric_binding.add(login_get_service(), metrictable_metric_binding); + metrictable_metric_binding.add(login_get_service(true), metrictable_metric_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -920,7 +921,7 @@ public class NetscalerResource implements ServerResource { monitor_metrictable_binding.set_monitorname(monitorName); monitor_metrictable_binding.set_metric(counterName); monitor_metrictable_binding.set_metricthreshold(1); // 1 is a dummy threshold - monitor_metrictable_binding.add(login_get_service(), monitor_metrictable_binding); + monitor_metrictable_binding.add(login_get_service(true), monitor_metrictable_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -953,7 +954,7 @@ public class NetscalerResource implements ServerResource { timerPolicy.set_name(policyName); timerPolicy.set_action((isScaleUpPolicy(autoScalePolicyTO))? scaleUpActionName : scaleDownActionName); timerPolicy.set_rule(policyExpression); - timerPolicy.add(login_get_service(), timerPolicy); + timerPolicy.add(login_get_service(true), timerPolicy); } catch (Exception e) { // Ignore Exception throw e; @@ -976,7 +977,7 @@ public class NetscalerResource implements ServerResource { timer_policy_binding.set_thresholdsize(sampleSize); // We are not exposing this parameter as of now. // i.e. n(m) is not exposed to CS user. So thresholdSize == sampleSize timer_policy_binding.set_priority(priority); - timer_policy_binding.add(login_get_service(), timer_policy_binding); + timer_policy_binding.add(login_get_service(true), timer_policy_binding); } catch (Exception e) { // Ignore Exception throw e; @@ -1016,7 +1017,7 @@ public class NetscalerResource implements ServerResource { private boolean isAutoScaleSupportedInNetScaler() throws ExecutionException { autoscaleprofile autoscaleProfile = new autoscaleprofile(); try { - autoscaleProfile.get(login_get_service()); + autoscaleProfile.get(login_get_service(true)); } catch (Exception ex) { // Looks like autoscale is not supported in this netscaler. // TODO: Config team has introduce a new command to check @@ -1080,7 +1081,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.basic.server nsServer = new com.citrix.netscaler.nitro.resource.config.basic.server(); nsServer.set_name(nsServerName); nsServer.set_ipaddress(destination.getDestIp()); - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.add(login_get_service(), nsServer); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.add(login_get_service(null), nsServer); if ((apiCallResult.errorcode != 0) && (apiCallResult.errorcode != NitroError.NS_RESOURCE_EXISTS)) { throw new ExecutionException("Failed to add server " + destination.getDestIp() + " due to" + apiCallResult.message); } @@ -1095,7 +1096,7 @@ public class NetscalerResource implements ServerResource { newService.set_state("ENABLED"); newService.set_servicetype(lbProtocol); - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.add(login_get_service(), newService); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.add(login_get_service(null), newService); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to create service " + nsServiceName + " using server " + nsServerName + " due to" + apiCallResult.message); } @@ -1106,7 +1107,7 @@ public class NetscalerResource implements ServerResource { com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding svcBinding = new com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding(); svcBinding.set_name(nsVirtualServerName); svcBinding.set_servicename(nsServiceName); - apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.add(login_get_service(), svcBinding); + apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.add(login_get_service(null), svcBinding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to bind service: " + nsServiceName + " to the lb virtual server: " + nsVirtualServerName + " on Netscaler device"); @@ -1117,13 +1118,13 @@ public class NetscalerResource implements ServerResource { } } else { // remove a destination from the deployed load balancing rule - com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(), + com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(null), nsVirtualServerName); if (serviceBindings != null) { for (com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding binding : serviceBindings) { if (nsServiceName.equalsIgnoreCase(binding.get_servicename())) { // delete the binding - apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.delete(login_get_service(), binding); + apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.delete(login_get_service(null), binding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to delete the binding between the virtual server: " + nsVirtualServerName + " and service:" + nsServiceName + " due to" + apiCallResult.message); @@ -1132,16 +1133,16 @@ public class NetscalerResource implements ServerResource { // check if service is bound to any other virtual server if (!isServiceBoundToVirtualServer(nsServiceName)) { // no lb virtual servers are bound to this service so delete it - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(), nsServiceName); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(null), nsServiceName); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to delete service: " + nsServiceName + " due to " + apiCallResult.message); } } // delete the server if there is no associated services - server_service_binding[] services = server_service_binding.get(login_get_service(), nsServerName); + server_service_binding[] services = server_service_binding.get(login_get_service(null), nsServerName); if ((services == null) || (services.length == 0)) { - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(), nsServerName); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(null), nsServerName); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove server:" + nsServerName + " due to " + apiCallResult.message); } @@ -1156,33 +1157,33 @@ public class NetscalerResource implements ServerResource { lbvserver lbserver = getVirtualServerIfExisits(nsVirtualServerName); if (lbserver != null) { //unbind the all services associated with this virtual server - com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(), + com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(null), nsVirtualServerName); if (serviceBindings != null) { for (com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding binding : serviceBindings) { String serviceName = binding.get_servicename(); - apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.delete(login_get_service(), binding); + apiCallResult = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.delete(login_get_service(null), binding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to unbind service from the lb virtual server: " + nsVirtualServerName + " due to " + apiCallResult.message); } - com.citrix.netscaler.nitro.resource.config.basic.service svc = com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service(), serviceName); + com.citrix.netscaler.nitro.resource.config.basic.service svc = com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service(null), serviceName); String nsServerName = svc.get_servername(); // check if service is bound to any other virtual server if (!isServiceBoundToVirtualServer(serviceName)) { // no lb virtual servers are bound to this service so delete it - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(), serviceName); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(null), serviceName); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to delete service: " + serviceName + " due to " + apiCallResult.message); } } //delete the server if no more services attached - server_service_binding[] services = server_service_binding.get(login_get_service(), nsServerName); + server_service_binding[] services = server_service_binding.get(login_get_service(null), nsServerName); if ((services == null) || (services.length == 0)) { - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(), nsServerName); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(null), nsServerName); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove server:" + nsServerName + " due to " + apiCallResult.message); } @@ -1497,7 +1498,7 @@ public class NetscalerResource implements ServerResource { if (!rule.revoked()) { try { - iNatRule = inat.get(login_get_service(), iNatRuleName); + iNatRule = inat.get(login_get_service(null), iNatRuleName); } catch (nitro_exception e) { if (e.getErrorCode() != NitroError.NS_RESOURCE_NOT_EXISTS) { throw e; @@ -1512,7 +1513,7 @@ public class NetscalerResource implements ServerResource { iNatRule.set_usnip("OFF"); iNatRule.set_usip("ON"); try { - apiCallResult = inat.add(login_get_service(), iNatRule); + apiCallResult = inat.add(login_get_service(null), iNatRule); } catch (nitro_exception e) { if (e.getErrorCode() != NitroError.NS_RESOURCE_EXISTS) { throw e; @@ -1522,7 +1523,7 @@ public class NetscalerResource implements ServerResource { } } else { try { - inat.delete(login_get_service(), iNatRuleName); + inat.delete(login_get_service(null), iNatRuleName); } catch (nitro_exception e) { if (e.getErrorCode() != NitroError.NS_RESOURCE_NOT_EXISTS) { throw e; @@ -1568,7 +1569,7 @@ public class NetscalerResource implements ServerResource { selfIp.set_ipaddress(snip); selfIp.set_netmask(netmask); selfIp.set_type("SNIP"); - apiCallResult = nsip.add(login_get_service(), selfIp); + apiCallResult = nsip.add(login_get_service(null), selfIp); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to add SNIP object on the Netscaler device due to "+ apiCallResult.message); } @@ -1586,7 +1587,7 @@ public class NetscalerResource implements ServerResource { try { vlan vlanObj = new vlan(); vlanObj.set_id(vlanTag); - apiCallResult = vlan.add(login_get_service(), vlanObj); + apiCallResult = vlan.add(login_get_service(null), vlanObj); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to add new vlan with tag:" + vlanTag + "on the NetScaler device due to " + apiCallResult.message); } @@ -1602,7 +1603,7 @@ public class NetscalerResource implements ServerResource { selfIp.set_ipaddress(vlanSelfIp); selfIp.set_netmask(vlanNetmask); selfIp.set_type("SNIP"); - apiCallResult = nsip.add(login_get_service(), selfIp); + apiCallResult = nsip.add(login_get_service(null), selfIp); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to add SNIP object for the guest network on the Netscaler device due to "+ apiCallResult.message); } @@ -1618,7 +1619,7 @@ public class NetscalerResource implements ServerResource { ipVlanBinding.set_id(vlanTag); ipVlanBinding.set_ipaddress(vlanSelfIp); ipVlanBinding.set_netmask(vlanNetmask); - apiCallResult = vlan_nsip_binding.add(login_get_service(), ipVlanBinding); + apiCallResult = vlan_nsip_binding.add(login_get_service(null), ipVlanBinding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to bind VLAN with tag:" + vlanTag + " to the subnet due to " + apiCallResult.message); } @@ -1637,7 +1638,7 @@ public class NetscalerResource implements ServerResource { } vlanBinding.set_tagged(true); vlanBinding.set_id(vlanTag); - apiCallResult = vlan_interface_binding.add(login_get_service(), vlanBinding); + apiCallResult = vlan_interface_binding.add(login_get_service(null), vlanBinding); if (apiCallResult.errorcode != 0) { String vlanInterface = guestVlan ? _privateInterface : _publicInterface; throw new ExecutionException("Failed to bind vlan with tag:" + vlanTag + " with the interface " + vlanInterface + " due to " + apiCallResult.message); @@ -1666,7 +1667,7 @@ public class NetscalerResource implements ServerResource { vlanIfBinding.set_id(vlanTag); vlanIfBinding.set_ifnum(_privateInterface); vlanIfBinding.set_tagged(true); - apiCallResult = vlan_interface_binding.delete(login_get_service(), vlanIfBinding); + apiCallResult = vlan_interface_binding.delete(login_get_service(null), vlanIfBinding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to unbind vlan:" + vlanTag + " with the private interface due to " + apiCallResult.message); } @@ -1683,7 +1684,7 @@ public class NetscalerResource implements ServerResource { vlanSnipBinding.set_netmask(vlanNetmask); vlanSnipBinding.set_ipaddress(vlanSelfIp); vlanSnipBinding.set_id(vlanTag); - apiCallResult = vlan_nsip_binding.delete(login_get_service(), vlanSnipBinding); + apiCallResult = vlan_nsip_binding.delete(login_get_service(null), vlanSnipBinding); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to unbind vlan:" + vlanTag + " with the subnet due to " + apiCallResult.message); } @@ -1696,8 +1697,8 @@ public class NetscalerResource implements ServerResource { // remove subnet IP try { - nsip subnetIp = nsip.get(login_get_service(), vlanSelfIp); - apiCallResult = nsip.delete(login_get_service(), subnetIp); + nsip subnetIp = nsip.get(login_get_service(null), vlanSelfIp); + apiCallResult = nsip.delete(login_get_service(null), subnetIp); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove subnet ip:" + vlanSelfIp + " from the NetScaler device due to" + apiCallResult.message); } @@ -1711,7 +1712,7 @@ public class NetscalerResource implements ServerResource { // remove the vlan from the NetScaler device if (nsVlanExists(vlanTag)) { // remove vlan - apiCallResult = com.citrix.netscaler.nitro.resource.config.network.vlan.delete(login_get_service(), vlanTag); + apiCallResult = com.citrix.netscaler.nitro.resource.config.network.vlan.delete(login_get_service(null), vlanTag); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove vlan with tag:" + vlanTag + "due to" + apiCallResult.message); } @@ -1725,7 +1726,7 @@ public class NetscalerResource implements ServerResource { private boolean nsVlanExists(long vlanTag) throws ExecutionException { try { - if (vlan.get(login_get_service(), new Long(vlanTag)) != null) { + if (vlan.get(login_get_service(null), new Long(vlanTag)) != null) { return true; } else { return false; @@ -1743,7 +1744,7 @@ public class NetscalerResource implements ServerResource { private boolean nsSnipExists(String subnetIP) throws ExecutionException { try { - nsip snip = nsip.get(login_get_service(), subnetIP); + nsip snip = nsip.get(login_get_service(null), subnetIP); return (snip != null); } catch (nitro_exception e) { if (e.getErrorCode() == NitroError.NS_RESOURCE_NOT_EXISTS) { @@ -1758,7 +1759,7 @@ public class NetscalerResource implements ServerResource { private boolean nsServerExists(String serverName) throws ExecutionException { try { - if (com.citrix.netscaler.nitro.resource.config.basic.server.get(login_get_service(), serverName) != null) { + if (com.citrix.netscaler.nitro.resource.config.basic.server.get(login_get_service(null), serverName) != null) { return true; } else { return false; @@ -1776,7 +1777,7 @@ public class NetscalerResource implements ServerResource { private boolean nsVlanNsipBindingExists(long vlanTag, String vlanSelfIp) throws ExecutionException { try { - vlan_nsip_binding[] vlanNsipBindings = vlan_nsip_binding.get(login_get_service(), vlanTag); + vlan_nsip_binding[] vlanNsipBindings = vlan_nsip_binding.get(login_get_service(null), vlanTag); if (vlanNsipBindings != null && vlanNsipBindings[0] != null && vlanNsipBindings[0].get_ipaddress().equalsIgnoreCase(vlanSelfIp)) { return true; } else { @@ -1795,7 +1796,7 @@ public class NetscalerResource implements ServerResource { private lbvserver getVirtualServerIfExisits(String lbVServerName ) throws ExecutionException { try { - return lbvserver.get(login_get_service(), lbVServerName); + return lbvserver.get(login_get_service(true), lbVServerName); } catch (nitro_exception e) { if (e.getErrorCode() == NitroError.NS_RESOURCE_NOT_EXISTS) { return null; @@ -1809,11 +1810,11 @@ public class NetscalerResource implements ServerResource { private boolean isServiceBoundToVirtualServer(String serviceName) throws ExecutionException { try { - lbvserver[] lbservers = lbvserver.get(login_get_service()); + lbvserver[] lbservers = lbvserver.get(login_get_service(null)); for (lbvserver vserver : lbservers) { filtervalue[] filter = new filtervalue[1]; filter[0] = new filtervalue("servicename", serviceName); - lbvserver_service_binding[] result = lbvserver_service_binding.get_filtered(login_get_service(), vserver.get_name(), filter); + lbvserver_service_binding[] result = lbvserver_service_binding.get_filtered(login_get_service(null), vserver.get_name(), filter); if (result != null && result.length > 0) { return true; } @@ -1826,7 +1827,7 @@ public class NetscalerResource implements ServerResource { private boolean nsServiceExists(String serviceName) throws ExecutionException { try { - if (com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service(), serviceName) != null) { + if (com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service(null), serviceName) != null) { return true; } else { return false; @@ -1844,7 +1845,7 @@ public class NetscalerResource implements ServerResource { private boolean nsServiceBindingExists(String lbVirtualServer, String serviceName) throws ExecutionException { try { - com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(), lbVirtualServer); + com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding[] serviceBindings = com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding.get(login_get_service(null), lbVirtualServer); if (serviceBindings != null) { for (com.citrix.netscaler.nitro.resource.config.lb.lbvserver_service_binding binding : serviceBindings) { if (serviceName.equalsIgnoreCase(binding.get_servicename())) { @@ -1862,7 +1863,7 @@ public class NetscalerResource implements ServerResource { private void deleteServersInGuestVlan(long vlanTag, String vlanSelfIp, String vlanNetmask) throws ExecutionException { try { - com.citrix.netscaler.nitro.resource.config.basic.server[] serverList = com.citrix.netscaler.nitro.resource.config.basic.server.get(login_get_service()); + com.citrix.netscaler.nitro.resource.config.basic.server[] serverList = com.citrix.netscaler.nitro.resource.config.basic.server.get(login_get_service(null)); if (serverList == null) { return; @@ -1873,11 +1874,11 @@ public class NetscalerResource implements ServerResource { // check if server belong to same subnet as one associated with vlan if (NetUtils.sameSubnet(vlanSelfIp, server.get_ipaddress(), vlanNetmask)) { // first remove services associated with this server - com.citrix.netscaler.nitro.resource.config.basic.service serveicesList[] = com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service()); + com.citrix.netscaler.nitro.resource.config.basic.service serveicesList[] = com.citrix.netscaler.nitro.resource.config.basic.service.get(login_get_service(null)); if (serveicesList != null) { for (com.citrix.netscaler.nitro.resource.config.basic.service svc : serveicesList) { if (svc.get_servername().equals(server.get_ipaddress())) { - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(), svc.get_name()); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.service.delete(login_get_service(null), svc.get_name()); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove service:" + svc.get_name()); } @@ -1885,7 +1886,7 @@ public class NetscalerResource implements ServerResource { } } // remove the server - apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(), server.get_name()); + apiCallResult = com.citrix.netscaler.nitro.resource.config.basic.server.delete(login_get_service(null), server.get_name()); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to remove server:" + server.get_name()); } @@ -2004,9 +2005,9 @@ public class NetscalerResource implements ServerResource { } if (vserverExisis) { - apiCallResult = lbvserver.update(login_get_service(),vserver); + apiCallResult = lbvserver.update(login_get_service(vmGroupTO != null),vserver); } else { - apiCallResult = lbvserver.add(login_get_service(),vserver); + apiCallResult = lbvserver.add(login_get_service(vmGroupTO != null),vserver); } if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to create new load balancing virtual server:" + virtualServerName + " due to " + apiCallResult.message); @@ -2025,11 +2026,11 @@ public class NetscalerResource implements ServerResource { private void removeLBVirtualServer (String virtualServerName) throws ExecutionException { try { - lbvserver vserver = lbvserver.get(login_get_service(), virtualServerName); + lbvserver vserver = lbvserver.get(login_get_service(true), virtualServerName); if (vserver == null) { return; } - apiCallResult = lbvserver.delete(login_get_service(), vserver); + apiCallResult = lbvserver.delete(login_get_service(true), vserver); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Failed to delete virtual server:" + virtualServerName + " due to " + apiCallResult.message); } @@ -2046,7 +2047,7 @@ public class NetscalerResource implements ServerResource { private void saveConfiguration() throws ExecutionException { try { - apiCallResult = nsconfig.save(login_get_service()); + apiCallResult = nsconfig.save(login_get_service(true)); if (apiCallResult.errorcode != 0) { throw new ExecutionException("Error occured while saving configuration changes to Netscaler device due to " + apiCallResult.message); } @@ -2061,7 +2062,7 @@ public class NetscalerResource implements ServerResource { ExternalNetworkResourceUsageAnswer answer = new ExternalNetworkResourceUsageAnswer(cmd); try { - lbvserver_stats[] stats = lbvserver_stats.get(login_get_service()); + lbvserver_stats[] stats = lbvserver_stats.get(login_get_service(null)); if (stats == null || stats.length == 0) { return answer; @@ -2069,7 +2070,7 @@ public class NetscalerResource implements ServerResource { for (lbvserver_stats stat_entry : stats) { String lbvserverName = stat_entry.get_name(); - lbvserver vserver = lbvserver.get(login_get_service(), lbvserverName); + lbvserver vserver = lbvserver.get(login_get_service(null), lbvserverName); if(vserver != null){ String lbVirtualServerIp = vserver.get_ipv46(); @@ -2214,16 +2215,4 @@ public class NetscalerResource implements ServerResource { return; } - public static void main(String args[]) throws Exception { - NetscalerResource res = new NetscalerResource(); - res._ip = "10.102.31.86"; - res._username = "nsroot"; - res._password = "nsroot"; - // Deserialize a string and date from a file. - FileInputStream in = new FileInputStream("c:\\temp\\lbto.obj"); - ObjectInputStream s1 = new ObjectInputStream(in); - LoadBalancerTO loadBalancer = (LoadBalancerTO)s1.readObject(); - res.applyAutoScaleConfig(loadBalancer); - - } }