BUG-64 : initial rewrite, ObjectRegistry. 43/5643/4
authorDana Kutenicsova <dkutenic@cisco.com>
Fri, 14 Mar 2014 11:41:37 +0000 (12:41 +0100)
committerDana Kutenicsova <dkutenic@cisco.com>
Thu, 20 Mar 2014 09:32:15 +0000 (10:32 +0100)
Change-Id: I92764b8f0c44cab1b5b5c83f60f3153be873afda
Signed-off-by: Dana Kutenicsova <dkutenic@cisco.com>
25 files changed:
pcep/ietf-stateful02/src/main/java/org/opendaylight/protocol/pcep/crabbe/initiated00/PcinitiateMessageParser.java
pcep/ietf-stateful02/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful02/Stateful02PCReplyMessageParser.java
pcep/ietf-stateful02/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful02/Stateful02PCReportMessageParser.java
pcep/ietf-stateful02/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful02/Stateful02PCRequestMessageParser.java
pcep/ietf-stateful02/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful02/Stateful02PCUpdateRequestMessageParser.java
pcep/ietf-stateful07/src/main/java/org/opendaylight/protocol/pcep/ietf/initiated00/CInitiated00PCInitiateMessageParser.java
pcep/ietf-stateful07/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful07/Stateful07ErrorMessageParser.java
pcep/ietf-stateful07/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful07/Stateful07PCReportMessageParser.java
pcep/ietf-stateful07/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful07/Stateful07PCUpdateRequestMessageParser.java
pcep/ietf-stateful07/src/main/java/org/opendaylight/protocol/pcep/ietf/stateful07/StatefulActivator.java
pcep/ietf-stateful07/src/test/java/org/opendaylight/protocol/pcep/ietf/PCEPValidatorTest.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/Activator.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPCloseMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPErrorMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPKeepAliveMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPNotificationMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPOpenMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPReplyMessageParser.java
pcep/impl/src/main/java/org/opendaylight/protocol/pcep/impl/message/PCEPRequestMessageParser.java
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/AbstractMessageParser.java
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectHandlerRegistry.java [deleted file]
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectRegistry.java [new file with mode: 0644]
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/PCEPExtensionConsumerContext.java
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleObjectRegistry.java [moved from pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleObjectHandlerRegistry.java with 66% similarity]
pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimplePCEPExtensionProviderContext.java

index cf2f58b47272c9232304be7b729afcf1d9446ffd..45184711fd1f000dc41ca836c81ef819464ff63e 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated._00.rev140113.Pcinitiate;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated._00.rev140113.PcinitiateBuilder;
@@ -37,7 +37,7 @@ import com.google.common.collect.Lists;
 public class PcinitiateMessageParser extends AbstractMessageParser {
        public static final int TYPE = 12;
 
-       public PcinitiateMessageParser(final ObjectHandlerRegistry registry) {
+       public PcinitiateMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 18ec0ffe40410e307cbd6384de2cfa0dbf4b3f94..a395f2d72a9e767894f9db92e5cc79b305c849f1 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.Replies1;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.Replies1Builder;
@@ -42,7 +42,7 @@ import com.google.common.collect.Lists;
  */
 public final class Stateful02PCReplyMessageParser extends PCEPReplyMessageParser {
 
-       public Stateful02PCReplyMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful02PCReplyMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index edcaedee210eab7558ae5484e00bfe432d8eac0b..993bed582292e1848e8670255424d2ae60c7c50c 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.Pcrpt;
@@ -42,7 +42,7 @@ public final class Stateful02PCReportMessageParser extends AbstractMessageParser
 
        public static final int TYPE = 10;
 
-       public Stateful02PCReportMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful02PCReportMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 92548d11ab2e0a9ca719e39c8296fa10c8fbeddf..fce72d3671d0259d3065aa39d2d532277cc52d22 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.impl.message.PCEPRequestMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.P2p1;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.P2p1Builder;
@@ -47,7 +47,7 @@ import com.google.common.collect.Lists;
  */
 public final class Stateful02PCRequestMessageParser extends PCEPRequestMessageParser {
 
-       public Stateful02PCRequestMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful02PCRequestMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index fee0a0298e864d072dcce9c776c029b95eeafe8d..fb00c4f3741799039b40c259613a59b00e3f795c 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.stateful._02.rev140110.Pcupd;
@@ -42,7 +42,7 @@ public final class Stateful02PCUpdateRequestMessageParser extends AbstractMessag
 
        public static final int TYPE = 11;
 
-       public Stateful02PCUpdateRequestMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful02PCUpdateRequestMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index e58e55a580443837bcb8e33dc1e71a95a281ab77..4a2ec855a1f72ed001149594da22b3d49c7d804e 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Pcinitiate;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.PcinitiateBuilder;
@@ -42,7 +42,7 @@ public final class CInitiated00PCInitiateMessageParser extends AbstractMessagePa
 
        public static final int TYPE = 12;
 
-       public CInitiated00PCInitiateMessageParser(final ObjectHandlerRegistry registry) {
+       public CInitiated00PCInitiateMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 16138de4f0b3c76a7831a8ab6686a658c2fd7130..83a42f17000f808b7f14e7afa1bb6a644a9181da 100644 (file)
@@ -13,7 +13,7 @@ import java.util.ArrayList;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.protocol.pcep.spi.UnknownObject;
@@ -45,7 +45,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.typ
  */
 public final class Stateful07ErrorMessageParser extends PCEPErrorMessageParser {
 
-       public Stateful07ErrorMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful07ErrorMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 0972aad359cbfb3941c9495ff24eef9df3413f30..b00bc2a84f054ca44dae9ed174dd1dc8cde6e37c 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Pcrpt;
@@ -44,7 +44,7 @@ public final class Stateful07PCReportMessageParser extends AbstractMessageParser
 
        public static final int TYPE = 10;
 
-       public Stateful07PCReportMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful07PCReportMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index c35f844f4d7b23134a2791abcc8b7f1ddc9a40fc..5b9992721ef518db61a1fb8568d874773e00a077 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Pcupd;
@@ -43,7 +43,7 @@ public final class Stateful07PCUpdateRequestMessageParser extends AbstractMessag
 
        public static final int TYPE = 11;
 
-       public Stateful07PCUpdateRequestMessageParser(final ObjectHandlerRegistry registry) {
+       public Stateful07PCUpdateRequestMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 0125e462f9db915e916b8753997bbbae882cbf46..0733de79717e9ec25c255db5be1455dc82a53938 100644 (file)
@@ -10,7 +10,7 @@ package org.opendaylight.protocol.pcep.ietf.stateful07;
 import java.util.ArrayList;
 import java.util.List;
 
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPExtensionProviderContext;
 import org.opendaylight.protocol.pcep.spi.TlvRegistry;
 import org.opendaylight.protocol.pcep.spi.pojo.AbstractPCEPExtensionProviderActivator;
@@ -30,7 +30,7 @@ public final class StatefulActivator extends AbstractPCEPExtensionProviderActiva
        protected List<AutoCloseable> startImpl(final PCEPExtensionProviderContext context) {
                final List<AutoCloseable> regs = new ArrayList<>();
 
-               final ObjectHandlerRegistry objReg = context.getObjectHandlerRegistry();
+               final ObjectRegistry objReg = context.getObjectHandlerRegistry();
                regs.add(context.registerMessageParser(Stateful07PCUpdateRequestMessageParser.TYPE, new Stateful07PCUpdateRequestMessageParser(objReg)));
                regs.add(context.registerMessageSerializer(Pcupd.class, new Stateful07PCUpdateRequestMessageParser(objReg)));
                regs.add(context.registerMessageParser(Stateful07PCReportMessageParser.TYPE, new Stateful07PCReportMessageParser(objReg)));
index 61ea60a9221244a6699e9c9d9fbb681e880c3e60..4dd3464e780b7c8fb58adf0976482d22ab5e2764 100644 (file)
@@ -31,7 +31,7 @@ import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser
 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
 import org.opendaylight.protocol.pcep.impl.message.PCEPRequestMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
 import org.opendaylight.protocol.util.ByteArray;
@@ -148,7 +148,7 @@ import com.google.common.collect.Lists;
 
 public class PCEPValidatorTest {
 
-       private ObjectHandlerRegistry objectRegistry;
+       private ObjectRegistry objectRegistry;
 
        private Rp rpTrue;
        private Rp rpFalse;
index fb1ba57facd2afa70f89b0c5809518f9542b8c67..38e8b04998987246383bbc42d02067b924e29464 100644 (file)
@@ -66,7 +66,7 @@ import org.opendaylight.protocol.pcep.impl.tlv.OverloadedDurationTlvParser;
 import org.opendaylight.protocol.pcep.impl.tlv.ReqMissingTlvParser;
 import org.opendaylight.protocol.pcep.spi.EROSubobjectRegistry;
 import org.opendaylight.protocol.pcep.spi.LabelHandlerRegistry;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPExtensionProviderContext;
 import org.opendaylight.protocol.pcep.spi.RROSubobjectRegistry;
 import org.opendaylight.protocol.pcep.spi.TlvRegistry;
@@ -187,7 +187,7 @@ public final class Activator extends AbstractPCEPExtensionProviderActivator {
                context.registerTlvSerializer(OfList.class, new OFListTlvParser());
                context.registerTlvSerializer(Order.class, new OrderTlvParser());
 
-               final ObjectHandlerRegistry objReg = context.getObjectHandlerRegistry();
+               final ObjectRegistry objReg = context.getObjectHandlerRegistry();
                context.registerObjectParser(PCEPRequestParameterObjectParser.CLASS, PCEPRequestParameterObjectParser.TYPE,
                                new PCEPRequestParameterObjectParser(tlvReg));
                context.registerObjectParser(PCEPNoPathObjectParser.CLASS, PCEPNoPathObjectParser.TYPE, new PCEPNoPathObjectParser(tlvReg));
index 2001581b1637e27a09636a6e710b9bc49e1f120c..a700f467f0d01950d938dbf866ce5e5f2704fd4a 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.Close;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
@@ -30,7 +30,7 @@ public class PCEPCloseMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 7;
 
-       public PCEPCloseMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPCloseMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 3b763470f2e975017544571e63ccf58cc173eee8..a69d128cb131940134ba94b79b1124807bec5337 100644 (file)
@@ -13,7 +13,7 @@ import java.util.ArrayList;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.protocol.pcep.spi.UnknownObject;
@@ -43,7 +43,7 @@ public class PCEPErrorMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 6;
 
-       public PCEPErrorMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPErrorMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 7eedb858f08d801e91dd10f545ce56b4974d9770..81aaded51f247bc404d4898134a30eb6f0069bfe 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.KeepaliveMessage;
@@ -27,7 +27,7 @@ public class PCEPKeepAliveMessageParser extends AbstractMessageParser {
        private static final KeepaliveMessage MESSAGE = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build()).build();
        public static final int TYPE = 2;
 
-       public PCEPKeepAliveMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPKeepAliveMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index ca04a80df848a9128df4c3ac0e6490c55b0ad963..ed8a40d4969897b498a094c1d6e10dc5535bca2e 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
@@ -36,7 +36,7 @@ public class PCEPNotificationMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 5;
 
-       public PCEPNotificationMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPNotificationMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 2584a0144b484b9bf4a020706e8eadfca17c3d42..81e157ed6922593af2124420bed8af5174e1afa1 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
@@ -28,7 +28,7 @@ public class PCEPOpenMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 1;
 
-       public PCEPOpenMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPOpenMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index fba2eb3269df25a9d0904a63cc97b84b639810cc..590b5ec00ffdede221fec2729a1c6cdc603ebb9a 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.Pcrep;
@@ -50,7 +50,7 @@ public class PCEPReplyMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 4;
 
-       public PCEPReplyMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPReplyMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 44fbed0d2e6d84714fd5172874e87162671c3fb0..015ab58680e196ccaa711e37592b3951ccb185ee 100644 (file)
@@ -12,7 +12,7 @@ import io.netty.buffer.ByteBuf;
 import java.util.List;
 
 import org.opendaylight.protocol.pcep.spi.AbstractMessageParser;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.Pcreq;
@@ -58,7 +58,7 @@ public class PCEPRequestMessageParser extends AbstractMessageParser {
 
        public static final int TYPE = 3;
 
-       public PCEPRequestMessageParser(final ObjectHandlerRegistry registry) {
+       public PCEPRequestMessageParser(final ObjectRegistry registry) {
                super(registry);
        }
 
index 8d865e3f777bfc113e065512db93a6dad578fc64..97ce4243f357db907757fddfb7c6ebbd3d7b24f4 100644 (file)
@@ -53,9 +53,9 @@ public abstract class AbstractMessageParser implements MessageParser, MessageSer
        private static final int P_FLAG_OFFSET = 6;
        private static final int I_FLAG_OFFSET = 7;
 
-       private final ObjectHandlerRegistry registry;
+       private final ObjectRegistry registry;
 
-       protected AbstractMessageParser(final ObjectHandlerRegistry registry) {
+       protected AbstractMessageParser(final ObjectRegistry registry) {
                this.registry = Preconditions.checkNotNull(registry);
        }
 
@@ -63,9 +63,7 @@ public abstract class AbstractMessageParser implements MessageParser, MessageSer
                if (object == null) {
                        return new byte[] {};
                }
-               final ObjectSerializer serializer = this.registry.getObjectSerializer(object);
-               LOG.trace("Choosen serializer {}", serializer);
-               return serializer.serializeObject(object);
+               return this.registry.serializeObject(object);
        }
 
        private List<Object> parseObjects(final byte[] bytes) throws PCEPDeserializerException {
@@ -103,11 +101,10 @@ public abstract class AbstractMessageParser implements MessageParser, MessageSer
 
                        offset += objLength - COMMON_OBJECT_HEADER_LENGTH;
 
-                       final ObjectParser parser = Preconditions.checkNotNull(this.registry.getObjectParser(objClass, objType));
                        final ObjectHeader header = new ObjectHeaderImpl(flags.get(P_FLAG_OFFSET), flags.get(I_FLAG_OFFSET));
 
                        // parseObject is required to return null for P=0 errored objects
-                       final Object o = parser.parseObject(header, bytesToPass);
+                       final Object o = this.registry.parseObject(objClass, objType, header, bytesToPass);
                        if (o != null) {
                                objs.add(o);
                        }
@@ -131,9 +128,9 @@ public abstract class AbstractMessageParser implements MessageParser, MessageSer
                                new PcerrMessageBuilder().setErrorType(
                                                new RequestCaseBuilder().setRequest(
                                                                new RequestBuilder().setRps(Lists.newArrayList(new RpsBuilder().setRp(rp).build())).build()).build()).setErrors(
-                                               Arrays.asList(new ErrorsBuilder().setErrorObject(
-                                                               new ErrorObjectBuilder().setType(maping.getFromErrorsEnum(e).type).setValue(
-                                                                               maping.getFromErrorsEnum(e).value).build()).build())).build()).build();
+                                                                               Arrays.asList(new ErrorsBuilder().setErrorObject(
+                                                                                               new ErrorObjectBuilder().setType(maping.getFromErrorsEnum(e).type).setValue(
+                                                                                                               maping.getFromErrorsEnum(e).value).build()).build())).build()).build();
        }
 
        protected abstract Message validate(final List<Object> objects, final List<Message> errors) throws PCEPDeserializerException;
diff --git a/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectHandlerRegistry.java b/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectHandlerRegistry.java
deleted file mode 100644 (file)
index 7933b36..0000000
+++ /dev/null
@@ -1,15 +0,0 @@
-/*
- * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.protocol.pcep.spi;
-
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
-
-public interface ObjectHandlerRegistry {
-       ObjectParser getObjectParser(int objectClass, int objectType);
-       ObjectSerializer getObjectSerializer(Object object);
-}
diff --git a/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectRegistry.java b/pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/ObjectRegistry.java
new file mode 100644 (file)
index 0000000..248d933
--- /dev/null
@@ -0,0 +1,30 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.protocol.pcep.spi;
+
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Object;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ObjectHeader;
+
+public interface ObjectRegistry {
+       /**
+        * Finds parser for given object type and class in the registry. Delegates parsing to found parser.
+        * @param objectType object type
+        * @param objectClass object class
+        * @param buffer object raw binary value to be parsed
+        * @return null if the parser for this object could not be found
+        * @throws PCEPDeserializerException if the parsing did not succeed
+        */
+       Object parseObject(final int objectClass, final int objectType, final ObjectHeader header, final byte[] buffer) throws PCEPDeserializerException;
+
+       /**
+        * Find serializer for given object. Delegates parsing to found serializer.
+        * @param object to be parsed
+        * @return null if the serializer for this object could not be found
+        */
+       byte[] serializeObject(Object object);
+}
index b59452d47238d7ec84bfc80ac731ed4159d0ba7b..54867a23be430ecce4615c280923a5bbb271342b 100644 (file)
@@ -13,7 +13,7 @@ public interface PCEPExtensionConsumerContext {
 
        MessageHandlerRegistry getMessageHandlerRegistry();
 
-       ObjectHandlerRegistry getObjectHandlerRegistry();
+       ObjectRegistry getObjectHandlerRegistry();
 
        EROSubobjectRegistry getEROSubobjectHandlerRegistry();
 
similarity index 66%
rename from pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleObjectHandlerRegistry.java
rename to pcep/spi/src/main/java/org/opendaylight/protocol/pcep/spi/pojo/SimpleObjectRegistry.java
index c93b9374c2c8faef763cee3108fc5c64b8872d1d..c123d906e510f94f6b00ec5148bbe353ea2f2926 100644 (file)
@@ -8,9 +8,10 @@
 package org.opendaylight.protocol.pcep.spi.pojo;
 
 import org.opendaylight.protocol.concepts.HandlerRegistry;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
 import org.opendaylight.protocol.pcep.spi.ObjectParser;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.ObjectSerializer;
+import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
 import org.opendaylight.protocol.pcep.spi.UnknownObject;
 import org.opendaylight.protocol.util.Values;
@@ -23,7 +24,7 @@ import com.google.common.base.Preconditions;
 /**
  *
  */
-public final class SimpleObjectHandlerRegistry implements ObjectHandlerRegistry {
+public final class SimpleObjectRegistry implements ObjectRegistry {
        private final HandlerRegistry<DataContainer, ObjectParser, ObjectSerializer> handlers = new HandlerRegistry<>();
 
        private static int createKey(final int objectClass, final int objectType) {
@@ -43,35 +44,31 @@ public final class SimpleObjectHandlerRegistry implements ObjectHandlerRegistry
        }
 
        @Override
-       public ObjectParser getObjectParser(final int objectClass, final int objectType) {
-               final ObjectParser ret = this.handlers.getParser(createKey(objectClass, objectType));
-               if (ret != null) {
-                       return ret;
-               }
+       public Object parseObject(int objectClass, int objectType, ObjectHeader header, byte[] buffer) throws PCEPDeserializerException {
+               Preconditions.checkArgument(objectType >= 0 && objectType <= Values.UNSIGNED_SHORT_MAX_VALUE);
+               final ObjectParser parser = this.handlers.getParser(createKey(objectClass, objectType));
+
+               if (parser == null) {
 
-               final boolean foundClass = false;
+                       final boolean foundClass = false;
 
-               // FIXME: BUG-187: search the parsers, check classes
+                       // FIXME: BUG-187: search the parsers, check classes
 
-               if (!foundClass) {
-                       return new ObjectParser() {
-                               @Override
-                               public Object parseObject(final ObjectHeader header, final byte[] buffer) {
-                                       return new UnknownObject(PCEPErrors.UNRECOGNIZED_OBJ_CLASS);
-                               }
-                       };
-               } else {
-                       return new ObjectParser() {
-                               @Override
-                               public Object parseObject(final ObjectHeader header, final byte[] buffer) {
-                                       return new UnknownObject(PCEPErrors.UNRECOGNIZED_OBJ_TYPE);
-                               }
-                       };
+                       if (!foundClass) {
+                               return new UnknownObject(PCEPErrors.UNRECOGNIZED_OBJ_CLASS);
+                       } else {
+                               return new UnknownObject(PCEPErrors.UNRECOGNIZED_OBJ_TYPE);
+                       }
                }
+               return parser.parseObject(header, buffer);
        }
 
        @Override
-       public ObjectSerializer getObjectSerializer(final Object object) {
-               return this.handlers.getSerializer(object.getImplementedInterface());
+       public byte[] serializeObject(Object object) {
+               final ObjectSerializer serializer = this.handlers.getSerializer(object.getImplementedInterface());
+               if (serializer == null) {
+                       return null;
+               }
+               return serializer.serializeObject(object);
        }
 }
index 27fa7be5c912e542e3f862365130a8843c53d3af..5430775500d289f15ead790c67a4430e54b2adf2 100644 (file)
@@ -18,7 +18,7 @@ import org.opendaylight.protocol.pcep.spi.LabelSerializer;
 import org.opendaylight.protocol.pcep.spi.MessageHandlerRegistry;
 import org.opendaylight.protocol.pcep.spi.MessageParser;
 import org.opendaylight.protocol.pcep.spi.MessageSerializer;
-import org.opendaylight.protocol.pcep.spi.ObjectHandlerRegistry;
+import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
 import org.opendaylight.protocol.pcep.spi.ObjectParser;
 import org.opendaylight.protocol.pcep.spi.ObjectSerializer;
 import org.opendaylight.protocol.pcep.spi.PCEPExtensionProviderContext;
@@ -44,7 +44,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev
 public class SimplePCEPExtensionProviderContext implements PCEPExtensionProviderContext {
        private final SimpleLabelHandlerRegistry labelReg = new SimpleLabelHandlerRegistry();
        private final SimpleMessageHandlerRegistry msgReg = new SimpleMessageHandlerRegistry();
-       private final SimpleObjectHandlerRegistry objReg = new SimpleObjectHandlerRegistry();
+       private final SimpleObjectRegistry objReg = new SimpleObjectRegistry();
        private final SimpleEROSubobjectRegistry eroSubReg = new SimpleEROSubobjectRegistry();
        private final SimpleRROSubobjectRegistry rroSubReg = new SimpleRROSubobjectRegistry();
        private final SimpleXROSubobjectRegistry xroSubReg = new SimpleXROSubobjectRegistry();
@@ -61,7 +61,7 @@ public class SimplePCEPExtensionProviderContext implements PCEPExtensionProvider
        }
 
        @Override
-       public final ObjectHandlerRegistry getObjectHandlerRegistry() {
+       public final ObjectRegistry getObjectHandlerRegistry() {
                return this.objReg;
        }