diff options
| author | Shireesh Anjal <anjalshireesh@gmail.com> | 2011-07-07 09:00:09 -0700 |
|---|---|---|
| committer | Shireesh Anjal <anjalshireesh@gmail.com> | 2011-07-07 09:00:09 -0700 |
| commit | 3a0363633bacf93bf81eb8f3917ecea9d1adfc22 (patch) | |
| tree | 0138f6dcdb86aa24be982bd645601a264f9ff52c /src/com.gluster.storage.management.client | |
| parent | 5e04ff19a21ed84aa59004bb8040e1a0d6734542 (diff) | |
| parent | 529525fe5dec5d9ead5aab6bd39029ea1a63762b (diff) | |
Merge pull request #103 from Dhandapani/master
VolumeOptions data model change
Diffstat (limited to 'src/com.gluster.storage.management.client')
3 files changed, 24 insertions, 22 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 3704e2ff..0d4ef85c 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 @@ -25,10 +25,12 @@ import java.util.List; import javax.ws.rs.core.MultivaluedMap; +import com.gluster.storage.management.core.model.GlusterServer; import com.gluster.storage.management.core.model.Server; import com.gluster.storage.management.core.response.GenericResponse; import com.gluster.storage.management.core.response.ServerListResponse; import com.gluster.storage.management.core.response.ServerNameListResponse; +import com.gluster.storage.management.core.utils.GlusterCoreUtil; import com.sun.jersey.core.util.MultivaluedMapImpl; public class DiscoveredServersClient extends AbstractClient { @@ -59,7 +61,13 @@ public class DiscoveredServersClient extends AbstractClient { } public List<Server> getDiscoveredServerDetails() { - return ((ServerListResponse) getDiscoveredServers(Boolean.TRUE, ServerListResponse.class)).getServers(); + List<Server> servers = ((ServerListResponse) getDiscoveredServers(Boolean.TRUE, ServerListResponse.class)) + .getServers(); + + for (Server server : servers) { + GlusterCoreUtil.updateServerNameOnDevices(server); + } + return servers; } public Server getServer(String serverName) { diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java index 9ee4513c..6db98ed4 100644 --- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java +++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java @@ -19,7 +19,6 @@ package com.gluster.storage.management.client; import java.util.ArrayList; -import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; @@ -31,8 +30,8 @@ import com.gluster.storage.management.core.exceptions.GlusterRuntimeException; import com.gluster.storage.management.core.model.Brick; import com.gluster.storage.management.core.model.Cluster; import com.gluster.storage.management.core.model.ClusterListener; +import com.gluster.storage.management.core.model.Device.DEVICE_STATUS; 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.Event; import com.gluster.storage.management.core.model.Event.EVENT_TYPE; import com.gluster.storage.management.core.model.GlusterDataModel; @@ -605,10 +604,10 @@ public class GlusterDataModelManager { } } - public void setVolumeOption(Volume volume, Entry<String, String> entry) { - volume.setOption(entry.getKey(), (String) entry.getValue()); + public void setVolumeOption(Volume volume, String optionKey, String optionValue) { + volume.setOption(optionKey, optionValue); for (ClusterListener listener : listeners) { - listener.volumeChanged(volume, new Event(EVENT_TYPE.VOLUME_OPTION_SET, entry)); + listener.volumeChanged(volume, new Event(EVENT_TYPE.VOLUME_OPTION_SET, optionKey)); } } @@ -673,8 +672,7 @@ public class GlusterDataModelManager { } public void setAccessControlList(Volume volume, String accessControlList) { - volume.setAccessControlList(accessControlList); - setVolumeOption(volume, getOptionEntry(volume, Volume.OPTION_AUTH_ALLOW)); + setVolumeOption(volume, Volume.OPTION_AUTH_ALLOW, accessControlList); } public Server getGlusterServer(String serverName) { @@ -686,17 +684,6 @@ public class GlusterDataModelManager { return null; } - @SuppressWarnings({ "rawtypes", "unchecked" }) - private Entry<String, String> getOptionEntry(Volume volume, String optionKey) { - for (Entry entry : volume.getOptions().entrySet()) { - if (entry.getKey().equals(optionKey)) { - return entry; - } - } - throw new GlusterRuntimeException("Couldn't find entry for option [" + optionKey + "] on volume [" - + volume.getName()); - } - private Boolean isDiskUsed(Volume volume, Disk disk) { for (Brick brick : volume.getBricks()) { if (disk.getName().equals(brick.getDiskName()) && disk.getServerName().equals(brick.getServerName())) { @@ -707,7 +694,7 @@ public class GlusterDataModelManager { } public String getDiskStatus(Disk disk) { - if (disk.getStatus() == DISK_STATUS.AVAILABLE) { + if (disk.getStatus() == DEVICE_STATUS.INITIALIZED) { for (Volume volume : model.getCluster().getVolumes()) { if (isDiskUsed(volume, disk)) { return "In use"; diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java index 865ec5f2..0abccda5 100644 --- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java +++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java @@ -28,6 +28,7 @@ import com.gluster.storage.management.core.constants.RESTConstants; import com.gluster.storage.management.core.model.GlusterServer; import com.gluster.storage.management.core.model.Server; import com.gluster.storage.management.core.response.GlusterServerListResponse; +import com.gluster.storage.management.core.utils.GlusterCoreUtil; import com.sun.jersey.api.representation.Form; public class GlusterServersClient extends AbstractClient { @@ -50,11 +51,17 @@ public class GlusterServersClient extends AbstractClient { } public List<GlusterServer> getServers() { - return ((GlusterServerListResponse) fetchResource(GlusterServerListResponse.class)).getServers(); + List<GlusterServer> servers = ((GlusterServerListResponse) fetchResource(GlusterServerListResponse.class)).getServers(); + for(GlusterServer server : servers) { + GlusterCoreUtil.updateServerNameOnDevices(server); + } + return servers; } public GlusterServer getGlusterServer(String serverName) { - return (GlusterServer) fetchSubResource(serverName, GlusterServer.class); + GlusterServer server = (GlusterServer) fetchSubResource(serverName, GlusterServer.class); + GlusterCoreUtil.updateServerNameOnDevices(server); + return server; } public void addServer(Server discoveredServer) { |
