*/
package org.opendaylight.protocol.pcep.impl.message;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+
+import org.opendaylight.protocol.pcep.PCEPDeserializerException;
+import org.opendaylight.protocol.pcep.PCEPDocumentedException;
+import org.opendaylight.protocol.pcep.PCEPErrors;
+import org.opendaylight.protocol.pcep.PCEPObject;
+import org.opendaylight.protocol.pcep.impl.PCEPMessageValidator;
+import org.opendaylight.protocol.pcep.impl.object.UnknownObject;
+import org.opendaylight.protocol.pcep.message.PCEPErrorMessage;
+import org.opendaylight.protocol.pcep.message.PCEPReplyMessage;
+import org.opendaylight.protocol.pcep.object.CompositeErrorObject;
+import org.opendaylight.protocol.pcep.object.CompositePathObject;
+import org.opendaylight.protocol.pcep.object.CompositeReplySvecObject;
+import org.opendaylight.protocol.pcep.object.CompositeResponseObject;
+import org.opendaylight.protocol.pcep.object.PCEPErrorObject;
+import org.opendaylight.protocol.pcep.object.PCEPExplicitRouteObject;
+import org.opendaylight.protocol.pcep.object.PCEPIncludeRouteObject;
+import org.opendaylight.protocol.pcep.object.PCEPLspObject;
+import org.opendaylight.protocol.pcep.object.PCEPLspaObject;
+import org.opendaylight.protocol.pcep.object.PCEPMetricObject;
+import org.opendaylight.protocol.pcep.object.PCEPNoPathObject;
+import org.opendaylight.protocol.pcep.object.PCEPObjectiveFunctionObject;
+import org.opendaylight.protocol.pcep.object.PCEPRequestParameterObject;
+import org.opendaylight.protocol.pcep.object.PCEPRequestedPathBandwidthObject;
+import org.opendaylight.protocol.pcep.object.PCEPSvecObject;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
+
+import com.google.common.collect.Lists;
/**
* PCEPReplyMessage validator. Validates message integrity.
*/
-// FIXME: merge with parser
-class PCEPReplyMessageValidator {
-
- // private static class SubReplyValidator {
- //
- // private boolean requestRejected = true;
- //
- // private List<Message> msgs = Lists.newArrayList();
- //
- // private PCEPRequestParameterObject rpObj;
- //
- // private PCEPNoPathObject noPath;
- // private PCEPLspObject lsp;
- // private PCEPLspaObject lspa;
- // private PCEPRequestedPathBandwidthObject bandwidth;
- // private List<PCEPMetricObject> metrics;
- // private PCEPIncludeRouteObject iro;
- // private List<CompositePathObject> paths;
- //
- // private void init() {
- // this.requestRejected = false;
- // this.msgs = Lists.newArrayList();
- //
- // this.noPath = null;
- // this.lsp = null;
- // this.lspa = null;
- // this.iro = null;
- // this.rpObj = null;
- // this.metrics = new ArrayList<PCEPMetricObject>();
- // this.paths = new ArrayList<CompositePathObject>();
- // }
- //
- // public List<Message> validate(final List<Object> objects, final List<CompositeReplySvecObject> svecList) {
- // this.init();
- //
- // if (!(objects.get(0) instanceof PCEPRequestParameterObject))
- // return null;
- //
- // final PCEPRequestParameterObject rpObj = (PCEPRequestParameterObject) objects.get(0);
- // objects.remove(0);
- //
- // Object obj;
- // int state = 1;
- // while (!objects.isEmpty()) {
- // obj = objects.get(0);
- // if (obj instanceof UnknownObject) {
- // if (((UnknownObject) obj).isProcessingRule()) {
- // this.msgs.add(new PCEPErrorMessage(new CompositeErrorObject(copyRP(rpObj, false), new
- // PCEPErrorObject(((UnknownObject) obj).getError()))));
- // this.requestRejected = true;
- // }
- //
- // objects.remove(0);
- // continue;
- // }
- //
- // switch (state) {
- // case 1:
- // state = 2;
- // if (obj instanceof PCEPNoPathObject) {
- // this.noPath = (PCEPNoPathObject) obj;
- // break;
- // }
- // case 2:
- // state = 3;
- // if (obj instanceof PCEPLspObject) {
- // this.lsp = (PCEPLspObject) obj;
- // break;
- // }
- // case 3:
- // state = 4;
- // if (obj instanceof PCEPLspaObject) {
- // this.lspa = (PCEPLspaObject) obj;
- // break;
- // }
- // case 4:
- // state = 5;
- // if (obj instanceof PCEPRequestedPathBandwidthObject) {
- // this.bandwidth = (PCEPRequestedPathBandwidthObject) obj;
- // break;
- // }
- // case 5:
- // state = 6;
- // if (obj instanceof PCEPMetricObject) {
- // this.metrics.add((PCEPMetricObject) obj);
- // state = 5;
- // break;
- // }
- // case 6:
- // state = 7;
- // if (obj instanceof PCEPIncludeRouteObject) {
- // this.iro = (PCEPIncludeRouteObject) obj;
- // state = 8;
- // break;
- // }
- // }
- //
- // if (state == 7)
- // break;
- //
- // objects.remove(0);
- //
- // if (state == 8)
- // break;
- // }
- //
- // if (!objects.isEmpty()) {
- // CompositePathObject path = this.getValidCompositePath(objects);
- // while (path != null) {
- // this.paths.add(path);
- // if (objects.isEmpty())
- // break;
- // path = this.getValidCompositePath(objects);
- // }
- // }
- //
- // if (!this.requestRejected) {
- // this.msgs.add(new PCEPReplyMessage(Collections.unmodifiableList(Arrays.asList(new CompositeResponseObject(rpObj,
- // this.noPath, this.lsp, this.lspa, this.bandwidth, this.metrics, this.iro, this.paths))),
- // Collections.unmodifiableList(svecList)));
- // }
- //
- // return this.msgs;
- // }
- //
- // private CompositePathObject getValidCompositePath(final List<Object> objects) {
- // if (!(objects.get(0) instanceof PCEPExplicitRouteObject))
- // return null;
- //
- // final PCEPExplicitRouteObject explicitRoute = (PCEPExplicitRouteObject) objects.get(0);
- // objects.remove(0);
- //
- // PCEPLspaObject pathLspa = null;
- // PCEPRequestedPathBandwidthObject pathBandwidth = null;
- // final List<PCEPMetricObject> pathMetrics = new ArrayList<PCEPMetricObject>();
- // PCEPIncludeRouteObject pathIro = null;
- //
- // Object obj;
- // int state = 1;
- // while (!objects.isEmpty()) {
- // obj = objects.get(0);
- // if (obj instanceof UnknownObject) {
- // if (((UnknownObject) obj).isProcessingRule()) {
- // this.msgs.add(new PCEPErrorMessage(new CompositeErrorObject(copyRP(this.rpObj, false), new
- // PCEPErrorObject(((UnknownObject) obj).getError()))));
- // this.requestRejected = true;
- // }
- // objects.remove(0);
- // continue;
- // }
- //
- // switch (state) {
- // case 1:
- // state = 2;
- // if (obj instanceof PCEPLspaObject) {
- // pathLspa = (PCEPLspaObject) obj;
- // break;
- // }
- // case 2:
- // state = 3;
- // if (obj instanceof PCEPRequestedPathBandwidthObject) {
- // pathBandwidth = (PCEPRequestedPathBandwidthObject) obj;
- // break;
- // }
- // case 3:
- // state = 4;
- // if (obj instanceof PCEPMetricObject) {
- // pathMetrics.add((PCEPMetricObject) obj);
- // state = 3;
- // break;
- // }
- // case 4:
- // state = 5;
- // if (obj instanceof PCEPIncludeRouteObject) {
- // pathIro = (PCEPIncludeRouteObject) obj;
- // state = 6;
- // break;
- // }
- //
- // }
- //
- // if (state == 5)
- // break;
- //
- // objects.remove(0);
- //
- // if (state == 6)
- // break;
- // }
- //
- // return new CompositePathObject(explicitRoute, pathLspa, pathBandwidth, pathMetrics, pathIro);
- // }
- // }
- //
- // @Override
- // public List<Message> validate(final List<Object> objects) throws PCEPDeserializerException {
- // if (objects == null)
- // throw new IllegalArgumentException("Passed list can't be null.");
- //
- // final List<Message> msgs = Lists.newArrayList();
- // final List<CompositeReplySvecObject> svecList = new ArrayList<CompositeReplySvecObject>();
- //
- // CompositeReplySvecObject svecComp;
- // while (!objects.isEmpty()) {
- // try {
- // if ((svecComp = this.getValidSvecComposite(objects)) == null)
- // break;
- // } catch (final PCEPDocumentedException e) {
- // msgs.add(new PCEPErrorMessage(new PCEPErrorObject(e.getError())));
- // return msgs;
- // }
- //
- // svecList.add(svecComp);
- // }
- //
- // List<Message> subMessages;
- // final SubReplyValidator subValidator = new SubReplyValidator();
- // while (!objects.isEmpty()) {
- // subMessages = subValidator.validate(objects, svecList);
- // if (subMessages == null)
- // break;
- // msgs.addAll(subMessages);
- // }
- //
- // if (msgs.isEmpty()) {
- // msgs.add(new PCEPErrorMessage(new PCEPErrorObject(PCEPErrors.RP_MISSING)));
- // return msgs;
- // }
- //
- // if (!objects.isEmpty())
- // throw new PCEPDeserializerException("Unprocessed Objects: " + objects);
- //
- // return msgs;
- // }
- //
- // private CompositeReplySvecObject getValidSvecComposite(final List<Object> objects) throws PCEPDocumentedException
- // {
- // if (objects == null)
- // throw new IllegalArgumentException("List cannot be null.");
- //
- // if (!(objects.get(0) instanceof PCEPSvecObject))
- // return null;
- //
- // final PCEPSvecObject svec = (PCEPSvecObject) objects.get(0);
- // objects.remove(0);
- //
- // PCEPObjectiveFunctionObject of = null;
- // final List<PCEPMetricObject> metrics = new ArrayList<PCEPMetricObject>();
- //
- // Object obj;
- // int state = 1;
- // while (!objects.isEmpty()) {
- // obj = objects.get(0);
- //
- // if (obj instanceof UnknownObject)
- // throw new PCEPDocumentedException("Unknown object", ((UnknownObject) obj).getError());
- //
- // switch (state) {
- // case 1:
- // state = 2;
- // if (obj instanceof PCEPObjectiveFunctionObject) {
- // of = (PCEPObjectiveFunctionObject) obj;
- // break;
- // }
- // case 2:
- // state = 3;
- // if (obj instanceof PCEPMetricObject) {
- // metrics.add((PCEPMetricObject) obj);
- // state = 2;
- // break;
- // }
- // }
- //
- // if (state == 3)
- // break;
- //
- // objects.remove(0);
- // }
- //
- // return new CompositeReplySvecObject(svec, of, metrics);
- // }
- //
- // private static PCEPRequestParameterObject copyRP(final PCEPRequestParameterObject origRp, final boolean
- // processed) {
- // return new PCEPRequestParameterObject(origRp.isLoose(), origRp.isBidirectional(), origRp.isReoptimized(),
- // origRp.isMakeBeforeBreak(), origRp.isReportRequestOrder(), origRp.isSuplyOFOnResponse(),
- // origRp.isFragmentation(), origRp.isP2mp(), origRp.isEroCompression(), origRp.getPriority(),
- // origRp.getRequestID(), origRp.getTlvs(), processed, origRp.isIgnored());
- // }
+public class PCEPReplyMessageValidator extends PCEPMessageValidator {
+
+ private static class SubReplyValidator {
+
+ private boolean requestRejected = true;
+
+ private List<Message> msgs = Lists.newArrayList();
+
+ private PCEPRequestParameterObject rpObj;
+
+ private PCEPNoPathObject noPath;
+ private PCEPLspObject lsp;
+ private PCEPLspaObject lspa;
+ private PCEPRequestedPathBandwidthObject bandwidth;
+ private List<PCEPMetricObject> metrics;
+ private PCEPIncludeRouteObject iro;
+ private List<CompositePathObject> paths;
+
+ private void init() {
+ this.requestRejected = false;
+ this.msgs = Lists.newArrayList();
+
+ this.noPath = null;
+ this.lsp = null;
+ this.lspa = null;
+ this.iro = null;
+ this.rpObj = null;
+ this.metrics = new ArrayList<PCEPMetricObject>();
+ this.paths = new ArrayList<CompositePathObject>();
+ }
+
+ public List<Message> validate(final List<PCEPObject> objects, final List<CompositeReplySvecObject> svecList) {
+ this.init();
+
+ if (!(objects.get(0) instanceof PCEPRequestParameterObject))
+ return null;
+
+ final PCEPRequestParameterObject rpObj = (PCEPRequestParameterObject) objects.get(0);
+ objects.remove(0);
+
+ PCEPObject obj;
+ int state = 1;
+ while (!objects.isEmpty()) {
+ obj = objects.get(0);
+ if (obj instanceof UnknownObject) {
+ if (((UnknownObject) obj).isProcessed()) {
+ this.msgs.add(new PCEPErrorMessage(new CompositeErrorObject(copyRP(rpObj, false), new PCEPErrorObject(((UnknownObject) obj).getError()))));
+ this.requestRejected = true;
+ }
+
+ objects.remove(0);
+ continue;
+ }
+
+ switch (state) {
+ case 1:
+ state = 2;
+ if (obj instanceof PCEPNoPathObject) {
+ this.noPath = (PCEPNoPathObject) obj;
+ break;
+ }
+ case 2:
+ state = 3;
+ if (obj instanceof PCEPLspObject) {
+ this.lsp = (PCEPLspObject) obj;
+ break;
+ }
+ case 3:
+ state = 4;
+ if (obj instanceof PCEPLspaObject) {
+ this.lspa = (PCEPLspaObject) obj;
+ break;
+ }
+ case 4:
+ state = 5;
+ if (obj instanceof PCEPRequestedPathBandwidthObject) {
+ this.bandwidth = (PCEPRequestedPathBandwidthObject) obj;
+ break;
+ }
+ case 5:
+ state = 6;
+ if (obj instanceof PCEPMetricObject) {
+ this.metrics.add((PCEPMetricObject) obj);
+ state = 5;
+ break;
+ }
+ case 6:
+ state = 7;
+ if (obj instanceof PCEPIncludeRouteObject) {
+ this.iro = (PCEPIncludeRouteObject) obj;
+ state = 8;
+ break;
+ }
+ }
+
+ if (state == 7)
+ break;
+
+ objects.remove(0);
+
+ if (state == 8)
+ break;
+ }
+
+ if (!objects.isEmpty()) {
+ CompositePathObject path = this.getValidCompositePath(objects);
+ while (path != null) {
+ this.paths.add(path);
+ if (objects.isEmpty())
+ break;
+ path = this.getValidCompositePath(objects);
+ }
+ }
+
+ if (!this.requestRejected) {
+ this.msgs.add(new PCEPReplyMessage(Collections.unmodifiableList(Arrays.asList(new CompositeResponseObject(rpObj, this.noPath, this.lsp, this.lspa, this.bandwidth, this.metrics, this.iro, this.paths))), Collections.unmodifiableList(svecList)));
+ }
+
+ return this.msgs;
+ }
+
+ private CompositePathObject getValidCompositePath(final List<PCEPObject> objects) {
+ if (!(objects.get(0) instanceof PCEPExplicitRouteObject))
+ return null;
+
+ final PCEPExplicitRouteObject explicitRoute = (PCEPExplicitRouteObject) objects.get(0);
+ objects.remove(0);
+
+ PCEPLspaObject pathLspa = null;
+ PCEPRequestedPathBandwidthObject pathBandwidth = null;
+ final List<PCEPMetricObject> pathMetrics = new ArrayList<PCEPMetricObject>();
+ PCEPIncludeRouteObject pathIro = null;
+
+ PCEPObject obj;
+ int state = 1;
+ while (!objects.isEmpty()) {
+ obj = objects.get(0);
+ if (obj instanceof UnknownObject) {
+ if (((UnknownObject) obj).isProcessed()) {
+ this.msgs.add(new PCEPErrorMessage(new CompositeErrorObject(copyRP(this.rpObj, false), new PCEPErrorObject(((UnknownObject) obj).getError()))));
+ this.requestRejected = true;
+ }
+ objects.remove(0);
+ continue;
+ }
+
+ switch (state) {
+ case 1:
+ state = 2;
+ if (obj instanceof PCEPLspaObject) {
+ pathLspa = (PCEPLspaObject) obj;
+ break;
+ }
+ case 2:
+ state = 3;
+ if (obj instanceof PCEPRequestedPathBandwidthObject) {
+ pathBandwidth = (PCEPRequestedPathBandwidthObject) obj;
+ break;
+ }
+ case 3:
+ state = 4;
+ if (obj instanceof PCEPMetricObject) {
+ pathMetrics.add((PCEPMetricObject) obj);
+ state = 3;
+ break;
+ }
+ case 4:
+ state = 5;
+ if (obj instanceof PCEPIncludeRouteObject) {
+ pathIro = (PCEPIncludeRouteObject) obj;
+ state = 6;
+ break;
+ }
+
+ }
+
+ if (state == 5)
+ break;
+
+ objects.remove(0);
+
+ if (state == 6)
+ break;
+ }
+
+ return new CompositePathObject(explicitRoute, pathLspa, pathBandwidth, pathMetrics, pathIro);
+ }
+ }
+
+ @Override
+ public List<Message> validate(final List<PCEPObject> objects) throws PCEPDeserializerException {
+ if (objects == null)
+ throw new IllegalArgumentException("Passed list can't be null.");
+
+ final List<Message> msgs = Lists.newArrayList();
+ final List<CompositeReplySvecObject> svecList = new ArrayList<CompositeReplySvecObject>();
+
+ CompositeReplySvecObject svecComp;
+ while (!objects.isEmpty()) {
+ try {
+ if ((svecComp = this.getValidSvecComposite(objects)) == null)
+ break;
+ } catch (final PCEPDocumentedException e) {
+ msgs.add(new PCEPErrorMessage(new PCEPErrorObject(e.getError())));
+ return msgs;
+ }
+
+ svecList.add(svecComp);
+ }
+
+ List<Message> subMessages;
+ final SubReplyValidator subValidator = new SubReplyValidator();
+ while (!objects.isEmpty()) {
+ subMessages = subValidator.validate(objects, svecList);
+ if (subMessages == null)
+ break;
+ msgs.addAll(subMessages);
+ }
+
+ if (msgs.isEmpty()) {
+ msgs.add(new PCEPErrorMessage(new PCEPErrorObject(PCEPErrors.RP_MISSING)));
+ return msgs;
+ }
+
+ if (!objects.isEmpty())
+ throw new PCEPDeserializerException("Unprocessed Objects: " + objects);
+
+ return msgs;
+ }
+
+ private CompositeReplySvecObject getValidSvecComposite(final List<PCEPObject> objects) throws PCEPDocumentedException {
+ if (objects == null)
+ throw new IllegalArgumentException("List cannot be null.");
+
+ if (!(objects.get(0) instanceof PCEPSvecObject))
+ return null;
+
+ final PCEPSvecObject svec = (PCEPSvecObject) objects.get(0);
+ objects.remove(0);
+
+ PCEPObjectiveFunctionObject of = null;
+ final List<PCEPMetricObject> metrics = new ArrayList<PCEPMetricObject>();
+
+ PCEPObject obj;
+ int state = 1;
+ while (!objects.isEmpty()) {
+ obj = objects.get(0);
+
+ if (obj instanceof UnknownObject)
+ throw new PCEPDocumentedException("Unknown object", ((UnknownObject) obj).getError());
+
+ switch (state) {
+ case 1:
+ state = 2;
+ if (obj instanceof PCEPObjectiveFunctionObject) {
+ of = (PCEPObjectiveFunctionObject) obj;
+ break;
+ }
+ case 2:
+ state = 3;
+ if (obj instanceof PCEPMetricObject) {
+ metrics.add((PCEPMetricObject) obj);
+ state = 2;
+ break;
+ }
+ }
+
+ if (state == 3)
+ break;
+
+ objects.remove(0);
+ }
+
+ return new CompositeReplySvecObject(svec, of, metrics);
+ }
+
+ private static PCEPRequestParameterObject copyRP(final PCEPRequestParameterObject origRp, final boolean processed) {
+ return new PCEPRequestParameterObject(origRp.isLoose(), origRp.isBidirectional(), origRp.isReoptimized(), origRp.isMakeBeforeBreak(), origRp.isReportRequestOrder(), origRp.isSuplyOFOnResponse(), origRp.isFragmentation(), origRp.isP2mp(), origRp.isEroCompression(), origRp.getPriority(), origRp.getRequestID(), origRp.getTlvs(), processed, origRp.isIgnored());
+ }
}
Code Review / bgpcep.git / blobdiff