clean batch operations
Change-Id: I7187de40bb5276d6ae9e9831e5d47d36e16560ad
diff --git a/core/api/src/main/java/org/onlab/onos/net/flow/CompletedBatchOperation.java b/core/api/src/main/java/org/onlab/onos/net/flow/CompletedBatchOperation.java
index bde752e..e9889cd 100644
--- a/core/api/src/main/java/org/onlab/onos/net/flow/CompletedBatchOperation.java
+++ b/core/api/src/main/java/org/onlab/onos/net/flow/CompletedBatchOperation.java
@@ -1,6 +1,29 @@
package org.onlab.onos.net.flow;
-public class CompletedBatchOperation {
+import java.util.List;
+
+import com.google.common.collect.ImmutableList;
+
+public class CompletedBatchOperation implements BatchOperationResult<FlowEntry> {
+
+
+ private final boolean success;
+ private final List<FlowEntry> failures;
+
+ public CompletedBatchOperation(boolean success, List<FlowEntry> failures) {
+ this.success = success;
+ this.failures = ImmutableList.copyOf(failures);
+ }
+
+ @Override
+ public boolean isSuccess() {
+ return success;
+ }
+
+ @Override
+ public List<FlowEntry> failedItems() {
+ return failures;
+ }
}
diff --git a/core/api/src/main/java/org/onlab/onos/net/flow/DefaultFlowEntry.java b/core/api/src/main/java/org/onlab/onos/net/flow/DefaultFlowEntry.java
index 5a0f55b..d4657d2 100644
--- a/core/api/src/main/java/org/onlab/onos/net/flow/DefaultFlowEntry.java
+++ b/core/api/src/main/java/org/onlab/onos/net/flow/DefaultFlowEntry.java
@@ -17,6 +17,10 @@
private long lastSeen = -1;
+ private final int errType;
+
+ private final int errCode;
+
public DefaultFlowEntry(DeviceId deviceId, TrafficSelector selector,
TrafficTreatment treatment, int priority, FlowEntryState state,
@@ -27,6 +31,8 @@
this.life = life;
this.packets = packets;
this.bytes = bytes;
+ this.errCode = -1;
+ this.errType = -1;
this.lastSeen = System.currentTimeMillis();
}
@@ -37,6 +43,8 @@
this.life = life;
this.packets = packets;
this.bytes = bytes;
+ this.errCode = -1;
+ this.errType = -1;
this.lastSeen = System.currentTimeMillis();
}
@@ -46,9 +54,18 @@
this.life = 0;
this.packets = 0;
this.bytes = 0;
+ this.errCode = -1;
+ this.errType = -1;
this.lastSeen = System.currentTimeMillis();
}
+ public DefaultFlowEntry(FlowRule rule, int errType, int errCode) {
+ super(rule);
+ this.state = FlowEntryState.FAILED;
+ this.errType = errType;
+ this.errCode = errCode;
+ }
+
@Override
public long life() {
return life;
@@ -100,6 +117,16 @@
}
@Override
+ public int errType() {
+ return this.errType;
+ }
+
+ @Override
+ public int errCode() {
+ return this.errCode;
+ }
+
+ @Override
public String toString() {
return toStringHelper(this)
.add("rule", super.toString())
@@ -108,4 +135,6 @@
}
+
+
}
diff --git a/core/api/src/main/java/org/onlab/onos/net/flow/FlowEntry.java b/core/api/src/main/java/org/onlab/onos/net/flow/FlowEntry.java
index 5b5f89b..882c9df 100644
--- a/core/api/src/main/java/org/onlab/onos/net/flow/FlowEntry.java
+++ b/core/api/src/main/java/org/onlab/onos/net/flow/FlowEntry.java
@@ -29,7 +29,12 @@
/**
* Flow has been removed from flow table and can be purged.
*/
- REMOVED
+ REMOVED,
+
+ /**
+ * Indicates that the installation of this flow has failed.
+ */
+ FAILED
}
/**
@@ -95,4 +100,16 @@
*/
void setBytes(long bytes);
+ /**
+ * Indicates the error type.
+ * @return an integer value of the error
+ */
+ int errType();
+
+ /**
+ * Indicates the error code.
+ * @return an integer value of the error
+ */
+ int errCode();
+
}
diff --git a/core/api/src/main/java/org/onlab/onos/net/flow/FlowRuleProvider.java b/core/api/src/main/java/org/onlab/onos/net/flow/FlowRuleProvider.java
index 68762ac..3592e39 100644
--- a/core/api/src/main/java/org/onlab/onos/net/flow/FlowRuleProvider.java
+++ b/core/api/src/main/java/org/onlab/onos/net/flow/FlowRuleProvider.java
@@ -37,6 +37,12 @@
*/
void removeRulesById(ApplicationId id, FlowRule... flowRules);
- Future<Void> executeBatch(BatchOperation<FlowRuleBatchEntry> batch);
+ /**
+ * Installs a batch of flow rules. Each flowrule is associated to an
+ * operation which results in either addition, removal or modification.
+ * @param batch a batch of flow rules
+ * @return a future indicating the status of this execution
+ */
+ Future<CompletedBatchOperation> executeBatch(BatchOperation<FlowRuleBatchEntry> batch);
}