anmolbabu has uploaded a new change for review. Change subject: engine: Bll to resume geo-rep session ......................................................................
engine: Bll to resume geo-rep session Bll to resume geo-rep session Change-Id: I4c8a94c84758d89096c8726b9c11d5d0990a7002 Signed-off-by: Anmol Babu <anb...@redhat.com> --- A backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/gluster/ResumeGeoRepGlusterVolumeCommand.java A backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/action/gluster/ResumeGeoRepGlusterVolumeParameters.java 2 files changed, 93 insertions(+), 0 deletions(-) git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/35/32935/1 diff --git a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/gluster/ResumeGeoRepGlusterVolumeCommand.java b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/gluster/ResumeGeoRepGlusterVolumeCommand.java new file mode 100644 index 0000000..19d0aea --- /dev/null +++ b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/gluster/ResumeGeoRepGlusterVolumeCommand.java @@ -0,0 +1,46 @@ +package org.ovirt.engine.core.bll.gluster; + +import org.ovirt.engine.core.common.AuditLogType; +import org.ovirt.engine.core.common.action.gluster.ResumeGeoRepGlusterVolumeParameters; +import org.ovirt.engine.core.common.errors.VdcBllMessages; +import org.ovirt.engine.core.common.vdscommands.VDSCommandType; +import org.ovirt.engine.core.common.vdscommands.VDSReturnValue; +import org.ovirt.engine.core.common.vdscommands.gluster.GlusterVolumeResumeGeoRepVDSParameters; + +public class ResumeGeoRepGlusterVolumeCommand extends GlusterVolumeCommandBase<ResumeGeoRepGlusterVolumeParameters>{ + + + public ResumeGeoRepGlusterVolumeCommand(ResumeGeoRepGlusterVolumeParameters params) { + super(params); + } + + @Override + protected void setActionMessageParameters() { + addCanDoActionMessage(VdcBllMessages.VAR_ACTION_GEO_REP_RESUME); + addCanDoActionMessage(VdcBllMessages.VAR__TYPE__GLUSTER_VOLUME); + } + + + @Override + protected void executeCommand() { + ResumeGeoRepGlusterVolumeParameters parameters = getParameters(); + setGlusterVolumeId(parameters.getVolumeId()); + VDSReturnValue returnValue = runVdsCommand(VDSCommandType.ResumeGeoRepGlusterVolume, new GlusterVolumeResumeGeoRepVDSParameters(upServer.getId(), getGlusterVolumeName(), parameters.getSlaveHostName(), parameters.getSlaveVolumeName(), parameters.isForce())); + setSucceeded(returnValue.getSucceeded()); + if(!getSucceeded()) { + handleVdsError(AuditLogType.GLUSTER_VOLUME_GEO_REP_RESUME_FAILED, returnValue.getVdsError().getMessage()); + return; + } + } + + @Override + public AuditLogType getAuditLogTypeValue() { + if(getSucceeded()) { + return AuditLogType.GLUSTER_VOLUME_GEO_REP_RESUME; + } else { + return AuditLogType.GLUSTER_VOLUME_GEO_REP_RESUME_FAILED; + } + } + + +} diff --git a/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/action/gluster/ResumeGeoRepGlusterVolumeParameters.java b/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/action/gluster/ResumeGeoRepGlusterVolumeParameters.java new file mode 100644 index 0000000..7e16cb4 --- /dev/null +++ b/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/action/gluster/ResumeGeoRepGlusterVolumeParameters.java @@ -0,0 +1,47 @@ +package org.ovirt.engine.core.common.action.gluster; + +import org.ovirt.engine.core.compat.Guid; + +public class ResumeGeoRepGlusterVolumeParameters extends GlusterVolumeParameters { + + private static final long serialVersionUID = 1L; + + private String slaveHostName; + private String slaveVolumeName; + private boolean force; + + public ResumeGeoRepGlusterVolumeParameters() { + + } + + public ResumeGeoRepGlusterVolumeParameters(Guid volumeId, String slaveHostName, String slaveVolumeName, boolean force) { + super(volumeId); + this.slaveHostName = slaveHostName; + this.slaveVolumeName = slaveVolumeName; + this.force = force; + } + + public String getSlaveHostName() { + return slaveHostName; + } + + public void setSlaveHostName(String slaveHostName) { + this.slaveHostName = slaveHostName; + } + + public String getSlaveVolumeName() { + return slaveVolumeName; + } + + public void setSlaveVolumeName(String slaveVolumeName) { + this.slaveVolumeName = slaveVolumeName; + } + + public boolean isForce() { + return force; + } + + public void setForce(boolean force) { + this.force = force; + } +} -- To view, visit http://gerrit.ovirt.org/32935 To unsubscribe, visit http://gerrit.ovirt.org/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I4c8a94c84758d89096c8726b9c11d5d0990a7002 Gerrit-PatchSet: 1 Gerrit-Project: ovirt-engine Gerrit-Branch: master Gerrit-Owner: anmolbabu <anb...@redhat.com> _______________________________________________ Engine-patches mailing list Engine-patches@ovirt.org http://lists.ovirt.org/mailman/listinfo/engine-patches