diff options
author | Jim Hahn <jrh3@att.com> | 2019-09-27 11:22:47 -0400 |
---|---|---|
committer | Jim Hahn <jrh3@att.com> | 2019-10-22 16:06:10 -0400 |
commit | ac5c19ddbed1ff5905d16a6359ee23b4888c717a (patch) | |
tree | acd501248ae73dcd90b2318695acc535a9bb9dcc /controlloop/common/guard | |
parent | 636a1b2fcafa5249cf2bf380dfb6e20f6fe98691 (diff) |
Modify drools-applications to use new Lock API
Modified code to use new Lock API.
Also deleted TargetLock and PolicyGuard, as they are no longer needed.
Issue-ID: POLICY-2113
Signed-off-by: Jim Hahn <jrh3@att.com>
Change-Id: I5bc9b7732f9cfc6056789b2902d9f6f838b560be
Diffstat (limited to 'controlloop/common/guard')
8 files changed, 0 insertions, 869 deletions
diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/LockCallback.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/LockCallback.java deleted file mode 100644 index 2b33e0e57..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/LockCallback.java +++ /dev/null @@ -1,29 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * Copyright (C) 2017-2018 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard; - -public interface LockCallback { - - public boolean isActive(); - - public boolean releaseLock(); - -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/PolicyGuard.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/PolicyGuard.java deleted file mode 100644 index 90e6e8753..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/PolicyGuard.java +++ /dev/null @@ -1,241 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved. - * Modifications Copyright (C) 2019 Tech Mahindra - * ================================================================================ - * 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. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard; - -import java.util.UUID; -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.drools.core.lock.PolicyResourceLockManager; -import org.onap.policy.guard.impl.PnfTargetLock; -import org.onap.policy.guard.impl.VmTargetLock; -import org.onap.policy.guard.impl.VnfTargetLock; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class PolicyGuard { - - private static final Logger logger = LoggerFactory.getLogger(PolicyGuard.class); - - /** - * Factory to access various objects. Can be changed for junit tests. - */ - private static Factory factory = new Factory(); - - public static class LockResult<A, B> { - private A parameterA; - private B parameterB; - - public LockResult(A parameterA, B parameterB) { - this.parameterA = parameterA; - this.parameterB = parameterB; - } - - public A getA() { - return parameterA; - } - - public B getB() { - return parameterB; - } - - public static <A, B> LockResult<A, B> createLockResult(A parameterA, B parameterB) { - return new LockResult<>(parameterA, parameterB); - } - } - - private PolicyGuard() { - // Cannot instantiate this static class - } - - /** - * Get the factory. - * - * @return the factory used to access various objects - */ - protected static Factory getFactory() { - return factory; - } - - /** - * Sets the factory to be used by junit tests. - * @param factory factory - */ - protected static void setFactory(Factory factory) { - PolicyGuard.factory = factory; - } - - /** - * Create a lock. - * - * @param targetType the target type - * @param targetInstance the target instance - * @param requestId the request Id - * @return the TargetLock - * @throws IllegalArgumentException if an argument is null - */ - public static TargetLock createTargetLock(TargetType targetType, String targetInstance, - UUID requestId, LockCallback callback) { - switch (targetType) { - case PNF: - // - // Create the Lock object - // - return new PnfTargetLock(targetType, targetInstance, requestId, callback); - case VM: - // - // Create the Lock object - // - return new VmTargetLock(targetType, targetInstance, requestId, callback); - case VNF: - // - // Create the Lock object - // - return new VnfTargetLock(targetType, targetInstance, requestId, callback); - - case VFMODULE: - // - // Create the Lock object - // - return new VnfTargetLock(targetType, targetInstance, requestId, callback); - default: - logger.error("invalid target type {} for lock on {}", targetType, targetInstance); - return null; - } - } - - /** - * Lock a target. - * - * @param targetType the target type - * @param targetInstance the target instance - * @param requestId the request Id - * @param callback the LockCallback - * @param holdSec maximum number of seconds to hold the lock - * @return the LockResult - * @throws IllegalArgumentException if an argument is null - */ - public static LockResult<GuardResult, TargetLock> lockTarget(TargetType targetType, String targetInstance, - UUID requestId, LockCallback callback, int holdSec) { - String owner = makeOwner(targetType, requestId); - boolean result = factory.getManager().lock(targetInstance, owner, holdSec); - if (!result) { - return LockResult.createLockResult(GuardResult.LOCK_DENIED, null); - } - - TargetLock lock = createTargetLock(targetType, targetInstance, requestId, callback); - if (lock == null) { - // - // Bad lock type: unlock and return exception result - // - factory.getManager().unlock(targetInstance, owner); - return LockResult.createLockResult(GuardResult.LOCK_EXCEPTION, null); - } else { - // - // Return result - // - logger.debug("Locked {}", lock); - return LockResult.createLockResult(GuardResult.LOCK_ACQUIRED, lock); - } - } - - /** - * Extends a lock on a target. - * @param lock current lock - * @param holdSec maximum number of seconds to hold the lock - * @return the result: acquired or denied - */ - public static GuardResult lockTarget(TargetLock lock, int holdSec) { - String owner = makeOwner(lock.getTargetType(), lock.getRequestId()); - - boolean result = factory.getManager().refresh(lock.getTargetInstance(), owner, holdSec); - - logger.debug("Lock {} extend {}", lock, result); - return (result ? GuardResult.LOCK_ACQUIRED : GuardResult.LOCK_DENIED); - } - - /** - * Unlock a target. - * - * @param lock the target lock to unlock - * @return <code>true</code> if the target is successfully unlocked, <code>false</code> - * otherwise - * @throws IllegalArgumentException if an argument is null - */ - public static boolean unlockTarget(TargetLock lock) { - String owner = makeOwner(lock.getTargetType(), lock.getRequestId()); - boolean result = factory.getManager().unlock(lock.getTargetInstance(), owner); - - if (result) { - logger.debug("Unlocked {}", lock); - return true; - } - - return false; - } - - /** - * Check if a target is locked. - * - * @param targetType the target type - * @param targetInstance the target instance - * @param requestId the request Id - * @return <code>true</code> if the target is locked, <code>false</code> otherwise - * @throws IllegalArgumentException if an argument is null - */ - public static boolean isLocked(TargetType targetType, String targetInstance, UUID requestId) { - String owner = makeOwner(targetType, requestId); - return factory.getManager().isLockedBy(targetInstance, owner); - } - - /** - * Combines the target type and request ID to yield a single, "owner" string. - * @param targetType target type - * @param requestID request id - * @return the "owner" of a resource - * @throws IllegalArgumentException if either argument is null - */ - private static String makeOwner(TargetType targetType, UUID requestId) { - if (targetType == null) { - throw new IllegalArgumentException("null targetType for lock request id " + requestId); - } - - if (requestId == null) { - throw new IllegalArgumentException("null requestID for lock type " + targetType); - } - - return targetType + ":" + requestId; - } - - /** - * Factory to access various objects. - */ - public static class Factory { - - /** - * Get the manager. - * - * @return the lock manager to be used - */ - public PolicyResourceLockManager getManager() { - return PolicyResourceLockManager.getInstance(); - } - } -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/TargetLock.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/TargetLock.java deleted file mode 100644 index eea46c3cc..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/TargetLock.java +++ /dev/null @@ -1,37 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard; - -import java.util.UUID; - -import org.onap.policy.controlloop.policy.TargetType; - -public interface TargetLock { - - public UUID getLockId(); - - public TargetType getTargetType(); - - public String getTargetInstance(); - - public UUID getRequestId(); - -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/PnfTargetLock.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/PnfTargetLock.java deleted file mode 100644 index 8ddb5ffcf..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/PnfTargetLock.java +++ /dev/null @@ -1,47 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard.impl; - -import java.util.UUID; -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.guard.LockCallback; - -public class PnfTargetLock extends TargetLockImpl { - - private static final long serialVersionUID = 2335897394577202732L; - - /** - * Construct an instance. - * - * @param type the target type - * @param target the target - * @param requestId the request Id - * @param callback the callback - */ - public PnfTargetLock(TargetType type, String target, UUID requestId, LockCallback callback) { - super(type, target, requestId, callback); - } - - @Override - public String toString() { - return "PnfTargetLock [" + super.toString() + "]"; - } -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/TargetLockImpl.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/TargetLockImpl.java deleted file mode 100644 index d406999f4..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/TargetLockImpl.java +++ /dev/null @@ -1,86 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * Copyright (C) 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard.impl; - -import java.io.Serializable; -import java.util.UUID; - -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.guard.LockCallback; -import org.onap.policy.guard.TargetLock; - -public class TargetLockImpl implements TargetLock, Serializable { - - private static final long serialVersionUID = 2335897394577202732L; - - private final UUID lockId; - private final TargetType targetType; - private final String target; - private final UUID requestId; - private final transient LockCallback callback; - - /** - * Construct an instance. - * - * @param type the target type - * @param target the target - * @param requestId the request Id - * @param callback the callback - */ - public TargetLockImpl(TargetType type, String target, UUID requestId, LockCallback callback) { - this.lockId = UUID.randomUUID(); - this.targetType = type; - this.target = target; - this.requestId = requestId; - this.callback = callback; - } - - @Override - public UUID getLockId() { - return this.lockId; - } - - - @Override - public TargetType getTargetType() { - return targetType; - } - - @Override - public String getTargetInstance() { - return target; - } - - @Override - public UUID getRequestId() { - return this.requestId; - } - - public LockCallback getCallback() { - return this.callback; - } - - @Override - public String toString() { - return "lockId=" + lockId + ", targetType=" + targetType + ", target=" + target + ", requestId=" - + requestId; - } -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VmTargetLock.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VmTargetLock.java deleted file mode 100644 index 2e612a03a..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VmTargetLock.java +++ /dev/null @@ -1,47 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard.impl; - -import java.util.UUID; -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.guard.LockCallback; - -public class VmTargetLock extends TargetLockImpl { - - private static final long serialVersionUID = 2335897394577202732L; - - /** - * Construct an instance. - * - * @param type the target type - * @param target the target - * @param requestId the request Id - * @param callback the callback - */ - public VmTargetLock(TargetType type, String target, UUID requestId, LockCallback callback) { - super(type, target, requestId, callback); - } - - @Override - public String toString() { - return "VmTargetLock [" + super.toString() + "]"; - } -} diff --git a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VnfTargetLock.java b/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VnfTargetLock.java deleted file mode 100644 index 2912c7ad4..000000000 --- a/controlloop/common/guard/src/main/java/org/onap/policy/guard/impl/VnfTargetLock.java +++ /dev/null @@ -1,47 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard.impl; - -import java.util.UUID; -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.guard.LockCallback; - -public class VnfTargetLock extends TargetLockImpl { - - private static final long serialVersionUID = 2335897394577202732L; - - /** - * Construct an instance. - * - * @param type the target type - * @param target the target - * @param requestId the request Id - * @param callback the callback - */ - public VnfTargetLock(TargetType type, String target, UUID requestId, LockCallback callback) { - super(type, target, requestId, callback); - } - - @Override - public String toString() { - return "VnfTargetLock [" + super.toString() + "]"; - } -} diff --git a/controlloop/common/guard/src/test/java/org/onap/policy/guard/PolicyGuardTest.java b/controlloop/common/guard/src/test/java/org/onap/policy/guard/PolicyGuardTest.java deleted file mode 100644 index 5f77d0331..000000000 --- a/controlloop/common/guard/src/test/java/org/onap/policy/guard/PolicyGuardTest.java +++ /dev/null @@ -1,335 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * guard - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.guard; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertNull; -import static org.junit.Assert.assertTrue; -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.spy; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; - -import java.util.UUID; -import org.junit.AfterClass; -import org.junit.Before; -import org.junit.BeforeClass; -import org.junit.Test; -import org.onap.policy.controlloop.policy.TargetType; -import org.onap.policy.drools.core.lock.PolicyResourceLockManager; -import org.onap.policy.guard.PolicyGuard.Factory; -import org.onap.policy.guard.PolicyGuard.LockResult; -import org.onap.policy.guard.impl.PnfTargetLock; -import org.onap.policy.guard.impl.VmTargetLock; -import org.onap.policy.guard.impl.VnfTargetLock; - -public class PolicyGuardTest { - private static final String INSTANCENAME = "targetInstance"; - private static final int LOCK_SEC = 10; - - private static Factory saveFactory; - - private Factory factory; - private PolicyResourceLockManager mgr; - private UUID uuid; - private DummyLockCallback dlcb; - - private class DummyLockCallback implements LockCallback { - @Override - public boolean isActive() { - return false; - } - - @Override - public boolean releaseLock() { - return false; - } - } - - private class DummyTargetLock implements TargetLock { - private TargetType type; - private UUID reqid; - - public DummyTargetLock(TargetType type, UUID reqid) { - this.type = type; - this.reqid = reqid; - } - - @Override - public UUID getLockId() { - return null; - } - - @Override - public TargetType getTargetType() { - return type; - } - - @Override - public String getTargetInstance() { - return INSTANCENAME; - } - - @Override - public UUID getRequestId() { - return reqid; - } - } - - @BeforeClass - public static void setUpBeforeClass() { - saveFactory = PolicyGuard.getFactory(); - } - - @AfterClass - public static void tearDownAfterClass() { - PolicyGuard.setFactory(saveFactory); - } - - /** - * Setup method. - */ - @Before - public void setUp() { - mgr = spy(new PolicyResourceLockManager() { - /* - * we want each test to have its own lock manager, but the constructor for the - * manager is protected; this gets around that - */ - }); - - factory = mock(Factory.class); - when(factory.getManager()).thenReturn(mgr); - - uuid = UUID.randomUUID(); - dlcb = new DummyLockCallback(); - - PolicyGuard.setFactory(factory); - } - - @Test - public void testLockVm() { - TargetType type = TargetType.VM; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VmTargetLock.class, result.getB().getClass()); - - VmTargetLock vtl = (VmTargetLock) result.getB(); - assertNotNull(vtl.getLockId()); - assertEquals(INSTANCENAME, vtl.getTargetInstance()); - assertEquals(TargetType.VM, vtl.getTargetType()); - assertNotNull(vtl.getRequestId()); - assertEquals(dlcb, vtl.getCallback()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - @Test - public void testLockPnf() { - TargetType type = TargetType.PNF; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(PnfTargetLock.class, result.getB().getClass()); - - PnfTargetLock ptl = (PnfTargetLock) result.getB(); - assertNotNull(ptl.getLockId()); - assertEquals(INSTANCENAME, ptl.getTargetInstance()); - assertEquals(TargetType.PNF, ptl.getTargetType()); - assertNotNull(ptl.getRequestId()); - assertEquals(dlcb, ptl.getCallback()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - - @Test - public void testLockVnf() { - TargetType type = TargetType.VNF; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VnfTargetLock.class, result.getB().getClass()); - - VnfTargetLock vtl = (VnfTargetLock) result.getB(); - assertNotNull(vtl.getLockId()); - assertEquals(INSTANCENAME, vtl.getTargetInstance()); - assertEquals(TargetType.VNF, vtl.getTargetType()); - assertNotNull(vtl.getRequestId()); - assertEquals(dlcb, vtl.getCallback()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - @Test - public void testLockVfc() { - TargetType type = TargetType.VFC; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_EXCEPTION, result.getA()); - assertNull(result.getB()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - @Test - public void testUnLockNotLocked() { - TargetType type = TargetType.VM; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VmTargetLock.class, result.getB().getClass()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - // Test unlock after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - @Test - public void testLockAlreadyLocked() { - TargetType type = TargetType.VM; - - // Test isLocked before and after lock added - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - LockResult<GuardResult, TargetLock> result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VmTargetLock.class, result.getB().getClass()); - - UUID uuid2 = UUID.randomUUID(); - result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid2, dlcb, LOCK_SEC); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid2)); - - assertTrue(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - - assertEquals(GuardResult.LOCK_DENIED, result.getA()); - assertNull(result.getB()); - - // Test isLocked after lock removed - PolicyGuard.unlockTarget(new DummyTargetLock(type, uuid)); - assertFalse(PolicyGuard.isLocked(type, INSTANCENAME, uuid)); - } - - @Test - public void testInnards() { - TargetType type = TargetType.VM; - - assertFalse(dlcb.isActive()); - assertFalse(dlcb.releaseLock()); - - DummyTargetLock dtl = new DummyTargetLock(type, uuid); - assertNull(dtl.getLockId()); - assertEquals(uuid, dtl.getRequestId()); - assertEquals(INSTANCENAME, dtl.getTargetInstance()); - assertEquals(type, dtl.getTargetType()); - } - - @Test - public void testLockTargetTargetTypeStringUuidLockCallbackInt() { - TargetType type = TargetType.VM; - - LockResult<GuardResult, TargetLock> result; - - // acquired - result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - verify(mgr).lock(INSTANCENAME, type + ":" + uuid, LOCK_SEC); - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VmTargetLock.class, result.getB().getClass()); - - // diff owner - denied - UUID uuid2 = UUID.randomUUID(); - result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid2, dlcb, LOCK_SEC + 10); - verify(mgr).lock(INSTANCENAME, type + ":" + uuid2, LOCK_SEC + 10); - assertEquals(GuardResult.LOCK_DENIED, result.getA()); - assertNull(result.getB()); - } - - @Test - public void testLockTargetTargetLockInt() { - TargetType type = TargetType.VM; - - LockResult<GuardResult, TargetLock> result; - - // acquired - result = PolicyGuard.lockTarget(type, INSTANCENAME, uuid, dlcb, LOCK_SEC); - verify(mgr).lock(INSTANCENAME, type + ":" + uuid, LOCK_SEC); - assertEquals(GuardResult.LOCK_ACQUIRED, result.getA()); - assertEquals(VmTargetLock.class, result.getB().getClass()); - - TargetLock lock = result.getB(); - - // refresh - re-acquired - assertEquals(GuardResult.LOCK_ACQUIRED, PolicyGuard.lockTarget(lock, LOCK_SEC + 1)); - verify(mgr).refresh(INSTANCENAME, type + ":" + uuid, LOCK_SEC + 1); - - // unlock - PolicyGuard.unlockTarget(lock); - - // refresh - denied, as we no longer own the lock - assertEquals(GuardResult.LOCK_DENIED, PolicyGuard.lockTarget(lock, LOCK_SEC + 2)); - } - - @Test(expected = IllegalArgumentException.class) - public void testMakeOwner_NullTargetType() { - PolicyGuard.isLocked(null, INSTANCENAME, uuid); - } - - @Test(expected = IllegalArgumentException.class) - public void testMakeOwner_NullReqId() { - PolicyGuard.isLocked(TargetType.PNF, INSTANCENAME, null); - } -} |