Add AsyncWriteTransaction.commit()
[controller.git] / opendaylight / md-sal / sal-binding-broker / src / main / java / org / opendaylight / controller / md / sal / binding / impl / FutureSchema.java
index 0c378390e529ca33dfd815fb9f9f36824a2cdeb8..0993a9fda90956ddc3e3582c91df369e0154206d 100644 (file)
@@ -11,6 +11,7 @@ package org.opendaylight.controller.md.sal.binding.impl;
 import com.google.common.base.Predicate;
 import com.google.common.base.Throwables;
 import com.google.common.util.concurrent.SettableFuture;
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.LinkedHashSet;
@@ -18,6 +19,7 @@ import java.util.Set;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
+import javax.annotation.Nonnull;
 import javax.annotation.concurrent.GuardedBy;
 import org.opendaylight.mdsal.binding.generator.util.BindingRuntimeContext;
 import org.opendaylight.yangtools.yang.binding.Augmentation;
@@ -90,7 +92,7 @@ class FutureSchema implements AutoCloseable {
     boolean waitForSchema(final QNameModule module) {
         return addPostponedOpAndWait(new FutureSchemaPredicate() {
             @Override
-            public boolean apply(final BindingRuntimeContext input) {
+            public boolean apply(@Nonnull final BindingRuntimeContext input) {
                 return input.getSchemaContext().findModule(module).isPresent();
             }
         });
@@ -145,6 +147,7 @@ class FutureSchema implements AutoCloseable {
             }
         }
 
+        @SuppressFBWarnings(value = "NP_NONNULL_PARAM_VIOLATION", justification = "Void is the only allowed value")
         final void unlockIfPossible(final BindingRuntimeContext context) {
             if (!this.schemaPromise.isDone() && apply(context)) {
                 this.schemaPromise.set(null);