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

   1 /*
   2  * Copyright (c) 2013 Pantheon Technologies s.r.o. 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
   9 package org.opendaylight.openflowjava.protocol.impl.deserialization.factories;
  10
  11 import io.netty.buffer.ByteBuf;
  12
  13 import java.util.ArrayList;
  14 import java.util.List;
  15
  16 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
  17 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowRemovedReason;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PacketInReason;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.PortReason;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetAsyncOutput;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.GetAsyncOutputBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.FlowRemovedMask;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.FlowRemovedMaskBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PacketInMask;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PacketInMaskBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMask;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.async.body.grouping.PortStatusMaskBuilder;
  29
  30 /**
  31  * Translates GetAsyncReply messages
  32  * @author timotej.kubas
  33  * @author michal.polkorab
  34  */
  35 public class GetAsyncReplyMessageFactory implements OFDeserializer<GetAsyncOutput> {
  36
  37     private static final byte SEPARATE_ROLES = 2;
  38
  39     @Override
  40     public GetAsyncOutput deserialize(ByteBuf rawMessage) {
  41         GetAsyncOutputBuilder builder = new GetAsyncOutputBuilder();
  42         builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
  43         builder.setXid(rawMessage.readUnsignedInt());
  44         builder.setPacketInMask(decodePacketInMask(rawMessage));
  45         builder.setPortStatusMask(decodePortStatusMask(rawMessage));
  46         builder.setFlowRemovedMask(decodeFlowRemovedMask(rawMessage));
  47         return builder.build();
  48     }
  49
  50     private static List<PacketInMask> decodePacketInMask(ByteBuf input) {
  51         List<PacketInMask> inMasks = new ArrayList<>();
  52         PacketInMaskBuilder maskBuilder;
  53         for (int i = 0; i < SEPARATE_ROLES; i++) {
  54             maskBuilder = new PacketInMaskBuilder();
  55             maskBuilder.setMask(decodePacketInReasons(input.readUnsignedInt()));
  56             inMasks.add(maskBuilder.build());
  57         }
  58         return inMasks;
  59     }
  60
  61     private static List<PortStatusMask> decodePortStatusMask(ByteBuf input) {
  62         List<PortStatusMask> inMasks = new ArrayList<>();
  63         PortStatusMaskBuilder maskBuilder;
  64         for (int i = 0; i < SEPARATE_ROLES; i++) {
  65             maskBuilder = new PortStatusMaskBuilder();
  66             maskBuilder.setMask(decodePortReasons(input.readUnsignedInt()));
  67             inMasks.add(maskBuilder.build());
  68         }
  69         return inMasks;
  70     }
  71
  72     private static List<FlowRemovedMask> decodeFlowRemovedMask(ByteBuf input) {
  73         List<FlowRemovedMask> inMasks = new ArrayList<>();
  74         FlowRemovedMaskBuilder maskBuilder;
  75         for (int i = 0; i < SEPARATE_ROLES; i++) {
  76             maskBuilder = new FlowRemovedMaskBuilder();
  77             maskBuilder.setMask(decodeFlowRemovedReasons(input.readUnsignedInt()));
  78             inMasks.add(maskBuilder.build());
  79         }
  80         return inMasks;
  81     }
  82
  83     private static List<PacketInReason> decodePacketInReasons(long input) {
  84         List<PacketInReason> reasons = new ArrayList<>();
  85         if ((input & (1 << 0)) != 0) {
  86             reasons.add(PacketInReason.OFPRNOMATCH);
  87         }
  88         if ((input & (1 << 1)) != 0) {
  89             reasons.add(PacketInReason.OFPRACTION);
  90         }
  91         if ((input & (1 << 2)) != 0) {
  92             reasons.add(PacketInReason.OFPRINVALIDTTL);
  93         }
  94         return reasons;
  95     }
  96
  97     private static List<PortReason> decodePortReasons(long input) {
  98         List<PortReason> reasons = new ArrayList<>();
  99         if ((input & (1 << 0)) != 0) {
 100             reasons.add(PortReason.OFPPRADD);
 101         }
 102         if ((input & (1 << 1)) != 0) {
 103             reasons.add(PortReason.OFPPRDELETE);
 104         }
 105         if ((input & (1 << 2)) != 0) {
 106             reasons.add(PortReason.OFPPRMODIFY);
 107         }
 108         return reasons;
 109     }
 110
 111     private static List<FlowRemovedReason> decodeFlowRemovedReasons(long input) {
 112         List<FlowRemovedReason> reasons = new ArrayList<>();
 113         if ((input & (1 << 0)) != 0) {
 114             reasons.add(FlowRemovedReason.OFPRRIDLETIMEOUT);
 115         }
 116         if ((input & (1 << 1)) != 0) {
 117             reasons.add(FlowRemovedReason.OFPRRHARDTIMEOUT);
 118         }
 119         if ((input & (1 << 2)) != 0) {
 120             reasons.add(FlowRemovedReason.OFPRRDELETE);
 121         }
 122         if ((input & (1 << 3)) != 0) {
 123             reasons.add(FlowRemovedReason.OFPRRGROUPDELETE);
 124         }
 125         return reasons;
 126     }
 127 }