summaryrefslogtreecommitdiffstats
path: root/src/com.gluster.storage.management.client
diff options
context:
space:
mode:
authorShireesh Anjal <anjalshireesh@gmail.com>2011-07-07 09:00:09 -0700
committerShireesh Anjal <anjalshireesh@gmail.com>2011-07-07 09:00:09 -0700
commit3a0363633bacf93bf81eb8f3917ecea9d1adfc22 (patch)
tree0138f6dcdb86aa24be982bd645601a264f9ff52c /src/com.gluster.storage.management.client
parent5e04ff19a21ed84aa59004bb8040e1a0d6734542 (diff)
parent529525fe5dec5d9ead5aab6bd39029ea1a63762b (diff)
Merge pull request #103 from Dhandapani/master
VolumeOptions data model change
Diffstat (limited to 'src/com.gluster.storage.management.client')
-rw-r--r--src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/DiscoveredServersClient.java10
-rw-r--r--src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java25
-rw-r--r--src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java11
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) {