diff options
| author | Selvam <selvam@gluster.com> | 2011-04-29 15:19:50 +0530 |
|---|---|---|
| committer | Selvam <selvam@gluster.com> | 2011-04-29 15:19:50 +0530 |
| commit | 1a2533deb10ed4dc0c4d910ce830a7065b845e68 (patch) | |
| tree | e9c83f01d03f0c959cfb65cb0d7a15935b53b543 /src/com.gluster.storage.management.client | |
| parent | 3149b18d24539f5680848c25064f447c15bbbcc4 (diff) | |
| parent | 3cc0768e0baf35ea140262e4f646cbdb9a3b8b84 (diff) | |
Merge branch 'expand-volume'
Conflicts:
src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java
src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/model/Volume.java
src/com.gluster.storage.management.core/src/com/gluster/storage/management/core/utils/StringUtil.java
src/com.gluster.storage.management.gui/plugin.xml
src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/actions/AddDiskAction.java
src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/AddDiskPage.java
src/com.gluster.storage.management.gui/src/com/gluster/storage/management/gui/dialogs/AddDiskWizard.java
src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/resources/VolumesResource.java
src/com.gluster.storage.management.server/src/com/gluster/storage/management/server/utils/GlusterUtil.java
Diffstat (limited to 'src/com.gluster.storage.management.client')
2 files changed, 42 insertions, 21 deletions
diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/DiscoveredServersClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/DiscoveredServersClient.java index eb6ef3a0..c7ea7507 100644 --- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/DiscoveredServersClient.java +++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/DiscoveredServersClient.java @@ -46,6 +46,7 @@ public class DiscoveredServersClient extends AbstractClient { MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl(); queryParams.putSingle("details", getDetails.toString()); + //System.out.println((String) fetchResource(queryParams, String.class)); return ((Response) fetchResource(queryParams, responseClass)).getData(); } diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java index b37c880c..87e02e28 100644 --- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java +++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java @@ -20,14 +20,22 @@ */ package com.gluster.storage.management.client; + +import java.util.ArrayList; +import java.util.List; + import javax.ws.rs.core.MultivaluedMap; import com.gluster.storage.management.core.constants.RESTConstants; +import com.gluster.storage.management.core.model.Disk; +import com.gluster.storage.management.core.model.Disk.DISK_STATUS; import com.gluster.storage.management.core.model.Status; import com.gluster.storage.management.core.model.Volume; import com.gluster.storage.management.core.response.LogMessageListResponse; import com.gluster.storage.management.core.response.VolumeListResponse; import com.gluster.storage.management.core.response.VolumeOptionInfoListResponse; +import com.gluster.storage.management.core.utils.GlusterCoreUtil; +import com.gluster.storage.management.core.utils.StringUtil; import com.sun.jersey.api.representation.Form; import com.sun.jersey.core.util.MultivaluedMapImpl; @@ -88,6 +96,13 @@ public class VolumesClient extends AbstractClient { return ((VolumeOptionInfoListResponse) fetchSubResource(RESTConstants.SUBRESOURCE_DEFAULT_OPTIONS, VolumeOptionInfoListResponse.class)); } + + public Status addDisks(String volumeName, List<Disk> diskList) { + String disks = StringUtil.ListToString( GlusterCoreUtil.getQualifiedDiskNames(diskList), ","); + Form form = new Form(); + form.add(RESTConstants.QUERY_PARAM_DISKS, disks); + return (Status) postRequest(volumeName + "/" + RESTConstants.SUBRESOURCE_DISKS, Status.class, form); + } public Status addDisks(String volumeName, String disks) { Form form = new Form(); @@ -108,27 +123,32 @@ public class VolumesClient extends AbstractClient { UsersClient usersClient = new UsersClient(); if (usersClient.authenticate("gluster", "gluster").isSuccess()) { VolumesClient client = new VolumesClient(usersClient.getSecurityToken()); - // List<Disk> disks = new ArrayList<Disk>(); - // Disk diskElement = new Disk(); - // diskElement.setName("sda1"); - // diskElement.setStatus(DISK_STATUS.READY); - // disks.add(diskElement); - // diskElement.setName("sda2"); - // diskElement.setStatus(DISK_STATUS.READY); - // disks.add(diskElement); - // - // Volume vol = new Volume("vol1", null, Volume.VOLUME_TYPE.PLAIN_DISTRIBUTE, - // Volume.TRANSPORT_TYPE.ETHERNET, - // Volume.VOLUME_STATUS.ONLINE); - // // vol.setDisks(disks); - // System.out.println(client.createVolume(vol)); - // for (VolumeOptionInfo option : client.getVolumeOptionsDefaults()) { - // System.out.println(option.getName() + "-" + option.getDescription() + "-" + option.getDefaultValue()); - // } - // System.out.println(client.getVolume("Volume3").getOptions()); - // System.out.println(client.setVolumeOption("Volume3", "network.frame-timeout", "600").getMessage()); - - Status status = client.addDisks("Volume3", "server1:sda, server1:sdb, server1:sdc"); +// List<Disk> disks = new ArrayList<Disk>(); +// Disk diskElement = new Disk(); +// diskElement.setName("sda1"); +// diskElement.setStatus(DISK_STATUS.READY); +// disks.add(diskElement); +// diskElement.setName("sda2"); +// diskElement.setStatus(DISK_STATUS.READY); +// disks.add(diskElement); +// +// Volume vol = new Volume("vol1", null, Volume.VOLUME_TYPE.PLAIN_DISTRIBUTE, Volume.TRANSPORT_TYPE.ETHERNET, +// Volume.VOLUME_STATUS.ONLINE); +// // vol.setDisks(disks); +// System.out.println(client.createVolume(vol)); +// for (VolumeOptionInfo option : client.getVolumeOptionsDefaults()) { +// System.out.println(option.getName() + "-" + option.getDescription() + "-" + option.getDefaultValue()); +// } +// System.out.println(client.getVolume("Volume3").getOptions()); +// System.out.println(client.setVolumeOption("Volume3", "network.frame-timeout", "600").getMessage()); + List<Disk> disks = new ArrayList<Disk>(); + Disk disk = new Disk(); + disk.setServerName("server1"); + disk.setName("sda"); + disk.setStatus(DISK_STATUS.READY); + disks.add(disk); + + Status status = client.addDisks("Volume3", disks); System.out.println(status.getMessage()); } } |
