mirror of https://github.com/apache/jclouds.git
issue 384: refactor sendScancode - andrei and adrian comments addressed
This commit is contained in:
parent
01c3319258
commit
8258415bbd
|
@ -106,18 +106,11 @@ public class CreateAndInstallVm implements Function<IMachineSpec, IMachine> {
|
||||||
}
|
}
|
||||||
|
|
||||||
private void configureOsInstallationWithKeyboardSequence(String vmName, String installationKeySequence) {
|
private void configureOsInstallationWithKeyboardSequence(String vmName, String installationKeySequence) {
|
||||||
|
|
||||||
Iterable<List<Integer>> scancodelist =
|
Iterable<List<Integer>> scancodelist =
|
||||||
transform(Splitter.on(" ").split(installationKeySequence), new StringToKeyCode());
|
transform(Splitter.on(" ").split(installationKeySequence), new StringToKeyCode());
|
||||||
|
|
||||||
for (List<Integer> scancodes : scancodelist) {
|
for (List<Integer> scancodes : scancodelist) {
|
||||||
machineUtils.lockSessionOnMachineAndApply(vmName, LockType.Shared, new SendScancode(scancodes));
|
machineUtils.lockSessionOnMachineAndApply(vmName, LockType.Shared, new SendScancode(scancodes));
|
||||||
// this is needed to avoid to miss any scancode
|
|
||||||
try {
|
|
||||||
Thread.sleep(300);
|
|
||||||
} catch (InterruptedException e) {
|
|
||||||
logger.error("Problem in sleeping the current thread.", e);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -20,12 +20,26 @@ package org.jclouds.virtualbox.functions;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import javax.inject.Named;
|
||||||
|
|
||||||
|
import org.jclouds.compute.reference.ComputeServiceConstants;
|
||||||
|
import org.jclouds.logging.Logger;
|
||||||
|
import org.jclouds.virtualbox.settings.KeyboardScancodes;
|
||||||
import org.virtualbox_4_1.ISession;
|
import org.virtualbox_4_1.ISession;
|
||||||
|
|
||||||
|
import com.beust.jcommander.internal.Lists;
|
||||||
import com.google.common.base.Function;
|
import com.google.common.base.Function;
|
||||||
|
import com.google.common.collect.Sets;
|
||||||
|
|
||||||
class SendScancode implements Function<ISession, Void> {
|
class SendScancode implements Function<ISession, Void> {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
@Named(ComputeServiceConstants.COMPUTE_LOGGER)
|
||||||
|
protected Logger logger = Logger.NULL;
|
||||||
|
|
||||||
|
|
||||||
|
private static final int MAX_KEYCODES_ACCEPTED = 30;
|
||||||
private final List<Integer> scancodes;
|
private final List<Integer> scancodes;
|
||||||
|
|
||||||
public SendScancode(List<Integer> scancodes) {
|
public SendScancode(List<Integer> scancodes) {
|
||||||
|
@ -34,8 +48,30 @@ class SendScancode implements Function<ISession, Void> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Void apply(ISession iSession) {
|
public Void apply(ISession iSession) {
|
||||||
for (Integer scancode : scancodes) {
|
int i = 0, j = 0, length = scancodes.size();
|
||||||
iSession.getConsole().getKeyboard().putScancode(scancode);
|
if (length > MAX_KEYCODES_ACCEPTED) {
|
||||||
|
while (i <= length) {
|
||||||
|
j = (i + 30 > length) ? length : i + MAX_KEYCODES_ACCEPTED;
|
||||||
|
List<Integer> sublist = Lists.newArrayList(scancodes).subList(i, j);
|
||||||
|
long codeStores = iSession.getConsole().getKeyboard().putScancodes(sublist);
|
||||||
|
logger.debug("List of scancodes sent: ", sublist);
|
||||||
|
assert(codeStores==sublist.size());
|
||||||
|
i = i + MAX_KEYCODES_ACCEPTED;
|
||||||
|
try {
|
||||||
|
Thread.sleep(50);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
logger.debug("There was a problem in sleeping this thread", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
iSession.getConsole().getKeyboard().putScancodes(scancodes);
|
||||||
|
if(Sets.difference(Sets.newHashSet(scancodes), Sets.newHashSet(KeyboardScancodes.SPECIAL_KEYBOARD_BUTTON_MAP_LIST.values())) != null) {
|
||||||
|
try {
|
||||||
|
Thread.sleep(200);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
logger.debug("There was a problem in sleeping this thread", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue