coe/impl/src/main/java/org/opendaylight/netvirt/coe/listeners/NetworkPolicyListener.java

   1 /*
   2  * Copyright (c) 2018 Red Hat, Inc. and others. All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.netvirt.coe.listeners;
   9
  10 import static org.opendaylight.genius.infra.Datastore.CONFIGURATION;
  11 import static org.opendaylight.netvirt.coe.utils.AceNetworkPolicyUtils.buildAcl;
  12 import static org.opendaylight.netvirt.coe.utils.AceNetworkPolicyUtils.getAclNameFromPolicy;
  13 import static org.opendaylight.netvirt.coe.utils.AclUtils.getAclIid;
  14
  15 import javax.annotation.Nonnull;
  16 import javax.inject.Inject;
  17 import javax.inject.Singleton;
  18 import org.apache.aries.blueprint.annotation.service.Reference;
  19 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  20 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  21 import org.opendaylight.genius.infra.RetryingManagedNewTransactionRunner;
  22 import org.opendaylight.infrautils.utils.concurrent.LoggingFutures;
  23 import org.opendaylight.serviceutils.tools.mdsal.listener.AbstractSyncDataTreeChangeListener;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160218.access.lists.Acl;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.k8s.network.policy.rev181205.network.policy.NetworkPolicies;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.k8s.network.policy.rev181205.network.policy.network.policies.NetworkPolicy;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.k8s.rev181205.K8s;
  28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 @Singleton
  33 public class NetworkPolicyListener extends AbstractSyncDataTreeChangeListener<NetworkPolicy> {
  34     private static final Logger LOG = LoggerFactory.getLogger(NetworkPolicyListener.class);
  35     private final RetryingManagedNewTransactionRunner txRunner;
  36
  37     @Inject
  38     public NetworkPolicyListener(@Reference DataBroker dataBroker) {
  39         super(dataBroker, LogicalDatastoreType.CONFIGURATION,
  40             InstanceIdentifier.create(K8s.class).child(NetworkPolicies.class).child(NetworkPolicy.class));
  41         this.txRunner = new RetryingManagedNewTransactionRunner(dataBroker);
  42     }
  43
  44     @Override
  45     public void add(@Nonnull InstanceIdentifier<NetworkPolicy> instanceIdentifier, @Nonnull NetworkPolicy policy) {
  46         LOG.info("add: id: {}\npolicy: {}", instanceIdentifier, policy);
  47         updateAcl(policy, false);
  48     }
  49
  50     @Override
  51     public void remove(@Nonnull InstanceIdentifier<NetworkPolicy> instanceIdentifier, @Nonnull NetworkPolicy policy) {
  52         LOG.info("remove: id: {}\npolicy: {}", instanceIdentifier, policy);
  53         updateAcl(policy, true);
  54     }
  55
  56     @Override
  57     public void update(@Nonnull InstanceIdentifier<NetworkPolicy> instanceIdentifier,
  58                        @Nonnull NetworkPolicy oldPolicy, @Nonnull NetworkPolicy policy) {
  59         LOG.info("update: id: {}\nold policy: {}\nnew policy: {}", instanceIdentifier, oldPolicy, policy);
  60         updateAcl(policy, false);
  61     }
  62
  63     private void updateAcl(@Nonnull NetworkPolicy policy, boolean isDeleted) {
  64         LoggingFutures.addErrorLogging(txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION, tx -> {
  65             String aclName = getAclNameFromPolicy(policy);
  66             Acl acl = buildAcl(policy, isDeleted);
  67             InstanceIdentifier<Acl> aclIid = getAclIid(aclName);
  68             // write the ace, and the api will create the acl parent if needed
  69             tx.put(aclIid, acl, true);
  70         }), LOG, "Failed to add acl from policy: {}", policy);
  71     }
  72 }