opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/connect/dom/ChangeOriginatedInDomBrokerTest.java

   1 package org.opendaylight.controller.sal.binding.test.connect.dom;
   2
   3 import com.google.common.collect.ImmutableMap;
   4 import org.junit.Test;
   5 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
   6 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler;
   7 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
   8 import org.opendaylight.controller.sal.common.util.CommitHandlerTransactions;
   9 import org.opendaylight.controller.sal.binding.test.AbstractDataServiceTest;
  10 import org.opendaylight.controller.sal.core.api.data.DataModificationTransaction;
  11 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpVersion;
  12 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Prefix;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.DecNwTtlCaseBuilder;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.dec.nw.ttl._case.DecNwTtl;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.dec.nw.ttl._case.DecNwTtlBuilder;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionBuilder;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionKey;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
  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.flow.types.rev131026.flow.InstructionsBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.MatchBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActionsCaseBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActionsBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.IpMatchBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4Match;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4MatchBuilder;
  40 import org.opendaylight.yangtools.concepts.Registration;
  41 import org.opendaylight.yangtools.yang.binding.DataObject;
  42 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  43 import org.opendaylight.yangtools.yang.common.QName;
  44 import org.opendaylight.yangtools.yang.common.RpcResult;
  45 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  46
  47 import java.util.ArrayList;
  48 import java.util.Collections;
  49 import java.util.List;
  50 import java.util.Map;
  51
  52 import static org.junit.Assert.assertEquals;
  53 import static org.junit.Assert.assertNotNull;
  54 import static org.junit.Assert.assertNull;
  55
  56 public class ChangeOriginatedInDomBrokerTest extends AbstractDataServiceTest {
  57
  58     private static final QName NODE_ID_QNAME = QName.create(Node.QNAME, "id");
  59     private static final QName FLOW_ID_QNAME = QName.create(Flow.QNAME, "id");
  60     private static final QName FLOW_NODE_QNAME = QName.create(Flow.QNAME, "node");
  61     private static final QName TABLE_ID_QNAME = QName.create(Table.QNAME, "id");
  62
  63     private static final String NODE_ID = "node:1";
  64     private static final FlowId FLOW_ID = new FlowId("1234");
  65     private static final Short TABLE_ID = Short.valueOf((short) 0);
  66
  67     private static final NodeKey NODE_KEY = new NodeKey(new NodeId(NODE_ID));
  68     private static final FlowKey FLOW_KEY = new FlowKey(FLOW_ID);
  69
  70     private DataModification<InstanceIdentifier<? extends DataObject>, DataObject> modificationCapture;
  71
  72     private static final Map<QName, Object> NODE_KEY_BI = Collections.<QName, Object> singletonMap(NODE_ID_QNAME,
  73             NODE_ID);
  74
  75     private static final InstanceIdentifier<Node> NODE_INSTANCE_ID_BA = InstanceIdentifier.builder(Nodes.class) //
  76             .child(Node.class, NODE_KEY).toInstance();
  77
  78     private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier NODE_INSTANCE_ID_BI = //
  79     org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  80             .node(Nodes.QNAME) //
  81             .nodeWithKey(Node.QNAME, NODE_KEY_BI) //
  82             .toInstance();
  83     private static final NodeRef NODE_REF = new NodeRef(NODE_INSTANCE_ID_BA);
  84
  85     private static final Map<QName, Object> FLOW_KEY_BI = //
  86     ImmutableMap.<QName, Object> of(FLOW_ID_QNAME, FLOW_ID.getValue());
  87
  88     private static final Map<QName, Object> TABLE_KEY_BI = //
  89     ImmutableMap.<QName, Object> of(TABLE_ID_QNAME, TABLE_ID);;
  90
  91     private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier FLOW_INSTANCE_ID_BI = //
  92     org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  93             .node(Nodes.QNAME) //
  94             .nodeWithKey(Node.QNAME, NODE_KEY_BI) //
  95             .nodeWithKey(Table.QNAME, TABLE_KEY_BI) //
  96             .nodeWithKey(Flow.QNAME, FLOW_KEY_BI) //
  97             .toInstance();
  98     private static final TableKey TABLE_KEY_BA = new TableKey((short) 0);
  99
 100     private static final InstanceIdentifier<Flow> FLOWS_PATH_BA = //
 101     InstanceIdentifier.builder(NODE_INSTANCE_ID_BA) //
 102             .augmentation(FlowCapableNode.class) //
 103             .child(Table.class, TABLE_KEY_BA) //
 104             .child(Flow.class) //
 105             .toInstance();
 106
 107     private static final InstanceIdentifier<Flow> FLOW_INSTANCE_ID_BA = //
 108     InstanceIdentifier.builder(FLOWS_PATH_BA.firstIdentifierOf(Table.class)) //
 109             .child(Flow.class, FLOW_KEY) //
 110             .toInstance();
 111
 112     @Test
 113     public void simpleModifyOperation() throws Exception {
 114
 115         assertNull(biDataService.readConfigurationData(FLOW_INSTANCE_ID_BI));
 116
 117         registerCommitHandler();
 118
 119         CompositeNode domflow = createTestFlow();
 120         DataModificationTransaction biTransaction = biDataService.beginTransaction();
 121         biTransaction.putConfigurationData(FLOW_INSTANCE_ID_BI, domflow);
 122         RpcResult<TransactionStatus> biResult = biTransaction.commit().get();
 123         assertEquals(TransactionStatus.COMMITED, biResult.getResult());
 124         assertNotNull(modificationCapture);
 125         Flow flow = (Flow) modificationCapture.getCreatedConfigurationData().get(FLOW_INSTANCE_ID_BA);
 126         assertNotNull(flow);
 127         assertNotNull(flow.getMatch());
 128         assertEquals(TransactionStatus.COMMITED, biResult.getResult());
 129
 130     }
 131
 132     private void registerCommitHandler() {
 133         DataCommitHandler<InstanceIdentifier<? extends DataObject>, DataObject> flowTestCommitHandler = new DataCommitHandler<InstanceIdentifier<? extends DataObject>, DataObject>() {
 134
 135             @Override
 136             public org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction<InstanceIdentifier<? extends DataObject>, DataObject> requestCommit(
 137                     DataModification<InstanceIdentifier<? extends DataObject>, DataObject> modification) {
 138                 modificationCapture = modification;
 139                 return CommitHandlerTransactions.allwaysSuccessfulTransaction(modification);
 140             }
 141
 142         };
 143         Registration<DataCommitHandler<InstanceIdentifier<? extends DataObject>, DataObject>> registration = baDataService
 144                 .registerCommitHandler(FLOWS_PATH_BA, flowTestCommitHandler);
 145         assertNotNull(registration);
 146     }
 147
 148     private CompositeNode createTestFlow() {
 149         FlowBuilder flow = new FlowBuilder();
 150         flow.setKey(FLOW_KEY);
 151         Short tableId = 0;
 152         flow.setTableId(tableId);
 153         MatchBuilder match = new MatchBuilder();
 154         match.setIpMatch(new IpMatchBuilder().setIpProto(IpVersion.Ipv4).build());
 155         Ipv4MatchBuilder ipv4Match = new Ipv4MatchBuilder();
 156         // ipv4Match.setIpv4Destination(new Ipv4Prefix(cliInput.get(4)));
 157         Ipv4Prefix prefix = new Ipv4Prefix("10.0.0.1/24");
 158         ipv4Match.setIpv4Destination(prefix);
 159         Ipv4Match i4m = ipv4Match.build();
 160         match.setLayer3Match(i4m);
 161         flow.setMatch(match.build());
 162
 163
 164
 165         // Create a drop action
 166         /*
 167          * Note: We are mishandling drop actions DropAction dropAction = new
 168          * DropActionBuilder().build(); ActionBuilder ab = new ActionBuilder();
 169          * ab.setAction(dropAction);
 170          */
 171
 172         DecNwTtl decNwTtl = new DecNwTtlBuilder().build();
 173         ActionBuilder ab = new ActionBuilder();
 174         ActionKey actionKey = new ActionKey(0);
 175         ab.setKey(actionKey );
 176         ab.setAction(new DecNwTtlCaseBuilder().setDecNwTtl(decNwTtl).build());
 177
 178         // Add our drop action to a list
 179         List<Action> actionList = new ArrayList<Action>();
 180         actionList.add(ab.build());
 181
 182         // Create an Apply Action
 183         ApplyActionsBuilder aab = new ApplyActionsBuilder();
 184         aab.setAction(actionList);
 185
 186         // Wrap our Apply Action in an Instruction
 187         InstructionBuilder ib = new InstructionBuilder();
 188         ib.setInstruction(new ApplyActionsCaseBuilder().setApplyActions(aab.build()).build());
 189
 190         // Put our Instruction in a list of Instructions
 191         InstructionsBuilder isb = new InstructionsBuilder();
 192         List<Instruction> instructions = new ArrayList<Instruction>();
 193         instructions.add(ib.build());
 194         isb.setInstruction(instructions);
 195
 196         // Add our instructions to the flow
 197         flow.setInstructions(isb.build());
 198
 199         flow.setPriority(2);
 200         flow.setFlowName("Foo Name");
 201         CompositeNode domFlow = mappingService.toDataDom(flow.build());
 202         return domFlow;
 203     }
 204 }