From 2de7e5642b9a61566e7e6ad52ccdcb5798f0924f Mon Sep 17 00:00:00 2001 From: Jim Hahn Date: Thu, 9 May 2019 15:43:53 -0400 Subject: Use group from cache even with new policy type When multiple policies are deployed to the same group in a single request, and the policies have different policy types, only the changes associated with the last policy are kept. Updated the policy type lookup to use cached groups, when available. This still needs a junit to verify the fix, but that can come later. Also added more logging. Change-Id: Ieaf866da504b167c884bf53f88aa8cb9e9b5e32a Issue-ID: POLICY-1761 Signed-off-by: Jim Hahn --- .../main/rest/depundep/PdpGroupDeleteProvider.java | 11 +++- .../main/rest/depundep/PdpGroupDeployProvider.java | 6 +++ .../policy/pap/main/rest/depundep/SessionData.java | 58 +++++++++++++++------- 3 files changed, 57 insertions(+), 18 deletions(-) diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java index 15620f7b..7a3190be 100644 --- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java +++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeleteProvider.java @@ -124,6 +124,15 @@ public class PdpGroupDeleteProvider extends ProviderBase { ToscaPolicyIdentifier desiredIdent = policy.getIdentifier(); // remove the policy from the subgroup - return (group, subgroup) -> subgroup.getPolicies().remove(desiredIdent); + return (group, subgroup) -> { + + boolean result = subgroup.getPolicies().remove(desiredIdent); + + logger.info("remove policy {} {} from subgroup {} {} count={}", desiredIdent.getName(), + desiredIdent.getVersion(), group.getName(), subgroup.getPdpType(), + subgroup.getPolicies().size()); + + return result; + }; } } diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java index fa721054..1fd99be9 100644 --- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java +++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/PdpGroupDeployProvider.java @@ -443,6 +443,8 @@ public class PdpGroupDeployProvider extends ProviderBase { if (subgroup.getPolicies().contains(desiredIdent)) { // already has the desired policy + logger.info("subgroup {} {} already contains policy {} {}", group.getName(), subgroup.getPdpType(), + desiredIdent.getName(), desiredIdent.getVersion()); return false; } @@ -454,6 +456,10 @@ public class PdpGroupDeployProvider extends ProviderBase { // add the policy to the subgroup subgroup.getPolicies().add(desiredIdent); + + logger.info("add policy {} {} to subgroup {} {} count={}", desiredIdent.getName(), + desiredIdent.getVersion(), group.getName(), subgroup.getPdpType(), + subgroup.getPolicies().size()); return true; }; } diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/SessionData.java b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/SessionData.java index 11b17e45..ab06befb 100644 --- a/main/src/main/java/org/onap/policy/pap/main/rest/depundep/SessionData.java +++ b/main/src/main/java/org/onap/policy/pap/main/rest/depundep/SessionData.java @@ -41,11 +41,15 @@ import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyFilter.Tosca import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifierOptVersion; import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyType; import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyTypeIdentifier; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Data used during a single REST call when updating PDP policies. */ public class SessionData { + private static final Logger logger = LoggerFactory.getLogger(SessionData.class); + /** * If a version string matches this, then it is just a prefix (i.e., major or * major.minor). @@ -95,8 +99,8 @@ public class SessionData { } /** - * Gets the policy type, referenced by an identifier. Loads it from the cache, if possible. - * Otherwise, gets it from the DB. + * Gets the policy type, referenced by an identifier. Loads it from the cache, if + * possible. Otherwise, gets it from the DB. * * @param desiredType policy type identifier * @return the specified policy type @@ -183,6 +187,8 @@ public class SessionData { throw new IllegalArgumentException("PDP name mismatch " + update.getName() + ", " + change.getName()); } + logger.info("add update and state-change {} {} {} policies={}", update.getName(), update.getPdpGroup(), + update.getPdpSubgroup(), update.getPolicies().size()); pdpRequests.put(update.getName(), Pair.of(update, change)); } @@ -193,6 +199,8 @@ public class SessionData { * @param update the update to be added */ public void addUpdate(PdpUpdate update) { + logger.info("add update {} {} {} policies={}", update.getName(), update.getPdpGroup(), update.getPdpSubgroup(), + update.getPolicies().size()); pdpRequests.compute(update.getName(), (name, data) -> Pair.of(update, (data == null ? null : data.getRight()))); } @@ -203,6 +211,7 @@ public class SessionData { * @param change the state-change to be added */ public void addStateChange(PdpStateChange change) { + logger.info("add state-change {}", change.getName()); pdpRequests.compute(change.getName(), (name, data) -> Pair.of((data == null ? null : data.getLeft()), change)); } @@ -255,6 +264,8 @@ public class SessionData { if (groupCache.put(name, new GroupData(newGroup, true)) != null) { throw new IllegalStateException("group already cached: " + name); } + + logger.info("create cached group {}", newGroup.getName()); } /** @@ -269,6 +280,7 @@ public class SessionData { throw new IllegalStateException("group not cached: " + name); } + logger.info("update cached group {}", newGroup.getName()); data.update(newGroup); } @@ -285,11 +297,16 @@ public class SessionData { if (data == null) { List lst = dao.getPdpGroups(name); if (lst.isEmpty()) { + logger.info("unknown group {}", name); return null; } + logger.info("cache group {}", name); data = new GroupData(lst.get(0)); groupCache.put(name, data); + + } else { + logger.info("use cached group {}", name); } return data.getGroup(); @@ -304,19 +321,17 @@ public class SessionData { */ public List getActivePdpGroupsByPolicyType(ToscaPolicyTypeIdentifier type) throws PfModelException { List data = type2groups.get(type); - if (data != null) { - return data.stream().map(GroupData::getGroup).collect(Collectors.toList()); - } - - PdpGroupFilter filter = PdpGroupFilter.builder().policyTypeList(Collections.singletonList(type)) - .groupState(PdpState.ACTIVE).build(); + if (data == null) { + PdpGroupFilter filter = PdpGroupFilter.builder().policyTypeList(Collections.singletonList(type)) + .groupState(PdpState.ACTIVE).build(); - List groups = dao.getFilteredPdpGroups(filter); + List groups = dao.getFilteredPdpGroups(filter); - data = groups.stream().map(this::addGroup).collect(Collectors.toList()); - type2groups.put(type, data); + data = groups.stream().map(this::addGroup).collect(Collectors.toList()); + type2groups.put(type, data); + } - return groups; + return data.stream().map(GroupData::getGroup).collect(Collectors.toList()); } /** @@ -327,12 +342,14 @@ public class SessionData { */ private GroupData addGroup(PdpGroup group) { GroupData data = groupCache.get(group.getName()); - if (data != null) { - return data; - } + if (data == null) { + logger.info("cache group {}", group.getName()); + data = new GroupData(group); + groupCache.put(group.getName(), data); - data = new GroupData(group); - groupCache.put(group.getName(), data); + } else { + logger.info("use cached group {}", group.getName()); + } return data; } @@ -346,6 +363,9 @@ public class SessionData { // create new groups List created = groupCache.values().stream().filter(GroupData::isNew).collect(Collectors.toList()); if (!created.isEmpty()) { + if (logger.isInfoEnabled()) { + created.forEach(group -> logger.info("creating DB group {}", group.getGroup().getName())); + } dao.createPdpGroups(created.stream().map(GroupData::getGroup).collect(Collectors.toList())); } @@ -353,6 +373,9 @@ public class SessionData { List updated = groupCache.values().stream().filter(GroupData::isUpdated).collect(Collectors.toList()); if (!updated.isEmpty()) { + if (logger.isInfoEnabled()) { + updated.forEach(group -> logger.info("updating DB group {}", group.getGroup().getName())); + } dao.updatePdpGroups(updated.stream().map(GroupData::getGroup).collect(Collectors.toList())); } } @@ -365,6 +388,7 @@ public class SessionData { * @throws PfModelException if an error occurred */ public void deleteGroupFromDb(PdpGroup group) throws PfModelException { + logger.info("deleting DB group {}", group.getName()); dao.deletePdpGroup(group.getName()); } } -- cgit 1.2.3-korg