Minor refactoring due to change in the library model

[openflowplugin.git] / openflowplugin / src / main / java / org / opendaylight / openflowplugin / openflow / md / core / translator / ErrorTranslator.java

diff --git a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/translator/ErrorTranslator.java b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/translator/ErrorTranslator.java
index ca56c5ec0cdc2781def68618b8e39a10b16ad129..8a26264fbe2e9bbd04a01feb6f5cc51a67ea5b03 100644 (file)
--- a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/translator/ErrorTranslator.java
+++ b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/translator/ErrorTranslator.java
@@ -7,35 +7,63 @@
  */
 package org.opendaylight.openflowplugin.openflow.md.core.translator;
 
-import org.opendaylight.openflowplugin.openflow.md.core.ByteUtil;
+import java.math.BigInteger;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+
 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
+import org.opendaylight.openflowplugin.openflow.md.util.ByteUtil;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.errors.rev131116.ErrorType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotification;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotificationBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev131103.TransactionId;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- * @author mirehak
- *
- */
-public class ErrorTranslator implements IMDMessageTranslator<OfHeader, DataObject> {
+public class ErrorTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
+
+    protected static final Logger LOG = LoggerFactory.getLogger(ErrorTranslator.class);
 
-    private static final Logger LOG = LoggerFactory
-            .getLogger(ErrorTranslator.class);
-    
     @Override
-    public DataObject translate(SwitchConnectionDistinguisher cookie,
-            SessionContext sc, OfHeader msg) {
-        ErrorMessage errorMsg = (ErrorMessage) msg;
-        LOG.error("errorMessage arrived: type={}, code={}, data={} | [{}]", 
-                errorMsg.getType(), errorMsg.getCode(),
-                new String(errorMsg.getData()), ByteUtil.bytesToHexstring(errorMsg.getData(), " "));
-        //TODO:: add sal-error wrapper
-        return null;
-    }
+    public List<DataObject> translate(SwitchConnectionDistinguisher cookie, SessionContext sc, OfHeader msg) {
+        if (msg instanceof ErrorMessage) {
+            ErrorMessage message = (ErrorMessage) msg;
+            List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
+            LOG.debug(" Error Message received: type={}[{}], code={}[{}], data=[{}] ", message.getType(),
+                    message.getTypeString(), message.getCode(), message.getCodeString(),
+                    ByteUtil.bytesToHexstring(message.getData(), " "));
+
+            // create a Node Error Notification event builder
+            NodeErrorNotificationBuilder nodeErrBuilder = new NodeErrorNotificationBuilder();
+
+            // Fill in the Node Error Notification Builder object from the Error
+            // Message
 
+            nodeErrBuilder.setTransactionId(new TransactionId(BigInteger.valueOf(message.getXid())));
+
+            nodeErrBuilder.setType(ErrorType.forValue(message.getType()));
+
+            nodeErrBuilder.setCode(message.getCode());
+
+            nodeErrBuilder.setData(new String(message.getData()));
+
+            // TODO -- Augmentation is not handled
+
+            // Note Error_TypeV10 is not handled.
+
+            NodeErrorNotification nodeErrorEvent = nodeErrBuilder.build();
+            list.add(nodeErrorEvent);
+            return list;
+        } else {
+            LOG.error("Message is not of Error Message ");
+            return Collections.emptyList();
+        }
+    }
 
 }