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

   1 package org.opendaylight.openflowplugin.openflow.md.core.translator;
   2
   3
   4 import java.math.BigInteger;
   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.yang.gen.v1.urn.opendaylight.flow.errors.rev131116.ErrorType;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotification;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotificationBuilder;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev131103.TransactionId;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
  17 import org.opendaylight.yangtools.yang.binding.DataObject;
  18 import org.slf4j.Logger;
  19 import org.slf4j.LoggerFactory;
  20
  21 public class ErrorTranslator implements IMDMessageTranslator<OfHeader, List<DataObject>> {
  22
  23         protected static final Logger LOG = LoggerFactory.getLogger(ErrorTranslator.class);
  24         @Override
  25         public List<DataObject> translate(SwitchConnectionDistinguisher cookie,
  26                         SessionContext sc, OfHeader msg) {
  27                 if( msg instanceof ErrorMessage) {
  28                         ErrorMessage message = (ErrorMessage)msg ;
  29                         List<DataObject> list = new CopyOnWriteArrayList<DataObject>();
  30                         LOG.error(" Error Message received: type={}, code={}, data={} ",
  31                         message.getType(), message.getCode(),
  32                         new String(message.getData()) ) ;
  33
  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 Message
  39
  40                         nodeErrBuilder.setTransactionId(new TransactionId(BigInteger.valueOf(message.getXid() ) ) ) ;
  41
  42                         nodeErrBuilder.setCode(message.getCode());
  43
  44                         nodeErrBuilder.setType(ErrorType.forValue(message.getType().getIntValue()));
  45
  46                         nodeErrBuilder.setData( new String( message.getData() ) ) ;
  47
  48                         // TODO -- Augmentation is not handled
  49
  50                         // Note Error_TypeV10 is not handled.
  51
  52                         NodeErrorNotification nodeErrorEvent = nodeErrBuilder.build() ;
  53                         list.add(nodeErrorEvent);
  54                         return list;
  55                 }else {
  56                         LOG.error( "Message is not of Error Message " ) ;
  57                         return null;
  58                 }
  59         }
  60
  61 }