commit | 1097c978fb72dc23a5c2c0ad678a765fd9df6edb | [log] [tgz] |
---|---|---|
author | alshabib <alshabibi.ali@gmail.com> | Fri Apr 10 14:41:32 2015 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Sat Apr 11 00:37:06 2015 +0000 |
tree | df0a363ae4727d4fd599e25ed29315a999f90cf4 | |
parent | d2e78f98043aba4bfcae9957703b3fac044dade9 [diff] |
Only process pending objectives if there are any. Change-Id: Ibb34dce32e0bfc55b317036130ead2c1babbaeac
diff --git a/core/net/src/main/java/org/onosproject/net/flowobjective/impl/FlowObjectiveManager.java b/core/net/src/main/java/org/onosproject/net/flowobjective/impl/FlowObjectiveManager.java index 29e5857..5ecfb14 100644 --- a/core/net/src/main/java/org/onosproject/net/flowobjective/impl/FlowObjectiveManager.java +++ b/core/net/src/main/java/org/onosproject/net/flowobjective/impl/FlowObjectiveManager.java
@@ -218,7 +218,8 @@ } private void processPendingObjectives(DeviceId deviceId) { - pendingObjectives.get(deviceId).forEach(obj -> { + pendingObjectives.getOrDefault(deviceId, + Collections.emptySet()).forEach(obj -> { if (obj instanceof NextObjective) { getDevicePipeliner(deviceId) .next(Collections.singletonList((NextObjective) obj));