alshabib

fix serializer in DistributedMcastStore.

Change-Id: I06935b450387da3dea3e2aa65af66e893a9a59a7
...@@ -6,7 +6,7 @@ import org.apache.felix.scr.annotations.Deactivate; ...@@ -6,7 +6,7 @@ import org.apache.felix.scr.annotations.Deactivate;
6 import org.apache.felix.scr.annotations.Reference; 6 import org.apache.felix.scr.annotations.Reference;
7 import org.apache.felix.scr.annotations.ReferenceCardinality; 7 import org.apache.felix.scr.annotations.ReferenceCardinality;
8 import org.apache.felix.scr.annotations.Service; 8 import org.apache.felix.scr.annotations.Service;
9 -import org.onlab.packet.IpPrefix; 9 +import org.onlab.packet.IpAddress;
10 import org.onlab.util.KryoNamespace; 10 import org.onlab.util.KryoNamespace;
11 import org.onosproject.net.ConnectPoint; 11 import org.onosproject.net.ConnectPoint;
12 import org.onosproject.net.mcast.McastEvent; 12 import org.onosproject.net.mcast.McastEvent;
...@@ -35,9 +35,9 @@ import static org.slf4j.LoggerFactory.getLogger; ...@@ -35,9 +35,9 @@ import static org.slf4j.LoggerFactory.getLogger;
35 public class DistributedMcastStore extends AbstractStore<McastEvent, McastStoreDelegate> 35 public class DistributedMcastStore extends AbstractStore<McastEvent, McastStoreDelegate>
36 implements McastStore { 36 implements McastStore {
37 //FIXME the number of events that will potentially be generated here is 37 //FIXME the number of events that will potentially be generated here is
38 - // not sustainable, consider changing this to an eventually consistent 38 + // not sustainable, consider changing this to an eventually consistent
39 - // map and not emitting events but rather use a provider-like mechanism 39 + // map and not emitting events but rather use a provider-like mechanism
40 - // to program the dataplane. 40 + // to program the dataplane.
41 41
42 private static final String MCASTRIB = "mcast-rib-table"; 42 private static final String MCASTRIB = "mcast-rib-table";
43 private Logger log = getLogger(getClass()); 43 private Logger log = getLogger(getClass());
...@@ -58,7 +58,7 @@ public class DistributedMcastStore extends AbstractStore<McastEvent, McastStoreD ...@@ -58,7 +58,7 @@ public class DistributedMcastStore extends AbstractStore<McastEvent, McastStoreD
58 MulticastData.class, 58 MulticastData.class,
59 McastRoute.class, 59 McastRoute.class,
60 McastRoute.Type.class, 60 McastRoute.Type.class,
61 - IpPrefix.class, 61 + IpAddress.class,
62 List.class, 62 List.class,
63 ConnectPoint.class 63 ConnectPoint.class
64 ).build())) 64 ).build()))
......