summaryrefslogtreecommitdiffstats
path: root/feature-active-standby-management/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'feature-active-standby-management/src/main')
-rw-r--r--feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/ActiveStandbyFeature.java18
-rw-r--r--feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/DroolsPdpsElectionHandler.java158
2 files changed, 88 insertions, 88 deletions
diff --git a/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/ActiveStandbyFeature.java b/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/ActiveStandbyFeature.java
index c34f9ace..6101073a 100644
--- a/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/ActiveStandbyFeature.java
+++ b/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/ActiveStandbyFeature.java
@@ -7,9 +7,9 @@
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -31,7 +31,7 @@ import javax.persistence.Persistence;
import org.onap.policy.drools.core.PolicySessionFeatureApi;
import org.onap.policy.drools.features.PolicyEngineFeatureApi;
-import org.onap.policy.drools.statemanagement.StateManagementFeatureAPI;
+import org.onap.policy.drools.statemanagement.StateManagementFeatureApi;
import org.onap.policy.drools.system.PolicyEngine;
import org.onap.policy.drools.utils.PropertyUtil;
import org.slf4j.Logger;
@@ -57,7 +57,7 @@ public class ActiveStandbyFeature implements ActiveStandbyFeatureApi,
private static Object myPdpSync = new Object();
private static DroolsPdpsElectionHandler electionHandler;
- private StateManagementFeatureAPI stateManagementFeature;
+ private StateManagementFeatureApi stateManagementFeature;
public static final int SEQ_NUM = 1;
@@ -82,7 +82,7 @@ public class ActiveStandbyFeature implements ActiveStandbyFeatureApi,
// This must come first since it initializes myPdp
initializePersistence(configDir);
- for (StateManagementFeatureAPI feature : StateManagementFeatureAPI.impl.getList()) {
+ for (StateManagementFeatureApi feature : StateManagementFeatureApi.impl.getList()) {
if (feature.getResourceName().equals(myPdp.getPdpId())) {
if (logger.isDebugEnabled()) {
logger.debug("ActiveStandbyFeature.globalInit: Found StateManagementFeature"
@@ -95,11 +95,11 @@ public class ActiveStandbyFeature implements ActiveStandbyFeatureApi,
if (stateManagementFeature == null) {
if (logger.isDebugEnabled()) {
logger.debug("ActiveStandbyFeature failed to initialize. "
- + "Unable to get instance of StateManagementFeatureAPI "
+ + "Unable to get instance of StateManagementFeatureApi "
+ "with resourceID: {}", myPdp.getPdpId());
}
logger.error("ActiveStandbyFeature failed to initialize. "
- + "Unable to get instance of StateManagementFeatureAPI "
+ + "Unable to get instance of StateManagementFeatureApi "
+ "with resourceID: {}", myPdp.getPdpId());
//
// Cannot add observer since stateManagementFeature is null
@@ -137,7 +137,7 @@ public class ActiveStandbyFeature implements ActiveStandbyFeatureApi,
private static void initializePersistence(String configDir) {
//Get the Active Standby properties
try {
- Properties activeStandbyProperties =
+ Properties activeStandbyProperties =
PropertyUtil.getProperties(configDir + "/feature-active-standby-management.properties");
ActiveStandbyProperties.initProperties(activeStandbyProperties);
logger.info("initializePersistence: ActiveStandbyProperties success");
@@ -188,7 +188,7 @@ public class ActiveStandbyFeature implements ActiveStandbyFeatureApi,
* Moved code to instantiate a JpaDroolsPdpsConnector object from main() to
* this method, so it can also be accessed from StandbyStateChangeNotifier
* class.
- *
+ *
* @param pu string
* @return connector object
*/
diff --git a/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/DroolsPdpsElectionHandler.java b/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/DroolsPdpsElectionHandler.java
index fddf0246..85a0e3ab 100644
--- a/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/DroolsPdpsElectionHandler.java
+++ b/feature-active-standby-management/src/main/java/org/onap/policy/drools/activestandby/DroolsPdpsElectionHandler.java
@@ -2,14 +2,14 @@
* ============LICENSE_START=======================================================
* feature-active-standby-management
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -28,12 +28,12 @@ import java.util.Timer;
import java.util.TimerTask;
import org.onap.policy.common.im.StateManagement;
-import org.onap.policy.drools.statemanagement.StateManagementFeatureAPI;
+import org.onap.policy.drools.statemanagement.StateManagementFeatureApi;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
- // get an instance of logger
+ // get an instance of logger
private static final Logger logger = LoggerFactory.getLogger(DroolsPdpsElectionHandler.class);
private DroolsPdpsConnector pdpsConnector;
private Object checkWaitTimerLock = new Object();
@@ -68,14 +68,14 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
*/
private Boolean allSeemsWell = null;
- private StateManagementFeatureAPI stateManagementFeature;
+ private StateManagementFeatureApi stateManagementFeature;
private static boolean isUnitTesting = false;
private static boolean isStalled = false;
/**
* Constructor.
- *
+ *
* @param pdps connectors
* @param myPdp pdp
*/
@@ -115,18 +115,18 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
final long nowMs = now.getTime();
// Create the timer which will update the updateDate in DroolsPdpEntity table.
- // This is the heartbeat
+ // This is the heartbeat
updateWorker = new Timer();
// Schedule the TimerUpdateClass to run at 100 ms and run at pdpCheckInterval ms thereafter
- // NOTE: The first run of the TimerUpdateClass results in myPdp being added to the
+ // NOTE: The first run of the TimerUpdateClass results in myPdp being added to the
// drools droolsPdpEntity table.
updateWorker.scheduleAtFixedRate(new TimerUpdateClass(), 100, pdpCheckInterval);
// Create the timer which will run the election algorithm
waitTimer = new Timer();
- // Schedule it to start in startMs ms
+ // Schedule it to start in startMs ms
// (so it will run after the updateWorker and run at pdpUpdateInterval ms thereafter
long startMs = getDWaiterStartMs();
designationWaiter = new DesignationWaiter();
@@ -135,7 +135,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
//Get the StateManagementFeature instance
- for (StateManagementFeatureAPI feature : StateManagementFeatureAPI.impl.getList()) {
+ for (StateManagementFeatureApi feature : StateManagementFeatureApi.impl.getList()) {
if (feature.getResourceName().equals(myPdp.getPdpId())) {
if (logger.isDebugEnabled()) {
logger.debug("DroolsPdpsElectionHandler: Found StateManagementFeature"
@@ -147,7 +147,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
if (stateManagementFeature == null) {
logger.error("DroolsPdpsElectionHandler failed to initialize. "
- + "Unable to get instance of StateManagementFeatureAPI "
+ + "Unable to get instance of StateManagementFeatureApi "
+ "with resourceID: {}", myPdp.getPdpId());
}
}
@@ -155,7 +155,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
public static void setIsUnitTesting(boolean val) {
isUnitTesting = val;
}
-
+
public static void setIsStalled(boolean val) {
isStalled = val;
}
@@ -164,7 +164,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
* When the JpaDroolsPdpsConnector.standDown() method is invoked, it needs
* access to myPdp, so it can keep its designation status in sync with the
* DB.
- *
+ *
* @param designated is designated value
*/
public static void setMyPdpDesignated(boolean designated) {
@@ -175,7 +175,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
private class DesignationWaiter extends TimerTask {
- // get an instance of logger
+ // get an instance of logger
private final Logger logger = LoggerFactory.getLogger(DesignationWaiter.class);
@Override
@@ -188,7 +188,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
//This is for testing the checkWaitTimer
if (isUnitTesting && isStalled) {
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run: isUnitTesting = {} isStalled = {}",
+ logger.debug("DesignatedWaiter.run: isUnitTesting = {} isStalled = {}",
isUnitTesting, isStalled);
}
return;
@@ -245,10 +245,10 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/*
* There are 4 combinations of isDesignated and isCurrent. We will examine each one in-turn
* and evaluate the each pdp in the list of pdps against each combination.
- *
+ *
* This is the first combination of isDesignated and isCurrent
*/
- if (pdp.isDesignated() && isCurrent) {
+ if (pdp.isDesignated() && isCurrent) {
//It is current, but it could have a standbystatus=coldstandby / hotstandby
//If so, we need to stand it down and demote it
if (!standbyStatus.equals(StateManagement.PROVIDING_SERVICE)) {
@@ -260,22 +260,22 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
// So, we must demote it
try {
- //Keep the order like this. StateManagement is last since it
+ //Keep the order like this. StateManagement is last since it
//triggers controller shutdown
//This will change isDesignated and it can enter another if(combination) below
- pdpsConnector.standDownPdp(pdp.getPdpId());
+ pdpsConnector.standDownPdp(pdp.getPdpId());
myPdp.setDesignated(false);
isDesignated = false;
- if (!(standbyStatus.equals(StateManagement.HOT_STANDBY)
+ if (!(standbyStatus.equals(StateManagement.HOT_STANDBY)
|| standbyStatus.equals(StateManagement.COLD_STANDBY))) {
/*
* Only demote it if it appears it has not already been demoted. Don't worry
- * about synching with the topic endpoint states. That is done by the
+ * about synching with the topic endpoint states. That is done by the
* refreshStateAudit
*/
stateManagementFeature.demote();
}
- //update the standbystatus to check in a later
+ //update the standbystatus to check in a later
//combination of isDesignated and isCurrent
standbyStatus = stateManagementFeature.getStandbyStatus(pdp.getPdpId());
} catch (Exception e) {
@@ -289,7 +289,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
logger.debug("\n\nDesignatedWaiter.run: myPdp {} is current and designated, "
+ "but standbystatus is not providingservice. "
+ " Cannot execute stateManagement.demote() "
- + "since it it is not myPdp\n\n",
+ + "since it it is not myPdp\n\n",
myPdp.getPdpId());
}
}
@@ -299,7 +299,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
if (logger.isDebugEnabled()) {
logger.debug("DesignatedWaiter.run: PDP= {} is designated, "
+ "current and {} Noting PDP as "
- + "designated, standbyStatus= {}",
+ + "designated, standbyStatus= {}",
pdp.getPdpId(), standbyStatus, standbyStatus);
}
listOfDesignated.add(pdp);
@@ -311,8 +311,8 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/*
* The second combination of isDesignated and isCurrent
- *
- * PDP is designated but not current; it has failed.
+ *
+ * PDP is designated but not current; it has failed.
* So we stand it down (it doesn't matter what
* its standbyStatus is). None of these go on the list.
*/
@@ -320,14 +320,14 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
if (logger.isDebugEnabled()) {
logger.debug("INFO: DesignatedWaiter.run: PDP= {} is currently "
+ "designated but is not current; "
- + "it has failed. Standing down. standbyStatus= {}",
+ + "it has failed. Standing down. standbyStatus= {}",
pdp.getPdpId(), standbyStatus);
}
/*
* Changes designated to 0 but it is still potentially providing service
* Will affect isDesignated, so, it can enter an if(combination) below
*/
- pdpsConnector.standDownPdp(pdp.getPdpId());
+ pdpsConnector.standDownPdp(pdp.getPdpId());
//need to change standbystatus to coldstandby
if (pdp.getPdpId().equals(myPdp.getPdpId())) {
@@ -367,13 +367,13 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
continue; //we are not going to do anything else with this pdp
- }
+ }
/*
* The third combination of isDesignated and isCurrent
* /*
- * If a PDP is not currently designated but is providing service
- * (erroneous, but recoverable) or hot standby
+ * If a PDP is not currently designated but is providing service
+ * (erroneous, but recoverable) or hot standby
* we can add it to the list of possible designated if all the designated have failed
*/
if (!pdp.isDesignated() && isCurrent) {
@@ -390,16 +390,16 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
//demote it
if (logger.isDebugEnabled()) {
logger.debug("DesignatedWaiter.run: PDP {} going to "
- + "setDesignated = false and calling stateManagement.demote",
+ + "setDesignated = false and calling stateManagement.demote",
pdp.getPdpId());
}
try {
- //Keep the order like this.
+ //Keep the order like this.
//StateManagement is last since it triggers controller shutdown
pdpsConnector.setDesignated(myPdp, false);
myPdp.setDesignated(false);
isDesignated = false;
- //This is definitely not a redundant call.
+ //This is definitely not a redundant call.
//It is attempting to correct a problem
stateManagementFeature.demote();
//recheck the standbystatus
@@ -417,7 +417,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
if (logger.isDebugEnabled()) {
logger.debug("INFO: DesignatedWaiter.run: PDP= {}"
+ " is not designated but is {} and designated PDP "
- + "has failed. standbyStatus= {}", pdp.getPdpId(),
+ + "has failed. standbyStatus= {}", pdp.getPdpId(),
standbyStatus, standbyStatus);
}
listOfDesignated.add(pdp);
@@ -427,26 +427,26 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/*
* The fourth combination of isDesignated and isCurrent
- *
+ *
* We are not going to put any of these on the list since it appears they have failed.
- *
+ *
*/
if (!pdp.isDesignated() && !isCurrent) {
if (logger.isDebugEnabled()) {
logger.debug("INFO: DesignatedWaiter.run: PDP= {} "
+ "designated= {}, current= {}, "
+ "designatedPdpHasFailed= {}, "
- + "standbyStatus= {}",pdp.getPdpId(),
+ + "standbyStatus= {}",pdp.getPdpId(),
pdp.isDesignated(), isCurrent, designatedPdpHasFailed, standbyStatus);
}
if (!standbyStatus.equals(StateManagement.COLD_STANDBY)) {
//stand it down
//disableFail it
- pdpsConnector.standDownPdp(pdp.getPdpId());
+ pdpsConnector.standDownPdp(pdp.getPdpId());
if (pdp.getPdpId().equals(myPdp.getPdpId())) {
/*
- * I don't actually know how this condition could happen,
+ * I don't actually know how this condition could happen,
* but if it did, we would want
* to declare it failed.
*/
@@ -456,7 +456,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
// So, we must disableFail it
try {
- //Keep the order like this.
+ //Keep the order like this.
//StateManagement is last since it triggers controller shutdown
pdpsConnector.setDesignated(myPdp, false);
myPdp.setDesignated(false);
@@ -464,22 +464,22 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
stateManagementFeature.disableFailed();
} catch (Exception e) {
logger.error("DesignatedWaiter.run: myPdp: {} Caught Exception attempting to "
- + "disableFail myPdp {}, message= {}",
+ + "disableFail myPdp {}, message= {}",
myPdp.getPdpId(), myPdp.getPdpId(), e);
}
} else { //it is remote
if (logger.isDebugEnabled()) {
logger.debug("\n\nDesignatedWaiter.run: myPdp {} is !current and !designated, "
- + " Executing stateManagement.disableFailed({})\n\n",
+ + " Executing stateManagement.disableFailed({})\n\n",
myPdp.getPdpId(), pdp.getPdpId());
}
// We already called standdown(pdp) which will change designated to false
- // Now we need to disableFail it to get its states in sync.
+ // Now we need to disableFail it to get its states in sync.
// StandbyStatus = coldstandby
try {
stateManagementFeature.disableFailed(pdp.getPdpId());
} catch (Exception e) {
- logger.error("DesignatedWaiter.run: for PDP {}"
+ logger.error("DesignatedWaiter.run: for PDP {}"
+ " Caught Exception attempting to disableFail({})"
+ ", message=", pdp.getPdpId(), pdp.getPdpId(), e);
}
@@ -493,10 +493,10 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/*
* We have checked the four combinations of isDesignated and isCurrent. Where appropriate,
* we added the PDPs to the potential list of designated pdps
- *
+ *
* We need to give priority to pdps on the same site that is currently being used
* First, however, we must sanitize the list of designated to make sure their are
- * only designated members or non-designated members. There should not be both in
+ * only designated members or non-designated members. There should not be both in
* the list. Because there are real time delays, it is possible that both types could
* be on the list.
*/
@@ -504,7 +504,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
listOfDesignated = santizeDesignatedList(listOfDesignated);
/*
- * We need to figure out the last pdp that was the primary so we can get the last site
+ * We need to figure out the last pdp that was the primary so we can get the last site
* name and the last session numbers. We need to create a "dummy" droolspdp since
* it will be used in later comparisons and cannot be null.
*/
@@ -521,8 +521,8 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
* occurs when there is a race condition with multiple nodes coming up at the same time. If that is
* the case we must determine which one is the one that should be designated and which one should
* be demoted.
- *
- * It is possible to have 0, 1, 2 or more but not all, or all designated.
+ *
+ * It is possible to have 0, 1, 2 or more but not all, or all designated.
* If we have one designated and current, we chose it and are done
* If we have 2 or more, but not all, we must determine which one is in the same site as
* the previously designated pdp.
@@ -542,7 +542,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
waitTimerLastRunDate = new Date();
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run (designatedPdp == null) waitTimerLastRunDate = {}",
+ logger.debug("DesignatedWaiter.run (designatedPdp == null) waitTimerLastRunDate = {}",
waitTimerLastRunDate);
}
myPdp.setUpdatedDate(waitTimerLastRunDate);
@@ -599,7 +599,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
myPdp.getPdpId(), e1);
}
- }
+ }
waitTimerLastRunDate = new Date();
if (logger.isDebugEnabled()) {
logger.debug("DesignatedWaiter.run (designatedPdp.getPdpId().equals(myPdp.getPdpId())) "
@@ -635,7 +635,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/**
* Sanitize designated list.
- *
+ *
* @param listOfDesignated list of designated pdps
* @return list of drools pdps
*/
@@ -646,7 +646,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
List<DroolsPdp> listForRemoval = new ArrayList<>();
for (DroolsPdp pdp : listOfDesignated) {
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run sanitizing: pdp = {}"
+ logger.debug("DesignatedWaiter.run sanitizing: pdp = {}"
+ " isDesignated = {}",pdp.getPdpId(), pdp.isDesignated());
}
if (pdp.isDesignated()) {
@@ -665,7 +665,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/**
* Compute most recent primary.
- *
+ *
* @param pdps collection of pdps
* @param listOfDesignated list of designated pdps
* @return drools pdp object
@@ -689,14 +689,14 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
//Only one or none is designated or hot standby. Choose the latest designated date
for (DroolsPdp pdp : pdps) {
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run pdp = {}"
- + " pdp.getDesignatedDate() = {}",
+ logger.debug("DesignatedWaiter.run pdp = {}"
+ + " pdp.getDesignatedDate() = {}",
pdp.getPdpId(), pdp.getDesignatedDate());
}
if (pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) > 0) {
mostRecentPrimary = pdp;
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run mostRecentPrimary = {}",
+ logger.debug("DesignatedWaiter.run mostRecentPrimary = {}",
mostRecentPrimary.getPdpId());
}
}
@@ -732,14 +732,14 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
if (logger.isDebugEnabled()) {
logger.debug("DesignatedWainter.run: Some but not all are designated or hot standby. ");
}
- //Some but not all are designated or hot standby.
+ //Some but not all are designated or hot standby.
if (containsDesignated) {
if (logger.isDebugEnabled()) {
logger.debug("DesignatedWainter.run: containsDesignated = {}", containsDesignated);
}
/*
* The list only contains designated. This is a problem. It is most likely a race
- * condition that resulted in two thinking they should be designated. Choose the
+ * condition that resulted in two thinking they should be designated. Choose the
* site with the latest designated date for the pdp not included on the designated list.
* This should be the site that had the last designation before this race condition
* occurred.
@@ -775,7 +775,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
/**
* Compue designated pdp.
- *
+ *
* @param listOfDesignated list of designated pdps
* @param mostRecentPrimary most recent primary pdpd
* @return drools pdp object
@@ -785,7 +785,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
DroolsPdp lowestPriorityPdp = null;
if (listOfDesignated.size() > 1) {
if (logger.isDebugEnabled()) {
- logger.debug("DesignatedWaiter.run: myPdp: {} listOfDesignated.size(): {}", myPdp.getPdpId(),
+ logger.debug("DesignatedWaiter.run: myPdp: {} listOfDesignated.size(): {}", myPdp.getPdpId(),
listOfDesignated.size());
}
DroolsPdp rejectedPdp = null;
@@ -805,7 +805,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
if (pdp.comparePriority(lowestPrioritySameSite) < 0) {
if (logger.isDebugEnabled()) {
- logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ " has lower priority than pdp ID: {}",myPdp.getPdpId(), pdp.getPdpId(),
lowestPrioritySameSite.getPdpId());
}
@@ -815,7 +815,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
} else {
//we need to reject pdp and keep lowestPrioritySameSite
if (logger.isDebugEnabled()) {
- logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {} "
+ logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {} "
+ " has higher priority than pdp ID: {}", myPdp.getPdpId(),pdp.getPdpId(),
lowestPrioritySameSite.getPdpId());
}
@@ -836,7 +836,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
if (pdp.comparePriority(lowestPriorityDifferentSite) < 0) {
if (logger.isDebugEnabled()) {
- logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ " has lower priority than pdp ID: {}", myPdp.getPdpId(), pdp.getPdpId(),
lowestPriorityDifferentSite.getPdpId());
}
@@ -846,7 +846,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
} else {
//we need to reject pdp and keep lowestPriorityDifferentSite
if (logger.isDebugEnabled()) {
- logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ logger.debug("\nDesignatedWaiter.run: myPdp {} listOfDesignated pdp ID: {}"
+ " has higher priority than pdp ID: {}", myPdp.getPdpId(), pdp.getPdpId(),
lowestPriorityDifferentSite.getPdpId());
}
@@ -858,8 +858,8 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
// for demoting itself
if (rejectedPdp != null && nullSafeEquals(rejectedPdp.getPdpId(),myPdp.getPdpId())) {
if (logger.isDebugEnabled()) {
- logger.debug("\n\nDesignatedWaiter.run: myPdp: {} listOfDesignated myPdp ID: {}"
- + " is NOT the lowest priority. Executing stateManagement.demote()\n\n",
+ logger.debug("\n\nDesignatedWaiter.run: myPdp: {} listOfDesignated myPdp ID: {}"
+ + " is NOT the lowest priority. Executing stateManagement.demote()\n\n",
myPdp.getPdpId(),
myPdp.getPdpId());
}
@@ -871,7 +871,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
pdpsConnector.setDesignated(myPdp, false);
isDesignated = false;
String standbyStatus = stateManagementFeature.getStandbyStatus();
- if (!(standbyStatus.equals(StateManagement.HOT_STANDBY)
+ if (!(standbyStatus.equals(StateManagement.HOT_STANDBY)
|| standbyStatus.equals(StateManagement.COLD_STANDBY))) {
/*
* Only call demote if it is not already in the right state. Don't worry about
@@ -885,7 +885,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
pdpsConnector.setDesignated(myPdp, false);
isDesignated = false;
logger.error("DesignatedWaiter.run: myPdp: {} Caught Exception attempting to "
- + "demote myPdp {} myPdp.getPdpId(), message= {}", myPdp.getPdpId(),
+ + "demote myPdp {} myPdp.getPdpId(), message= {}", myPdp.getPdpId(),
e);
}
}
@@ -898,7 +898,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
//now we have a valid value for lowestPriorityPdp
if (logger.isDebugEnabled()) {
logger.debug("\n\nDesignatedWaiter.run: myPdp: {} listOfDesignated "
- + "found the LOWEST priority pdp ID: {} "
+ + "found the LOWEST priority pdp ID: {} "
+ " It is now the designatedPpd from the perspective of myPdp ID: {} \n\n",
myPdp.getPdpId(), lowestPriorityPdp.getPdpId(), myPdp);
}
@@ -937,7 +937,7 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
}
}
}
-
+
@Override
public void checkThreadStatus() {
checkWaitTimer();
@@ -953,24 +953,24 @@ public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
long nowMs = now.getTime();
long waitTimerMs = waitTimerLastRunDate.getTime();
- //give it 10 times leeway
+ //give it 10 times leeway
if ((nowMs - waitTimerMs) > 10 * pdpUpdateInterval) {
if (allSeemsWell == null || allSeemsWell) {
allSeemsWell = false;
if (logger.isDebugEnabled()) {
logger.debug("checkWaitTimer: calling allSeemsWell with ALLNOTWELL param");
}
- stateManagementFeature.allSeemsWell(this.getClass().getName(),
- StateManagementFeatureAPI.ALLNOTWELL_STATE,
+ stateManagementFeature.allSeemsWell(this.getClass().getName(),
+ StateManagementFeatureApi.ALLNOTWELL_STATE,
"DesignationWaiter/ElectionHandler has STALLED");
}
- logger.error("checkWaitTimer: nowMs - waitTimerMs = {}"
+ logger.error("checkWaitTimer: nowMs - waitTimerMs = {}"
+ ", exceeds 10* pdpUpdateInterval = {}"
+ " DesignationWaiter is STALLED!", (nowMs - waitTimerMs), (10 * pdpUpdateInterval));
} else if (allSeemsWell == null || !allSeemsWell) {
allSeemsWell = true;
- stateManagementFeature.allSeemsWell(this.getClass().getName(),
- StateManagementFeatureAPI.ALLSEEMSWELL_STATE,
+ stateManagementFeature.allSeemsWell(this.getClass().getName(),
+ StateManagementFeatureApi.ALLSEEMSWELL_STATE,
"DesignationWaiter/ElectionHandler has RESUMED");
logger.info("DesignationWaiter/ElectionHandler has RESUMED");
}