X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fopenflow%2Fmd%2Fcore%2Fsal%2Fconvertor%2FGroupStatsResponseConvertor.java;h=8e7a0ecd73ce2db9f1e4c89196442bfff6440a49;hb=137e4d7d86e8f402f3d52fd0fa162792f9ff60eb;hp=861770a08e0c811043e7a12f4ceb0d11e2e99dae;hpb=8339b1175433d51ad1ace15ad7084ec91535d169;p=openflowplugin.git diff --git a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/GroupStatsResponseConvertor.java b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/GroupStatsResponseConvertor.java index 861770a08e..8e7a0ecd73 100644 --- a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/GroupStatsResponseConvertor.java +++ b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/core/sal/convertor/GroupStatsResponseConvertor.java @@ -13,10 +13,10 @@ import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Set; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter32; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter64; import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.common.Convertor; import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.data.VersionConvertorData; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter32; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Counter64; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.BucketId; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupId; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.Buckets; @@ -29,24 +29,28 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStatsBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.statistics.reply.GroupStatsKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.group.stats.BucketStats; -import org.opendaylight.yangtools.yang.binding.DataContainer; /** * Converts group related statistics messages coming from switch to MD-SAL messages. * + *

* Example usage: *

  * {@code
- * Optional> salGroupStats = ConvertorManager.getInstance().convert(ofGroupStats);
+ * VersionConvertorData data = new VersionConvertorData(version);
+ * Optional> salGroupStats = convertorManager.convert(ofGroupStats, data);
  * }
  * 
*/ -public class GroupStatsResponseConvertor implements Convertor< - List, +public class GroupStatsResponseConvertor extends Convertor< + List, List, VersionConvertorData> { - private static final Set> TYPES = Collections.singleton(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStats.class); + private static final Set> TYPES = Collections.singleton(org.opendaylight.yang.gen.v1.urn.opendaylight + .openflow.protocol.rev130731.multipart.reply.multipart.reply.body.multipart.reply.group._case.multipart + .reply.group.GroupStats.class); private Buckets toSALBuckets(List bucketStats) { BucketsBuilder salBuckets = new BucketsBuilder(); @@ -59,7 +63,7 @@ public class GroupStatsResponseConvertor implements Convertor< bucketCounter.setByteCount(new Counter64(bucketStat.getByteCount())); bucketCounter.setPacketCount(new Counter64(bucketStat.getPacketCount())); BucketId bucketId = new BucketId((long) bucketKey); - bucketCounter.setKey(new BucketCounterKey(bucketId)); + bucketCounter.withKey(new BucketCounterKey(bucketId)); bucketCounter.setBucketId(bucketId); bucketKey++; allBucketStats.add(bucketCounter.build()); @@ -70,16 +74,18 @@ public class GroupStatsResponseConvertor implements Convertor< } @Override - public Collection> getTypes() { + public Collection> getTypes() { return TYPES; } @Override - public List convert(List source, VersionConvertorData data) { + public List convert(List source, + VersionConvertorData data) { List convertedSALGroups = new ArrayList<>(); - for (org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply - .multipart.reply.body.multipart.reply.group._case.multipart.reply.group.GroupStats groupStats : source) { + for (org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.reply.multipart.reply + .body.multipart.reply.group._case.multipart.reply.group.GroupStats groupStats : source) { GroupStatsBuilder salGroupStats = new GroupStatsBuilder(); salGroupStats.setBuckets(toSALBuckets(groupStats.getBucketStats())); @@ -93,7 +99,7 @@ public class GroupStatsResponseConvertor implements Convertor< salGroupStats.setGroupId(new GroupId(groupStats.getGroupId().getValue())); salGroupStats.setPacketCount(new Counter64(groupStats.getPacketCount())); salGroupStats.setRefCount(new Counter32(groupStats.getRefCount())); - salGroupStats.setKey(new GroupStatsKey(salGroupStats.getGroupId())); + salGroupStats.withKey(new GroupStatsKey(salGroupStats.getGroupId())); convertedSALGroups.add(salGroupStats.build()); }