2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.protocol.bgp.rib.impl;
10 import com.google.common.base.Preconditions;
11 import com.google.common.util.concurrent.CheckedFuture;
13 import java.util.Map.Entry;
14 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
15 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
16 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
17 import org.opendaylight.protocol.bgp.rib.impl.spi.AdjRIBsOut;
18 import org.opendaylight.protocol.bgp.rib.spi.AdjRIBsTransaction;
19 import org.opendaylight.protocol.bgp.rib.spi.BGPObjectComparator;
20 import org.opendaylight.protocol.bgp.rib.spi.Peer;
21 import org.opendaylight.protocol.bgp.rib.spi.RouteEncoder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.Route;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.Tables;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.tables.Attributes;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.tables.AttributesBuilder;
26 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
27 import org.slf4j.Logger;
28 import org.slf4j.LoggerFactory;
31 class AdjRIBsTransactionImpl implements AdjRIBsTransaction {
32 private static final Logger LOG = LoggerFactory.getLogger(AdjRIBsTransactionImpl.class);
33 private final BGPObjectComparator comparator;
34 private final WriteTransaction trans;
35 private final Map<Peer, AdjRIBsOut> ribs;
37 AdjRIBsTransactionImpl(final Map<Peer, AdjRIBsOut> ribs, final BGPObjectComparator comparator, final WriteTransaction writeTransaction) {
38 this.comparator = Preconditions.checkNotNull(comparator);
39 this.trans = Preconditions.checkNotNull(writeTransaction);
40 this.ribs = Preconditions.checkNotNull(ribs);
44 public void setUptodate(final InstanceIdentifier<Tables> basePath, final boolean uptodate) {
45 final InstanceIdentifier<Attributes> aid = basePath.child(Attributes.class);
46 this.trans.merge(LogicalDatastoreType.OPERATIONAL, aid, new AttributesBuilder().setUptodate(uptodate).build());
47 LOG.debug("Table {} switching uptodate to {}", basePath, uptodate);
50 public CheckedFuture<Void, TransactionCommitFailedException> commit() {
51 return this.trans.submit();
55 public BGPObjectComparator comparator() {
56 return this.comparator;
60 public <K, V extends Route> void advertise(final RouteEncoder ribOut, final K key, final InstanceIdentifier<V> id, final Peer advertizingPeer, final V obj) {
61 this.trans.put(LogicalDatastoreType.OPERATIONAL, id, obj, true);
62 for (final Entry<Peer, AdjRIBsOut> e : this.ribs.entrySet()) {
63 if (e.getKey() != advertizingPeer) {
64 e.getValue().put(ribOut, key, obj);
65 LOG.trace("Advertizing to peer {}", e.getKey());
67 LOG.trace("Not advertizing to peer {}", e.getKey());
73 public <K, V extends Route> void withdraw(final RouteEncoder ribOut, final K key, final InstanceIdentifier<V> id) {
74 this.trans.delete(LogicalDatastoreType.OPERATIONAL, id);
75 for (final AdjRIBsOut r : this.ribs.values()) {
76 r.put(ribOut, key, null);