diff options
author | Pamela Dragosh <pdragosh@research.att.com> | 2020-03-27 11:12:11 -0400 |
---|---|---|
committer | Pamela Dragosh <pdragosh@research.att.com> | 2020-03-27 11:12:16 -0400 |
commit | 8b10bae2761fd7891044e9c758e712b2b54bd8ba (patch) | |
tree | 492b2adaf6633a327adf2a8e28e06654a544ffcc | |
parent | 438b24fcd54e25719583d16f689e03d1bcfee2a8 (diff) |
Use AtomicInteger and other sonar
Removed unused logger.
Added NOSONAR to main to remove security risk, as we do
validate arguments.
Used AtomicInteger.
Issue-ID: POLICY-2305
Change-Id: I18e91836e914b7fd6e3cd9a950dca58fcd8be5b5
Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
3 files changed, 8 insertions, 12 deletions
diff --git a/main/src/main/java/org/onap/policy/distribution/main/startstop/Main.java b/main/src/main/java/org/onap/policy/distribution/main/startstop/Main.java index 2c676333..c842bd2b 100644 --- a/main/src/main/java/org/onap/policy/distribution/main/startstop/Main.java +++ b/main/src/main/java/org/onap/policy/distribution/main/startstop/Main.java @@ -142,11 +142,11 @@ public class Main { } /** - * The main method. + * The main method. The args passed in are validated in the constructor, thus adding the NOSONAR. * * @param args the arguments */ - public static void main(final String[] args) { + public static void main(final String[] args) { // NOSONAR new Main(args); } } diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java index b89a679b..5d011f0c 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java @@ -27,7 +27,7 @@ import java.io.FileOutputStream; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; - +import java.util.concurrent.atomic.AtomicInteger; import org.onap.policy.common.parameters.ParameterService; import org.onap.policy.distribution.model.Csar; import org.onap.policy.distribution.reception.decoding.PolicyDecodingException; @@ -60,7 +60,7 @@ public class SdcReceptionHandler extends AbstractReceptionHandler implements INo private SdcReceptionHandlerStatus sdcReceptionHandlerStatus = SdcReceptionHandlerStatus.STOPPED; private IDistributionClient distributionClient; private SdcConfiguration sdcConfig; - private volatile int nbOfNotificationsOngoing = 0; + private AtomicInteger nbOfNotificationsOngoing = new AtomicInteger(); private int retryDelay; private SdcClientHandler sdcClientHandler; @@ -109,7 +109,7 @@ public class SdcReceptionHandler extends AbstractReceptionHandler implements INo handleIdleStatusChange(newStatus); break; case BUSY: - ++nbOfNotificationsOngoing; + nbOfNotificationsOngoing.incrementAndGet(); sdcReceptionHandlerStatus = newStatus; break; default: @@ -370,10 +370,10 @@ public class SdcReceptionHandler extends AbstractReceptionHandler implements INo * @param newStatus the new status */ private void handleIdleStatusChange(final SdcReceptionHandlerStatus newStatus) { - if (nbOfNotificationsOngoing > 1) { - --nbOfNotificationsOngoing; + if (nbOfNotificationsOngoing.get() > 1) { + nbOfNotificationsOngoing.decrementAndGet(); } else { - nbOfNotificationsOngoing = 0; + nbOfNotificationsOngoing.set(0); sdcReceptionHandlerStatus = newStatus; } } diff --git a/reception/src/main/java/org/onap/policy/distribution/reception/handling/PluginHandler.java b/reception/src/main/java/org/onap/policy/distribution/reception/handling/PluginHandler.java index 5067c841..aa822e7f 100644 --- a/reception/src/main/java/org/onap/policy/distribution/reception/handling/PluginHandler.java +++ b/reception/src/main/java/org/onap/policy/distribution/reception/handling/PluginHandler.java @@ -36,16 +36,12 @@ import org.onap.policy.distribution.reception.decoding.PolicyDecoder; import org.onap.policy.distribution.reception.parameters.PluginHandlerParameters; import org.onap.policy.distribution.reception.parameters.PolicyDecoderParameters; import org.onap.policy.models.tosca.authorative.concepts.ToscaEntity; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; /** * Handles the plugins to policy distribution. */ public class PluginHandler { - private static final Logger LOGGER = LoggerFactory.getLogger(PluginHandler.class); - private Collection<PolicyDecoder<PolicyInput, ToscaEntity>> policyDecoders; private Collection<PolicyForwarder> policyForwarders; |