X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflow-protocol-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowjava%2Fprotocol%2Fimpl%2Fserialization%2FSerializerRegistryImpl.java;h=9383187866dfa5608bdffad335ab332c9971356a;hb=0b153ce18153b71fc7e5bb6de5338d5dbaf9b1a1;hp=4d91deca481ac8ec46d68db9a21bbdb4e7b3d9a5;hpb=dab5b6e45ed8f2a8630cdfc47fdbff622d081bb0;p=openflowjava.git
diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializerRegistryImpl.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializerRegistryImpl.java
index 4d91deca..93831878 100644
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializerRegistryImpl.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/serialization/SerializerRegistryImpl.java
@@ -10,40 +10,44 @@ package org.opendaylight.openflowjava.protocol.impl.serialization;
import java.util.HashMap;
import java.util.Map;
-
-import org.opendaylight.openflowjava.protocol.api.extensibility.MessageTypeKey;
import org.opendaylight.openflowjava.protocol.api.extensibility.OFGeneralSerializer;
import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistryInjector;
+import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
import org.opendaylight.openflowjava.protocol.impl.util.OF10MatchSerializer;
import org.opendaylight.openflowjava.protocol.impl.util.OF13MatchSerializer;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.match.grouping.Match;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev130731.match.v10.grouping.MatchV10;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.grouping.Match;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.match.v10.grouping.MatchV10;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Stores and handles serializers
- * K - {@link MessageTypeKey} type
+ * Stores and handles serializers
+ * K - {@link MessageTypeKey} type
* S - returned serializer type
+ *
* @author michal.polkorab
* @author timotej.kubas
+ * @author giuseppex.petralia@intel.com
+ *
*/
public class SerializerRegistryImpl implements SerializerRegistry {
- private static final Logger LOGGER = LoggerFactory.getLogger(SerializerRegistryImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(SerializerRegistryImpl.class);
private static final short OF10 = EncodeConstants.OF10_VERSION_ID;
private static final short OF13 = EncodeConstants.OF13_VERSION_ID;
private Map, OFGeneralSerializer> registry;
-
@Override
public void init() {
registry = new HashMap<>();
// Openflow message type serializers
MessageFactoryInitializer.registerMessageSerializers(this);
+ // Register Additional serializers
+ AdditionalMessageFactoryInitializer.registerMessageSerializers(this);
+
// match structure serializers
registerSerializer(new MessageTypeKey<>(OF10, MatchV10.class), new OF10MatchSerializer());
registerSerializer(new MessageTypeKey<>(OF13, Match.class), new OF13MatchSerializer());
@@ -62,8 +66,7 @@ public class SerializerRegistryImpl implements SerializerRegistry {
*/
@Override
@SuppressWarnings("unchecked")
- public S getSerializer(
- MessageTypeKey msgTypeKey) {
+ public S getSerializer(MessageTypeKey msgTypeKey) {
OFGeneralSerializer serializer = registry.get(msgTypeKey);
if (serializer == null) {
throw new IllegalStateException("Serializer for key: " + msgTypeKey
@@ -74,16 +77,14 @@ public class SerializerRegistryImpl implements SerializerRegistry {
}
@Override
- public void registerSerializer(
- MessageTypeKey msgTypeKey, OFGeneralSerializer serializer) {
+ public void registerSerializer(MessageTypeKey msgTypeKey, OFGeneralSerializer serializer) {
if ((msgTypeKey == null) || (serializer == null)) {
throw new IllegalArgumentException("MessageTypeKey or Serializer is null");
}
OFGeneralSerializer serInRegistry = registry.put(msgTypeKey, serializer);
if (serInRegistry != null) {
- LOGGER.debug("Serializer for key " + msgTypeKey + " overwritten. Old serializer: "
- + serInRegistry.getClass().getName() + ", new serializer: "
- + serializer.getClass().getName() );
+ LOG.debug("Serializer for key {} overwritten. Old serializer: {}, new serializer: {}", msgTypeKey,
+ serInRegistry.getClass().getName(), serializer.getClass().getName());
}
if (serializer instanceof SerializerRegistryInjector) {
((SerializerRegistryInjector) serializer).injectSerializerRegistry(this);