diff options
author | Shireesh Anjal <anjalshireesh@gmail.com> | 2011-12-08 07:18:46 -0800 |
---|---|---|
committer | Shireesh Anjal <anjalshireesh@gmail.com> | 2011-12-08 07:18:46 -0800 |
commit | b816816a5dc5d4ff01d0b79250c89e16d6e9cbe6 (patch) | |
tree | 9742cfcfb7816ef63a665f9ae847fabbb6735eb5 /src | |
parent | ff226ed0a143df8e1b171162a9385f0af88c83c8 (diff) | |
parent | 94a9cbe7c4e1d7f88e673086f9d9ee961429ff25 (diff) |
Merge pull request #18 from Selvasundaram/master
Fixed not to return task status as null in case the gluster command for checking migration status fails. Now an exception will be thrown in such cases.
Diffstat (limited to 'src')
2 files changed, 10 insertions, 4 deletions
diff --git a/src/org.gluster.storage.management.console/src/org/gluster/storage/management/console/dialogs/MigrateBrickWizard.java b/src/org.gluster.storage.management.console/src/org/gluster/storage/management/console/dialogs/MigrateBrickWizard.java index e86b4020..7baae6b5 100644 --- a/src/org.gluster.storage.management.console/src/org/gluster/storage/management/console/dialogs/MigrateBrickWizard.java +++ b/src/org.gluster.storage.management.console/src/org/gluster/storage/management/console/dialogs/MigrateBrickWizard.java @@ -64,7 +64,7 @@ public class MigrateBrickWizard extends Wizard { String dialogTitle = "Brick migration"; try { - String reference = volume.getName() + "-" + sourceDir + "-" + targetDir; + String reference = volume.getName() + "#" + sourceDir + "#" + targetDir; TaskInfo existingTaskInfo = GlusterDataModelManager.getInstance().getTaskByReference(reference); if (existingTaskInfo != null && existingTaskInfo.getStatus().getCode() != Status.STATUS_CODE_SUCCESS && existingTaskInfo.getStatus().getCode() != Status.STATUS_CODE_FAILURE) { diff --git a/src/org.gluster.storage.management.gateway/src/org/gluster/storage/management/gateway/tasks/MigrateBrickTask.java b/src/org.gluster.storage.management.gateway/src/org/gluster/storage/management/gateway/tasks/MigrateBrickTask.java index 6cf4777d..7e61f615 100644 --- a/src/org.gluster.storage.management.gateway/src/org/gluster/storage/management/gateway/tasks/MigrateBrickTask.java +++ b/src/org.gluster.storage.management.gateway/src/org/gluster/storage/management/gateway/tasks/MigrateBrickTask.java @@ -96,7 +96,7 @@ public class MigrateBrickTask extends Task { // online server might have gone Offline. try with a new one. startMigration(getNewOnlineServer().getName()); } else { - throw new GlusterRuntimeException(e.getMessage()); + throw new GlusterRuntimeException("Error while starting migration!", e); } } } @@ -105,6 +105,7 @@ public class MigrateBrickTask extends Task { String volumeName = getTaskInfo().getReference().split("#")[0]; glusterInterface.startBrickMigration(onlineServerName, volumeName, getFromBrick(), getToBrick()); getTaskInfo().setStatus(new TaskStatus(new Status(Status.STATUS_CODE_RUNNING, "Brick Migration Started."))); + System.out.println(getTaskInfo().getStatus().toString()); } @Override @@ -193,9 +194,14 @@ public class MigrateBrickTask extends Task { if (e instanceof ConnectionException || serverUtil.isServerOnline(getOnlineServer()) == false) { // online server might have gone offline. try with a new one. return checkMigrationStatus(getNewOnlineServer().getName()); - } + } else { + if(e instanceof GlusterRuntimeException) { + throw ((GlusterRuntimeException)e); + } else { + throw new GlusterRuntimeException("Exception while checking brick migration status!", e); + } + } } - return null; } private TaskStatus checkMigrationStatus(String serverName) { |