diff options
| author | Shireesh Anjal <shireesh@gluster.com> | 2011-05-18 20:18:06 +0530 |
|---|---|---|
| committer | Shireesh Anjal <shireesh@gluster.com> | 2011-05-18 20:22:38 +0530 |
| commit | 7e001e8d07a538031ad185ac04718e44d821d42c (patch) | |
| tree | 46ec7e94f9bbe94440740ce20663baa7eef993f6 /src/com.gluster.storage.management.client | |
| parent | a3a32744665643f645949c7b504c0dfe768d3325 (diff) | |
Modified to execute commands on peers using SSH
Diffstat (limited to 'src/com.gluster.storage.management.client')
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()); } |
