Remove redundent byte[].class registration

Also added names to some serializer for debugging purpose

Change-Id: I0997b61a5d08df84c85ca28f6a5ed23417fb8c22

@@ -120,12 +120,12 @@ public class McastHandler {
         mcastNextObjStore = storageService
         mcastNextObjStore = storageService
                 .<McastStoreKey, NextObjective>consistentMapBuilder()
                 .<McastStoreKey, NextObjective>consistentMapBuilder()
                 .withName("onos-mcast-nextobj-store")
                 .withName("onos-mcast-nextobj-store")
-                .withSerializer(Serializer.using(mcastKryo.build()))
+                .withSerializer(Serializer.using(mcastKryo.build("McastHandler-NextObj")))
                 .build();
                 .build();
         mcastRoleStore = storageService
         mcastRoleStore = storageService
                 .<McastStoreKey, McastRole>consistentMapBuilder()
                 .<McastStoreKey, McastRole>consistentMapBuilder()
                 .withName("onos-mcast-role-store")
                 .withName("onos-mcast-role-store")
-                .withSerializer(Serializer.using(mcastKryo.build()))
+                .withSerializer(Serializer.using(mcastKryo.build("McastHandler-Role")))
                 .build();
                 .build();
     }
     }
 
 

@@ -130,9 +130,8 @@ public class MessagingPerfApp {
             serializerPool = KryoNamespace.newBuilder()
             serializerPool = KryoNamespace.newBuilder()
                     .register(KryoNamespaces.BASIC)
                     .register(KryoNamespaces.BASIC)
                     .register(KryoNamespaces.MISC)
                     .register(KryoNamespaces.MISC)
-                    .register(byte[].class)
                     .register(Data.class)
                     .register(Data.class)
-                    .build();
+                    .build("MessagingPerfApp");
         }
         }
     };
     };
 
 

@@ -66,7 +66,7 @@ public class DistributedFlowObjectiveStore
                         new KryoNamespace.Builder()
                         new KryoNamespace.Builder()
                                 .register(byte[].class)
                                 .register(byte[].class)
                                 .register(Versioned.class)
                                 .register(Versioned.class)
-                                .build()))
+                                .build("DistributedFlowObjectiveStore")))
                 .build();
                 .build();
 
 
         nextIds = storageService.getAtomicCounter("next-objective-counter");
         nextIds = storageService.getAtomicCounter("next-objective-counter");

@@ -105,7 +105,7 @@ public abstract class AbstractCorsaPipeline extends AbstractHandlerBehaviour imp
             .register(DefaultGroupKey.class)
             .register(DefaultGroupKey.class)
             .register(CorsaGroup.class)
             .register(CorsaGroup.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("AbstractCorsaPipeline");
 
 
     private Cache<GroupKey, NextObjective> pendingGroups;
     private Cache<GroupKey, NextObjective> pendingGroups;
 
 

@@ -39,7 +39,7 @@ public class DefaultMoveExtensionTreatment extends AbstractExtension
 
 
     private final KryoNamespace appKryo = new KryoNamespace.Builder()
     private final KryoNamespace appKryo = new KryoNamespace.Builder()
             .register(byte[].class).register(Integer.class).register(Map.class)
             .register(byte[].class).register(Integer.class).register(Map.class)
-            .build();
+            .build("DefaultMoveExtensionTreatment");
 
 
     /**
     /**
      * Creates a new move Treatment.
      * Creates a new move Treatment.

@@ -46,7 +46,7 @@ public class NiciraResubmit extends AbstractExtension implements ExtensionTreatm
             .register(new PortNumberSerializer(), PortNumber.class)
             .register(new PortNumberSerializer(), PortNumber.class)
             .register(Map.class).register(HashMap.class)
             .register(Map.class).register(HashMap.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("NiciraResubmit");
 
 
     /**
     /**
      * Creates a new resubmit instruction.
      * Creates a new resubmit instruction.

@@ -47,7 +47,7 @@ public class NiciraResubmitTable extends AbstractExtension implements
             .register(new PortNumberSerializer(), PortNumber.class)
             .register(new PortNumberSerializer(), PortNumber.class)
             .register(Map.class).register(HashMap.class)
             .register(Map.class).register(HashMap.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("NiciraResubmitTable");
 
 
     /**
     /**
      * Creates a new resubmit-table instruction.
      * Creates a new resubmit-table instruction.

@@ -39,7 +39,7 @@ public class NiciraSetTunnelDst extends AbstractExtension implements
     private final KryoNamespace appKryo = new KryoNamespace.Builder()
     private final KryoNamespace appKryo = new KryoNamespace.Builder()
             .register(new Ip4AddressSerializer(), Ip4Address.class)
             .register(new Ip4AddressSerializer(), Ip4Address.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("NiciraSetTunnelDst");
 
 
     /**
     /**
      * Creates a new set tunnel destination instruction.
      * Creates a new set tunnel destination instruction.

@@ -134,7 +134,7 @@ public class CentecV350Pipeline extends AbstractHandlerBehaviour implements Pipe
             .register(DefaultGroupKey.class)
             .register(DefaultGroupKey.class)
             .register(CentecV350Group.class)
             .register(CentecV350Group.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("CentecV350Pipeline");
 
 
     private Cache<GroupKey, NextObjective> pendingGroups;
     private Cache<GroupKey, NextObjective> pendingGroups;
 
 

@@ -69,7 +69,7 @@ public class DefaultSingleTablePipeline extends AbstractHandlerBehaviour impleme
             .register(DefaultGroupKey.class)
             .register(DefaultGroupKey.class)
             .register(SingleGroup.class)
             .register(SingleGroup.class)
             .register(byte[].class)
             .register(byte[].class)
-            .build();
+            .build("DefaultSingleTablePipeline");
 
 
 
 
     @Override
     @Override

@@ -121,9 +121,8 @@ public class Ofdpa2Pipeline extends AbstractHandlerBehaviour implements Pipeline
         .register(GroupKey.class)
         .register(GroupKey.class)
         .register(DefaultGroupKey.class)
         .register(DefaultGroupKey.class)
         .register(Ofdpa2GroupHandler.OfdpaNextGroup.class)
         .register(Ofdpa2GroupHandler.OfdpaNextGroup.class)
-        .register(byte[].class)
         .register(ArrayDeque.class)
         .register(ArrayDeque.class)
-        .build();
+        .build("Ofdpa2Pipeline");
 
 
     protected Ofdpa2GroupHandler groupHandler;
     protected Ofdpa2GroupHandler groupHandler;
 
 

@@ -114,8 +114,7 @@ public class OltPipeline extends AbstractHandlerBehaviour implements Pipeliner {
             .register(GroupKey.class)
             .register(GroupKey.class)
             .register(DefaultGroupKey.class)
             .register(DefaultGroupKey.class)
             .register(OLTPipelineGroup.class)
             .register(OLTPipelineGroup.class)
-            .register(byte[].class)
-            .build();
+            .build("OltPipeline");
 
 
     @Override
     @Override
     public void init(DeviceId deviceId, PipelinerContext context) {
     public void init(DeviceId deviceId, PipelinerContext context) {

@@ -90,8 +90,7 @@ public class PicaPipeline extends AbstractHandlerBehaviour implements Pipeliner
     private KryoNamespace appKryo = new KryoNamespace.Builder()
     private KryoNamespace appKryo = new KryoNamespace.Builder()
             .register(KryoNamespaces.API)
             .register(KryoNamespaces.API)
             .register(PicaGroup.class)
             .register(PicaGroup.class)
-            .register(byte[].class)
-            .build();
+            .build("PicaPipeline");
 
 
     @Override
     @Override
     public void init(DeviceId deviceId, PipelinerContext context) {
     public void init(DeviceId deviceId, PipelinerContext context) {

@@ -140,8 +140,7 @@ public class SpringOpenTTP extends AbstractHandlerBehaviour
             .register(DefaultGroupKey.class)
             .register(DefaultGroupKey.class)
             .register(TrafficTreatment.class)
             .register(TrafficTreatment.class)
             .register(SpringOpenGroup.class)
             .register(SpringOpenGroup.class)
-            .register(byte[].class)
-            .build();
+            .build("SpringOpenTTP");
 
 
     @Override
     @Override
     public void init(DeviceId deviceId, PipelinerContext context) {
     public void init(DeviceId deviceId, PipelinerContext context) {