Add bundle control and ONF experimenter error deserializers

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / deserialization / experimenter / OnfExperimenterErrorFactory.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/experimenter/OnfExperimenterErrorFactory.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/experimenter/OnfExperimenterErrorFactory.java
new file mode 100644 (file)
index 0000000..a104531
--- /dev/null
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/deserialization/experimenter/OnfExperimenterErrorFactory.java
@@ -0,0 +1,72 @@
+/*
+ * Copyright (c) 2016 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.openflowjava.protocol.impl.deserialization.experimenter;
+
+import io.netty.buffer.ByteBuf;
+import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
+import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.approved.extensions.rev160802.OnfExperimenterErrorCode;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev150225.ExperimenterIdError;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.augments.rev150225.ExperimenterIdErrorBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ErrorType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ExperimenterId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Translates (ONF approved) experimenter error messages.
+ */
+public class OnfExperimenterErrorFactory implements OFDeserializer<ErrorMessage> {
+
+    private static final Logger LOG = LoggerFactory.getLogger(OnfExperimenterErrorFactory.class);
+    private static final String UNKNOWN_TYPE = "UNKNOWN_TYPE";
+    private static final String UNKNOWN_CODE = "UNKNOWN_CODE";
+
+    @Override
+    public ErrorMessage deserialize(ByteBuf message) {
+        ErrorMessageBuilder builder = new ErrorMessageBuilder();
+        builder.setVersion((short) EncodeConstants.OF13_VERSION_ID);
+        builder.setXid(message.readUnsignedInt());
+
+        int type = message.readUnsignedShort();
+        ErrorType errorType = ErrorType.forValue(type);
+        if (errorType != null && errorType.equals(ErrorType.EXPERIMENTER)) {
+            builder.setType(errorType.getIntValue());
+            builder.setTypeString(errorType.getName());
+        } else {
+            LOG.warn("Deserializing other than {} error message with {}", ErrorType.EXPERIMENTER.getName(),
+                    this.getClass().getCanonicalName());
+            builder.setType(type);
+            builder.setTypeString(UNKNOWN_TYPE);
+        }
+
+        int code = message.readUnsignedShort();
+        OnfExperimenterErrorCode errorCode = OnfExperimenterErrorCode.forValue(code);
+        if (errorCode != null) {
+            builder.setCode(errorCode.getIntValue());
+            builder.setCodeString(errorCode.getName());
+        } else {
+            builder.setCode(code);
+            builder.setCodeString(UNKNOWN_CODE);
+        }
+
+        builder.addAugmentation(ExperimenterIdError.class, new ExperimenterIdErrorBuilder()
+                .setExperimenter(new ExperimenterId(message.readUnsignedInt()))
+                .build());
+
+        if (message.readableBytes() > 0) {
+            byte[] data = new byte[message.readableBytes()];
+            message.readBytes(data);
+            builder.setData(data);
+        }
+        return builder.build();
+    }
+}