Class FlatBatchUtil
java.lang.Object
org.opendaylight.openflowplugin.impl.util.FlatBatchUtil
Provides flat batch util methods.
-
Method Summary
Modifier and TypeMethodDescriptionstatic List
<BatchPlanStep> assembleBatchPlan
(Collection<Batch> batches) static com.google.common.util.concurrent.ListenableFuture
<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>> createEmptyRpcBatchResultFuture
(boolean status) Creates empty result future for flat batch service.static void
markBarriersWhereNeeded
(List<BatchPlanStep> batchPlan) static com.google.common.util.concurrent.ListenableFuture
<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>> mergeJobsResultsFutures
(List<com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>>> firedJobs) Merge list of Futures with partial results into one ListenableFuture with single result.
-
Method Details
-
markBarriersWhereNeeded
-
assembleBatchPlan
-
mergeJobsResultsFutures
public static com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>> mergeJobsResultsFutures(List<com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>>> firedJobs) Merge list of Futures with partial results into one ListenableFuture with single result.- Parameters:
firedJobs
- list of ListenableFutures with RPC resultsProcessFlatBatchOutput
- Returns:
- ListenableFuture of RPC result with combined status and all errors + batch failures
-
createEmptyRpcBatchResultFuture
public static com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProcessFlatBatchOutput>> createEmptyRpcBatchResultFuture(boolean status) Creates empty result future for flat batch service.- Parameters:
status
- RPC result status- Returns:
- ListenableFuture of RPC result with empty list of errors and batch failures
-