mirror of
https://github.com/apache/jclouds.git
synced 2025-02-26 20:47:14 +00:00
guests are now accessible because host-only ips are assigned in the same network as the default vbox host-only network (vboxnet0)
This commit is contained in:
parent
68290ba2b2
commit
92a940e95d
@ -88,17 +88,17 @@ public class IMachineToNodeMetadata implements Function<IMachine, NodeMetadata>
|
|||||||
for (String nameProtocolnumberAddressInboudportGuestTargetport : natAdapter.getNatDriver().getRedirects()) {
|
for (String nameProtocolnumberAddressInboudportGuestTargetport : natAdapter.getNatDriver().getRedirects()) {
|
||||||
Iterable<String> stuff = Splitter.on(',').split(nameProtocolnumberAddressInboudportGuestTargetport);
|
Iterable<String> stuff = Splitter.on(',').split(nameProtocolnumberAddressInboudportGuestTargetport);
|
||||||
String protocolNumber = Iterables.get(stuff, 1);
|
String protocolNumber = Iterables.get(stuff, 1);
|
||||||
String hostAddress = Iterables.get(stuff, 2);
|
|
||||||
String inboundPort = Iterables.get(stuff, 3);
|
String inboundPort = Iterables.get(stuff, 3);
|
||||||
String targetPort = Iterables.get(stuff, 5);
|
String targetPort = Iterables.get(stuff, 5);
|
||||||
if ("1".equals(protocolNumber) && "22".equals(targetPort)) {
|
if ("1".equals(protocolNumber) && "22".equals(targetPort)) {
|
||||||
int inPort = Integer.parseInt(inboundPort);
|
int inPort = Integer.parseInt(inboundPort);
|
||||||
ipTermination = inPort % NodeCreator.NODE_PORT_INIT;
|
ipTermination = inPort % NodeCreator.NODE_PORT_INIT + 2;
|
||||||
nodeMetadataBuilder.publicAddresses(ImmutableSet.of(hostAddress)).loginPort(inPort);
|
// nodeMetadataBuilder.publicAddresses(ImmutableSet.of(hostAddress)).loginPort(inPort);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
nodeMetadataBuilder.privateAddresses(ImmutableSet.of((NodeCreator.VMS_NETWORK + ipTermination) + ""));
|
nodeMetadataBuilder.privateAddresses(ImmutableSet.of((NodeCreator.VMS_NETWORK + ipTermination) + ""));
|
||||||
|
nodeMetadataBuilder.publicAddresses(ImmutableSet.of((NodeCreator.VMS_NETWORK + ipTermination) + ""));
|
||||||
|
|
||||||
LoginCredentials loginCredentials = new LoginCredentials("toor", "password", null, true);
|
LoginCredentials loginCredentials = new LoginCredentials("toor", "password", null, true);
|
||||||
nodeMetadataBuilder.credentials(loginCredentials);
|
nodeMetadataBuilder.credentials(loginCredentials);
|
||||||
|
@ -23,7 +23,6 @@ import static com.google.common.base.Preconditions.checkNotNull;
|
|||||||
import static org.jclouds.virtualbox.config.VirtualBoxConstants.VIRTUALBOX_IMAGE_PREFIX;
|
import static org.jclouds.virtualbox.config.VirtualBoxConstants.VIRTUALBOX_IMAGE_PREFIX;
|
||||||
import static org.jclouds.virtualbox.config.VirtualBoxConstants.VIRTUALBOX_NODE_PREFIX;
|
import static org.jclouds.virtualbox.config.VirtualBoxConstants.VIRTUALBOX_NODE_PREFIX;
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
import javax.inject.Inject;
|
import javax.inject.Inject;
|
||||||
@ -32,9 +31,10 @@ import javax.inject.Singleton;
|
|||||||
import org.jclouds.compute.ComputeServiceAdapter.NodeAndInitialCredentials;
|
import org.jclouds.compute.ComputeServiceAdapter.NodeAndInitialCredentials;
|
||||||
import org.jclouds.compute.callables.RunScriptOnNode;
|
import org.jclouds.compute.callables.RunScriptOnNode;
|
||||||
import org.jclouds.compute.domain.NodeMetadata;
|
import org.jclouds.compute.domain.NodeMetadata;
|
||||||
|
import org.jclouds.compute.domain.NodeMetadataBuilder;
|
||||||
import org.jclouds.compute.options.RunScriptOptions;
|
import org.jclouds.compute.options.RunScriptOptions;
|
||||||
import org.jclouds.domain.LoginCredentials;
|
import org.jclouds.domain.LoginCredentials;
|
||||||
import org.jclouds.virtualbox.domain.BridgedIf;
|
import org.jclouds.virtualbox.config.VirtualBoxComputeServiceContextModule;
|
||||||
import org.jclouds.virtualbox.domain.CloneSpec;
|
import org.jclouds.virtualbox.domain.CloneSpec;
|
||||||
import org.jclouds.virtualbox.domain.ExecutionType;
|
import org.jclouds.virtualbox.domain.ExecutionType;
|
||||||
import org.jclouds.virtualbox.domain.Master;
|
import org.jclouds.virtualbox.domain.Master;
|
||||||
@ -48,13 +48,17 @@ import org.jclouds.virtualbox.statements.SetIpAddress;
|
|||||||
import org.jclouds.virtualbox.util.MachineUtils;
|
import org.jclouds.virtualbox.util.MachineUtils;
|
||||||
import org.virtualbox_4_1.CleanupMode;
|
import org.virtualbox_4_1.CleanupMode;
|
||||||
import org.virtualbox_4_1.IMachine;
|
import org.virtualbox_4_1.IMachine;
|
||||||
|
import org.virtualbox_4_1.INetworkAdapter;
|
||||||
import org.virtualbox_4_1.IProgress;
|
import org.virtualbox_4_1.IProgress;
|
||||||
import org.virtualbox_4_1.ISession;
|
import org.virtualbox_4_1.ISession;
|
||||||
import org.virtualbox_4_1.NetworkAttachmentType;
|
import org.virtualbox_4_1.NetworkAttachmentType;
|
||||||
import org.virtualbox_4_1.VirtualBoxManager;
|
import org.virtualbox_4_1.VirtualBoxManager;
|
||||||
|
|
||||||
import com.google.common.base.Function;
|
import com.google.common.base.Function;
|
||||||
|
import com.google.common.base.Splitter;
|
||||||
import com.google.common.base.Supplier;
|
import com.google.common.base.Supplier;
|
||||||
|
import com.google.common.collect.ImmutableSet;
|
||||||
|
import com.google.common.collect.Iterables;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates nodes, by cloning a master vm and based on the provided {@link NodeSpec}. Must be
|
* Creates nodes, by cloning a master vm and based on the provided {@link NodeSpec}. Must be
|
||||||
@ -70,7 +74,7 @@ public class NodeCreator implements Function<NodeSpec, NodeAndInitialCredentials
|
|||||||
public static final int NODE_PORT_INIT = 3000;
|
public static final int NODE_PORT_INIT = 3000;
|
||||||
|
|
||||||
// TODO parameterize
|
// TODO parameterize
|
||||||
public static final String VMS_NETWORK = "33.33.33.";
|
public static final String VMS_NETWORK = "192.168.86.";
|
||||||
|
|
||||||
// TODO parameterize
|
// TODO parameterize
|
||||||
public static final String HOST_ONLY_IFACE_NAME = "vboxnet0";
|
public static final String HOST_ONLY_IFACE_NAME = "vboxnet0";
|
||||||
@ -97,8 +101,8 @@ public class NodeCreator implements Function<NodeSpec, NodeAndInitialCredentials
|
|||||||
RunScriptOnNode.Factory scriptRunnerFactory, Supplier<NodeMetadata> hostSupplier) {
|
RunScriptOnNode.Factory scriptRunnerFactory, Supplier<NodeMetadata> hostSupplier) {
|
||||||
this.manager = manager;
|
this.manager = manager;
|
||||||
this.cloner = cloner;
|
this.cloner = cloner;
|
||||||
this.nodePorts = new AtomicInteger(NODE_PORT_INIT + 1);
|
this.nodePorts = new AtomicInteger(NODE_PORT_INIT);
|
||||||
this.nodeIps = new AtomicInteger(1);
|
this.nodeIps = new AtomicInteger(2);
|
||||||
this.machineUtils = machineUtils;
|
this.machineUtils = machineUtils;
|
||||||
this.imachineToNodeMetadata = imachineToNodeMetadata;
|
this.imachineToNodeMetadata = imachineToNodeMetadata;
|
||||||
this.scriptRunnerFactory = scriptRunnerFactory;
|
this.scriptRunnerFactory = scriptRunnerFactory;
|
||||||
@ -145,10 +149,6 @@ public class NodeCreator implements Function<NodeSpec, NodeAndInitialCredentials
|
|||||||
.addHostInterfaceName(HOST_ONLY_IFACE_NAME).slot(1L).build();
|
.addHostInterfaceName(HOST_ONLY_IFACE_NAME).slot(1L).build();
|
||||||
|
|
||||||
NetworkSpec networkSpec = createNetworkSpecForHostOnlyNATNICs(natIfaceCard, hostOnlyIfaceCard);
|
NetworkSpec networkSpec = createNetworkSpecForHostOnlyNATNICs(natIfaceCard, hostOnlyIfaceCard);
|
||||||
// //
|
|
||||||
|
|
||||||
// CASE BRIDGED
|
|
||||||
// NetworkSpec networkSpec = createNetworkSpecForBridgedNIC();
|
|
||||||
|
|
||||||
CloneSpec cloneSpec = CloneSpec.builder().linked(USE_LINKED).master(master.getMachine()).network(networkSpec)
|
CloneSpec cloneSpec = CloneSpec.builder().linked(USE_LINKED).master(master.getMachine()).network(networkSpec)
|
||||||
.vm(cloneVmSpec).build();
|
.vm(cloneVmSpec).build();
|
||||||
@ -157,13 +157,15 @@ public class NodeCreator implements Function<NodeSpec, NodeAndInitialCredentials
|
|||||||
|
|
||||||
new LaunchMachineIfNotAlreadyRunning(manager.get(), EXECUTION_TYPE, "").apply(cloned);
|
new LaunchMachineIfNotAlreadyRunning(manager.get(), EXECUTION_TYPE, "").apply(cloned);
|
||||||
|
|
||||||
|
// IMachineToNodeMetadata produces the final ip's but these need to be set before so we build a
|
||||||
|
// NodeMetadata just for the sake of running the gshadow and setip scripts
|
||||||
|
NodeMetadata partialNodeMetadata = buildPartialNodeMetadata(cloned);
|
||||||
|
|
||||||
// see DeleteGShadowLock for a detailed explanation
|
// see DeleteGShadowLock for a detailed explanation
|
||||||
machineUtils
|
machineUtils.runScriptOnNode(partialNodeMetadata, new DeleteGShadowLock(), RunScriptOptions.NONE);
|
||||||
.runScriptOnNode(imachineToNodeMetadata.apply(cloned), new DeleteGShadowLock(), RunScriptOptions.NONE);
|
|
||||||
|
|
||||||
// CASE NAT + HOST-ONLY
|
// CASE NAT + HOST-ONLY
|
||||||
machineUtils.runScriptOnNode(imachineToNodeMetadata.apply(cloned), new SetIpAddress(hostOnlyIfaceCard),
|
machineUtils.runScriptOnNode(partialNodeMetadata, new SetIpAddress(hostOnlyIfaceCard), RunScriptOptions.NONE);
|
||||||
RunScriptOptions.NONE);
|
|
||||||
// //
|
// //
|
||||||
|
|
||||||
// TODO get credentials from somewhere else (they are also HC in
|
// TODO get credentials from somewhere else (they are also HC in
|
||||||
@ -174,22 +176,32 @@ public class NodeCreator implements Function<NodeSpec, NodeAndInitialCredentials
|
|||||||
return nodeAndInitialCredentials;
|
return nodeAndInitialCredentials;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private NodeMetadata buildPartialNodeMetadata(IMachine clone) {
|
||||||
|
INetworkAdapter realNatAdapter = clone.getNetworkAdapter(0l);
|
||||||
|
NodeMetadataBuilder nodeMetadataBuilder = new NodeMetadataBuilder();
|
||||||
|
nodeMetadataBuilder.id(clone.getName());
|
||||||
|
nodeMetadataBuilder.state(VirtualBoxComputeServiceContextModule.machineToNodeState.get(clone.getState()));
|
||||||
|
nodeMetadataBuilder.publicAddresses(ImmutableSet.of(realNatAdapter.getNatDriver().getHostIP()));
|
||||||
|
for (String nameProtocolnumberAddressInboudportGuestTargetport : realNatAdapter.getNatDriver().getRedirects()) {
|
||||||
|
Iterable<String> stuff = Splitter.on(',').split(nameProtocolnumberAddressInboudportGuestTargetport);
|
||||||
|
String protocolNumber = Iterables.get(stuff, 1);
|
||||||
|
String inboundPort = Iterables.get(stuff, 3);
|
||||||
|
String targetPort = Iterables.get(stuff, 5);
|
||||||
|
if ("1".equals(protocolNumber) && "22".equals(targetPort)) {
|
||||||
|
int inPort = Integer.parseInt(inboundPort);
|
||||||
|
nodeMetadataBuilder.loginPort(inPort);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
LoginCredentials loginCredentials = new LoginCredentials("toor", "password", null, true);
|
||||||
|
nodeMetadataBuilder.credentials(loginCredentials);
|
||||||
|
|
||||||
|
return nodeMetadataBuilder.build();
|
||||||
|
}
|
||||||
|
|
||||||
private NetworkSpec createNetworkSpecForHostOnlyNATNICs(NetworkInterfaceCard natIfaceCard,
|
private NetworkSpec createNetworkSpecForHostOnlyNATNICs(NetworkInterfaceCard natIfaceCard,
|
||||||
NetworkInterfaceCard hostOnlyIfaceCard) {
|
NetworkInterfaceCard hostOnlyIfaceCard) {
|
||||||
return NetworkSpec.builder().addNIC(natIfaceCard).addNIC(hostOnlyIfaceCard).build();
|
return NetworkSpec.builder().addNIC(natIfaceCard).addNIC(hostOnlyIfaceCard).build();
|
||||||
}
|
}
|
||||||
|
|
||||||
private NetworkSpec createNetworkSpecForBridgedNIC() {
|
|
||||||
List<BridgedIf> activeBridgedInterfaces = new RetrieveActiveBridgedInterfaces(scriptRunnerFactory)
|
|
||||||
.apply(hostSupplier.get());
|
|
||||||
BridgedIf bridgedActiveInterface = checkNotNull(activeBridgedInterfaces.get(0), "activeBridgedIf");
|
|
||||||
|
|
||||||
NetworkAdapter bridgedAdapter = NetworkAdapter.builder().networkAttachmentType(NetworkAttachmentType.Bridged)
|
|
||||||
.build();
|
|
||||||
NetworkInterfaceCard bridgedNIC = NetworkInterfaceCard.builder().addNetworkAdapter(bridgedAdapter)
|
|
||||||
.addHostInterfaceName(bridgedActiveInterface.getName()).slot(0L).build();
|
|
||||||
|
|
||||||
NetworkSpec networkSpec = NetworkSpec.builder().addNIC(bridgedNIC).build();
|
|
||||||
return networkSpec;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user