pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPMonitoringReplyMessageParser.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.protocol.pcep.impl.message;
  10
  11 import com.google.common.base.Optional;
  12 import com.google.common.base.Preconditions;
  13 import io.netty.buffer.ByteBuf;
  14 import io.netty.buffer.Unpooled;
  15 import java.util.ArrayList;
  16 import java.util.List;
  17 import org.opendaylight.protocol.pcep.impl.spi.Util;
  18 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
  19 import org.opendaylight.protocol.pcep.spi.MessageUtil;
  20 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
  21 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  22 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.Pcmonrep;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcmonrepBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.metrics.MetricPce;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.object.Monitoring;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.GeneralMetricsList;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.GeneralMetricsListBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.SpecificMetricsList;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.SpecificMetricsListBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.specific.metrics.list.SpecificMetrics;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.monitoring.response.monitoring.metrics.list.specific.metrics.list.SpecificMetricsBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcc.id.req.object.PccIdReq;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcmonrep.message.PcmonrepMessage;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcmonrep.message.PcmonrepMessageBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
  39
  40
  41 /**
  42  * Parser for {@link Pcmonrep}
  43  * @see <a href="https://tools.ietf.org/html/rfc5886#section-3.2">Path Monitoring Replay Message</a>
  44  */
  45 public class PCEPMonitoringReplyMessageParser extends AbstractMessageParser {
  46
  47     public static final int TYPE = 9;
  48
  49     public PCEPMonitoringReplyMessageParser(final ObjectRegistry registry) {
  50         super(registry);
  51     }
  52
  53     @Override
  54     public void serializeMessage(final Message message, final ByteBuf buffer) {
  55         Preconditions.checkArgument(message instanceof Pcmonrep, "Wrong instance of Message. Passed instance of %s. Need Pcmonrep.", message.getClass());
  56         final PcmonrepMessage monRepMsg = ((Pcmonrep) message).getPcmonrepMessage();
  57         Preconditions.checkArgument(monRepMsg.getMonitoring() != null, "MONITORING object is mandatory.");
  58         final ByteBuf body = Unpooled.buffer();
  59         serializeObject(monRepMsg.getMonitoring(), body);
  60         serializeObject(monRepMsg.getPccIdReq(), body);
  61         if (monRepMsg.getMonitoringMetricsList() instanceof GeneralMetricsList) {
  62             final GeneralMetricsList gml = (GeneralMetricsList) monRepMsg.getMonitoringMetricsList();
  63             if (gml.getMetricPce() != null) {
  64                 for (final MetricPce metricPce : gml.getMetricPce()) {
  65                     serializeMetricPce(metricPce, body);
  66                 }
  67             }
  68         } else if (monRepMsg.getMonitoringMetricsList() instanceof SpecificMetricsList) {
  69             final SpecificMetricsList sml = (SpecificMetricsList) monRepMsg.getMonitoringMetricsList();
  70             if (sml.getSpecificMetrics() != null) {
  71                 for (final SpecificMetrics specificMetrics : sml.getSpecificMetrics()) {
  72                     serializeObject(specificMetrics.getRp(), body);
  73                     if (specificMetrics.getMetricPce() != null) {
  74                         for (final MetricPce metricPce : specificMetrics.getMetricPce()) {
  75                             serializeMetricPce(metricPce, body);
  76                         }
  77                     }
  78                 }
  79             }
  80         }
  81
  82         MessageUtil.formatMessage(TYPE, body, buffer);
  83     }
  84
  85     private void serializeMetricPce(final MetricPce metricPce, final ByteBuf buffer) {
  86         Preconditions.checkArgument(metricPce.getPceId() != null, "PCE-ID must be present.");
  87         serializeObject(metricPce.getPceId(), buffer);
  88         serializeObject(metricPce.getProcTime(), buffer);
  89         serializeObject(metricPce.getOverload(), buffer);
  90     }
  91
  92     @Override
  93     protected Message validate(final List<Object> objects, final List<Message> errors) throws PCEPDeserializerException {
  94         Preconditions.checkArgument(objects != null, "Passed list can't be null.");
  95         if (objects.isEmpty()) {
  96             throw new PCEPDeserializerException("Pcmonrep message cannot be empty.");
  97         }
  98         if (!(objects.get(0) instanceof Monitoring)) {
  99             errors.add(createErrorMsg(PCEPErrors.MONITORING_OBJECT_MISSING, Optional.<Rp>absent()));
 100             return null;
 101         }
 102         final PcmonrepMessageBuilder builder = new PcmonrepMessageBuilder();
 103         builder.setMonitoring((Monitoring) objects.get(0));
 104         objects.remove(0);
 105         if (!objects.isEmpty() && objects.get(0) instanceof PccIdReq) {
 106             builder.setPccIdReq((PccIdReq) objects.get(0));
 107             objects.remove(0);
 108         }
 109         validateSpecificMetrics(objects, builder);
 110         if (!objects.isEmpty()) {
 111             throw new PCEPDeserializerException("Unprocessed Objects: " + objects);
 112         }
 113         return new PcmonrepBuilder().setPcmonrepMessage(builder.build()).build();
 114     }
 115
 116     private void validateSpecificMetrics(final List<Object> objects, final PcmonrepMessageBuilder builder) throws PCEPDeserializerException {
 117         final List<SpecificMetrics> specificMetrics = new ArrayList<>();
 118         while (!objects.isEmpty()) {
 119             final SpecificMetricsBuilder smb = new SpecificMetricsBuilder();
 120             final List<MetricPce> metricPceList = new ArrayList<>();
 121             if (objects.get(0) instanceof Rp) {
 122                 smb.setRp((Rp) objects.get(0));
 123                 objects.remove(0);
 124             }
 125             while (!objects.isEmpty() && !(objects.get(0) instanceof Rp)) {
 126                 metricPceList.add(Util.validateMonitoringMetrics(objects));
 127             }
 128             if (smb.getRp() != null) {
 129                 smb.setMetricPce(metricPceList);
 130                 specificMetrics.add(smb.build());
 131             } else if (!metricPceList.isEmpty()) {
 132                 builder.setMonitoringMetricsList(new GeneralMetricsListBuilder().setMetricPce(metricPceList).build());
 133             }
 134         }
 135         if (!specificMetrics.isEmpty()) {
 136             builder.setMonitoringMetricsList(new SpecificMetricsListBuilder().setSpecificMetrics(specificMetrics).build());
 137         }
 138     }
 139 }