diff options
| author | Selvasundaram <selvam@gluster.com> | 2011-07-07 15:54:59 +0530 |
|---|---|---|
| committer | Selvasundaram <selvam@gluster.com> | 2011-07-07 15:54:59 +0530 |
| commit | f82c3a6b43aca0c2502e0241dd6508b05d179b10 (patch) | |
| tree | c3ebaaa7ce9db732e3bbdf7ad6492922b8c952c2 /src/com.gluster.storage.management.client | |
| parent | 9f0728357a909a9b38d74866ebb03a1be23dae87 (diff) | |
Rebalance volume bug fixes
Diffstat (limited to 'src/com.gluster.storage.management.client')
2 files changed, 3 insertions, 3 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 8d821174..d4242089 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 @@ -616,7 +616,7 @@ public class GlusterDataModelManager { public void removeTask(TaskInfo taskInfo) { model.getCluster().removeTaskInfo(taskInfo); for (ClusterListener listener : listeners) { - listener.taskAdded(taskInfo); + listener.taskRemoved(taskInfo); } } diff --git a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java index 7beb8433..3435b2e1 100644 --- a/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java +++ b/src/com.gluster.storage.management.client/src/com/gluster/storage/management/client/VolumesClient.java @@ -232,13 +232,13 @@ public class VolumesClient extends AbstractClient { return putRequestURI(volumeName + "/" + RESTConstants.RESOURCE_BRICKS, form); } - public void rebalanceStart(String volumeName, Boolean fixLayout, Boolean migrateData, Boolean forcedDataMigrate) { + public URI rebalanceStart(String volumeName, Boolean fixLayout, Boolean migrateData, Boolean forcedDataMigrate) { Form form = new Form(); form.add(RESTConstants.FORM_PARAM_OPERATION, RESTConstants.TASK_REBALANCE_START); form.add(RESTConstants.FORM_PARAM_FIX_LAYOUT, fixLayout); form.add(RESTConstants.FORM_PARAM_MIGRATE_DATA, migrateData); form.add(RESTConstants.FORM_PARAM_FORCED_DATA_MIGRATE, forcedDataMigrate); - putRequest(volumeName, form); + return putRequestURI(volumeName, form); } public void rebalanceStop(String volumeName) { |