96badb54e0cf8cbf30406a37150470fcbdee7bd1
[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / serialization / factories / EchoInputMessageFactory.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 org.opendaylight.openflowjava.protocol.impl.serialization.OFSerializer;\r
7 import org.opendaylight.openflowjava.protocol.impl.util.ByteBufUtils;\r
8 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoInput;\r
9 \r
10 /**\r
11  * @author michal.polkorab\r
12  *\r
13  */\r
14 public class EchoInputMessageFactory implements OFSerializer<EchoInput> {\r
15 \r
16     /** Code type of EchoRequest message */\r
17     public static final byte MESSAGE_TYPE = 2;\r
18     private static EchoInputMessageFactory instance;\r
19     private static final int MESSAGE_LENGTH = 8;\r
20     \r
21     private EchoInputMessageFactory() {\r
22         // do nothing, just singleton\r
23     }\r
24     \r
25     /**\r
26      * @return singleton factory\r
27      */\r
28     public static synchronized EchoInputMessageFactory getInstance() {\r
29         if (instance == null) {\r
30             instance = new EchoInputMessageFactory();\r
31         }\r
32         return instance;\r
33     }\r
34 \r
35     @Override\r
36     public void messageToBuffer(short version, ByteBuf out, EchoInput message) {\r
37         ByteBufUtils.writeOFHeader(instance, message, out);\r
38         byte[] data = message.getData();\r
39         if (data != null) {\r
40             out.writeBytes(data);\r
41         }\r
42     }\r
43 \r
44     @Override\r
45     public int computeLength(EchoInput message) {\r
46         int length = MESSAGE_LENGTH;\r
47         byte[] data = message.getData();\r
48         if (data != null) {\r
49             length += data.length;\r
50         }\r
51         return length;\r
52     }\r
53 \r
54     @Override\r
55     public byte getMessageType() {\r
56         return MESSAGE_TYPE;\r
57     }\r
58     \r
59 }\r