2 * Copyright (c) 2015 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.bmp.parser.message;
11 import com.google.common.base.Preconditions;
12 import io.netty.buffer.ByteBuf;
13 import io.netty.buffer.Unpooled;
14 import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry;
15 import org.opendaylight.protocol.bmp.spi.parser.AbstractBmpPerPeerMessageParser;
16 import org.opendaylight.protocol.bmp.spi.parser.BmpDeserializationException;
17 import org.opendaylight.protocol.bmp.spi.parser.BmpTlvRegistry;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.OpenBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.UpdateBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.RouteMirroringMessage;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.RouteMirroringMessageBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.Tlv;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.mirror.Tlvs;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.mirror.TlvsBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.mirror.information.tlv.MirrorInformationTlv;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.mirror.pdu.tlvs.PduOpenTlv;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev150512.mirror.pdu.tlvs.PduUpdateTlv;
28 import org.opendaylight.yangtools.yang.binding.Notification;
30 public class RouteMirroringMessageHandler extends AbstractBmpPerPeerMessageParser<TlvsBuilder> {
32 private static final int MESSAGE_TYPE = 6;
34 public RouteMirroringMessageHandler(final MessageRegistry bgpMssageRegistry, final BmpTlvRegistry tlvRegistry) {
35 super(bgpMssageRegistry, tlvRegistry);
39 public void serializeMessageBody(final Notification message, final ByteBuf buffer) {
40 super.serializeMessageBody(message, buffer);
41 Preconditions.checkArgument(message instanceof RouteMirroringMessage, "An instance of RouteMirroringMessage is required");
42 final RouteMirroringMessage routeMirror = (RouteMirroringMessage) message;
43 serializeTlvs(routeMirror.getTlvs(), buffer);
47 public Notification parseMessageBody(final ByteBuf bytes) throws BmpDeserializationException {
48 final RouteMirroringMessageBuilder routeMirror = new RouteMirroringMessageBuilder().setPeerHeader(parsePerPeerHeader(bytes));
49 final TlvsBuilder tlvsBuilder = new TlvsBuilder();
50 parseTlvs(tlvsBuilder, bytes);
51 return routeMirror.setTlvs(tlvsBuilder.build()).build();
54 protected void serializeTlvs(final Tlvs tlvs, final ByteBuf output) {
55 final ByteBuf tlvsBuffer = Unpooled.buffer();
56 if (tlvs.getMirrorInformationTlv() != null) {
57 serializeTlv(tlvs.getMirrorInformationTlv(), tlvsBuffer);
59 if (tlvs.getPduUpdateTlv() != null) {
60 getBgpMessageRegistry().serializeMessage(new UpdateBuilder(tlvs.getPduUpdateTlv()).build(), tlvsBuffer);
62 if (tlvs.getPduOpenTlv() != null) {
63 getBgpMessageRegistry().serializeMessage(new OpenBuilder(tlvs.getPduOpenTlv()).build(), tlvsBuffer);
66 output.writeBytes(tlvsBuffer);
71 public int getBmpMessageType() {
76 protected void addTlv(final TlvsBuilder builder, final Tlv tlv) {
77 if (tlv instanceof MirrorInformationTlv) {
78 builder.setMirrorInformationTlv((MirrorInformationTlv) tlv);
79 } else if (tlv instanceof PduUpdateTlv) {
80 builder.setPduUpdateTlv((PduUpdateTlv) tlv);
81 } else if (tlv instanceof PduOpenTlv) {
82 builder.setPduOpenTlv((PduOpenTlv) tlv);