etan39
/
cloudstack
mirror of https://github.com/apache/cloudstack.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AutoScale. Apply mutiple nitro logins only to autoscale netscaler

This commit is contained in:
Vijay 2012-07-20 14:25:19 +05:30
parent 2c3d0f724d
commit 6c6fd3f47d
1 changed files with 84 additions and 95 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

179
core/src/com/cloud/network/resource/NetscalerResource.java
View File

@ -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<com.citrix.netscaler.nitro.service.nitro_service> netscalerServices = new ArrayList<com.citrix.netscaler.nitro.service.nitro_service>();
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);
}
}