diff options
author | Selvasundaram <selvam@gluster.com> | 2011-11-24 14:28:46 +0530 |
---|---|---|
committer | Selvasundaram <selvam@gluster.com> | 2011-11-24 14:28:46 +0530 |
commit | 8c7203104004e425579a4fcbc1b9b91bb82f8f2e (patch) | |
tree | 4cdbc20ee60ddffde626ae2b1ff9215e406fb635 /src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java | |
parent | 7476d5ee5b3f96ef8b637a4a016634cb1d098187 (diff) |
Disk Initialization enhanced with user selectable file system and mount point
Diffstat (limited to 'src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java')
-rw-r--r-- | src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java b/src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java index da1a8487..fcaec52e 100644 --- a/src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java +++ b/src/com.gluster.storage.management.gateway/src/com/gluster/storage/management/gateway/services/GlusterServerService.java @@ -35,6 +35,7 @@ import com.gluster.storage.management.core.exceptions.GlusterValidationException import com.gluster.storage.management.core.model.GlusterServer; import com.gluster.storage.management.core.model.Server; import com.gluster.storage.management.core.model.Server.SERVER_STATUS; +import com.gluster.storage.management.core.response.StringListResponse; import com.gluster.storage.management.core.utils.GlusterCoreUtil; import com.gluster.storage.management.core.utils.ProcessUtil; import com.gluster.storage.management.core.utils.StringUtil; @@ -142,6 +143,20 @@ public class GlusterServerService { return server; } } + + // Server not found. It's possible that the server name returned by glusterfs is actually IP address + // Hence fetch details of all servers and then compare the host names again. + String errMsg = fetchDetailsOfServers(Collections.synchronizedList(servers)); + if (!errMsg.isEmpty()) { + throw new GlusterRuntimeException("Couldn't fetch details for server(s): " + errMsg); + } + for (GlusterServer server : servers) { + if (server.getName().equalsIgnoreCase(serverName)) { + return server; + } + } + + // still not found! return null; } @@ -504,4 +519,12 @@ public class GlusterServerService { } } } + + public StringListResponse getFsType(String clusterName, String serverName) { + if (isValidServer(clusterName, serverName)) { + return serverUtil.getFsType(serverName); + } else { + throw new GlusterRuntimeException(serverName + " is not belongs to the cluster [" + clusterName + "]"); + } + } } |