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

   1 package org.opendaylight.openflowplugin.openflow.md.core.translator;
   2
   3 import java.math.BigInteger;
   4 import java.util.Collections;
   5 import java.util.List;
   6 import java.util.concurrent.CopyOnWriteArrayList;
   7
   8 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
   9 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
  10 import org.opendaylight.openflowplugin.openflow.md.core.session.SessionContext;
  11 import org.opendaylight.openflowplugin.openflow.md.util.ByteUtil;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.errors.rev131116.ErrorType;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotification;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotificationBuilder;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev131103.TransactionId;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
  18 import org.opendaylight.yangtools.yang.binding.DataObject;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 public class ErrorTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
  23
  24     protected static final Logger LOG = LoggerFactory.getLogger(ErrorTranslator.class);
  25
  26     @Override
  27     public List<DataObject> translate(SwitchConnectionDistinguisher cookie, SessionContext sc, OfHeader msg) {
  28         if (msg instanceof ErrorMessage) {
  29             ErrorMessage message = (ErrorMessage) msg;
  30             List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
  31             LOG.error(" Error Message received: type={}[{}], code={}[{}], data={}[{}] ", message.getType(),
  32                     message.getTypeString(), message.getCode(), message.getCodeString(), new String(message.getData()),
  33                     ByteUtil.bytesToHexstring(message.getData(), " "));
  34
  35             // create a Node Error Notification event builder
  36             NodeErrorNotificationBuilder nodeErrBuilder = new NodeErrorNotificationBuilder();
  37
  38             // Fill in the Node Error Notification Builder object from the Error
  39             // Message
  40
  41             nodeErrBuilder.setTransactionId(new TransactionId(BigInteger.valueOf(message.getXid())));
  42
  43             nodeErrBuilder.setType(ErrorType.forValue(message.getType()));
  44
  45             nodeErrBuilder.setCode(message.getCode());
  46
  47             nodeErrBuilder.setData(new String(message.getData()));
  48
  49             // TODO -- Augmentation is not handled
  50
  51             // Note Error_TypeV10 is not handled.
  52
  53             NodeErrorNotification nodeErrorEvent = nodeErrBuilder.build();
  54             list.add(nodeErrorEvent);
  55             return list;
  56         } else {
  57             LOG.error("Message is not of Error Message ");
  58             return Collections.emptyList();
  59         }
  60     }
  61
  62 }