> logger.debug(">> rebooting nodes matching(%s)", filter);
> -
> transformParallel(nodesMatchingFilterAndNotTerminatedExceptionIfNotFound(filter),
> - new Function<NodeMetadata, ListenableFuture<? extends Void>>() {
> - // TODO use native async
> - @Override
> - public ListenableFuture<Void> apply(NodeMetadata from) {
> - rebootNode(from.getId());
> - return immediateFuture(null);
> - }
> -
> - }, userExecutor, null, logger, "rebootNodesMatching(" + filter +
> ")");
> + Set<NodeMetadata> set =
> ImmutableSet.copyOf(transformParallel(nodesMatchingFilterAndNotTerminatedExceptionIfNotFound(filter),
> + new Function<NodeMetadata, ListenableFuture<? extends
> NodeMetadata>>() {
The idea for this was copied from the method "destroyNodesMatching" which does
exactly the same thing. Is there a better way to go about this?
---
Reply to this email directly or view it on GitHub:
https://github.com/jclouds/jclouds/pull/419/files#r14142345
