openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/factories/FlowModInputMessageFactory.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */\r
   2 package org.opendaylight.openflowjava.protocol.impl.serialization.factories;\r
   3 \r
   4 import io.netty.buffer.ByteBuf;\r
   5 \r
   6 import java.util.HashMap;\r
   7 import java.util.Map;\r
   8 \r
   9 import org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
  10 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.FlowModFlags;\r
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowModInput;\r
  13 \r
  14 /**\r
  15  * @author timotej.kubas\r
  16  * @author michal.polkorab\r
  17  */\r
  18 public class FlowModInputMessageFactory implements OFSerializer<FlowModInput> {\r
  19     private static final byte MESSAGE_TYPE = 14;\r
  20     private static final byte PADDING_IN_FLOW_MOD_MESSAGE = 2;\r
  21     private static final int MESSAGE_LENGTH = 48; //flags\r
  22     private static FlowModInputMessageFactory instance;\r
  23    \r
  24     private FlowModInputMessageFactory() {\r
  25         // singleton\r
  26     }\r
  27     \r
  28     /**\r
  29      * @return singleton factory\r
  30      */\r
  31     public static synchronized FlowModInputMessageFactory getInstance() {\r
  32         if(instance == null) {\r
  33             instance = new FlowModInputMessageFactory();\r
  34         }\r
  35         return instance;\r
  36     }\r
  37     \r
  38     @Override\r
  39     public void messageToBuffer(short version, ByteBuf out, FlowModInput message) {\r
  40         ByteBufUtils.writeOFHeader(instance, message, out);\r
  41         out.writeLong(message.getCookie().longValue());\r
  42         out.writeLong(message.getCookieMask().longValue());\r
  43         out.writeByte(message.getTableId().getValue().byteValue());\r
  44         out.writeByte(message.getCommand().getIntValue());\r
  45         out.writeShort(message.getIdleTimeout().intValue());\r
  46         out.writeShort(message.getHardTimeout().intValue());\r
  47         out.writeShort(message.getPriority());\r
  48         out.writeInt(message.getOutPort().getValue().intValue());\r
  49         out.writeInt(message.getOutGroup().intValue());\r
  50         out.writeShort(createFlowModFlagsBitmask(message.getFlags()));\r
  51         ByteBufUtils.padBuffer(PADDING_IN_FLOW_MOD_MESSAGE, out);\r
  52         // TODO implementation of match structure\r
  53         // TODO implementation of instructions\r
  54     }\r
  55 \r
  56     @Override\r
  57     public int computeLength(FlowModInput message) {\r
  58         return MESSAGE_LENGTH;\r
  59     }\r
  60 \r
  61     @Override\r
  62     public byte getMessageType() {\r
  63         return MESSAGE_TYPE;\r
  64     }\r
  65     \r
  66     private static int createFlowModFlagsBitmask(FlowModFlags flags) {\r
  67         int flowModFlagBitmask = 0;\r
  68         Map<Integer, Boolean> flowModFlagsMap = new HashMap<>();\r
  69         flowModFlagsMap.put(0, flags.isOFPFFSENDFLOWREM());\r
  70         flowModFlagsMap.put(1, flags.isOFPFFCHECKOVERLAP());\r
  71         flowModFlagsMap.put(2, flags.isOFPFFRESETCOUNTS());\r
  72         flowModFlagsMap.put(3, flags.isOFPFFNOPKTCOUNTS());\r
  73         flowModFlagsMap.put(4, flags.isOFPFFNOBYTCOUNTS());\r
  74         \r
  75         flowModFlagBitmask = ByteBufUtils.fillBitMaskFromMap(flowModFlagsMap);\r
  76         return flowModFlagBitmask;\r
  77     }\r
  78 }\r