openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/factories/OF10StatsRequestInputFactory.java

   1 /*
   2  * Copyright (c) 2015 NetIDE Consortium and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
   9
  10 import io.netty.buffer.ByteBuf;
  11 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
  12 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistryInjector;
  13 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
  14 import org.opendaylight.openflowjava.protocol.api.keys.MessageCodeKey;
  15 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartRequestFlags;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.v10.grouping.MatchV10;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInputBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCaseBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDescCase;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDescCaseBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterCase;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterCaseBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlowCase;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlowCaseBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCase;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCaseBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCase;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCaseBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableCase;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableCaseBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.aggregate._case.MultipartRequestAggregateBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.desc._case.MultipartRequestDescBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.experimenter._case.MultipartRequestExperimenterBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.flow._case.MultipartRequestFlowBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStatsBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueueBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table._case.MultipartRequestTableBuilder;
  42
  43 /**
  44  * @author giuseppex.petralia@intel.com
  45  *
  46  */
  47 public class OF10StatsRequestInputFactory
  48         implements OFDeserializer<MultipartRequestInput>, DeserializerRegistryInjector {
  49     private DeserializerRegistry registry;
  50     private static final byte FLOW_PADDING_1 = 1;
  51     private static final byte AGGREGATE_PADDING_1 = 1;
  52
  53     @Override
  54     public MultipartRequestInput deserialize(ByteBuf rawMessage) {
  55         MultipartRequestInputBuilder builder = new MultipartRequestInputBuilder();
  56         builder.setVersion((short) EncodeConstants.OF10_VERSION_ID);
  57         builder.setXid(rawMessage.readUnsignedInt());
  58         int type = rawMessage.readUnsignedShort();
  59         builder.setType(getMultipartType(type));
  60         builder.setFlags(getMultipartRequestFlags(rawMessage.readUnsignedShort()));
  61         switch (getMultipartType(type)) {
  62         case OFPMPDESC:
  63             builder.setMultipartRequestBody(setDesc(rawMessage));
  64             break;
  65         case OFPMPFLOW:
  66             builder.setMultipartRequestBody(setFlow(rawMessage));
  67             break;
  68         case OFPMPAGGREGATE:
  69             builder.setMultipartRequestBody(setAggregate(rawMessage));
  70             break;
  71         case OFPMPTABLE:
  72             builder.setMultipartRequestBody(setTable(rawMessage));
  73             break;
  74         case OFPMPPORTSTATS:
  75             builder.setMultipartRequestBody(setPortStats(rawMessage));
  76             break;
  77         case OFPMPQUEUE:
  78             builder.setMultipartRequestBody(setQueue(rawMessage));
  79             break;
  80         case OFPMPEXPERIMENTER:
  81             builder.setMultipartRequestBody(setExperimenter(rawMessage));
  82             break;
  83         default:
  84             break;
  85         }
  86         return builder.build();
  87     }
  88
  89     private MultipartRequestExperimenterCase setExperimenter(ByteBuf input) {
  90         MultipartRequestExperimenterCaseBuilder caseBuilder = new MultipartRequestExperimenterCaseBuilder();
  91         MultipartRequestExperimenterBuilder experimenterBuilder = new MultipartRequestExperimenterBuilder();
  92         caseBuilder.setMultipartRequestExperimenter(experimenterBuilder.build());
  93         return caseBuilder.build();
  94     }
  95
  96     private MultipartRequestQueueCase setQueue(ByteBuf input) {
  97         MultipartRequestQueueCaseBuilder caseBuilder = new MultipartRequestQueueCaseBuilder();
  98         MultipartRequestQueueBuilder queueBuilder = new MultipartRequestQueueBuilder();
  99         queueBuilder.setPortNo((long) input.readUnsignedShort());
 100         input.skipBytes(2);
 101         queueBuilder.setQueueId(input.readUnsignedInt());
 102         caseBuilder.setMultipartRequestQueue(queueBuilder.build());
 103         return caseBuilder.build();
 104     }
 105
 106     private MultipartRequestPortStatsCase setPortStats(ByteBuf input) {
 107         MultipartRequestPortStatsCaseBuilder caseBuilder = new MultipartRequestPortStatsCaseBuilder();
 108         MultipartRequestPortStatsBuilder portBuilder = new MultipartRequestPortStatsBuilder();
 109         portBuilder.setPortNo((long) input.readUnsignedShort());
 110         caseBuilder.setMultipartRequestPortStats(portBuilder.build());
 111         return caseBuilder.build();
 112     }
 113
 114     private MultipartRequestTableCase setTable(ByteBuf input) {
 115         MultipartRequestTableCaseBuilder caseBuilder = new MultipartRequestTableCaseBuilder();
 116         MultipartRequestTableBuilder tableBuilder = new MultipartRequestTableBuilder();
 117         tableBuilder.setEmpty(true);
 118         caseBuilder.setMultipartRequestTable(tableBuilder.build());
 119         return caseBuilder.build();
 120     }
 121
 122     private MultipartRequestAggregateCase setAggregate(ByteBuf input) {
 123         MultipartRequestAggregateCaseBuilder caseBuilder = new MultipartRequestAggregateCaseBuilder();
 124         MultipartRequestAggregateBuilder aggregateBuilder = new MultipartRequestAggregateBuilder();
 125         OFDeserializer<MatchV10> matchDeserializer = registry.getDeserializer(
 126                 new MessageCodeKey(EncodeConstants.OF10_VERSION_ID, EncodeConstants.EMPTY_VALUE, MatchV10.class));
 127         aggregateBuilder.setMatchV10(matchDeserializer.deserialize(input));
 128         aggregateBuilder.setTableId(input.readUnsignedByte());
 129         input.skipBytes(AGGREGATE_PADDING_1);
 130         aggregateBuilder.setOutPort((long) input.readUnsignedShort());
 131         caseBuilder.setMultipartRequestAggregate(aggregateBuilder.build());
 132         return caseBuilder.build();
 133     }
 134
 135     private MultipartRequestFlowCase setFlow(ByteBuf input) {
 136         MultipartRequestFlowCaseBuilder caseBuilder = new MultipartRequestFlowCaseBuilder();
 137         MultipartRequestFlowBuilder flowBuilder = new MultipartRequestFlowBuilder();
 138         OFDeserializer<MatchV10> matchDeserializer = registry.getDeserializer(
 139                 new MessageCodeKey(EncodeConstants.OF10_VERSION_ID, EncodeConstants.EMPTY_VALUE, MatchV10.class));
 140         flowBuilder.setMatchV10(matchDeserializer.deserialize(input));
 141         flowBuilder.setTableId(input.readUnsignedByte());
 142         input.skipBytes(FLOW_PADDING_1);
 143         flowBuilder.setOutPort((long) input.readUnsignedShort());
 144         caseBuilder.setMultipartRequestFlow(flowBuilder.build());
 145         return caseBuilder.build();
 146     }
 147
 148     private MultipartRequestDescCase setDesc(ByteBuf input) {
 149         MultipartRequestDescCaseBuilder caseBuilder = new MultipartRequestDescCaseBuilder();
 150         MultipartRequestDescBuilder descBuilder = new MultipartRequestDescBuilder();
 151         descBuilder.setEmpty(true);
 152         caseBuilder.setMultipartRequestDesc(descBuilder.build());
 153         return caseBuilder.build();
 154     }
 155
 156     private static MultipartRequestFlags getMultipartRequestFlags(int input) {
 157         final Boolean _oFPMPFREQMORE = (input & (1 << 0)) > 0;
 158         MultipartRequestFlags flag = new MultipartRequestFlags(_oFPMPFREQMORE);
 159         return flag;
 160     }
 161
 162     private static MultipartType getMultipartType(int input) {
 163         return MultipartType.forValue(input);
 164     }
 165
 166     @Override
 167     public void injectDeserializerRegistry(DeserializerRegistry deserializerRegistry) {
 168         registry = deserializerRegistry;
 169     }
 170 }