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;
14 import java.util.Map.Entry;
16 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
17 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
18 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
19 import org.opendaylight.protocol.bgp.rib.impl.spi.AdjRIBsOut;
20 import org.opendaylight.protocol.bgp.rib.spi.AdjRIBsTransaction;
21 import org.opendaylight.protocol.bgp.rib.spi.BGPObjectComparator;
22 import org.opendaylight.protocol.bgp.rib.spi.Peer;
23 import org.opendaylight.protocol.bgp.rib.spi.RouteEncoder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.Route;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.Tables;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.tables.Attributes;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev130925.rib.tables.AttributesBuilder;
28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
32 class AdjRIBsTransactionImpl implements AdjRIBsTransaction {
33 private static final Logger LOG = LoggerFactory.getLogger(AdjRIBsTransactionImpl.class);
34 private final BGPObjectComparator comparator;
35 private final WriteTransaction trans;
36 private final Map<Peer, AdjRIBsOut> ribs;
38 AdjRIBsTransactionImpl(final Map<Peer, AdjRIBsOut> ribs, final BGPObjectComparator comparator, final WriteTransaction writeTransaction) {
39 this.comparator = Preconditions.checkNotNull(comparator);
40 this.trans = Preconditions.checkNotNull(writeTransaction);
41 this.ribs = Preconditions.checkNotNull(ribs);
45 public void setUptodate(final InstanceIdentifier<Tables> basePath, final boolean uptodate) {
46 final InstanceIdentifier<Attributes> aid = basePath.child(Attributes.class);
47 trans.merge(LogicalDatastoreType.OPERATIONAL, aid, new AttributesBuilder().setUptodate(uptodate).build());
48 LOG.debug("Table {} switching uptodate to {}", basePath, uptodate);
51 public CheckedFuture<Void, TransactionCommitFailedException> commit() {
52 return trans.submit();
56 public BGPObjectComparator comparator() {
61 public <K, V extends Route> void advertise(final RouteEncoder ribOut, final K key, final InstanceIdentifier<V> id, final Peer peer, final V obj) {
62 trans.put(LogicalDatastoreType.OPERATIONAL, id, obj, true);
63 for (Entry<Peer, AdjRIBsOut> e : ribs.entrySet()) {
64 if (e.getKey() != peer) {
65 e.getValue().put(ribOut, key, obj);
71 public <K, V extends Route> void withdraw(final RouteEncoder ribOut, final K key, final InstanceIdentifier<V> id) {
72 trans.delete(LogicalDatastoreType.OPERATIONAL, id);
73 for (AdjRIBsOut r : ribs.values()) {
74 r.put(ribOut, key, null);