mirror of https://github.com/apache/jclouds.git
remove overrides from AzureComputeService for destroyNode and destroyNodesMatching
- uses https://github.com/jclouds/jclouds/pull/1135
This commit is contained in:
parent
fd00c7db75
commit
79daee361a
|
@ -16,13 +16,6 @@
|
|||
*/
|
||||
package org.jclouds.azurecompute.arm.compute;
|
||||
|
||||
import static com.google.common.collect.Iterables.filter;
|
||||
import static com.google.common.collect.Sets.newHashSet;
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_RUNNING;
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_SUSPENDED;
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_TERMINATED;
|
||||
import static org.jclouds.compute.predicates.NodePredicates.all;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
import java.util.Set;
|
||||
|
@ -69,6 +62,10 @@ import com.google.common.collect.ImmutableMultimap;
|
|||
import com.google.common.collect.ImmutableSet;
|
||||
import com.google.common.util.concurrent.ListeningExecutorService;
|
||||
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_RUNNING;
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_SUSPENDED;
|
||||
import static org.jclouds.compute.config.ComputeServiceProperties.TIMEOUT_NODE_TERMINATED;
|
||||
|
||||
@Singleton
|
||||
public class AzureComputeService extends BaseComputeService {
|
||||
private final CleanupResources cleanupResources;
|
||||
|
@ -127,28 +124,5 @@ public class AzureComputeService extends BaseComputeService {
|
|||
cleanupResources.deleteResourceGroupIfEmpty(resourceGroup);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void destroyNode(String id) {
|
||||
// Azure ARM does not return TERMINATED nodes, so in practice no node will never reach the TERMINATED
|
||||
// state, and the deleted nodes will never be returned.
|
||||
// In order to be able to clean up the resources associated to the deleted nodes, we have to retrieve
|
||||
// the details of the nodes before deleting them.
|
||||
NodeMetadata nodeMetadataBeforeDelete = getNodeMetadata(id);
|
||||
super.destroyNode(id);
|
||||
//Node metadata is null after deletion but we still need to clean up incidental resources
|
||||
cleanUpIncidentalResourcesOfDeadNodes(ImmutableSet.of(nodeMetadataBeforeDelete));
|
||||
}
|
||||
|
||||
@Override
|
||||
public Set<? extends NodeMetadata> destroyNodesMatching(Predicate<? super NodeMetadata> filter) {
|
||||
// Azure ARM does not return TERMINATED nodes, so in practice no node will never reach the TERMINATED
|
||||
// state, and the deleted nodes will never be returned.
|
||||
// In order to be able to clean up the resources associated to the deleted nodes, we have to retrieve
|
||||
// the details of the nodes before deleting them.
|
||||
Set<? extends NodeMetadata> nodes = newHashSet(filter(listNodesDetailsMatching(all()), filter));
|
||||
super.destroyNodesMatching(filter); // This returns an empty list (a list of null elements) in Azure ARM, as the api does not return deleted nodes
|
||||
cleanUpIncidentalResourcesOfDeadNodes(nodes);
|
||||
return nodes;
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue