diff options
Diffstat (limited to 'framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java')
-rw-r--r-- | framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java b/framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java index b0cbbdd6..1df2f049 100644 --- a/framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java +++ b/framework/src/onos/cli/src/main/java/org/onosproject/cli/Comparators.java @@ -25,6 +25,8 @@ import org.onosproject.net.ElementId; import org.onosproject.net.Port; import org.onosproject.net.flow.FlowRule; import org.onosproject.net.group.Group; + +import org.onosproject.net.statistic.TypedFlowEntryWithLoad; import org.onosproject.net.topology.TopologyCluster; import java.util.Comparator; @@ -115,4 +117,12 @@ public final class Comparators { public static final Comparator<Interface> INTERFACES_COMPARATOR = (intf1, intf2) -> CONNECT_POINT_COMPARATOR.compare(intf1.connectPoint(), intf2.connectPoint()); + public static final Comparator<TypedFlowEntryWithLoad> TYPEFLOWENTRY_WITHLOAD_COMPARATOR = + new Comparator<TypedFlowEntryWithLoad>() { + @Override + public int compare(TypedFlowEntryWithLoad fe1, TypedFlowEntryWithLoad fe2) { + long delta = fe1.load().rate() - fe2.load().rate(); + return delta == 0 ? 0 : (delta > 0 ? -1 : +1); + } + }; } |