apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-12-17 02:53:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

move network group to oss

Browse Source
This commit is contained in:
anthony 2010-12-06 13:08:10 -08:00
parent 6cbe5208cf
commit aa0fed787e
1 changed files with 46 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
core/src/com/cloud/hypervisor/xen/resource/XenServerResource.java
View File

@ -21,6 +21,10 @@ import javax.ejb.Local;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.apache.xmlrpc.XmlRpcException; import org.apache.xmlrpc.XmlRpcException;
import com.cloud.agent.api.Answer;
import com.cloud.agent.api.Command;
import com.cloud.agent.api.NetworkIngressRuleAnswer;
import com.cloud.agent.api.NetworkIngressRulesCmd;
import com.cloud.hypervisor.xen.resource.CitrixResourceBase; import com.cloud.hypervisor.xen.resource.CitrixResourceBase;
import com.xensource.xenapi.VM; import com.xensource.xenapi.VM;
import com.cloud.resource.ServerResource; import com.cloud.resource.ServerResource;
@ -32,11 +36,19 @@ import com.xensource.xenapi.Types.XenAPIException;
public class XenServerResource extends CitrixResourceBase { public class XenServerResource extends CitrixResourceBase {
private static final Logger s_logger = Logger.getLogger(XenServerResource.class); private static final Logger s_logger = Logger.getLogger(XenServerResource.class);
public XenServerResource() { public XenServerResource() {
super(); super();
} }
@Override
public Answer executeRequest(Command cmd) {
if (cmd instanceof NetworkIngressRulesCmd) {
return execute((NetworkIngressRulesCmd) cmd);
} else {
return super.executeRequest(cmd);
}
}
@Override @Override
protected String getGuestOsType(String stdType, boolean bootFromCD) { protected String getGuestOsType(String stdType, boolean bootFromCD) {
return CitrixHelper.getXenServerGuestOsType(stdType); return CitrixHelper.getXenServerGuestOsType(stdType);
@ -52,4 +64,37 @@ public class XenServerResource extends CitrixResourceBase {
return "scripts/vm/hypervisor/xenserver/xenserver56"; return "scripts/vm/hypervisor/xenserver/xenserver56";
} }
@Override
protected boolean can_bridge_firewall() {
return Boolean.valueOf(callHostPlugin("vmops", "can_bridge_firewall", "host_uuid", _host.uuid));
}
private Answer execute(NetworkIngressRulesCmd cmd) {
if (s_logger.isTraceEnabled()) {
s_logger.trace("Sending network rules command to " + _host.ip);
}
if (!_canBridgeFirewall) {
s_logger.info("Host " + _host.ip + " cannot do bridge firewalling");
return new NetworkIngressRuleAnswer(cmd, false, "Host " + _host.ip + " cannot do bridge firewalling");
}
String result = callHostPlugin("vmops", "network_rules",
"vmName", cmd.getVmName(),
"vmIP", cmd.getGuestIp(),
"vmMAC", cmd.getGuestMac(),
"vmID", Long.toString(cmd.getVmId()),
"signature", cmd.getSignature(),
"seqno", Long.toString(cmd.getSeqNum()),
"rules", cmd.stringifyRules());
if (result == null || result.isEmpty() || !Boolean.parseBoolean(result)) {
s_logger.warn("Failed to program network rules for vm " + cmd.getVmName());
return new NetworkIngressRuleAnswer(cmd, false, "programming network rules failed");
} else {
s_logger.info("Programmed network rules for vm " + cmd.getVmName() + " guestIp=" + cmd.getGuestIp() + ", numrules=" + cmd.getRuleSet().length);
return new NetworkIngressRuleAnswer(cmd);
}
}
} }