Changeset 20693 in vbox

Timestamp:

Jun 18, 2009 4:37:00 PM (16 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

48798

Message:

Python: Windows waiting for event, additional shell command

Location:

trunk/src/VBox

Files:

• Frontends/VBoxShell/vboxshell.py (modified) (5 diffs)
• Main/glue/vboxapi.py (modified) (4 diffs)

trunk/src/VBox/Frontends/VBoxShell/vboxshell.py

@@ -156 +156 @@
     def onShowWindow(self, winId):
         print  "%s: onShowWindow: %d" %(self.mach.name, winId)
+
+class VBoxMonitor:
+    def __init__(self, vbox):
+        self.vbox = vbox
+        pass
+
+    def onMachineStateChange(self, id, state):
+        print "onMachineStateChange: %s %d" %(id, state)
+
+    def onMachineDataChange(self,id):
+        print "onMachineDataChange: %s" %(id)
+    
+    def onExtraDataCanChange(self, id, key, value):
+        print "onExtraDataCanChange: %s %s=>%s" %(id, key, value)
+        return true
+
+    def onExtraDataChange(self, id, key, value):
+        print "onExtraDataChange: %s %s=>%s" %(id, key, value)
+
+    def onMediaRegistred(self, id, type, registred):
+        print "onMediaRegistred: %s" %(id)
+
+    def onMachineRegistred(self, id, registred):
+        print "onMachineRegistred: %s" %(id)
+
+    def onSessionStateChange(self, id, state):
+        print "onSessionStateChange: %s %d" %(id, state)
+
+    def onSnapshotTaken(self, mach, id):
+        print "onSnapshotTaken: %s %s" %(mach, id)
+
+    def onSnapshotDiscarded(self, mach, id):
+        print "onSnapshotDiscarded: %s %s" %(mach, id)
+
+    def onSnapshotChange(self, mach, id):
+        print "onSnapshotChange: %s %s" %(mach, id)
+
+    def onGuestPropertyChange(self, id, val1, val2, val3):
+        print "onGuestPropertyChange: %s" %(id)
+    
+
 
 g_hasreadline = 1
@@ -304 +345 @@
 def monitorGuest(ctx, machine, console, dur):
     import time
-    import xpcom
     cb = ctx['global'].createCallback('IConsoleCallback', GuestMonitor, machine)
     console.registerCallback(cb)
@@ -319 +359 @@
     console.unregisterCallback(cb)
 
-    
+
+def monitorVbox(ctx, dur):
+    import time
+    vbox = ctx['vb']
+    cb = ctx['global'].createCallback('IVirtualBoxCallback', VBoxMonitor, vbox)
+    vbox.registerCallback(cb)
+    if dur == -1:
+        # not infinity, but close enough
+        dur = 100000
+    try:
+        end = time.time() + dur
+        while  time.time() < end:
+            ctx['global'].waitForEvents(500)
+    # We need to catch all exceptions here, otherwise callback will never be unregistered
+    except Exception,e:
+        print e
+        if g_verbose:
+                traceback.print_exc()
+        pass    
+    vbox.unregisterCallback(cb)
 
 def cmdExistingVm(ctx,mach,cmd,args):
@@ -561 +620 @@
     return 0
 
+def monitorVboxCmd(ctx, args):
+    if (len(args) > 2):
+        print "usage: monitorVbox (duration)"
+        return 0
+    dur = 5
+    if len(args) > 1:
+        dur = float(args[1])
+    monitorVbox(ctx, dur)
+    return 0
+
 def evalCmd(ctx, args):
    expr = ' '.join(args[1:])
@@ -597 +666 @@
             'guest':['Execute command for guest: guest Win32 console.mouse.putMouseEvent(20, 20, 0, 0)', guestCmd],
             'monitorGuest':['Monitor what happens with the guest for some time: monitorGuest Win32 10', monitorGuestCmd],
+            'monitorVbox':['Monitor what happens with Virtual Box for some time: monitorVbox 10', monitorVboxCmd],
             }
 

trunk/src/VBox/Main/glue/vboxapi.py

@@ -92 +92 @@
                     return self.__dict__['_rootFake'].__getattr__(a)
 
+    VBOX_TLB_GUID  = '{46137EEC-703B-4FE5-AFD4-7C9BBBBA0259}'
+    VBOX_TLB_LCID  = 0
+    VBOX_TLB_MAJOR = 1
+    VBOX_TLB_MINOR = 0
+
     def __init__(self, params):
             from win32com import universal
@@ -99 +104 @@
             import pythoncom
             import win32api
-            self.constants = PlatformMSCOM.InterfacesWrapper()
+            self.constants = PlatformMSCOM.InterfacesWrapper()                        
 
     def getSessionObject(self, vbox):
@@ -135 +140 @@
         d['BaseClass'] = impl
         d['arg'] = arg
+        d['tlb_guid'] = PlatformMSCOM.VBOX_TLB_GUID
         str = ""
-        str += "import win32com.server.util"
+        str += "import win32com.server.util\n"
+        #str += "from win32com import universal\n"
+        #str += "import pythoncom\n"
+        #str += "universal.RegisterInterfaces(tlb_guid, 0, 1, 0, ['"+iface+"'])\n"
+
         str += "class "+iface+"Impl(BaseClass):\n"
         str += "   _com_interfaces_ = ['"+iface+"']\n"
-        str += "   _typelib_guid_ = '{46137EEC-703B-4FE5-AFD4-7C9BBBBA0259}'\n"
+        str += "   _typelib_guid_ = tlb_guid\n"
+        str += "   _typelib_version_ = 1, 0\n"
+        #str += "   _reg_clsctx_ = pythoncom.CLSCTX_INPROC_SERVER\n"
+        #str += "   _reg_clsid_ = '{F21202A2-959A-4149-B1C3-68B9013F3335}'\n"
+        #str += "   _reg_progid_ = 'VirtualBox."+iface+"Impl'\n"
+        #str += "   _reg_desc_ = 'Generated callback implementation class'\n"
+        #str += "   _reg_policy_spec_ = 'win32com.server.policy.EventHandlerPolicy'\n"
+
         str += "   def __init__(self): BaseClass.__init__(self, arg)\n"
         str += "result = win32com.server.util.wrap("+iface+"Impl())\n"        
@@ -146 +163 @@
 
     def waitForEvents(self, timeout):
-        # not really supported yet
-        pass
+        from win32file import CloseHandle
+        from win32con import DUPLICATE_SAME_ACCESS
+        from win32api import GetCurrentThread,DuplicateHandle,GetCurrentProcess
+        from win32event import MsgWaitForMultipleObjects, \
+                               QS_ALLINPUT, WAIT_TIMEOUT, WAIT_OBJECT_0
+        from pythoncom import PumpWaitingMessages
+
+        pid = GetCurrentProcess()
+        handle = DuplicateHandle(pid, GetCurrentThread(), pid, 0, 0, DUPLICATE_SAME_ACCESS)
+        
+        handles = []
+        handles.append(handle)
+
+        rc = MsgWaitForMultipleObjects(handles, 0, timeout, QS_ALLINPUT)
+        if rc >= WAIT_OBJECT_0 and rc < WAIT_OBJECT_0+len(handles):
+            # is it possible?
+            print "how come?"
+            pass
+        elif rc==WAIT_OBJECT_0 + len(handles):
+            # Waiting messages
+            PumpWaitingMessages()
+        else:
+            pass
+        CloseHandle(handle)
 
     def deinit(self):