2 * Copyright (c) 2015 Ericsson India Global Services Pvt Ltd. 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.vpnservice.fibmanager;
10 import com.google.common.util.concurrent.Futures;
11 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
12 import com.google.common.util.concurrent.FutureCallback;
13 import org.opendaylight.vpnservice.AbstractDataChangeListener;
14 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
15 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
16 import org.opendaylight.yangtools.concepts.ListenerRegistration;
17 import org.opendaylight.yangtools.yang.binding.DataObject;
18 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
20 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
21 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
22 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.fibmanager.rev150330.FibEntries;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
26 import com.google.common.base.Optional;
28 public class FibManager extends AbstractDataChangeListener<FibEntries> implements AutoCloseable{
29 private static final Logger LOG = LoggerFactory.getLogger(FibManager.class);
30 private ListenerRegistration<DataChangeListener> listenerRegistration;
31 private final DataBroker broker;
33 private static final FutureCallback<Void> DEFAULT_CALLBACK =
34 new FutureCallback<Void>() {
35 public void onSuccess(Void result) {
36 LOG.debug("Success in Datastore write operation");
39 public void onFailure(Throwable error) {
40 LOG.error("Error in Datastore write operation", error);
44 public FibManager(final DataBroker db) {
45 super(FibEntries.class);
51 public void close() throws Exception {
52 if (listenerRegistration != null) {
54 listenerRegistration.close();
55 } catch (final Exception e) {
56 LOG.error("Error when cleaning up DataChangeListener.", e);
58 listenerRegistration = null;
60 LOG.info("Fib Manager Closed");
63 private void registerListener(final DataBroker db) {
65 listenerRegistration = db.registerDataChangeListener(LogicalDatastoreType.CONFIGURATION,
66 getWildCardPath(), FibManager.this, DataChangeScope.SUBTREE);
67 } catch (final Exception e) {
68 LOG.error("FibManager DataChange listener registration fail!", e);
69 throw new IllegalStateException("FibManager registration Listener failed.", e);
74 protected void add(final InstanceIdentifier<FibEntries> identifier,
75 final FibEntries fibEntries) {
76 LOG.trace("key: " + identifier + ", value=" + fibEntries );
79 private <T extends DataObject> Optional<T> read(LogicalDatastoreType datastoreType,
80 InstanceIdentifier<T> path) {
82 ReadOnlyTransaction tx = broker.newReadOnlyTransaction();
84 Optional<T> result = Optional.absent();
86 result = tx.read(datastoreType, path).get();
87 } catch (Exception e) {
88 throw new RuntimeException(e);
94 private InstanceIdentifier<FibEntries> getWildCardPath() {
95 return InstanceIdentifier.create(FibEntries.class);
99 protected void remove(InstanceIdentifier<FibEntries> identifier, FibEntries del) {
100 LOG.trace("key: " + identifier + ", value=" + del );
104 protected void update(InstanceIdentifier<FibEntries> identifier, FibEntries original, FibEntries update) {
105 LOG.trace("key: " + identifier + ", original=" + original + ", update=" + update );
108 private <T extends DataObject> void asyncWrite(LogicalDatastoreType datastoreType,
109 InstanceIdentifier<T> path, T data, FutureCallback<Void> callback) {
110 WriteTransaction tx = broker.newWriteOnlyTransaction();
111 tx.put(datastoreType, path, data, true);
112 Futures.addCallback(tx.submit(), callback);