Michael Kublin has uploaded a new change for review.

Change subject: engine: Improving EventQueueMonitor for RecoverySroragePool 
scenario
......................................................................

engine: Improving EventQueueMonitor for RecoverySroragePool scenario

The following improvements will not allow to submitt a new events except of 
VDSCONNECTTOPOOL
during recovery process.
The current behaviour is good, but after chnage it will become much better

Change-Id: I06f1065db0dd017d1db5ea1dcbd5e8c983a6c46b
Signed-off-by: Michael Kublin <mkub...@redhat.com>
---
M 
backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/eventqueue/EventQueueMonitor.java
1 file changed, 8 insertions(+), 0 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/69/11869/1

diff --git 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/eventqueue/EventQueueMonitor.java
 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/eventqueue/EventQueueMonitor.java
index 4f8b5e1..19565c7 100644
--- 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/eventqueue/EventQueueMonitor.java
+++ 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/eventqueue/EventQueueMonitor.java
@@ -69,6 +69,14 @@
             Event currentEvent = poolCurrentEventMap.get(storagePoolId);
             if (currentEvent != null) {
                 switch (currentEvent.getEventType()) {
+                case RECOVERY:
+                    if (event.getEventType() == EventType.VDSCONNECTTOPOOL) {
+                        task = addTaskToQueue(event, callable, storagePoolId, 
isEventShouldBeFirst(event));
+                    } else {
+                        log.debugFormat("Current event was skiped because of 
recovery is running now for pool {0}, event {1}",
+                                storagePoolId, event);
+                    }
+                    break;
                 case RECONSTRUCT:
                     if (event.getEventType() == EventType.VDSCONNECTTOPOOL || 
event.getEventType() == EventType.RECOVERY) {
                         task = addTaskToQueue(event, callable, storagePoolId, 
isEventShouldBeFirst(event));


--
To view, visit http://gerrit.ovirt.org/11869
To unsubscribe, visit http://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I06f1065db0dd017d1db5ea1dcbd5e8c983a6c46b
Gerrit-PatchSet: 1
Gerrit-Project: ovirt-engine
Gerrit-Branch: master
Gerrit-Owner: Michael Kublin <mkub...@redhat.com>
_______________________________________________
Engine-patches mailing list
Engine-patches@ovirt.org
http://lists.ovirt.org/mailman/listinfo/engine-patches

Reply via email to