1 package org.opendaylight.openflowplugin.applications.frm.impl;
3 import org.opendaylight.openflowplugin.common.wait.SimpleTaskRetryLooper;
5 import java.util.concurrent.Callable;
6 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
7 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
8 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
9 import org.opendaylight.openflowplugin.applications.frm.ForwardingRulesManager;
10 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.service.rev131026.UpdateTableInputBuilder;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.service.rev131026.table.update.OriginalTableBuilder;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.service.rev131026.table.update.UpdatedTableBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.TableRef;
20 import org.opendaylight.yangtools.concepts.ListenerRegistration;
21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
24 import com.google.common.base.Preconditions;
26 public class TableForwarder extends AbstractListeningCommiter<Table> {
28 private static final Logger LOG = LoggerFactory.getLogger(TableForwarder.class);
30 private ListenerRegistration<TableForwarder> listenerRegistration;
32 public TableForwarder (final ForwardingRulesManager manager, final DataBroker db) {
33 super(manager, Table.class);
34 Preconditions.checkNotNull(db, "DataBroker can not be null!");
35 final DataTreeIdentifier<Table> treeId = new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, getWildCardPath());
38 SimpleTaskRetryLooper looper = new SimpleTaskRetryLooper(ForwardingRulesManagerImpl.STARTUP_LOOP_TICK,
39 ForwardingRulesManagerImpl.STARTUP_LOOP_MAX_RETRIES);
40 listenerRegistration = looper.loopUntilNoException(new Callable<ListenerRegistration<TableForwarder>>() {
42 public ListenerRegistration<TableForwarder> call() throws Exception {
43 return db.registerDataTreeChangeListener(treeId, TableForwarder.this);
46 } catch (final Exception e) {
47 LOG.warn("FRM Table DataChange listener registration fail!");
48 LOG.debug("FRM Table DataChange listener registration fail ..", e);
49 throw new IllegalStateException("TableForwarder startup fail! System needs restart.", e);
55 if (listenerRegistration != null) {
57 listenerRegistration.close();
58 } catch (Exception e) {
59 LOG.error("Error by stop FRM TableChangeListener.", e);
61 listenerRegistration = null;
66 protected InstanceIdentifier<Table> getWildCardPath() {
67 return InstanceIdentifier.create(Nodes.class).child(Node.class)
68 .augmentation(FlowCapableNode.class).child(Table.class);
72 public void remove(final InstanceIdentifier<Table> identifier, final Table removeDataObj,
73 final InstanceIdentifier<FlowCapableNode> nodeIdent) {
78 public void update(final InstanceIdentifier<Table> identifier,
79 final Table original, final Table update,
80 final InstanceIdentifier<FlowCapableNode> nodeIdent) {
81 LOG.debug( "Received the Table Update request [Tbl id, node Id, original, upd" +
82 " " + identifier + " " + nodeIdent + " " + original + " " + update );
84 final Table originalTable = (original);
87 updatedTable = (original);
89 updatedTable = (update);
91 final UpdateTableInputBuilder builder = new UpdateTableInputBuilder();
93 builder.setNode(new NodeRef(nodeIdent.firstIdentifierOf(Node.class)));
94 builder.setTableRef(new TableRef(identifier));
96 builder.setTransactionUri(new Uri(provider.getNewTransactionId()));
98 builder.setUpdatedTable((new UpdatedTableBuilder(updatedTable)).build());
100 builder.setOriginalTable((new OriginalTableBuilder(originalTable)).build());
101 LOG.debug( "Invoking SalTableService " ) ;
103 if( this.provider.getSalTableService() != null )
104 System.out.println( " Handle to SalTableServices" + this.provider.getSalTableService()) ;
105 this.provider.getSalTableService().updateTable(builder.build());
110 public void add(final InstanceIdentifier<Table> identifier, final Table addDataObj,
111 final InstanceIdentifier<FlowCapableNode> nodeIdent) {