2 * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.protocol.pcep.ietf.stateful07;
10 import io.netty.buffer.ByteBuf;
12 import java.util.ArrayList;
13 import java.util.List;
15 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
16 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
17 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
18 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
19 import org.opendaylight.protocol.pcep.spi.UnknownObject;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.StatefulCase;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.stateful._case.stateful.Srps;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.stateful._case.stateful.SrpsBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
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.PcerrMessage;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCase;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCaseBuilder;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCase;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.RequestBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.Rps;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.RpsBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
44 * Parser for {@link PcerrMessage}
46 public final class Stateful07ErrorMessageParser extends PCEPErrorMessageParser {
48 public Stateful07ErrorMessageParser(final ObjectRegistry registry) {
53 public void serializeMessage(final Message message, final ByteBuf buffer) {
54 if (!(message instanceof PcerrMessage)) {
55 throw new IllegalArgumentException("Wrong instance of Message. Passed instance " + message.getClass()
56 + ". Nedded ErrorMessage.");
58 final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessage err = ((PcerrMessage) message).getPcerrMessage();
60 if (err.getErrors() == null || err.getErrors().isEmpty()) {
61 throw new IllegalArgumentException("Errors should not be empty.");
64 if (err.getErrorType() instanceof RequestCase) {
65 final List<Rps> rps = ((RequestCase) err.getErrorType()).getRequest().getRps();
66 for (final Rps r : rps) {
67 buffer.writeBytes(serializeObject(r.getRp()));
71 if (err.getErrorType() instanceof StatefulCase) {
72 final List<Srps> srps = ((StatefulCase) err.getErrorType()).getStateful().getSrps();
73 for (final Srps s : srps) {
74 buffer.writeBytes(serializeObject(s.getSrp()));
78 for (final Errors e : err.getErrors()) {
79 buffer.writeBytes(serializeObject(e.getErrorObject()));
82 if (err.getErrorType() instanceof SessionCase) {
83 buffer.writeBytes(serializeObject(((SessionCase) err.getErrorType()).getSession().getOpen()));
88 protected PcerrMessage validate(final List<Object> objects, final List<Message> errors) throws PCEPDeserializerException {
89 if (objects == null) {
90 throw new IllegalArgumentException("Passed list can't be null.");
93 if (objects.isEmpty()) {
94 throw new PCEPDeserializerException("Error message is empty.");
97 final List<Rps> requestParameters = new ArrayList<>();
98 final List<Srps> srps = new ArrayList<>();
99 final List<Errors> errorObjects = new ArrayList<>();
100 final PcerrMessageBuilder b = new PcerrMessageBuilder();
103 State state = State.Init;
104 obj = objects.get(0);
106 if (obj instanceof ErrorObject) {
107 final ErrorObject o = (ErrorObject) obj;
108 errorObjects.add(new ErrorsBuilder().setErrorObject(o).build());
109 state = State.ErrorIn;
111 } else if (obj instanceof Rp) {
112 final Rp o = (Rp) obj;
113 if (o.isProcessingRule()) {
114 errors.add(createErrorMsg(PCEPErrors.P_FLAG_NOT_SET));
117 requestParameters.add(new RpsBuilder().setRp(o).build());
120 } else if (obj instanceof Srp) {
121 final Srp s = (Srp) obj;
122 srps.add(new SrpsBuilder().setSrp(s).build());
127 while (!objects.isEmpty()) {
128 obj = objects.get(0);
130 if (obj instanceof UnknownObject) {
131 return new PcerrBuilder().setPcerrMessage(b.setErrors(((UnknownObject) obj).getErrors()).build()).build();
137 if (obj instanceof ErrorObject) {
138 final ErrorObject o = (ErrorObject) obj;
139 errorObjects.add(new ErrorsBuilder().setErrorObject(o).build());
140 state = State.ErrorIn;
145 if (obj instanceof Rp) {
146 final Rp o = ((Rp) obj);
147 requestParameters.add(new RpsBuilder().setRp(o).build());
153 if (obj instanceof Srp) {
154 final Srp o = ((Srp) obj);
155 srps.add(new SrpsBuilder().setSrp(o).build());
160 state = State.OpenIn;
161 if (obj instanceof Open) {
162 b.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen((Open) obj).build()).build());
166 state = State.OpenIn;
167 if (obj instanceof ErrorObject) {
168 final ErrorObject o = (ErrorObject) obj;
169 errorObjects.add(new ErrorsBuilder().setErrorObject(o).build());
181 if (!state.equals(State.End)) {
186 if (errorObjects.isEmpty() && errorObjects.isEmpty()) {
187 throw new PCEPDeserializerException("At least one PCEPErrorObject is mandatory.");
190 if (!objects.isEmpty()) {
191 throw new PCEPDeserializerException("Unprocessed Objects: " + objects);
193 if (requestParameters != null && !requestParameters.isEmpty()) {
194 b.setErrorType(new RequestCaseBuilder().setRequest(new RequestBuilder().setRps(requestParameters).build()).build());
197 return new PcerrBuilder().setPcerrMessage(b.setErrors(errorObjects).build()).build();
201 Init, ErrorIn, RpIn, SrpIn, Open, Error, OpenIn, End