import com.google.common.util.concurrent.CheckedFuture;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
+
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
+import java.util.Objects;
import java.util.stream.Collectors;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
ReadableAsyncByKey<Sgt, MasterDatabaseBinding> {
private static final Logger LOG = LoggerFactory.getLogger(MasterDatabaseBindingDaoImpl.class);
- private static final ListenableFuture<Optional<MasterDatabaseBinding>> READ_FUTURE_ABSENT = Futures.immediateFuture(Optional.absent());
+ private static final ListenableFuture<Optional<MasterDatabaseBinding>>
+ READ_FUTURE_ABSENT = Futures.immediateFuture(Optional.absent());
private final DataBroker dataBroker;
private final SimpleCachedDao<IpPrefix, MasterDatabaseBinding> cachedDao;
public Optional<MasterDatabaseBinding> apply(@Nullable final Void input) {
return lookup(cachedDao, key);
}
- });
+ }, MoreExecutors.directExecutor());
}
}
final CheckedFuture<Optional<Topology>, ReadFailedException> read =
rTx.read(LogicalDatastoreType.CONFIGURATION, buildReadPath(null));
- Futures.addCallback(read, SxpListenerUtil.createTxCloseCallback(rTx));
+ Futures.addCallback(read, SxpListenerUtil.createTxCloseCallback(rTx), MoreExecutors.directExecutor());
return Futures.transform(read, new Function<Optional<Topology>, Void>() {
@Nullable
}
return null;
}
- });
+ }, MoreExecutors.directExecutor());
}
private InstanceIdentifier<Topology> buildReadPath(final Sgt key) {
}
return foundGroups;
}
- });
+ }, MoreExecutors.directExecutor());
}
}