diff options
| author | Dhandapani <dhandapani@gluster.com> | 2011-04-25 14:25:47 +0530 |
|---|---|---|
| committer | Dhandapani <dhandapani@gluster.com> | 2011-04-25 14:53:04 +0530 |
| commit | 8af8228a2f2e93be63a041edcd76a3b26f8a0cd9 (patch) | |
| tree | ad4776ea86eb29511c223b4453b98713e4a85677 /src/com.gluster.storage.management.server | |
| parent | 6c7fe56253c08eccf62c765a151629f70c7c85d1 (diff) | |
| parent | 9d8fdadfeedbd132ab01dd0cdd79f21f52f90a4e (diff) | |
Story #3: Code review updates
Diffstat (limited to 'src/com.gluster.storage.management.server')
| -rw-r--r-- | src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java | 27 |
1 files changed, 15 insertions, 12 deletions
diff --git a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java index 92fba9f3..e30462f2 100644 --- a/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java +++ b/src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java @@ -26,6 +26,8 @@ import static com.gluster.storage.management.core.constants.RESTConstants.FORM_P import static com.gluster.storage.management.core.constants.RESTConstants.PATH_PARAM_VOLUME_NAME; import static com.gluster.storage.management.core.constants.RESTConstants.QUERY_PARAM_DISK_NAME; import static com.gluster.storage.management.core.constants.RESTConstants.QUERY_PARAM_LINE_COUNT; +import static com.gluster.storage.management.core.constants.RESTConstants.QUERY_PARAM_VOLUME_NAME; +import static com.gluster.storage.management.core.constants.RESTConstants.QUERY_PARAM_DELETE_OPTION; import static com.gluster.storage.management.core.constants.RESTConstants.RESOURCE_PATH_VOLUMES; import static com.gluster.storage.management.core.constants.RESTConstants.SUBRESOURCE_DEFAULT_OPTIONS; import static com.gluster.storage.management.core.constants.RESTConstants.SUBRESOURCE_LOGS; @@ -143,7 +145,8 @@ public class VolumesResource { @DELETE @Path("{" + PATH_PARAM_VOLUME_NAME + "}") @Produces(MediaType.TEXT_XML) - public Status deleteVolume(@QueryParam("volumeName") String volumeName, @QueryParam("deleteOption") int deleteOption) { + public Status deleteVolume(@QueryParam(QUERY_PARAM_VOLUME_NAME) String volumeName, + @QueryParam(QUERY_PARAM_DELETE_OPTION) int deleteOption) { Volume volume = glusterUtil.getVolume(volumeName); Status status = glusterUtil.deleteVolume(volumeName); @@ -257,38 +260,38 @@ public class VolumesResource { } return new Status(Status.STATUS_CODE_SUCCESS, "Directories cleaned up successfully!"); } - + private List<LogMessage> getDiskLogs(String volumeName, String diskName, Integer lineCount) throws GlusterRuntimeException { - String[] diskParts = diskName.split(":"); + String[] diskParts = diskName.split(":"); String server = diskParts[0]; String disk = diskParts[1]; - + // Usage: get_volume_disk_log.py <volumeName> <diskName> <lineCount> Status logStatus = (Status) serverUtil.executeOnServer(true, server, VOLUME_DISK_LOG_SCRIPT + " " + volumeName + " " + disk + " " + lineCount, Status.class); - if(!logStatus.isSuccess()) { + if (!logStatus.isSuccess()) { throw new GlusterRuntimeException(logStatus.toString()); } - + return extractLogMessages(logStatus.getMessage()); } private List<LogMessage> extractLogMessages(String logContent) { List<LogMessage> logMessages = new ArrayList<LogMessage>(); - for(String logMessage : logContent.split(CoreConstants.NEWLINE)) { + for (String logMessage : logContent.split(CoreConstants.NEWLINE)) { logMessages.add(new LogMessage(logMessage)); } - + return logMessages; } - + @GET @Path("{" + PATH_PARAM_VOLUME_NAME + "}/" + SUBRESOURCE_LOGS) public LogMessageListResponse getLogs(@PathParam(PATH_PARAM_VOLUME_NAME) String volumeName, @QueryParam(QUERY_PARAM_DISK_NAME) String diskName, @QueryParam(QUERY_PARAM_LINE_COUNT) Integer lineCount) { List<LogMessage> logMessages = null; - + try { if (diskName == null || diskName.isEmpty()) { logMessages = new ArrayList<LogMessage>(); @@ -304,7 +307,7 @@ public class VolumesResource { } catch (Exception e) { return new LogMessageListResponse(new Status(e), null); } - + return new LogMessageListResponse(Status.STATUS_SUCCESS, logMessages); } @@ -325,7 +328,7 @@ public class VolumesResource { // Status status = vr.createVolume(volume); // System.out.println(status.getMessage()); Form form = new Form(); - form.add(RESTConstants.FORM_PARAM_VOLUME_NAME, volume.getName()); + form.add("volumeName", volume.getName()); form.add(RESTConstants.FORM_PARAM_DELETE_OPTION, 1); Status status = vr.deleteVolume("Vol2", 1); System.out.println("Code : " + status.getCode()); |
