summaryrefslogtreecommitdiffstats
path: root/src/com.gluster.storage.management.client
diff options
context:
space:
mode:
authorShireesh Anjal <shireesh@gluster.com>2011-05-18 20:18:06 +0530
committerShireesh Anjal <shireesh@gluster.com>2011-05-18 20:22:38 +0530
commit7e001e8d07a538031ad185ac04718e44d821d42c (patch)
tree46ec7e94f9bbe94440740ce20663baa7eef993f6 /src/com.gluster.storage.management.client
parenta3a32744665643f645949c7b504c0dfe768d3325 (diff)
Modified to execute commands on peers using SSH
Diffstat (limited to 'src/com.gluster.storage.management.client')
-rw-r--r--src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterDataModelManager.java8
-rw-r--r--src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/GlusterServersClient.java8
2 files changed, 9 insertions, 7 deletions
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 41d76e58..e639f615 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
@@ -112,13 +112,13 @@ public class GlusterDataModelManager {
servers.add(server);
}
- public void initializeModel(String securityToken) {
+ public void initializeModel(String securityToken, String knownServer) {
model = new GlusterDataModel("Gluster Data Model");
setSecurityToken(securityToken);
Cluster cluster = new Cluster("Home", model);
- initializeGlusterServers(cluster);
+ initializeGlusterServers(cluster, knownServer);
initializeVolumes(cluster);
initializeAutoDiscoveredServers(cluster);
@@ -227,8 +227,8 @@ public class GlusterDataModelManager {
volume5.addDisk("server5:sdb");
}
- private void initializeGlusterServers(Cluster cluster) {
- cluster.setServers(new GlusterServersClient(securityToken).getServers());
+ private void initializeGlusterServers(Cluster cluster, String knownServer) {
+ cluster.setServers(new GlusterServersClient(securityToken).getServers(knownServer));
}
private void initializeAutoDiscoveredServers(Cluster cluster) {
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 d4809daf..98b8878c 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
@@ -44,8 +44,10 @@ public class GlusterServersClient extends AbstractClient {
return RESOURCE_NAME;
}
- public List<GlusterServer> getServers() {
- GlusterServerListResponse response = (GlusterServerListResponse) fetchResource(GlusterServerListResponse.class);
+ public List<GlusterServer> getServers(String knownServer) {
+ MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
+ queryParams.add(RESTConstants.QUERY_PARAM_KNOWN_SERVER, knownServer);
+ GlusterServerListResponse response = (GlusterServerListResponse) fetchResource(queryParams, GlusterServerListResponse.class);
return response.getServers();
}
@@ -76,7 +78,7 @@ public class GlusterServersClient extends AbstractClient {
if (usersClient.authenticate("gluster", "gluster").isSuccess()) {
GlusterServersClient serverResource = new GlusterServersClient(usersClient.getSecurityToken());
- List<GlusterServer> glusterServers = serverResource.getServers();
+ List<GlusterServer> glusterServers = serverResource.getServers("127.0.0.1");
for (GlusterServer server : glusterServers) {
System.out.println(server.getName());
}