opendaylight/md-sal/sal-binding-dom-it/src/test/java/org/opendaylight/controller/sal/binding/test/bugfix/FlagsSerializationTest.java

   1 package org.opendaylight.controller.sal.binding.test.bugfix;
   2
   3 import com.google.common.collect.ImmutableSet;
   4 import org.junit.Test;
   5 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
   6 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
   7 import org.opendaylight.controller.sal.binding.test.AbstractDataServiceTest;
   8 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.PopMplsActionCaseBuilder;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.action.pop.mpls.action._case.PopMplsActionBuilder;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.ActionBuilder;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.TableKey;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.FlowModFlags;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.InstructionsBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.MatchBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActionsCaseBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActionsBuilder;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.VlanMatchBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.vlan.match.fields.VlanIdBuilder;
  34 import org.opendaylight.yangtools.yang.binding.DataObject;
  35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  36 import org.opendaylight.yangtools.yang.common.QName;
  37 import org.opendaylight.yangtools.yang.common.RpcResult;
  38 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  39
  40 import java.util.ArrayList;
  41 import java.util.Collections;
  42 import java.util.List;
  43 import java.util.Map;
  44
  45 import static org.junit.Assert.assertEquals;
  46 import static org.junit.Assert.assertNotNull;
  47 import static org.junit.Assert.assertNull;
  48
  49 public class FlagsSerializationTest extends AbstractDataServiceTest {
  50
  51     private static final QName NODE_ID_QNAME = QName.create(Node.QNAME, "id");
  52     private static final QName FLOW_ID_QNAME = QName.create(Flow.QNAME, "id");
  53     private static final QName FLOW_NODE_QNAME = QName.create(Flow.QNAME, "node");
  54     private static final String FLOW_ID = "1234";
  55     private static final short TABLE_ID = (short)0;
  56     private static final String NODE_ID = "node:1";
  57
  58     private static final NodeKey NODE_KEY = new NodeKey(new NodeId(NODE_ID));
  59     private static final FlowKey FLOW_KEY = new FlowKey(new FlowId(FLOW_ID));
  60     private static final TableKey TABLE_KEY = new TableKey(TABLE_ID);
  61
  62     private static final Map<QName, Object> NODE_KEY_BI = Collections.<QName, Object> singletonMap(NODE_ID_QNAME,
  63             NODE_ID);
  64
  65     private static final InstanceIdentifier<Node> NODE_INSTANCE_ID_BA = InstanceIdentifier.builder(Nodes.class) //
  66             .child(Node.class, NODE_KEY).toInstance();
  67
  68     private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier NODE_INSTANCE_ID_BI = //
  69     org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  70             .node(Nodes.QNAME) //
  71             .nodeWithKey(Node.QNAME, NODE_KEY_BI) //
  72             .toInstance();
  73     private static final NodeRef NODE_REF = new NodeRef(NODE_INSTANCE_ID_BA);
  74
  75
  76
  77 //    private static final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier FLOW_INSTANCE_ID_BI = //
  78 //    org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.builder() //
  79 //
  80 //            .node(Flows.QNAME) //
  81 //            .nodeWithKey(Flow.QNAME, FLOW_KEY_BI) //
  82 //            .toInstance();
  83     private static final InstanceIdentifier<? extends DataObject> FLOW_INSTANCE_ID_BA = //
  84     InstanceIdentifier.builder(NODE_INSTANCE_ID_BA) //
  85             .augmentation(FlowCapableNode.class)
  86             .child(Table.class,TABLE_KEY)
  87             .child(Flow.class, FLOW_KEY) //
  88             .toInstance();
  89     private static final QName FLOW_FLAGS_QNAME = QName.create(Flow.QNAME, "flags");
  90
  91     @Test
  92     public void testIndirectGeneration() throws Exception {
  93
  94         FlowModFlags checkOverlapFlags = new FlowModFlags(true,false,false,false,false);
  95         ImmutableSet<String> domCheckOverlapFlags = ImmutableSet.<String>of("CHECK_OVERLAP");
  96         testFlags(checkOverlapFlags,domCheckOverlapFlags);
  97
  98
  99
 100         FlowModFlags allFalseFlags = new FlowModFlags(false,false,false,false,false);
 101         ImmutableSet<String> domAllFalseFlags = ImmutableSet.<String>of();
 102         testFlags(allFalseFlags,domAllFalseFlags);
 103
 104         FlowModFlags allTrueFlags = new FlowModFlags(true,true,true,true,true);
 105         ImmutableSet<String> domAllTrueFlags = ImmutableSet.<String>of("CHECK_OVERLAP","NO_BYT_COUNTS", "NO_PKT_COUNTS", "RESET_COUNTS", "SEND_FLOW_REM");
 106         testFlags(allTrueFlags,domAllTrueFlags);
 107
 108         FlowModFlags nullFlags = null;
 109         ImmutableSet<String> domNullFlags = null;
 110         testFlags(null,null);
 111
 112
 113
 114     }
 115
 116     private void testFlags(FlowModFlags flagsToTest, ImmutableSet<String> domFlags) throws Exception {
 117         Flow flow = createFlow(flagsToTest);
 118         assertNotNull(flow);
 119
 120         CompositeNode domFlow = biDataService.readConfigurationData(mappingService.toDataDom(FLOW_INSTANCE_ID_BA));
 121
 122         assertNotNull(domFlow);
 123         org.opendaylight.yangtools.yang.data.api.Node<?> readedFlags = domFlow.getFirstSimpleByName(FLOW_FLAGS_QNAME);
 124
 125         if(domFlags != null) {
 126             assertNotNull(readedFlags);
 127             assertEquals(domFlags,readedFlags.getValue());
 128         } else {
 129             assertNull(readedFlags);
 130         }
 131         assertEquals(flagsToTest, flow.getFlags());
 132
 133         DataModificationTransaction transaction = baDataService.beginTransaction();
 134         transaction.removeConfigurationData(FLOW_INSTANCE_ID_BA);
 135         RpcResult<TransactionStatus> result = transaction.commit().get();
 136         assertEquals(TransactionStatus.COMMITED, result.getResult());
 137
 138     }
 139
 140     private Flow createFlow(FlowModFlags flagsToTest) throws Exception {
 141
 142         DataModificationTransaction modification = baDataService.beginTransaction();
 143
 144         FlowBuilder flow = new FlowBuilder();
 145         MatchBuilder match = new MatchBuilder();
 146         VlanMatchBuilder vlanBuilder = new VlanMatchBuilder();
 147         VlanIdBuilder vlanIdBuilder = new VlanIdBuilder();
 148         VlanId vlanId = new VlanId(10);
 149         vlanBuilder.setVlanId(vlanIdBuilder.setVlanId(vlanId).build());
 150         match.setVlanMatch(vlanBuilder.build());
 151
 152         flow.setKey(FLOW_KEY);
 153         flow.setMatch(match.build());
 154
 155         flow.setFlags(flagsToTest);
 156
 157         InstructionsBuilder instructions = new InstructionsBuilder();
 158         InstructionBuilder instruction = new InstructionBuilder();
 159
 160         instruction.setOrder(10);
 161         ApplyActionsBuilder applyActions = new ApplyActionsBuilder();
 162         List<Action> actionList = new ArrayList<>();
 163         PopMplsActionBuilder popMplsAction = new PopMplsActionBuilder();
 164         popMplsAction.setEthernetType(34);
 165         actionList.add(new ActionBuilder().setAction(new PopMplsActionCaseBuilder().setPopMplsAction(popMplsAction.build()).build()).setOrder(10).build());
 166
 167         applyActions.setAction(actionList );
 168
 169         instruction.setInstruction(new ApplyActionsCaseBuilder().setApplyActions(applyActions.build()).build());
 170
 171
 172         List<Instruction> instructionList = Collections.<Instruction>singletonList(instruction.build());
 173         instructions.setInstruction(instructionList );
 174
 175         flow.setInstructions(instructions.build());
 176         modification.putConfigurationData(FLOW_INSTANCE_ID_BA, flow.build());
 177         RpcResult<TransactionStatus> ret = modification.commit().get();
 178         assertNotNull(ret);
 179         assertEquals(TransactionStatus.COMMITED, ret.getResult());
 180         return (Flow) baDataService.readConfigurationData(FLOW_INSTANCE_ID_BA);
 181     }
 182 }