opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/md/sal/binding/data/WildcardedDataChangeListenerTest.java

   1 package org.opendaylight.controller.md.sal.binding.data;
   2
   3 import static org.junit.Assert.assertFalse;
   4 import static org.junit.Assert.assertNotNull;
   5 import static org.junit.Assert.assertTrue;
   6
   7 import java.util.Collections;
   8 import java.util.concurrent.ExecutionException;
   9 import java.util.concurrent.TimeUnit;
  10 import java.util.concurrent.TimeoutException;
  11
  12 import org.junit.Test;
  13 import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent;
  14 import org.opendaylight.controller.sal.binding.api.data.DataChangeListener;
  15 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
  16 import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
  17 import org.opendaylight.controller.sal.binding.test.AbstractDataServiceTest;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.TableBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.TableKey;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.table.features.TableFeatures;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.table.features.TableFeaturesBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.table.types.rev131026.table.features.TableFeaturesKey;
  33 import org.opendaylight.yangtools.yang.binding.DataObject;
  34 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  35
  36 import com.google.common.util.concurrent.SettableFuture;
  37
  38 /*
  39  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
  40  *
  41  * This program and the accompanying materials are made available under the
  42  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
  43  * and is available at http://www.eclipse.org/legal/epl-v10.html
  44  */
  45 public class WildcardedDataChangeListenerTest extends AbstractDataServiceTest {
  46
  47     private static final NodeKey NODE_0_KEY = new NodeKey(new NodeId("test:0"));
  48     private static final NodeKey NODE_1_KEY = new NodeKey(new NodeId("test:1"));
  49
  50     public static final InstanceIdentifier<Flow> DEEP_WILDCARDED_PATH = InstanceIdentifier.builder(Nodes.class)
  51             .child(Node.class) //
  52             .augmentation(FlowCapableNode.class) //
  53             .child(Table.class) //
  54             .child(Flow.class) //
  55             .build();
  56
  57     private static final TableKey TABLE_0_KEY = new TableKey((short) 0);
  58     private static final TableFeaturesKey TABLE_FEATURES_KEY = new TableFeaturesKey((short) 0);
  59
  60     private static final InstanceIdentifier<Table> NODE_0_TABLE_PATH = InstanceIdentifier.builder(Nodes.class)
  61             .child(Node.class, NODE_0_KEY) //
  62             .augmentation(FlowCapableNode.class) //
  63             .child(Table.class, TABLE_0_KEY) //
  64             .build();
  65
  66     private static final InstanceIdentifier<Table> NODE_1_TABLE_PATH = InstanceIdentifier.builder(Nodes.class)
  67             .child(Node.class, NODE_1_KEY) //
  68             .augmentation(FlowCapableNode.class) //
  69             .child(Table.class, TABLE_0_KEY) //
  70             .build();
  71
  72     private static final FlowKey FLOW_KEY = new FlowKey(new FlowId("test"));
  73
  74     private static final InstanceIdentifier<Flow> NODE_0_FLOW_PATH = InstanceIdentifier.builder(NODE_0_TABLE_PATH)
  75             .child(Flow.class, FLOW_KEY).build();
  76
  77     private static final InstanceIdentifier<Flow> NODE_1_FLOW_PATH = InstanceIdentifier.builder(NODE_1_TABLE_PATH)
  78             .child(Flow.class, FLOW_KEY).build();
  79
  80     private static final InstanceIdentifier<TableFeatures> NODE_0_TABLE_FEATURES_PATH = InstanceIdentifier
  81             .builder(NODE_0_TABLE_PATH).child(TableFeatures.class, TABLE_FEATURES_KEY).build();
  82
  83     private static final TableFeatures TABLE_FEATURES = new TableFeaturesBuilder()//
  84             .setKey(TABLE_FEATURES_KEY) //
  85             .setName("Foo") //
  86             .setMaxEntries(1000L) //
  87             .build();
  88
  89     private static final Flow FLOW = new FlowBuilder() //
  90             .setKey(FLOW_KEY) //
  91             .setBarrier(true) //
  92             .setStrict(true) //
  93             .build();
  94
  95     @Test
  96     public void testSepareteWrites() throws InterruptedException, TimeoutException, ExecutionException {
  97
  98         DataProviderService dataBroker = testContext.getBindingDataBroker();
  99
 100         final SettableFuture<DataChangeEvent<InstanceIdentifier<?>, DataObject>> eventFuture = SettableFuture.create();
 101         dataBroker.registerDataChangeListener(DEEP_WILDCARDED_PATH, new DataChangeListener() {
 102
 103             @Override
 104             public void onDataChanged(final DataChangeEvent<InstanceIdentifier<?>, DataObject> dataChangeEvent) {
 105                 eventFuture.set(dataChangeEvent);
 106             }
 107         });
 108
 109         DataModificationTransaction transaction = dataBroker.beginTransaction();
 110         transaction.putOperationalData(NODE_0_TABLE_FEATURES_PATH, TABLE_FEATURES);
 111         transaction.putOperationalData(NODE_0_FLOW_PATH, FLOW);
 112         transaction.putOperationalData(NODE_1_FLOW_PATH, FLOW);
 113         transaction.commit().get();
 114
 115         DataChangeEvent<InstanceIdentifier<?>, DataObject> event = eventFuture.get(1000, TimeUnit.MILLISECONDS);
 116
 117         validateEvent(event);
 118     }
 119
 120     @Test
 121     public void testWriteByReplace() throws InterruptedException, TimeoutException, ExecutionException {
 122
 123         DataProviderService dataBroker = testContext.getBindingDataBroker();
 124
 125         final SettableFuture<DataChangeEvent<InstanceIdentifier<?>, DataObject>> eventFuture = SettableFuture.create();
 126         dataBroker.registerDataChangeListener(DEEP_WILDCARDED_PATH, new DataChangeListener() {
 127
 128             @Override
 129             public void onDataChanged(final DataChangeEvent<InstanceIdentifier<?>, DataObject> dataChangeEvent) {
 130                 eventFuture.set(dataChangeEvent);
 131             }
 132         });
 133
 134         DataModificationTransaction tableTx = dataBroker.beginTransaction();
 135         tableTx.putOperationalData(NODE_0_TABLE_FEATURES_PATH, TABLE_FEATURES);
 136         tableTx.commit().get();
 137
 138         assertFalse(eventFuture.isDone());
 139
 140         DataModificationTransaction flowTx = dataBroker.beginTransaction();
 141
 142         Table table = new TableBuilder() //
 143                 .setKey(TABLE_0_KEY) //
 144                 .setFlow(Collections.singletonList(FLOW)) //
 145                 .build();
 146
 147         flowTx.putOperationalData(NODE_0_TABLE_PATH, table);
 148         flowTx.putOperationalData(NODE_1_FLOW_PATH, FLOW);
 149         flowTx.commit().get();
 150
 151         validateEvent(eventFuture.get(1000, TimeUnit.MILLISECONDS));
 152     }
 153
 154     @Test
 155     public void testNoChangeOnReplaceWithSameValue() throws InterruptedException, TimeoutException, ExecutionException {
 156
 157         DataProviderService dataBroker = testContext.getBindingDataBroker();
 158
 159         // We wrote initial state NODE_0_FLOW
 160         DataModificationTransaction transaction = dataBroker.beginTransaction();
 161         transaction.putOperationalData(NODE_0_FLOW_PATH, FLOW);
 162         transaction.commit().get();
 163
 164         // We registered DataChangeListener
 165         final SettableFuture<DataChangeEvent<InstanceIdentifier<?>, DataObject>> eventFuture = SettableFuture.create();
 166         dataBroker.registerDataChangeListener(DEEP_WILDCARDED_PATH, new DataChangeListener() {
 167
 168             @Override
 169             public void onDataChanged(final DataChangeEvent<InstanceIdentifier<?>, DataObject> dataChangeEvent) {
 170                 eventFuture.set(dataChangeEvent);
 171             }
 172         });
 173         assertFalse(eventFuture.isDone());
 174
 175         DataModificationTransaction secondTx = dataBroker.beginTransaction();
 176         secondTx.putOperationalData(NODE_0_FLOW_PATH, FLOW);
 177         secondTx.putOperationalData(NODE_1_FLOW_PATH, FLOW);
 178         secondTx.commit().get();
 179
 180         DataChangeEvent<InstanceIdentifier<?>, DataObject> event = (eventFuture.get(1000, TimeUnit.MILLISECONDS));
 181         assertNotNull(event);
 182         // Data change should contains NODE_1 Flow - which was added
 183         assertTrue(event.getCreatedOperationalData().containsKey(NODE_1_FLOW_PATH));
 184         // Data change must not containe NODE_0 Flow which was replaced with same value.
 185         assertFalse(event.getUpdatedOperationalData().containsKey(NODE_0_FLOW_PATH));
 186     }
 187
 188     private static void validateEvent(final DataChangeEvent<InstanceIdentifier<?>, DataObject> event) {
 189         assertNotNull(event);
 190         assertTrue(event.getCreatedOperationalData().containsKey(NODE_1_FLOW_PATH));
 191         assertTrue(event.getCreatedOperationalData().containsKey(NODE_0_FLOW_PATH));
 192         assertFalse(event.getCreatedOperationalData().containsKey(NODE_0_TABLE_FEATURES_PATH));
 193     }
 194
 195 }