452fd0f33b11dc60aad994e3001c74415179d401vboxsync

452fd0f33b11dc60aad994e3001c74415179d401vboxsyncimport os,sys

452fd0f33b11dc60aad994e3001c74415179d401vboxsyncimport traceback

452fd0f33b11dc60aad994e3001c74415179d401vboxsyncimport shlex

452fd0f33b11dc60aad994e3001c74415179d401vboxsyncimport time

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncimport re

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncimport platform

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncclass GuestMonitor:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def __init__(self, mach):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.mach = mach

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMousePointerShapeChange(self, visible, alpha, xHot, yHot, width, height, shape):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onMousePointerShapeChange: visible=%d shape=%d bytes" %(self.mach.name, visible,len(shape))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMouseCapabilityChange(self, supportsAbsolute, supportsRelative, needsHostCursor):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onMouseCapabilityChange: supportsAbsolute = %d, supportsRelative = %d, needsHostCursor = %d" %(self.mach.name, supportsAbsolute, supportsRelative, needsHostCursor)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onKeyboardLedsChange(self, numLock, capsLock, scrollLock):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onKeyboardLedsChange capsLock=%d" %(self.mach.name, capsLock)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onStateChange(self, state):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onStateChange state=%d" %(self.mach.name, state)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onAdditionsStateChange(self):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onAdditionsStateChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onNetworkAdapterChange(self, adapter):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onNetworkAdapterChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSerialPortChange(self, port):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onSerialPortChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onParallelPortChange(self, port):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onParallelPortChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onStorageControllerChange(self):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onStorageControllerChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMediumChange(self, attachment):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onMediumChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onVRDPServerChange(self):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onVRDPServerChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onUSBControllerChange(self):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onUSBControllerChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onUSBDeviceStateChange(self, device, attached, error):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onUSBDeviceStateChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSharedFolderChange(self, scope):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onSharedFolderChange" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onRuntimeError(self, fatal, id, message):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onRuntimeError fatal=%d message=%s" %(self.mach.name, fatal, message)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onCanShowWindow(self):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onCanShowWindow" %(self.mach.name)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return True

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onShowWindow(self, winId):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: onShowWindow: %d" %(self.mach.name, winId)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncclass VBoxMonitor:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def __init__(self, params):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.vbox = params[0]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.isMscom = params[1]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync pass

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMachineStateChange(self, id, state):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onMachineStateChange: %s %d" %(id, state)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMachineDataChange(self,id):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onMachineDataChange: %s" %(id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onExtraDataCanChange(self, id, key, value):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onExtraDataCanChange: %s %s=>%s" %(id, key, value)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # Witty COM bridge thinks if someone wishes to return tuple, hresult

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # is one of values we want to return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if self.isMscom:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return "", 0, True

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return True, ""

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onExtraDataChange(self, id, key, value):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onExtraDataChange: %s %s=>%s" %(id, key, value)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMediaRegistered(self, id, type, registered):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onMediaRegistered: %s" %(id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onMachineRegistered(self, id, registred):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onMachineRegistered: %s" %(id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSessionStateChange(self, id, state):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onSessionStateChange: %s %d" %(id, state)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSnapshotTaken(self, mach, id):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onSnapshotTaken: %s %s" %(mach, id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSnapshotDeleted(self, mach, id):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onSnapshotDeleted: %s %s" %(mach, id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onSnapshotChange(self, mach, id):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onSnapshotChange: %s %s" %(mach, id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def onGuestPropertyChange(self, id, name, newValue, flags):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "onGuestPropertyChange: %s: %s=%s" %(id, name, newValue)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncg_hasreadline = True

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsynctry:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_hasreadline:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync import readline

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync import rlcompleter

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncexcept:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync g_hasreadline = False

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

1015282e080c4f8f1f472292af76275506de8313vboxsyncg_hascolors = True

1015282e080c4f8f1f472292af76275506de8313vboxsyncterm_colors = {

1015282e080c4f8f1f472292af76275506de8313vboxsync 'red':'\033[31m',

1015282e080c4f8f1f472292af76275506de8313vboxsync 'blue':'\033[94m',

1015282e080c4f8f1f472292af76275506de8313vboxsync 'green':'\033[92m',

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'yellow':'\033[93m',

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'magenta':'\033[35m'

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync }

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colored(string,color):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if not g_hascolors:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return string

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync global term_colors

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync col = term_colors.get(color,None)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if col:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return col+str(string)+'\033[0m'

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return string

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncif g_hasreadline:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync import string

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync class CompleterNG(rlcompleter.Completer):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def __init__(self, dic, ctx):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.ctx = ctx

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return rlcompleter.Completer.__init__(self,dic)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def complete(self, text, state):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync """

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if False and text == "":

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return ['\t',None][state]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return rlcompleter.Completer.complete(self,text,state)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def canBePath(self, phrase,word):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return word.startswith('/')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def canBeCommand(self, phrase, word):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync spaceIdx = phrase.find(" ")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync begIdx = readline.get_begidx()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync firstWord = (spaceIdx == -1 or begIdx < spaceIdx)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if firstWord:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return True

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if phrase.startswith('help'):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return True

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return False

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def canBeMachine(self,phrase,word):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return not self.canBePath(phrase,word) and not self.canBeCommand(phrase, word)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def global_matches(self, text):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync """

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync matches = []

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync phrase = readline.get_line_buffer()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if self.canBePath(phrase,text):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync (dir,rest) = os.path.split(text)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync n = len(rest)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for word in os.listdir(dir):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if n == 0 or word[:n] == rest:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync matches.append(os.path.join(dir,word))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if self.canBeCommand(phrase,text):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync n = len(text)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for list in [ self.namespace ]:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for word in list:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if word[:n] == text:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync matches.append(word)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if self.canBeMachine(phrase,text):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync n = len(text)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for m in getMachines(self.ctx, False, True):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # although it has autoconversion, we need to cast

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # explicitly for subscripts to work

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync word = re.sub("(?<!\\\\) ", "\\ ", str(m.name))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if word[:n] == text:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync matches.append(word)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync word = str(m.id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if word[:n] == text:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync matches.append(word)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception,e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(e)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return matches

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef autoCompletion(commands, ctx):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if not g_hasreadline:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync comps = {}

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for (k,v) in commands.items():

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync comps[k] = None

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync completer = CompleterNG(comps, ctx)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.set_completer(completer.complete)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync delims = readline.get_completer_delims()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.set_completer_delims(re.sub("[\\./-]", "", delims)) # remove some of the delimiters

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.parse_and_bind("set editing-mode emacs")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # OSX need it

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if platform.system() == 'Darwin':

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # see http://www.certif.com/spec_help/readline.html

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.parse_and_bind ("bind ^I rl_complete")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.parse_and_bind ("bind ^W ed-delete-prev-word")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # Doesn't work well

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # readline.parse_and_bind ("bind ^R em-inc-search-prev")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync readline.parse_and_bind("tab: complete")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncg_verbose = False

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef split_no_quotes(s):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return shlex.split(s)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef progressBar(ctx,p,wait=1000):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync while not p.completed:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s %%\r" %(colored(str(p.percent),'red')),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync sys.stdout.flush()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync p.waitForCompletion(wait)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['global'].waitForEvents(0)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 1

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except KeyboardInterrupt:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Interrupted."

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if p.cancelable:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Canceling task..."

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync p.cancel()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 0

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef printErr(ctx,e):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print colored(str(e), 'red')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef reportError(ctx,progress):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ei = progress.errorInfo

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if ei:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print colored("Error in %s: %s" %(ei.component, ei.text), 'red')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colCat(ctx,str):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(str, 'magenta')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colVm(ctx,vm):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(vm, 'blue')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colPath(ctx,p):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(p, 'green')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colSize(ctx,m):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(m, 'red')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef colSizeM(ctx,m):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(str(m)+'M', 'red')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef createVm(ctx,name,kind,base):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mgr = ctx['mgr']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb = ctx['vb']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = vb.createMachine(name, kind, base, "", False)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach.saveSettings()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "created machine with UUID",mach.id

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb.registerMachine(mach)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # update cache

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync getMachines(ctx, True)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef removeVm(ctx,mach):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mgr = ctx['mgr']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb = ctx['vb']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync id = mach.id

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "removing machine ",mach.name,"with UUID",id

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cmdClosedVm(ctx, mach, detachVmDevice, ["ALL"])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = vb.unregisterMachine(id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if mach:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach.deleteSettings()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # update cache

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync getMachines(ctx, True)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef startVm(ctx,mach,type):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mgr = ctx['mgr']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb = ctx['vb']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync perf = ctx['perf']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session = mgr.getSessionObject(vb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync uuid = mach.id

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync progress = vb.openRemoteSession(session, uuid, type, "")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if progressBar(ctx, progress, 100) and int(progress.resultCode) == 0:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # we ignore exceptions to allow starting VM even if

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # perf collector cannot be started

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if perf:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync perf.setup(['*'], [mach], 10, 15)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception,e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(ctx, e)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # if session not opened, close doesn't make sense

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session.close()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync reportError(ctx,progress)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncclass CachedMach:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync def __init__(self, mach):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.name = mach.name

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync self.id = mach.id

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef cacheMachines(ctx,list):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync result = []

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for m in list:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync elem = CachedMach(m)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync result.append(elem)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return result

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef getMachines(ctx, invalidate = False, simple=False):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if ctx['vb'] is not None:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if ctx['_machlist'] is None or invalidate:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['_machlist'] = ctx['global'].getArray(ctx['vb'], 'machines')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['_machlistsimple'] = cacheMachines(ctx,ctx['_machlist'])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if simple:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return ctx['_machlistsimple']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return ctx['_machlist']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return []

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef asState(var):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if var:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored('on', 'green')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored('off', 'green')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef asFlag(var):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if var:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 'yes'

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 'no'

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef perfStats(ctx,mach):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if not ctx['perf']:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for metric in ctx['perf'].query(["*"], [mach]):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print metric['name'], metric['values_as_string']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef guestExec(ctx, machine, console, cmds):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync exec cmds

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef monitorGuest(ctx, machine, console, dur):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cb = ctx['global'].createCallback('IConsoleCallback', GuestMonitor, machine)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync console.registerCallback(cb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if dur == -1:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # not infinity, but close enough

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync dur = 100000

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync end = time.time() + dur

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync while time.time() < end:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['global'].waitForEvents(500)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # We need to catch all exceptions here, otherwise callback will never be unregistered

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync pass

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync console.unregisterCallback(cb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef monitorVBox(ctx, dur):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vbox = ctx['vb']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync isMscom = (ctx['global'].type == 'MSCOM')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cb = ctx['global'].createCallback('IVirtualBoxCallback', VBoxMonitor, [vbox, isMscom])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vbox.registerCallback(cb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if dur == -1:

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync # not infinity, but close enough

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync dur = 100000

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync try:

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync end = time.time() + dur

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync while time.time() < end:

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync ctx['global'].waitForEvents(500)

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync # We need to catch all exceptions here, otherwise callback will never be unregistered

1cd59fdf671ca60c64d77e3f7046aaecf7003824vboxsync except:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync pass

1522fd0a1b3f8a389582eaf96f3980cfe141547cvboxsync vbox.unregisterCallback(cb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef takeScreenshot(ctx,console,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync from PIL import Image

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync display = console.display

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 0:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync f = args[0]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync f = "/tmp/screenshot.png"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 3:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync screen = int(args[3])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync screen = 0

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync (fbw, fbh, fbbpp) = display.getScreenResolution(screen)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 1:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync w = int(args[1])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync w = fbw

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 2:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync h = int(args[2])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync h = fbh

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Saving screenshot (%d x %d) screen %d in %s..." %(w,h,screen,f)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync data = display.takeScreenShotToArray(screen, w,h)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync size = (w,h)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mode = "RGBA"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync im = Image.frombuffer(mode, size, str(data), "raw", mode, 0, 1)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync im.save(f, "PNG")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef teleport(ctx,session,console,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if args[0].find(":") == -1:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Use host:port format for teleport target"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync (host,port) = args[0].split(":")

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 1:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync passwd = args[1]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync passwd = ""

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 2:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync maxDowntime = int(args[2])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync maxDowntime = 250

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync port = int(port)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Teleporting to %s:%d..." %(host,port)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync progress = console.teleport(host, port, passwd, maxDowntime)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if progressBar(ctx, progress, 100) and int(progress.resultCode) == 0:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Success!"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync reportError(ctx,progress)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef guestStats(ctx,console,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync guest = console.guest

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # we need to set up guest statistics

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) > 0 :

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync update = args[0]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync update = 1

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if guest.statisticsUpdateInterval != update:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync guest.statisticsUpdateInterval = update

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync time.sleep(float(update)+0.1)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # to allow sleep interruption

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync pass

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync all_stats = ctx['ifaces'].all_values('GuestStatisticType')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cpu = 0

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for s in all_stats.keys():

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync val = guest.getStatistic( cpu, all_stats[s])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%s: %d" %(s, val)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # likely not implemented

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync pass

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef plugCpu(ctx,machine,session,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cpu = int(args[0])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Adding CPU %d..." %(cpu)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync machine.hotPlugCPU(cpu)

556b9e3b1c6d79e049afbfa9c42a3aadeb5f8526vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef unplugCpu(ctx,machine,session,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cpu = int(args[0])

556b9e3b1c6d79e049afbfa9c42a3aadeb5f8526vboxsync print "Removing CPU %d..." %(cpu)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync machine.hotUnplugCPU(cpu)

556b9e3b1c6d79e049afbfa9c42a3aadeb5f8526vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef mountIso(ctx,machine,session,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync machine.mountMedium(args[0], args[1], args[2], args[3], args[4])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync machine.saveSettings()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef cond(c,v1,v2):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if c:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return v1

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return v2

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef printHostUsbDev(ctx,ud):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print " %s: %s (vendorId=%d productId=%d serial=%s) %s" %(ud.id, colored(ud.product,'blue'), ud.vendorId, ud.productId, ud.serialNumber,asEnumElem(ctx, 'USBDeviceState', ud.state))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef printUsbDev(ctx,ud):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print " %s: %s (vendorId=%d productId=%d serial=%s)" %(ud.id, colored(ud.product,'blue'), ud.vendorId, ud.productId, ud.serialNumber)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef printSf(ctx,sf):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print " name=%s host=%s %s %s" %(sf.name, sf.hostPath, cond(sf.accessible, "accessible", "not accessible"), cond(sf.writable, "writable", "read-only"))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef ginfo(ctx,console, args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync guest = console.guest

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if guest.additionsActive:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vers = int(str(guest.additionsVersion))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Additions active, version %d.%d" %(vers >> 16, vers & 0xffff)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Support seamless: %s" %(asFlag(guest.supportsSeamless))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Support graphics: %s" %(asFlag(guest.supportsGraphics))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Baloon size: %d" %(guest.memoryBalloonSize)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Statistic update interval: %d" %(guest.statisticsUpdateInterval)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "No additions"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync usbs = ctx['global'].getArray(console, 'USBDevices')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Attached USB:"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for ud in usbs:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printUsbDev(ctx,ud)

8f35148193cfa7ae5fd29370c1a09105e655c08dvboxsync rusbs = ctx['global'].getArray(console, 'remoteUSBDevices')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Remote USB:"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for ud in rusbs:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printHostUsbDev(ctx,ud)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Transient shared folders:"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync sfs = rusbs = ctx['global'].getArray(console, 'sharedFolders')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for sf in sfs:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printSf(ctx,sf)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef cmdExistingVm(ctx,mach,cmd,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session = None

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb = ctx['vb']

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session = ctx['mgr'].getSessionObject(vb)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync vb.openExistingSession(session, mach.id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception,e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(ctx, "Session to '%s' not open: %s" %(mach.name,str(e)))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if session.state != ctx['ifaces'].SessionState_Open:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Session to '%s' in wrong state: %s" %(mach.name, session.state)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session.close()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # this could be an example how to handle local only (i.e. unavailable

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync # in Webservices) functionality

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if ctx['remote'] and cmd == 'some_local_only_command':

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print 'Trying to use local only functionality, ignored'

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session.close()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync console=session.console

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ops={'pause': lambda: console.pause(),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'resume': lambda: console.resume(),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'powerdown': lambda: console.powerDown(),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'powerbutton': lambda: console.powerButton(),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'stats': lambda: perfStats(ctx, mach),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'guest': lambda: guestExec(ctx, mach, console, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'ginfo': lambda: ginfo(ctx, console, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'guestlambda': lambda: args[0](ctx, mach, console, args[1:]),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'monitorGuest': lambda: monitorGuest(ctx, mach, console, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'save': lambda: progressBar(ctx,console.saveState()),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'screenshot': lambda: takeScreenshot(ctx,console,args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'teleport': lambda: teleport(ctx,session,console,args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'gueststats': lambda: guestStats(ctx, console, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'plugcpu': lambda: plugCpu(ctx, session.machine, session, args),

48f33dfd8f615d457106bf76ae2d09b8b9167c1avboxsync 'unplugcpu': lambda: unplugCpu(ctx, session.machine, session, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync 'mountiso': lambda: mountIso(ctx, session.machine, session, args),

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync }

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ops[cmd]()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception, e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(ctx,e)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session.close()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef cmdClosedVm(ctx,mach,cmd,args=[],save=True):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session = ctx['global'].openMachineSession(mach.id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = session.machine

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cmd(ctx, mach, args)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception, e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync save = False

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(ctx,e)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if save:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach.saveSettings()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['global'].closeMachineSession(session)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef cmdAnyVm(ctx,mach,cmd, args=[],save=False):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync session = ctx['global'].openMachineSession(mach.id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = session.machine

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync try:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cmd(ctx, mach, session.console, args)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync except Exception, e:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync save = False;

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync printErr(ctx,e)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if g_verbose:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync traceback.print_exc()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if save:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach.saveSettings()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync ctx['global'].closeMachineSession(session)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef machById(ctx,id):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = None

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for m in getMachines(ctx):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if m.name == id:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = m

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync break

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mid = str(m.id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if mid[0] == '{':

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mid = mid[1:-1]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if mid == id:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync mach = m

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync break

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return mach

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef argsToMach(ctx,args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) < 2:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "usage: %s [vmname|uuid]" %(args[0])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return None

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync id = args[1]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync m = machById(ctx, id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if m == None:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Machine '%s' is unknown, use list command to find available machines" %(id)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return m

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef helpSingleCmd(cmd,h,sp):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if sp != 0:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync spec = " [ext from "+sp+"]"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync spec = ""

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print " %s: %s%s" %(colored(cmd,'blue'),h,spec)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef helpCmd(ctx, args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if len(args) == 1:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Help page:"

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync names = commands.keys()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync names.sort()

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for i in names:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync helpSingleCmd(i, commands[i][0], commands[i][2])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync cmd = args[1]

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync c = commands.get(cmd)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if c == None:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "Command '%s' not known" %(cmd)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync helpSingleCmd(cmd, c[0], c[2])

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 0

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef asEnumElem(ctx,enum,elem):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync all = ctx['ifaces'].all_values(enum)

48f33dfd8f615d457106bf76ae2d09b8b9167c1avboxsync for e in all.keys():

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if str(elem) == str(all[e]):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored(e, 'green')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return colored("<unknown>", 'green')

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef enumFromString(ctx,enum,str):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync all = ctx['ifaces'].all_values(enum)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return all.get(str, None)

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsyncdef listCmd(ctx, args):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync for m in getMachines(ctx, True):

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync if m.teleporterEnabled:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync tele = "[T] "

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync else:

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync tele = " "

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync print "%sMachine '%s' [%s], machineState=%s, sessionState=%s" %(tele,colVm(ctx,m.name),m.id,asEnumElem(ctx, "MachineState", m.state), asEnumElem(ctx,"SessionState", m.sessionState))

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync return 0

febf3f1de573e25fb134b8453a22b0732b4c52e2vboxsync

def infoCmd(ctx,args):

if (len(args) < 2):

print "usage: info [vmname|uuid]"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

os = ctx['vb'].getGuestOSType(mach.OSTypeId)

print " One can use setvar <mach> <var> <value> to change variable, using name in []."

print " Name [name]: %s" %(colVm(ctx,mach.name))

print " Description [description]: %s" %(mach.description)

print " ID [n/a]: %s" %(mach.id)

print " OS Type [via OSTypeId]: %s" %(os.description)

print " Firmware [firmwareType]: %s (%s)" %(asEnumElem(ctx,"FirmwareType", mach.firmwareType),mach.firmwareType)

print

print " CPUs [CPUCount]: %d" %(mach.CPUCount)

print " RAM [memorySize]: %dM" %(mach.memorySize)

print " VRAM [VRAMSize]: %dM" %(mach.VRAMSize)

print " Monitors [monitorCount]: %d" %(mach.monitorCount)

print

print " Clipboard mode [clipboardMode]: %s (%s)" %(asEnumElem(ctx,"ClipboardMode", mach.clipboardMode), mach.clipboardMode)

print " Machine status [n/a]: %s (%s)" % (asEnumElem(ctx,"SessionState", mach.sessionState), mach.sessionState)

print

if mach.teleporterEnabled:

print " Teleport target on port %d (%s)" %(mach.teleporterPort, mach.teleporterPassword)

print

bios = mach.BIOSSettings

print " ACPI [BIOSSettings.ACPIEnabled]: %s" %(asState(bios.ACPIEnabled))

print " APIC [BIOSSettings.IOAPICEnabled]: %s" %(asState(bios.IOAPICEnabled))

hwVirtEnabled = mach.getHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_Enabled)

print " Hardware virtualization [mach.setHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_Enabled,value)]: " + asState(hwVirtEnabled)

hwVirtVPID = mach.getHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_VPID)

print " VPID support [mach.setHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_VPID,value)]: " + asState(hwVirtVPID)

hwVirtNestedPaging = mach.getHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_NestedPaging)

print " Nested paging [mach.setHWVirtExProperty(ctx['global'].constants.HWVirtExPropertyType_NestedPaging,value)]: " + asState(hwVirtNestedPaging)

print " Hardware 3d acceleration [accelerate3DEnabled]: " + asState(mach.accelerate3DEnabled)

print " Hardware 2d video acceleration [accelerate2DVideoEnabled]: " + asState(mach.accelerate2DVideoEnabled)

print " Use universal time [RTCUseUTC]: %s" %(asState(mach.RTCUseUTC))

print " HPET [hpetEnabled]: %s" %(asState(mach.hpetEnabled))

if mach.audioAdapter.enabled:

print " Audio [via audioAdapter]: chip %s; host driver %s" %(asEnumElem(ctx,"AudioControllerType", mach.audioAdapter.audioController), asEnumElem(ctx,"AudioDriverType", mach.audioAdapter.audioDriver))

if mach.USBController.enabled:

print " USB [via USBController]: high speed %s" %(asState(mach.USBController.enabledEhci))

print " CPU hotplugging [CPUHotPlugEnabled]: %s" %(asState(mach.CPUHotPlugEnabled))

print " Keyboard [keyboardHidType]: %s (%s)" %(asEnumElem(ctx,"KeyboardHidType", mach.keyboardHidType), mach.keyboardHidType)

print " Pointing device [pointingHidType]: %s (%s)" %(asEnumElem(ctx,"PointingHidType", mach.pointingHidType), mach.pointingHidType)

print " Last changed [n/a]: " + time.asctime(time.localtime(long(mach.lastStateChange)/1000))

print " VRDP server [VRDPServer.enabled]: %s" %(asState(mach.VRDPServer.enabled))

print

print colCat(ctx," I/O subsystem info:")

print " Cache enabled [ioCacheEnabled]: %s" %(asState(mach.ioCacheEnabled))

print " Cache size [ioCacheSize]: %dM" %(mach.ioCacheSize)

print " Bandwidth limit [ioBandwidthMax]: %dM/s" %(mach.ioBandwidthMax)

controllers = ctx['global'].getArray(mach, 'storageControllers')

if controllers:

print

print colCat(ctx," Controllers:")

for controller in controllers:

print " '%s': bus %s type %s" % (controller.name, asEnumElem(ctx,"StorageBus", controller.bus), asEnumElem(ctx,"StorageControllerType", controller.controllerType))

attaches = ctx['global'].getArray(mach, 'mediumAttachments')

if attaches:

print

print colCat(ctx," Media:")

for a in attaches:

print " Controller: '%s' port/device: %d:%d type: %s (%s):" % (a.controller, a.port, a.device, asEnumElem(ctx,"DeviceType", a.type), a.type)

m = a.medium

if a.type == ctx['global'].constants.DeviceType_HardDisk:

print " HDD:"

print " Id: %s" %(m.id)

print " Location: %s" %(m.location)

print " Name: %s" %(m.name)

print " Format: %s" %(m.format)

if a.type == ctx['global'].constants.DeviceType_DVD:

print " DVD:"

if m:

print " Id: %s" %(m.id)

print " Name: %s" %(m.name)

if m.hostDrive:

print " Host DVD %s" %(m.location)

if a.passthrough:

print " [passthrough mode]"

else:

print " Virtual image at %s" %(m.location)

print " Size: %s" %(m.size)

if a.type == ctx['global'].constants.DeviceType_Floppy:

print " Floppy:"

if m:

print " Id: %s" %(m.id)

print " Name: %s" %(m.name)

if m.hostDrive:

print " Host floppy %s" %(m.location)

else:

print " Virtual image at %s" %(m.location)

print " Size: %s" %(m.size)

print

print colCat(ctx," Shared folders:")

for sf in ctx['global'].getArray(mach, 'sharedFolders'):

printSf(ctx,sf)

return 0

def startCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

if len(args) > 2:

type = args[2]

else:

type = "gui"

startVm(ctx, mach, type)

return 0

def createVmCmd(ctx, args):

if (len(args) < 3 or len(args) > 4):

print "usage: createvm name ostype <basefolder>"

return 0

name = args[1]

oskind = args[2]

if len(args) == 4:

base = args[3]

else:

base = ''

try:

ctx['vb'].getGuestOSType(oskind)

except Exception, e:

print 'Unknown OS type:',oskind

return 0

createVm(ctx, name, oskind, base)

return 0

def ginfoCmd(ctx,args):

if (len(args) < 2):

print "usage: ginfo [vmname|uuid]"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'ginfo', '')

return 0

def execInGuest(ctx,console,args,env,user,passwd,tmo):

if len(args) < 1:

print "exec in guest needs at least program name"

return

guest = console.guest

# shall contain program name as argv[0]

gargs = args

print "executing %s with args %s as %s" %(args[0], gargs, user)

(progress, pid) = guest.executeProcess(args[0], 0, gargs, env, user, passwd, tmo)

print "executed with pid %d" %(pid)

if pid != 0:

try:

while True:

data = guest.getProcessOutput(pid, 0, 1000, 4096)

if data and len(data) > 0:

sys.stdout.write(data)

continue

progress.waitForCompletion(100)

ctx['global'].waitForEvents(0)

if progress.completed:

break

except KeyboardInterrupt:

print "Interrupted."

if progress.cancelable:

progress.cancel()

(reason, code, flags) = guest.getProcessStatus(pid)

print "Exit code: %d" %(code)

return 0

else:

reportError(ctx, progress)

def nh_raw_input(prompt=""):

stream = sys.stdout

prompt = str(prompt)

if prompt:

stream.write(prompt)

line = sys.stdin.readline()

if not line:

raise EOFError

if line[-1] == '\n':

line = line[:-1]

return line

def getCred(ctx):

import getpass

user = getpass.getuser()

user_inp = raw_input("User (%s): " %(user))

if len (user_inp) > 0:

user = user_inp

passwd = getpass.getpass()

return (user,passwd)

def gexecCmd(ctx,args):

if (len(args) < 2):

print "usage: gexec [vmname|uuid] command args"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

gargs = args[2:]

env = [] # ["DISPLAY=:0"]

(user,passwd) = getCred(ctx)

gargs.insert(0, lambda ctx,mach,console,args: execInGuest(ctx,console,args,env,user,passwd,1000))

cmdExistingVm(ctx, mach, 'guestlambda', gargs)

return 0

def gcatCmd(ctx,args):

if (len(args) < 2):

print "usage: gcat [vmname|uuid] local_file | guestProgram, such as gcat linux /home/nike/.bashrc | sh -c 'cat >'"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

gargs = args[2:]

env = []

(user,passwd) = getCred(ctx)

gargs.insert(0, lambda ctx,mach,console,args: execInGuest(ctx,console,args,env, user, passwd, 0))

cmdExistingVm(ctx, mach, 'guestlambda', gargs)

return 0

def removeVmCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

removeVm(ctx, mach)

return 0

def pauseCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'pause', '')

return 0

def powerdownCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'powerdown', '')

return 0

def powerbuttonCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'powerbutton', '')

return 0

def resumeCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'resume', '')

return 0

def saveCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'save', '')

return 0

def statsCmd(ctx, args):

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'stats', '')

return 0

def guestCmd(ctx, args):

if (len(args) < 3):

print "usage: guest name commands"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'guest', ' '.join(args[2:]))

return 0

def screenshotCmd(ctx, args):

if (len(args) < 2):

print "usage: screenshot vm <file> <width> <height> <monitor>"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'screenshot', args[2:])

return 0

def teleportCmd(ctx, args):

if (len(args) < 3):

print "usage: teleport name host:port <password>"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'teleport', args[2:])

return 0

def portalsettings(ctx,mach,args):

enabled = args[0]

mach.teleporterEnabled = enabled

if enabled:

port = args[1]

passwd = args[2]

mach.teleporterPort = port

mach.teleporterPassword = passwd

def openportalCmd(ctx, args):

if (len(args) < 3):

print "usage: openportal name port <password>"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

port = int(args[2])

if (len(args) > 3):

passwd = args[3]

else:

passwd = ""

if not mach.teleporterEnabled or mach.teleporterPort != port or passwd:

cmdClosedVm(ctx, mach, portalsettings, [True, port, passwd])

startVm(ctx, mach, "gui")

return 0

def closeportalCmd(ctx, args):

if (len(args) < 2):

print "usage: closeportal name"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

if mach.teleporterEnabled:

cmdClosedVm(ctx, mach, portalsettings, [False])

return 0

def gueststatsCmd(ctx, args):

if (len(args) < 2):

print "usage: gueststats name <check interval>"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdExistingVm(ctx, mach, 'gueststats', args[2:])

return 0

def plugcpu(ctx,mach,args):

plug = args[0]

cpu = args[1]

if plug:

print "Adding CPU %d..." %(cpu)

mach.hotPlugCPU(cpu)

else:

print "Removing CPU %d..." %(cpu)

mach.hotUnplugCPU(cpu)

def plugcpuCmd(ctx, args):

if (len(args) < 2):

print "usage: plugcpu name cpuid"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

if str(mach.sessionState) != str(ctx['ifaces'].SessionState_Open):

if mach.CPUHotPlugEnabled:

cmdClosedVm(ctx, mach, plugcpu, [True, int(args[2])])

else:

cmdExistingVm(ctx, mach, 'plugcpu', args[2])

return 0

def unplugcpuCmd(ctx, args):

if (len(args) < 2):

print "usage: unplugcpu name cpuid"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

if str(mach.sessionState) != str(ctx['ifaces'].SessionState_Open):

if mach.CPUHotPlugEnabled:

cmdClosedVm(ctx, mach, plugcpu, [False, int(args[2])])

else:

cmdExistingVm(ctx, mach, 'unplugcpu', args[2])

return 0

def setvar(ctx,mach,args):

expr = 'mach.'+args[0]+' = '+args[1]

print "Executing",expr

exec expr

def setvarCmd(ctx, args):

if (len(args) < 4):

print "usage: setvar [vmname|uuid] expr value"

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0

cmdClosedVm(ctx, mach, setvar, args[2:])

return 0

def setvmextra(ctx,mach,args):

key = args[0]

value = args[1]

print "%s: setting %s to %s" %(mach.name, key, value)

mach.setExtraData(key, value)

def setExtraDataCmd(ctx, args):

if (len(args) < 3):

print "usage: setextra [vmname|uuid|global] key <value>"

return 0

key = args[2]

if len(args) == 4:

value = args[3]

else:

value = None

if args[1] == 'global':

ctx['vb'].setExtraData(key, value)

return 0

mach = argsToMach(ctx,args)

if mach == None:

return 0