Update MRI projects for Aluminium
[bgpcep.git] / bgp / extensions / linkstate / src / main / java / org / opendaylight / protocol / bgp / linkstate / spi / pojo / SimpleBindingSubTlvsRegistry.java
1 /*
2  * Copyright (c) 2016 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 package org.opendaylight.protocol.bgp.linkstate.spi.pojo;
9
10 import io.netty.buffer.ByteBuf;
11 import java.util.ArrayList;
12 import java.util.List;
13 import org.opendaylight.protocol.bgp.linkstate.spi.BindingSubTlvsParser;
14 import org.opendaylight.protocol.bgp.linkstate.spi.BindingSubTlvsSerializer;
15 import org.opendaylight.protocol.concepts.HandlerRegistry;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.ProtocolId;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev200120.binding.sid.tlv.BindingSubTlvs;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev200120.binding.sid.tlv.BindingSubTlvsBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.segment.routing.ext.rev200120.binding.sub.tlvs.BindingSubTlv;
20 import org.opendaylight.yangtools.concepts.Registration;
21 import org.opendaylight.yangtools.yang.binding.DataContainer;
22 import org.slf4j.Logger;
23 import org.slf4j.LoggerFactory;
24
25 public final class SimpleBindingSubTlvsRegistry {
26     private static final Logger LOG = LoggerFactory.getLogger(SimpleBindingSubTlvsRegistry.class);
27     private static final SimpleBindingSubTlvsRegistry SINGLETON = new SimpleBindingSubTlvsRegistry();
28     private final HandlerRegistry<DataContainer, BindingSubTlvsParser, BindingSubTlvsSerializer> handlers =
29             new HandlerRegistry<>();
30
31     private SimpleBindingSubTlvsRegistry() {
32     }
33
34     public static SimpleBindingSubTlvsRegistry getInstance() {
35         return SINGLETON;
36     }
37
38     public Registration registerBindingSubTlvsParser(final int bindingSubTlvsType, final BindingSubTlvsParser parser) {
39         return this.handlers.registerParser(bindingSubTlvsType, parser);
40     }
41
42     public Registration registerBindingSubTlvsSerializer(final Class<? extends BindingSubTlv> esiType,
43             final BindingSubTlvsSerializer serializer) {
44         return this.handlers.registerSerializer(esiType, serializer);
45     }
46
47     public void serializeBindingSubTlvs(final List<BindingSubTlvs> bindingSubTlvs, final ByteBuf aggregator) {
48         if (bindingSubTlvs != null) {
49             for (final BindingSubTlvs subTlv : bindingSubTlvs) {
50                 final BindingSubTlv bindingSubTlv = subTlv.getBindingSubTlv();
51                 final BindingSubTlvsSerializer serializer = this.handlers.getSerializer(
52                     bindingSubTlv.implementedInterface());
53                 if (serializer == null) {
54                     LOG.info("Unknown binding sub Tlv type {}", subTlv);
55                     return;
56                 }
57                 serializer.serializeSubTlv(bindingSubTlv, aggregator);
58             }
59         }
60     }
61
62     public List<BindingSubTlvs> parseBindingSubTlvs(final ByteBuf buffer, final ProtocolId protocolId) {
63         final List<BindingSubTlvs> subTlvs = new ArrayList<>();
64         if (buffer != null) {
65             while (buffer.isReadable()) {
66                 final int type = buffer.readUnsignedShort();
67                 final int length = buffer.readUnsignedShort();
68                 final ByteBuf slice = buffer.readSlice(length);
69                 final BindingSubTlvsParser parser = this.handlers.getParser(type);
70                 if (parser == null) {
71                     return null;
72                 }
73                 subTlvs.add(new BindingSubTlvsBuilder().setBindingSubTlv(parser.parseSubTlv(slice, protocolId))
74                     .build());
75             }
76         }
77         return subTlvs;
78     }
79 }