> 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>>() {
Ooo...eeek. What is this "dummy" function at the end here - is that just an
evil way of calling `rebootNode` on all the matching nodes in parallel? If so,
please add a comment?
---
Reply to this email directly or view it on GitHub:
https://github.com/jclouds/jclouds/pull/419/files#r14141309
