diff options
author | Jim Hahn <jrh3@att.com> | 2018-02-19 16:56:06 -0500 |
---|---|---|
committer | Jim Hahn <jrh3@att.com> | 2018-02-20 09:59:15 -0500 |
commit | a45f8909871dc1ddb75845f067a602951afc8d11 (patch) | |
tree | fa72aff7ceede971d4e6922f62a503a8ee8924d5 /feature-active-standby-management/src/test | |
parent | 1708e9a45cb88571613c10b68d392811b2b3f0f4 (diff) |
Sonar fixes to drools-pdp
Fixed most of the instances of the following sonar issues:
Moved array designator
Used diamond operator
Changed System.out/err to use a logger
Changed several Thread.sleep() in test code to a single sleep()
Useless assignments
Replaced comparison with "" to string.isEmpty()
Merged if's
Replaced ArrayList with List in method returns
Reordered type modifiers
Reordered constructor methods
Defined constants for literals, or replaced them with method calls
Removed "throws Xxx" for subclasses of RuntimeException
Combined identical "catch" blocks
Re-interrupted the current thread after catching an InterruptedException
Removed tests against the literal "false"
Fix indentation of new makeTopicOperError() method.
Fix exception variable name in new methods, logNoUebEncoder()
and logNoDmaapEncoder().
Change-Id: Iddae5210553662f733b67333b372dec8c3fe2c94
Issue-ID: POLICY-336
Signed-off-by: Jim Hahn <jrh3@att.com>
Diffstat (limited to 'feature-active-standby-management/src/test')
2 files changed, 31 insertions, 25 deletions
diff --git a/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/AllSeemsWellTest.java b/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/AllSeemsWellTest.java index 0318bed6..19265206 100644 --- a/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/AllSeemsWellTest.java +++ b/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/AllSeemsWellTest.java @@ -37,7 +37,6 @@ import org.junit.After; import org.junit.AfterClass; import org.junit.Before; import org.junit.BeforeClass; -import org.junit.Ignore; import org.junit.Test; import org.onap.policy.common.im.StateManagement; import org.onap.policy.drools.activestandby.ActiveStandbyFeatureAPI; @@ -264,7 +263,7 @@ public class AllSeemsWellTest { logger.debug("testAllSeemsWell: Sleeping {} ms, to allow JpaDroolsPdpsConnector " + "time to check droolspdpentity table", sleepTime); - Thread.sleep(sleepTime); + sleep(sleepTime); // Verify that this formerly un-designated PDP in HOT_STANDBY is now designated and providing service. @@ -292,7 +291,7 @@ public class AllSeemsWellTest { //It takes 10x the update interval (1 sec) before the watcher will declare the election handler dead //and that just stops forward progress counter. So, the fp monitor must then run to determine //if the fpc has stalled. That will take about another 5 sec. - Thread.sleep(stalledElectionHandlerSleepTime); + sleep(stalledElectionHandlerSleepTime); logger.debug("testAllSeemsWell: After isStalled=true, PDP= {} " + "has standbyStatus= {}", thisPdpId, smf.getStandbyStatus(thisPdpId)); @@ -302,7 +301,7 @@ public class AllSeemsWellTest { //Now lets resume the election handler DroolsPdpsElectionHandler.setIsStalled(false); - Thread.sleep(resumedElectionHandlerSleepTime); + sleep(resumedElectionHandlerSleepTime); logger.debug("testAllSeemsWell: After isStalled=false, PDP= {} " + "has standbyStatus= {}", thisPdpId, smf.getStandbyStatus(thisPdpId)); @@ -313,4 +312,8 @@ public class AllSeemsWellTest { logger.debug("\n\ntestAllSeemsWell: Exiting\n\n"); } + + private void sleep(long sleepms) throws InterruptedException { + Thread.sleep(sleepms); + } } diff --git a/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/StandbyStateManagementTest.java b/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/StandbyStateManagementTest.java index 876cd99a..66af3eaa 100644 --- a/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/StandbyStateManagementTest.java +++ b/feature-active-standby-management/src/test/java/org/onap/policy/drools/controller/test/StandbyStateManagementTest.java @@ -38,7 +38,6 @@ import org.junit.After; import org.junit.AfterClass; import org.junit.Before; import org.junit.BeforeClass; -import org.junit.Ignore; import org.junit.Test; import org.onap.policy.common.im.AdministrativeStateException; import org.onap.policy.common.im.IntegrityMonitor; @@ -274,7 +273,7 @@ public class StandbyStateManagementTest { assertTrue(pmNotifier.getPreviousStandbyStatus().equals(PMStandbyStateChangeNotifier.HOTSTANDBY_OR_COLDSTANDBY)); //Sleep long enough for the delayActivationTimer to run - Thread.sleep(5000); + sleep(5000); assertTrue(pmNotifier.getPreviousStandbyStatus().equals(StateManagement.PROVIDING_SERVICE)); //standbystatus = providingservice @@ -790,7 +789,7 @@ public class StandbyStateManagementTest { logger.debug("testColdStandby: Runner started; Sleeping " + interruptRecoveryTime + "ms before promoting PDP= {}", thisPdpId); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); logger.debug("testColdStandby: Promoting PDP={}", thisPdpId); smf.promote(); @@ -802,7 +801,7 @@ public class StandbyStateManagementTest { logger.debug("testColdStandby: Locking smf"); smf.lock(); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); // Verify that the PDP is no longer designated. @@ -812,7 +811,7 @@ public class StandbyStateManagementTest { assertTrue(droolsPdpEntity.isDesignated() == false); logger.debug("\n\ntestColdStandby: Exiting\n\n"); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); } @@ -918,7 +917,7 @@ public class StandbyStateManagementTest { logger.debug("testHotStandby1: Sleeping {} ms, to allow JpaDroolsPdpsConnector " + "time to check droolspdpentity table", sleepTime); - Thread.sleep(sleepTime); + sleep(sleepTime); // Verify that this formerly un-designated PDP in HOT_STANDBY is now designated and providing service. @@ -936,7 +935,7 @@ public class StandbyStateManagementTest { //policyManagementRunner.stopRunner(); logger.debug("\n\ntestHotStandby1: Exiting\n\n"); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); } @@ -1066,7 +1065,7 @@ public class StandbyStateManagementTest { logger.info("testHotStandby2: Runner started; Sleeping {} " + "ms before promoting/demoting", interruptRecoveryTime); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); logger.info("testHotStandby2: Runner started; promoting PDP={}", activePdpId); //At this point, the newly created pdp will have set the state to disabled/failed/cold standby @@ -1085,7 +1084,7 @@ public class StandbyStateManagementTest { logger.info("testHotStandby2: Sleeping {} ms, to allow JpaDroolsPdpsConnector " + "time to check droolspdpentity table", sleepTime); - Thread.sleep(sleepTime); + sleep(sleepTime); /* * Verify that this PDP, demoted to HOT_STANDBY, is now @@ -1108,7 +1107,7 @@ public class StandbyStateManagementTest { //policyManagementRunner.stopRunner(); logger.info("\n\ntestHotStandby2: Exiting\n\n"); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); } @@ -1221,7 +1220,7 @@ public class StandbyStateManagementTest { logger.debug("testLocking1: Runner started; Sleeping " + interruptRecoveryTime + "ms before promoting PDP={}", thisPdpId); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); logger.debug("testLocking1: Promoting PDP={}", thisPdpId); sm.promote(); @@ -1229,7 +1228,7 @@ public class StandbyStateManagementTest { logger.debug("testLocking1: Sleeping {} ms, to allow time for " + "policy-management.Main class to come up, designated= {}", sleepTime, conn.getPdp(thisPdpId).isDesignated()); - Thread.sleep(sleepTime); + sleep(sleepTime); logger.debug("testLocking1: Waking up and invoking startTransaction on active PDP={}" + ", designated= {}",thisPdpId, conn.getPdp(thisPdpId).isDesignated()); @@ -1258,7 +1257,7 @@ public class StandbyStateManagementTest { logger.debug("testLocking1: sleeping" + electionWaitSleepTime + " to allow election handler to re-promote PDP={}", thisPdpId); - Thread.sleep(electionWaitSleepTime); + sleep(electionWaitSleepTime); logger.debug("testLocking1: Invoking startTransaction on re-promoted PDP={}" + ", designated={}", thisPdpId, conn.getPdp(thisPdpId).isDesignated()); @@ -1283,7 +1282,7 @@ public class StandbyStateManagementTest { // Just to avoid any race conditions, sleep a little after locking logger.debug("testLocking1: Sleeping a few millis after locking, to avoid race condition"); - Thread.sleep(100); + sleep(100); logger.debug("testLocking1: Invoking startTransaction on locked PDP= {}" + ", designated= {}",thisPdpId, conn.getPdp(thisPdpId).isDesignated()); @@ -1309,7 +1308,7 @@ public class StandbyStateManagementTest { // Just to avoid any race conditions, sleep a little after locking logger.debug("testLocking1: Sleeping a few millis after unlocking, to avoid race condition"); - Thread.sleep(electionWaitSleepTime); + sleep(electionWaitSleepTime); logger.debug("testLocking1: Invoking startTransaction on unlocked PDP=" + thisPdpId @@ -1337,7 +1336,7 @@ public class StandbyStateManagementTest { // Just to avoid any race conditions, sleep a little after promoting logger.debug("testLocking1: Sleeping a few millis after demoting, to avoid race condition"); - Thread.sleep(100); + sleep(100); logger.debug("testLocking1: Invoking startTransaction on demoted PDP={}" + ", designated={}", thisPdpId, conn.getPdp(thisPdpId).isDesignated()); @@ -1357,7 +1356,7 @@ public class StandbyStateManagementTest { } logger.debug("\n\ntestLocking1: Exiting\n\n"); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); } @@ -1483,7 +1482,7 @@ public class StandbyStateManagementTest { logger.debug("testLocking2: Runner started; Sleeping {} ms " + "before promoting/demoting", interruptRecoveryTime); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); logger.debug("testLocking2: Promoting PDP= {}", thisPdpId); sm.promote(); @@ -1493,7 +1492,7 @@ public class StandbyStateManagementTest { sm2.demote(); logger.debug("testLocking2: Sleeping {} ms, to allow time for to come up", sleepTime); - Thread.sleep(sleepTime); + sleep(sleepTime); logger.debug("testLocking2: Waking up and invoking startTransaction on active PDP={}" + ", designated= {}", thisPdpId, conn.getPdp(thisPdpId).isDesignated()); @@ -1521,7 +1520,7 @@ public class StandbyStateManagementTest { logger.debug("testLocking2: sleeping {}" + " to allow election handler to re-promote PDP={}", electionWaitSleepTime, thisPdpId); - Thread.sleep(electionWaitSleepTime); + sleep(electionWaitSleepTime); logger.debug("testLocking2: Waking up and invoking startTransaction " + "on re-promoted PDP= {}, designated= {}", @@ -1546,6 +1545,10 @@ public class StandbyStateManagementTest { assertTrue(standbyPdpDesignated == false); logger.debug("\n\ntestLocking2: Exiting\n\n"); - Thread.sleep(interruptRecoveryTime); + sleep(interruptRecoveryTime); + } + + private void sleep(long sleepms) throws InterruptedException { + Thread.sleep(sleepms); } } |