commit 1bec2be62253aaa81c4ff570887aded007274e50
author Saurav Das <sauravdas@alumni.stanford.edu> Mon Mar 06 13:52:48 2017 -0800
committer Ray Milkey <ray@onlab.us> Tue Mar 07 00:58:58 2017 +0000
tree b53bf65778547fc8455f345e7a138783debb1d33
parent 44e2a7015aa9ccf5185ddd5f06ba6890d03310cf

Making the REST interface accept deferred instructions while adding flows

Change-Id: I6ac2d6a78e11d372f5d72f097554187a564801b1

core/common/src/main/java/org/onosproject/codec/impl/TrafficTreatmentCodec.java

diff --git a/core/common/src/main/java/org/onosproject/codec/impl/TrafficTreatmentCodec.java b/core/common/src/main/java/org/onosproject/codec/impl/TrafficTreatmentCodec.java
index 6ec5a67..1378c3e 100644
--- a/core/common/src/main/java/org/onosproject/codec/impl/TrafficTreatmentCodec.java
+++ b/core/common/src/main/java/org/onosproject/codec/impl/TrafficTreatmentCodec.java
@@ -34,6 +34,7 @@
  */
 public final class TrafficTreatmentCodec extends JsonCodec<TrafficTreatment> {
     private static final String INSTRUCTIONS = "instructions";
+    private static final String DEFERRED = "deferred";
 
     @Override
     public ObjectNode encode(TrafficTreatment treatment, CodecContext context) {
@@ -78,6 +79,15 @@
                             instructionsCodec.decode(get(instructionsJson, i),
                                     context)));
         }
+
+        JsonNode deferredJson = json.get(DEFERRED);
+        if (deferredJson != null) {
+            IntStream.range(0, deferredJson.size())
+            .forEach(i -> builder.deferred().add(
+                    instructionsCodec.decode(get(deferredJson, i),
+                            context)));
+        }
+
         return builder.build();
     }
 }