\r
private static final byte MESSAGE_TYPE = 16;\r
private static final int MESSAGE_LENGTH = 12;\r
+ private static final byte FLOW_BODY_LENGTH = 44;\r
+ private static final byte AGGREGATE_BODY_LENGTH = 44;\r
+ private static final byte PORT_STATS_BODY_LENGTH = 8;\r
+ private static final byte QUEUE_BODY_LENGTH = 8;\r
+ private static final byte EXPERIMENTER_BODY_LENGTH = 4;\r
+ private static final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;\r
+ private static final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;\r
+ private static final byte PADING_IN_QUEUE_BODY = 2;\r
\r
private static OF10StatsRequestInputFactory instance; \r
\r
int length = 0;\r
MultipartType type = message.getType();\r
if (type.equals(MultipartType.OFPMPFLOW)) {\r
- final byte FLOW_BODY_LENGTH = 44;\r
length += FLOW_BODY_LENGTH;\r
} else if (type.equals(MultipartType.OFPMPAGGREGATE)) {\r
- final byte AGGREGATE_BODY_LENGTH = 44;\r
length += AGGREGATE_BODY_LENGTH;\r
} else if (type.equals(MultipartType.OFPMPPORTSTATS)) {\r
- final byte PORT_STATS_BODY_LENGTH = 8;\r
length += PORT_STATS_BODY_LENGTH;\r
} else if (type.equals(MultipartType.OFPMPQUEUE)) {\r
- final byte QUEUE_BODY_LENGTH = 8;\r
length += QUEUE_BODY_LENGTH;\r
} else if (type.equals(MultipartType.OFPMPEXPERIMENTER)) {\r
- final byte EXPERIMENTER_BODY_LENGTH = 4;\r
MultipartRequestExperimenter body = (MultipartRequestExperimenter) message.getMultipartRequestBody();\r
length += EXPERIMENTER_BODY_LENGTH;\r
if (body.getData() != null) {\r
\r
private static void encodeFlowAndAggregateBody(\r
MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
- final byte PADDING_IN_MULTIPART_REQUEST_FLOW_BODY = 1;\r
MultipartRequestFlow flow = (MultipartRequestFlow) multipartRequestBody;\r
OF10MatchSerializer.encodeMatchV10(output, flow.getMatchV10());\r
output.writeByte(flow.getTableId().shortValue());\r
}\r
\r
private static void encodePortBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
- final byte PADDING_IN_MULTIPART_REQUEST_PORT_BODY = 6;\r
MultipartRequestPortStats portstats = (MultipartRequestPortStats) multipartRequestBody;\r
output.writeShort(portstats.getPortNo().intValue());\r
ByteBufUtils.padBuffer(PADDING_IN_MULTIPART_REQUEST_PORT_BODY, output);\r
}\r
\r
private static void encodeQueueBody(MultipartRequestBody multipartRequestBody, ByteBuf output) {\r
- final byte PADING_IN_QUEUE_BODY = 2;\r
MultipartRequestQueue queue = (MultipartRequestQueue) multipartRequestBody;\r
output.writeShort(queue.getPortNo().intValue());\r
ByteBufUtils.padBuffer(PADING_IN_QUEUE_BODY, output);\r