2 * Copyright (c) 2014 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
9 package org.opendaylight.protocol.pcep.segment.routing02;
11 import com.google.common.base.Optional;
12 import com.google.common.collect.Lists;
13 import io.netty.buffer.ByteBuf;
14 import java.util.List;
15 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
16 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
17 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
18 import org.opendaylight.protocol.pcep.spi.VendorInformationObjectRegistry;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.Result;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCase;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCaseBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.SuccessBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.Paths;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.PathsBuilder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
32 public class SrPcRepMessageParser extends PCEPReplyMessageParser {
34 public SrPcRepMessageParser(final ObjectRegistry registry, final VendorInformationObjectRegistry viRegistry) {
35 super(registry, viRegistry);
39 protected void serializeReply(Replies reply, ByteBuf buffer) {
40 final Rp rp = reply.getRp();
41 if (SrEroUtil.isSegmentRoutingPath(rp)) {
42 serializeObject(rp, buffer);
43 if (reply.getResult() instanceof SuccessCase) {
44 final SuccessCase s = (SuccessCase) reply.getResult();
45 for (final Paths p : s.getSuccess().getPaths()) {
46 final Ero ero = p.getEro();
47 serializeObject(ero, buffer);
51 super.serializeReply(reply, buffer);
56 protected Replies getValidReply(List<Object> objects, List<Message> errors) {
57 if (!(objects.get(0) instanceof Rp)) {
58 errors.add(createErrorMsg(PCEPErrors.RP_MISSING, Optional.<Rp>absent()));
61 final Rp rp = (Rp) objects.get(0);
62 if (SrEroUtil.isSegmentRoutingPath(rp)) {
65 if (objects.get(0) instanceof Ero) {
66 final SuccessBuilder builder = new SuccessBuilder();
67 final List<Paths> paths = Lists.newArrayList();
68 final PathsBuilder pBuilder = new PathsBuilder();
69 while (!objects.isEmpty()) {
70 final Object object = objects.get(0);
71 if (object instanceof Ero) {
72 final Ero ero = (Ero) object;
73 final PCEPErrors error = SrEroUtil.validateSrEroSubobjects(ero);
75 errors.add(createErrorMsg(error, Optional.<Rp>absent()));
78 paths.add(pBuilder.setEro(ero).build());
83 builder.setPaths(paths);
84 res = new SuccessCaseBuilder().setSuccess(builder.build()).build();
86 return new RepliesBuilder().setRp(rp).setResult(res).build();
88 return super.getValidReply(objects, errors);