summaryrefslogtreecommitdiffstats
path: root/context
diff options
context:
space:
mode:
Diffstat (limited to 'context')
-rw-r--r--context/context-management/src/main/java/org/onap/policy/apex/context/parameters/ContextParameters.java2
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ArtifactKeyTestEntity.java86
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ReferenceKeyTestEntity.java86
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/package-info.java2
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/AlbumModifier.java11
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/LockType.java18
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/NoLockAlbumModifier.java9
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/ReadLockAlbumModifier.java9
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/SingleValueWriteLockAlbumModifier.java12
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/WriteLockAlbumModifier.java10
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/package-info.java25
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProvider.java83
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProviderImpl.java102
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/Constants.java11
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/IntegrationThreadFactory.java12
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/NetworkUtils.java6
-rw-r--r--context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ZooKeeperServerServiceProvider.java17
-rwxr-xr-xcontext/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/package-info.java27
18 files changed, 514 insertions, 14 deletions
diff --git a/context/context-management/src/main/java/org/onap/policy/apex/context/parameters/ContextParameters.java b/context/context-management/src/main/java/org/onap/policy/apex/context/parameters/ContextParameters.java
index 2a109d48f..80ec0eb2d 100644
--- a/context/context-management/src/main/java/org/onap/policy/apex/context/parameters/ContextParameters.java
+++ b/context/context-management/src/main/java/org/onap/policy/apex/context/parameters/ContextParameters.java
@@ -31,7 +31,7 @@ import org.onap.policy.common.parameters.ParameterGroup;
* <ol>
* <li>flushPeriod: Context is flushed to any persistor plugin that is defined periodically, and the
* period for flushing is the flush period.
- * <li>distributorParameters: The parameters (a {@link distributorParameters} instance) for the
+ * <li>distributorParameters: The parameters (a {@link DistributorParameters} instance) for the
* distributor plugin that is being used for context album distribution
* <li>schemaParameters: The parameters (a {@link SchemaParameters} instance) for the schema plugin
* that is being used for context album schemas
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ArtifactKeyTestEntity.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ArtifactKeyTestEntity.java
index 49802c2da..2653ca271 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ArtifactKeyTestEntity.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ArtifactKeyTestEntity.java
@@ -33,6 +33,9 @@ import org.onap.policy.apex.model.basicmodel.concepts.AxConcept;
import org.onap.policy.apex.model.basicmodel.concepts.AxKey;
import org.onap.policy.apex.model.basicmodel.concepts.AxValidationResult;
+/**
+ * The Class ArtifactKeyTestEntity is an entity for testing artifact keys.
+ */
@Entity
@Table(name = "ArtifactKeyTestEntity")
public class ArtifactKeyTestEntity extends AxConcept {
@@ -44,62 +47,130 @@ public class ArtifactKeyTestEntity extends AxConcept {
private double doubleValue;
+ /**
+ * Instantiates a new artifact key test entity.
+ */
public ArtifactKeyTestEntity() {
this.key = new AxArtifactKey();
this.doubleValue = 0;
}
+ /**
+ * Instantiates a new artifact key test entity.
+ *
+ * @param doubleValue the double value
+ */
public ArtifactKeyTestEntity(final Double doubleValue) {
this.key = new AxArtifactKey();
this.doubleValue = doubleValue;
}
+ /**
+ * Instantiates a new artifact key test entity.
+ *
+ * @param key the key
+ * @param doubleValue the double value
+ */
public ArtifactKeyTestEntity(final AxArtifactKey key, final Double doubleValue) {
this.key = key;
this.doubleValue = doubleValue;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKey()
+ */
@Override
public AxArtifactKey getKey() {
return key;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKeys()
+ */
@Override
public List<AxKey> getKeys() {
return Arrays.asList((AxKey) getKey());
}
+ /**
+ * Sets the key.
+ *
+ * @param key the new key
+ */
public void setKey(final AxArtifactKey key) {
this.key = key;
}
+ /**
+ * Check set key.
+ *
+ * @return true, if successful
+ */
public boolean checkSetKey() {
return (this.key != null);
}
+ /**
+ * Gets the double value.
+ *
+ * @return the double value
+ */
public double getDoubleValue() {
return doubleValue;
}
+ /**
+ * Sets the double value.
+ *
+ * @param doubleValue the new double value
+ */
public void setDoubleValue(final double doubleValue) {
this.doubleValue = doubleValue;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see
+ * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#validate(org.onap.policy.apex.model.basicmodel.concepts.
+ * AxValidationResult)
+ */
@Override
public AxValidationResult validate(final AxValidationResult result) {
return key.validate(result);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#clean()
+ */
@Override
public void clean() {
key.clean();
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#toString()
+ */
@Override
public String toString() {
return "ArtifactKeyTestEntity [key=" + key + ", doubleValue=" + doubleValue + "]";
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see
+ * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#copyTo(org.onap.policy.apex.model.basicmodel.concepts.
+ * AxConcept)
+ */
@Override
public AxConcept copyTo(final AxConcept target) {
final Object copyObject = ((target == null) ? new ArtifactKeyTestEntity() : target);
@@ -117,6 +188,11 @@ public class ArtifactKeyTestEntity extends AxConcept {
}
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#hashCode()
+ */
@Override
public int hashCode() {
final int prime = 31;
@@ -125,6 +201,11 @@ public class ArtifactKeyTestEntity extends AxConcept {
return result;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#equals(java.lang.Object)
+ */
@Override
public boolean equals(final Object obj) {
if (obj == null) {
@@ -147,6 +228,11 @@ public class ArtifactKeyTestEntity extends AxConcept {
return (Double.compare(doubleValue, other.doubleValue) == 0);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see java.lang.Comparable#compareTo(java.lang.Object)
+ */
@Override
public int compareTo(final AxConcept otherObj) {
if (otherObj == null) {
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ReferenceKeyTestEntity.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ReferenceKeyTestEntity.java
index 6f276335b..d172f0276 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ReferenceKeyTestEntity.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/ReferenceKeyTestEntity.java
@@ -35,6 +35,9 @@ import org.onap.policy.apex.model.basicmodel.concepts.AxReferenceKey;
import org.onap.policy.apex.model.basicmodel.concepts.AxValidationResult;
import org.onap.policy.apex.model.basicmodel.xml.AxReferenceKeyAdapter;
+/**
+ * The Class ReferenceKeyTestEntity provides a reference key test concept.
+ */
@Entity
@Table(name = "ReferenceKeyTestEntity")
public class ReferenceKeyTestEntity extends AxConcept {
@@ -47,62 +50,130 @@ public class ReferenceKeyTestEntity extends AxConcept {
private double doubleValue;
+ /**
+ * Instantiates a new reference key test entity.
+ */
public ReferenceKeyTestEntity() {
this.key = new AxReferenceKey();
this.doubleValue = 0;
}
+ /**
+ * Instantiates a new reference key test entity.
+ *
+ * @param doubleValue the double value
+ */
public ReferenceKeyTestEntity(final Double doubleValue) {
this.key = new AxReferenceKey();
this.doubleValue = doubleValue;
}
+ /**
+ * Instantiates a new reference key test entity.
+ *
+ * @param key the key
+ * @param doubleValue the double value
+ */
public ReferenceKeyTestEntity(final AxReferenceKey key, final Double doubleValue) {
this.key = key;
this.doubleValue = doubleValue;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKey()
+ */
@Override
public AxReferenceKey getKey() {
return key;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKeys()
+ */
@Override
public List<AxKey> getKeys() {
return Arrays.asList((AxKey) getKey());
}
+ /**
+ * Sets the key.
+ *
+ * @param key the new key
+ */
public void setKey(final AxReferenceKey key) {
this.key = key;
}
+ /**
+ * Check set key.
+ *
+ * @return true, if successful
+ */
public boolean checkSetKey() {
return (this.key != null);
}
+ /**
+ * Gets the double value.
+ *
+ * @return the double value
+ */
public double getDoubleValue() {
return doubleValue;
}
+ /**
+ * Sets the double value.
+ *
+ * @param doubleValue the new double value
+ */
public void setDoubleValue(final double doubleValue) {
this.doubleValue = doubleValue;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see
+ * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#validate(org.onap.policy.apex.model.basicmodel.concepts.
+ * AxValidationResult)
+ */
@Override
public AxValidationResult validate(final AxValidationResult result) {
return key.validate(result);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#clean()
+ */
@Override
public void clean() {
key.clean();
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#toString()
+ */
@Override
public String toString() {
return "ReferenceKeyTestEntity [key=" + key + ", doubleValue=" + doubleValue + "]";
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see
+ * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#copyTo(org.onap.policy.apex.model.basicmodel.concepts.
+ * AxConcept)
+ */
@Override
public AxConcept copyTo(final AxConcept target) {
final Object copyObject = ((target == null) ? new ReferenceKeyTestEntity() : target);
@@ -120,6 +191,11 @@ public class ReferenceKeyTestEntity extends AxConcept {
}
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#hashCode()
+ */
@Override
public int hashCode() {
final int prime = 31;
@@ -128,6 +204,11 @@ public class ReferenceKeyTestEntity extends AxConcept {
return result;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#equals(java.lang.Object)
+ */
@Override
public boolean equals(final Object obj) {
if (obj == null) {
@@ -150,6 +231,11 @@ public class ReferenceKeyTestEntity extends AxConcept {
return (Double.compare(doubleValue, other.doubleValue) == 0);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see java.lang.Comparable#compareTo(java.lang.Object)
+ */
@Override
public int compareTo(final AxConcept otherObj) {
if (otherObj == null) {
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/package-info.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/package-info.java
index 8a4ea4cee..be51a4e7e 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/package-info.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/entities/package-info.java
@@ -19,7 +19,7 @@
*/
/**
- * Contains common test entities
+ * Contains common test entities.
* @author Dinh Danh Le (dinh.danh.le@ericsson.com)
*
*/
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/AlbumModifier.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/AlbumModifier.java
index 14ceba425..1253d2234 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/AlbumModifier.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/AlbumModifier.java
@@ -23,8 +23,19 @@ package org.onap.policy.apex.context.test.lock.modifier;
import org.onap.policy.apex.context.ContextAlbum;
import org.onap.policy.apex.context.ContextException;
+/**
+ * The Interface AlbumModifier defines the interface to allow context albums be modified during context tests.
+ */
public interface AlbumModifier {
+ /**
+ * Modify album.
+ *
+ * @param contextAlbum the context album
+ * @param loopSize the loop size
+ * @param arraySize the array size
+ * @throws ContextException the context exception
+ */
void modifyAlbum(final ContextAlbum contextAlbum, final int loopSize, final int arraySize) throws ContextException;
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/LockType.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/LockType.java
index 228ca7a40..82de5b4a7 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/LockType.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/LockType.java
@@ -22,6 +22,9 @@ package org.onap.policy.apex.context.test.lock.modifier;
import org.onap.policy.apex.context.ContextRuntimeException;
+/**
+ * The Enum LockType defines the type of lock on a test context album.
+ */
public enum LockType {
NO_LOCK(0) {
@@ -56,10 +59,20 @@ public enum LockType {
private final int value;
+ /**
+ * Instantiates a new lock type.
+ *
+ * @param value the value
+ */
private LockType(final int value) {
this.value = value;
}
+ /**
+ * Gets the value.
+ *
+ * @return the value
+ */
public int getValue() {
return value;
}
@@ -78,6 +91,11 @@ public enum LockType {
throw new ContextRuntimeException("Invalid Lock type value: " + value);
}
+ /**
+ * Gets the album modifier.
+ *
+ * @return the album modifier
+ */
public abstract AlbumModifier getAlbumModifier();
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/NoLockAlbumModifier.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/NoLockAlbumModifier.java
index 6c273a0ae..4ce7890be 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/NoLockAlbumModifier.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/NoLockAlbumModifier.java
@@ -27,9 +27,18 @@ import org.onap.policy.apex.context.test.concepts.TestContextLongItem;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * The Class NoLockAlbumModifier implements a non lock context album.
+ */
public class NoLockAlbumModifier implements AlbumModifier {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(NoLockAlbumModifier.class);
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.lock.modifier.AlbumModifier#modifyAlbum(org.onap.policy.apex.context.
+ * ContextAlbum, int, int)
+ */
@Override
public void modifyAlbum(final ContextAlbum contextAlbum, final int loopSize, final int arraySize) {
final Random rand = new Random();
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/ReadLockAlbumModifier.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/ReadLockAlbumModifier.java
index 854179ccd..fbafb1081 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/ReadLockAlbumModifier.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/ReadLockAlbumModifier.java
@@ -28,9 +28,18 @@ import org.onap.policy.apex.context.test.concepts.TestContextLongItem;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * The Class ReadLockAlbumModifier implements a read lock context album.
+ */
public class ReadLockAlbumModifier implements AlbumModifier {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(ReadLockAlbumModifier.class);
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.lock.modifier.AlbumModifier#modifyAlbum(org.onap.policy.apex.context.
+ * ContextAlbum, int, int)
+ */
@Override
public void modifyAlbum(final ContextAlbum contextAlbum, final int loopSize, final int arraySize) {
final Random rand = new Random();
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/SingleValueWriteLockAlbumModifier.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/SingleValueWriteLockAlbumModifier.java
index 959e93c67..674cf3af2 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/SingleValueWriteLockAlbumModifier.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/SingleValueWriteLockAlbumModifier.java
@@ -28,13 +28,21 @@ import org.onap.policy.apex.context.test.concepts.TestContextLongItem;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * The Class SingleValueWriteLockAlbumModifier implements a single value lock context album.
+ */
public class SingleValueWriteLockAlbumModifier implements AlbumModifier {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(SingleValueWriteLockAlbumModifier.class);
-
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.lock.modifier.AlbumModifier#modifyAlbum(org.onap.policy.apex.context.
+ * ContextAlbum, int, int)
+ */
@Override
public void modifyAlbum(final ContextAlbum contextAlbum, final int loopSize, final int arraySize)
- throws ContextException {
+ throws ContextException {
for (int i = 0; i < loopSize; i++) {
try {
contextAlbum.lockForWriting(TEST_VALUE);
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/WriteLockAlbumModifier.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/WriteLockAlbumModifier.java
index d1f5ec17e..7136121f7 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/WriteLockAlbumModifier.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/WriteLockAlbumModifier.java
@@ -28,10 +28,18 @@ import org.onap.policy.apex.context.test.concepts.TestContextLongItem;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * The Class WriteLockAlbumModifier implements a write lock context album.
+ */
public class WriteLockAlbumModifier implements AlbumModifier {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(WriteLockAlbumModifier.class);
-
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.lock.modifier.AlbumModifier#modifyAlbum(org.onap.policy.apex.context.
+ * ContextAlbum, int, int)
+ */
@Override
public void modifyAlbum(final ContextAlbum contextAlbum, final int loopSize, final int arraySize) {
final Random rand = new Random();
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/package-info.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/package-info.java
new file mode 100644
index 000000000..bf5bcb31c
--- /dev/null
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/lock/modifier/package-info.java
@@ -0,0 +1,25 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2016-2018 Ericsson. 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.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+/**
+ * Provides modifiers that allow the locking on a contest album to be modified in various ways.
+ */
+
+package org.onap.policy.apex.context.test.lock.modifier;
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProvider.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProvider.java
index b842f7aca..f3a49dfbb 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProvider.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProvider.java
@@ -30,35 +30,116 @@ import org.onap.policy.apex.context.test.lock.modifier.AlbumModifier;
import org.onap.policy.apex.context.test.lock.modifier.LockType;
import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+/**
+ * The Interface ConfigrationProvider provides the configuration for a context test to a context test executor.
+ */
public interface ConfigrationProvider {
+ /**
+ * Gets the test name.
+ *
+ * @return the test name
+ */
String getTestName();
+ /**
+ * Gets the loop size.
+ *
+ * @return the loop size
+ */
int getLoopSize();
+ /**
+ * Gets the thread count.
+ *
+ * @return the thread count
+ */
int getThreadCount();
+ /**
+ * Gets the jvm count.
+ *
+ * @return the jvm count
+ */
int getJvmCount();
+ /**
+ * Gets the album size.
+ *
+ * @return the album size
+ */
int getAlbumSize();
+ /**
+ * Gets the executor service.
+ *
+ * @return the executor service
+ */
ExecutorService getExecutorService();
+ /**
+ * Gets the executor service.
+ *
+ * @param threadFactoryName the thread factory name
+ * @param threadPoolSize the thread pool size
+ * @return the executor service
+ */
ExecutorService getExecutorService(final String threadFactoryName, final int threadPoolSize);
+ /**
+ * Gets the distributor.
+ *
+ * @param key the key
+ * @return the distributor
+ */
Distributor getDistributor(final AxArtifactKey key);
+ /**
+ * Gets the distributor.
+ *
+ * @return the distributor
+ */
Distributor getDistributor();
+ /**
+ * Gets the context album.
+ *
+ * @param distributor the distributor
+ * @return the context album
+ */
ContextAlbum getContextAlbum(final Distributor distributor);
+ /**
+ * Gets the context album.
+ *
+ * @param distributor the distributor
+ * @param axContextAlbumKey the ax context album key
+ * @param artifactKeys the artifact keys
+ * @return the context album
+ * @throws ContextException the context exception
+ */
ContextAlbum getContextAlbum(final Distributor distributor, AxArtifactKey axContextAlbumKey,
- AxArtifactKey[] artifactKeys) throws ContextException;
+ AxArtifactKey[] artifactKeys) throws ContextException;
+ /**
+ * Gets the context album init values.
+ *
+ * @return the context album init values
+ */
Map<String, Object> getContextAlbumInitValues();
+ /**
+ * Gets the album modifier.
+ *
+ * @return the album modifier
+ */
AlbumModifier getAlbumModifier();
+ /**
+ * Gets the lock type.
+ *
+ * @return the lock type
+ */
LockType getLockType();
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProviderImpl.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProviderImpl.java
index 87b81643a..c63280966 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProviderImpl.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ConfigrationProviderImpl.java
@@ -38,6 +38,9 @@ import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
import org.onap.policy.apex.model.contextmodel.concepts.AxContextModel;
import org.onap.policy.apex.model.utilities.Assertions;
+/**
+ * The Class ConfigrationProviderImpl provides configuration information for a context test back to the caller.
+ */
public class ConfigrationProviderImpl implements ConfigrationProvider {
private final String testType;
@@ -49,6 +52,7 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
/**
* The parameterized ConfigrationProviderImpl constructor.
+ *
* @param testType the test type
* @param jvmCount the JVM count
* @param threadCount the thread count
@@ -57,7 +61,7 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
* @param lockType the lock type
*/
public ConfigrationProviderImpl(final String testType, final int jvmCount, final int threadCount,
- final int loopSize, final int albumSize, final int lockType) {
+ final int loopSize, final int albumSize, final int lockType) {
this.testType = testType;
this.jvmCount = jvmCount;
this.threadCount = threadCount;
@@ -66,31 +70,61 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
this.lockType = LockType.getLockType(lockType);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getTestName()
+ */
@Override
public String getTestName() {
return testType;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getLoopSize()
+ */
@Override
public int getLoopSize() {
return loopSize;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getThreadCount()
+ */
@Override
public int getThreadCount() {
return threadCount;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getJvmCount()
+ */
@Override
public int getJvmCount() {
return jvmCount;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getAlbumSize()
+ */
@Override
public int getAlbumSize() {
return albumSize;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getExecutorService()
+ */
@Override
public ExecutorService getExecutorService() {
final String name = getThreadFactoryName(jvmCount, testType);
@@ -99,6 +133,11 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
return executorService;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getExecutorService(java.lang.String, int)
+ */
@Override
public ExecutorService getExecutorService(final String threadFactoryName, final int threadPoolSize) {
final IntegrationThreadFactory threadFactory = new IntegrationThreadFactory(threadFactoryName);
@@ -106,6 +145,13 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
return executorService;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see
+ * org.onap.policy.apex.context.test.utils.ConfigrationProvider#getDistributor(org.onap.policy.apex.model.basicmodel
+ * .concepts.AxArtifactKey)
+ */
@Override
public Distributor getDistributor(final AxArtifactKey key) {
try {
@@ -115,20 +161,38 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
}
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getDistributor()
+ */
@Override
public Distributor getDistributor() {
final AxArtifactKey distributorKey = new AxArtifactKey("ApexDistributor", "0.0.1");
return getDistributor(distributorKey);
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getContextAlbum(org.onap.policy.apex.context.
+ * Distributor)
+ */
@Override
public ContextAlbum getContextAlbum(final Distributor distributor) {
return getContextAlbum(distributor, Constants.L_TYPE_CONTEXT_ALBUM, Constants.getAxArtifactKeyArray());
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getContextAlbum(org.onap.policy.apex.context.
+ * Distributor, org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey,
+ * org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey[])
+ */
@Override
public ContextAlbum getContextAlbum(final Distributor distributor, final AxArtifactKey axContextAlbumKey,
- final AxArtifactKey[] artifactKeys) {
+ final AxArtifactKey[] artifactKeys) {
final AxContextModel axContextModel = TestContextAlbumFactory.createMultiAlbumsContextModel();
try {
distributor.registerModel(axContextModel);
@@ -141,6 +205,11 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
}
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getContextAlbumInitValues()
+ */
@Override
public Map<String, Object> getContextAlbumInitValues() {
final Map<String, Object> values = new HashMap<>();
@@ -150,27 +219,48 @@ public class ConfigrationProviderImpl implements ConfigrationProvider {
return values;
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getAlbumModifier()
+ */
@Override
public AlbumModifier getAlbumModifier() {
return lockType.getAlbumModifier();
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.onap.policy.apex.context.test.utils.ConfigrationProvider#getLockType()
+ */
@Override
public LockType getLockType() {
return lockType;
}
-
+ /**
+ * Gets the thread factory name.
+ *
+ * @param jvmCount the jvm count
+ * @param testType the test type
+ * @return the thread factory name
+ */
private String getThreadFactoryName(final int jvmCount, final String testType) {
return jvmCount == 1 ? testType + ":TestConcurrentContextThread_0_"
- : testType + ":TestConcurrentContextJVMThread_";
+ : testType + ":TestConcurrentContextJVMThread_";
}
+ /*
+ * (non-Javadoc)
+ *
+ * @see java.lang.Object#toString()
+ */
@Override
public String toString() {
return "ConfigrationProviderImpl [testType=" + testType + ", jvmCount=" + jvmCount + ", threadCount="
- + threadCount + ", loopSize=" + loopSize + ", albumSize=" + albumSize + ", lockType=" + lockType + "]";
+ + threadCount + ", loopSize=" + loopSize + ", albumSize=" + albumSize + ", lockType=" + lockType
+ + "]";
}
-
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/Constants.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/Constants.java
index 118586437..927876e8f 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/Constants.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/Constants.java
@@ -25,6 +25,9 @@ import java.util.TimeZone;
import org.onap.policy.apex.context.test.concepts.TestPolicyContextItem;
import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+/**
+ * The Class Constants provides constants for context tests.
+ */
public class Constants {
public static final String MAP_CONTEXT_ALBUM = "MapContextAlbum";
public static final String LONG_CONTEXT_ALBUM = "LongContextAlbum";
@@ -61,10 +64,18 @@ public class Constants {
private static final AxArtifactKey[] USED_ARTIFACT_STACK_ARRAY = new AxArtifactKey[] {KEY, KEY2, KEY3};
+ /**
+ * Gets the ax artifact key array.
+ *
+ * @return the ax artifact key array
+ */
public static final AxArtifactKey[] getAxArtifactKeyArray() {
return USED_ARTIFACT_STACK_ARRAY;
}
+ /**
+ * Instantiates a new constants.
+ */
private Constants() {}
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/IntegrationThreadFactory.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/IntegrationThreadFactory.java
index d815c6b74..486a93cb4 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/IntegrationThreadFactory.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/IntegrationThreadFactory.java
@@ -26,6 +26,9 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * A factory for creating IntegrationThread objects.
+ */
public class IntegrationThreadFactory implements ThreadFactory {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(IntegrationThreadFactory.class);
@@ -34,10 +37,18 @@ public class IntegrationThreadFactory implements ThreadFactory {
private final AtomicInteger counter = new AtomicInteger();
+ /**
+ * Instantiates a new integration thread factory.
+ *
+ * @param threadFactoryName the thread factory name
+ */
public IntegrationThreadFactory(final String threadFactoryName) {
this.threadFactoryName = threadFactoryName;
}
+ /* (non-Javadoc)
+ * @see java.util.concurrent.ThreadFactory#newThread(java.lang.Runnable)
+ */
@Override
public Thread newThread(final Runnable runnable) {
final Thread thread = new Thread(runnable);
@@ -45,5 +56,4 @@ public class IntegrationThreadFactory implements ThreadFactory {
LOGGER.debug("started thread " + thread.getName());
return thread;
}
-
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/NetworkUtils.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/NetworkUtils.java
index 8d2c89254..980384043 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/NetworkUtils.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/NetworkUtils.java
@@ -27,8 +27,14 @@ import java.util.Collections;
import java.util.Enumeration;
import java.util.TreeSet;
+/**
+ * The Class NetworkUtils contains some utility functions for getting network information for context tests.
+ */
public class NetworkUtils {
+ /**
+ * Instantiates a new network utils.
+ */
private NetworkUtils() {}
/**
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ZooKeeperServerServiceProvider.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ZooKeeperServerServiceProvider.java
index 654040d3f..301e8cc61 100644
--- a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ZooKeeperServerServiceProvider.java
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/ZooKeeperServerServiceProvider.java
@@ -30,6 +30,9 @@ import org.apache.zookeeper.server.ZooKeeperServer;
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
+/**
+ * The Class ZooKeeperServerServiceProvider provides a zookeeper service to a caller.
+ */
public class ZooKeeperServerServiceProvider {
private static final XLogger LOGGER = XLoggerFactory.getXLogger(ZooKeeperServerServiceProvider.class);
@@ -37,11 +40,24 @@ public class ZooKeeperServerServiceProvider {
private File zookeeperDirectory;
private InetSocketAddress addr;
+ /**
+ * Instantiates a new zoo keeper server service provider.
+ *
+ * @param zookeeperDirectory the zookeeper directory
+ * @param addr the addr
+ */
public ZooKeeperServerServiceProvider(final File zookeeperDirectory, final InetSocketAddress addr) {
this.zookeeperDirectory = zookeeperDirectory;
this.addr = addr;
}
+ /**
+ * Instantiates a new zoo keeper server service provider.
+ *
+ * @param zookeeperDirectory the zookeeper directory
+ * @param addr the addr
+ * @param port the port
+ */
public ZooKeeperServerServiceProvider(final File zookeeperDirectory, final String addr, final int port) {
this.zookeeperDirectory = zookeeperDirectory;
this.addr = new InetSocketAddress(addr, port);
@@ -69,5 +85,4 @@ public class ZooKeeperServerServiceProvider {
zookeeperFactory.shutdown();
}
}
-
}
diff --git a/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/package-info.java b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/package-info.java
new file mode 100755
index 000000000..2872d20df
--- /dev/null
+++ b/context/context-test-utils/src/main/java/org/onap/policy/apex/context/test/utils/package-info.java
@@ -0,0 +1,27 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2016-2018 Ericsson. 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.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+/**
+ * Contains utilities for context tests.
+ *
+ * @author Liam Fallon (liam.fallon@ericsson.com)
+ */
+
+package org.onap.policy.apex.context.test.utils;