Moving pre-allocated lun API commands to OSS since it's not a premium feature

This commit is contained in:
Kris McQueen 2010-09-14 17:02:16 -07:00
parent 1d912fb608
commit cf6829a038
2 changed files with 242 additions and 0 deletions

View File

@ -0,0 +1,92 @@
/**
* Copyright (C) 2010 Cloud.com, Inc. All rights reserved.
*
* This software is licensed under the GNU General Public License v3 or later.
*
* It is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
package com.cloud.server.api.commands;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import com.cloud.api.BaseCmd;
import com.cloud.api.Parameter;
import com.cloud.api.ServerApiException;
import com.cloud.server.ManagementServer;
import com.cloud.utils.Pair;
public class DeletePreallocatedLunCmd extends BaseCmd {
private static final Logger s_logger = Logger.getLogger(DeletePreallocatedLunCmd.class);
private static final String s_name = "deletePreallocatedLunsResponse";
private static final List<Pair<Enum, Boolean>> s_properties = new ArrayList<Pair<Enum, Boolean>>();
static {
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.ID, Boolean.TRUE));
}
/////////////////////////////////////////////////////
//////////////// API parameters /////////////////////
/////////////////////////////////////////////////////
@Parameter(name="id", type=CommandType.LONG, required=true)
private Long id;
/////////////////////////////////////////////////////
/////////////////// Accessors ///////////////////////
/////////////////////////////////////////////////////
public Long getId() {
return id;
}
/////////////////////////////////////////////////////
/////////////// API Implementation///////////////////
/////////////////////////////////////////////////////
@Override
public List<Pair<String, Object>> execute(Map<String, Object> params) {
Long id = (Long) params.get(BaseCmd.Properties.ID.getName());
boolean success = false;
ManagementServer ms = getManagementServer();
try {
success = ms.unregisterPreallocatedLun(id);
} catch (Exception e) {
s_logger.error("Unable to unregister lun ", e);
throw new ServerApiException(BaseCmd.INTERNAL_ERROR, "Unable to unregister lun due to: " + e.getMessage());
}
List<Pair<String, Object>> returnValues = new ArrayList<Pair<String, Object>>();
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.SUCCESS.getName(), Boolean.toString(success)));
return returnValues;
}
@Override
public String getName() {
return s_name;
}
@Override
public List<Pair<Enum, Boolean>> getProperties() {
return s_properties;
}
}

View File

@ -0,0 +1,150 @@
/**
* Copyright (C) 2010 Cloud.com, Inc. All rights reserved.
*
* This software is licensed under the GNU General Public License v3 or later.
*
* It is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
package com.cloud.server.api.commands;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import com.cloud.api.BaseCmd;
import com.cloud.api.Parameter;
import com.cloud.api.ServerApiException;
import com.cloud.server.ManagementServer;
import com.cloud.storage.preallocatedlun.PreallocatedLunVO;
import com.cloud.utils.Pair;
public class RegisterPreallocatedLunCmd extends BaseCmd {
private static final Logger s_logger = Logger.getLogger(RegisterPreallocatedLunCmd.class);
private static final String s_name = "registerPreallocatedLunsResponse";
private static final List<Pair<Enum, Boolean>> s_properties = new ArrayList<Pair<Enum, Boolean>>();
static {
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.DISK_SIZE, Boolean.TRUE));
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.LUN, Boolean.TRUE));
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.PORTAL, Boolean.TRUE));
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.TAGS, Boolean.FALSE));
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.TARGET_IQN, Boolean.TRUE));
s_properties.add(new Pair<Enum, Boolean>(BaseCmd.Properties.ZONE_ID, Boolean.TRUE));
}
/////////////////////////////////////////////////////
//////////////// API parameters /////////////////////
/////////////////////////////////////////////////////
@Parameter(name="disksize", type=CommandType.LONG, required=true)
private Long diskSize;
@Parameter(name="lun", type=CommandType.INTEGER, required=true)
private Integer lun;
@Parameter(name="portal", type=CommandType.STRING, required=true)
private String portal;
@Parameter(name="tags", type=CommandType.STRING)
private String tags;
@Parameter(name="targetiqn", type=CommandType.STRING, required=true)
private String targetIqn;
@Parameter(name="zoneid", type=CommandType.LONG, required=true)
private Long zoneId;
/////////////////////////////////////////////////////
/////////////////// Accessors ///////////////////////
/////////////////////////////////////////////////////
public Long getDiskSize() {
return diskSize;
}
public Integer getLun() {
return lun;
}
public String getPortal() {
return portal;
}
public String getTags() {
return tags;
}
public String getTargetIqn() {
return targetIqn;
}
public Long getZoneId() {
return zoneId;
}
/////////////////////////////////////////////////////
/////////////// API Implementation///////////////////
/////////////////////////////////////////////////////
@Override
public List<Pair<String, Object>> execute(Map<String, Object> params) {
String targetIqn = (String)params.get(BaseCmd.Properties.TARGET_IQN.getName());
String portal = (String)params.get(BaseCmd.Properties.PORTAL.getName());
Long size = (Long)params.get(BaseCmd.Properties.DISK_SIZE.getName());
Long dcId = (Long)params.get(BaseCmd.Properties.ZONE_ID.getName());
Integer lun = (Integer)params.get(BaseCmd.Properties.LUN.getName());
String t = (String)params.get(BaseCmd.Properties.TAGS.getName());
PreallocatedLunVO registeredLun = null;
ManagementServer ms = getManagementServer();
try {
registeredLun = ms.registerPreallocatedLun(targetIqn, portal, lun, size, dcId, t);
} catch (Exception e) {
s_logger.error("Unable to register lun", e);
throw new ServerApiException(BaseCmd.INTERNAL_ERROR, "Unable to register lun");
}
List<Pair<String, Object>> embeddedObject = new ArrayList<Pair<String, Object>>();
List<Pair<String, Object>> returnValues = new ArrayList<Pair<String, Object>>();
if (registeredLun == null) {
throw new ServerApiException(BaseCmd.PARAM_ERROR, "Failed to register LUN.");
} else {
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.ID.getName(), registeredLun.getId()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.VOLUME_ID.getName(), registeredLun.getVolumeId()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.ZONE_ID.getName(), registeredLun.getDataCenterId()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.LUN.getName(), registeredLun.getLun()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.PORTAL.getName(), registeredLun.getPortal()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.SIZE.getName(), registeredLun.getSize()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.TAKEN.getName(), registeredLun.getTaken()));
returnValues.add(new Pair<String, Object>(BaseCmd.Properties.TARGET_IQN.getName(), registeredLun.getTargetIqn()));
embeddedObject.add(new Pair<String, Object>("preallocatedlun", new Object[] { returnValues } ));
}
return embeddedObject;
}
@Override
public String getName() {
return s_name;
}
@Override
public List<Pair<Enum, Boolean>> getProperties() {
return s_properties;
}
}