Changeset 30492 in vbox

Timestamp:

Jun 29, 2010 11:25:54 AM (15 years ago)

Author:

vboxsync

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

63183

Message:

python: bridge code for active listeners, sample using it in shell

Location:

trunk/src/VBox

Files:

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

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

@@ -432 +432 @@
 
 def monitorVBox2(ctx, dur):
+    def handleEventImpl(ev):
+         print "got event: %s %s" %(ev, str(ev.type))
+         if ev.type == ctx['global'].constants.VBoxEventType_OnMachineStateChange:
+             scev = ctx['global'].queryInterface(ev, 'IMachineStateChangeEvent')
+             if scev:
+                 print "state event: mach=%s state=%s" %(scev.machineId, scev.state)
+
+    class EventListener:
+     def __init__(self, arg):
+         pass
+
+     def handleEvent(self, ev):
+         handleEventImpl(ev)
+
     vbox = ctx['vb']
-    listener = vbox.eventSource.createListener()
+    active = True
+    if active:
+        listener = ctx['global'].createListener(EventListener)
+    else:
+        listener = vbox.eventSource.createListener()
     registered = False
     if dur == -1:
@@ -439 +457 @@
         dur = 100000
     try:
-        vbox.eventSource.registerListener(listener, [ctx['global'].constants.VBoxEventType_Any], False)
+        vbox.eventSource.registerListener(listener, [ctx['global'].constants.VBoxEventType_Any], active)
         registered = True
         end = time.time() + dur
         while  time.time() < end:
-            ev = vbox.eventSource.getEvent(listener, 500)
-            if ev:
-                print "got event: %s %s" %(ev, str(ev.type))
-                if ev.type == ctx['global'].constants.VBoxEventType_OnMachineStateChange:
-                    scev = ctx['global'].queryInterface(ev, 'IMachineStateChangeEvent')
-                    if scev:
-                        print "state event: mach=%s state=%s" %(scev.machineId, scev.state)
-                # otherwise waitable events will leak
-                vbox.eventSource.eventProcessed(listener, ev)
+            if active:
+                ctx['global'].waitForEvents(500)
+            else:
+                ev = vbox.eventSource.getEvent(listener, 500)
+                if ev:
+                    handleEventImpl(ev)
+                    # otherwise waitable events will leak (active listeners ACK automatically)
+                    vbox.eventSource.eventProcessed(listener, ev)
     # We need to catch all exceptions here, otherwise listener will never be unregistered
-    except Exception, e:
-        printErr(ctx,e)
-        traceback.print_exc()
+    except:
         pass
     if listener and registered:
@@ -1013 +1028 @@
         try:
             while True:
-                data = guest.getProcessOutput(pid, 0, 1000, 4096)
+                data = guest.getProcessOutput(pid, 0, 10000, 4096)
                 if data and len(data) > 0:
                     sys.stdout.write(data)
@@ -3058 +3073 @@
         pass
     cmds = []
-    
+
     if g_cmd is not None:
         cmds = g_cmd.split(';')

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

@@ -275 +275 @@
         return d['result']
 
+    def createListener(self, impl, arg):
+        d = {}
+        d['BaseClass'] = impl
+        d['arg'] = arg
+        d['tlb_guid'] = PlatformMSCOM.VBOX_TLB_GUID
+        str = ""
+        str += "import win32com.server.util\n"
+        str += "import pythoncom\n"
+
+        str += "class ListenerImpl(BaseClass):\n"
+        str += "   _com_interfaces_ = ['IEventListener']\n"
+        str += "   _typelib_guid_ = tlb_guid\n"
+        str += "   _typelib_version_ = 1, 0\n"
+        str += "   _reg_clsctx_ = pythoncom.CLSCTX_INPROC_SERVER\n"
+        # Maybe we'd better implement Dynamic invoke policy, to be more flexible here
+        str += "   _reg_policy_spec_ = 'win32com.server.policy.EventHandlerPolicy'\n"
+
+        # capitalized version of callback method
+        str += "   HandleEvent=BaseClass.handleEvent\n"
+        str += "   def __init__(self): BaseClass.__init__(self, arg)\n"
+        str += "result = ListenerImpl()\n"
+        exec (str,d,d)
+        return d['result']
+
     def waitForEvents(self, timeout):
         from win32api import GetCurrentThreadId
@@ -358 +382 @@
         str += "result = xpcom.components.classes['@virtualbox.org/CallbackWrapper;1'].createInstance()\n"
         str += "result.setLocalObject("+iface+"Impl())\n"
+        exec (str,d,d)
+        return d['result']
+
+    def createListener(self, impl, arg):
+        d = {}
+        d['BaseClass'] = impl
+        d['arg'] = arg
+        str = ""
+        str += "import xpcom.components\n"
+        str += "class ListenerImpl(BaseClass):\n"
+        str += "   _com_interfaces_ = xpcom.components.interfaces.IEventListener\n"
+        str += "   def __init__(self): BaseClass.__init__(self, arg)\n"
+        str += "result = ListenerImpl()\n"
         exec (str,d,d)
         return d['result']
@@ -444 +481 @@
         raise Exception("no callbacks for webservices")
 
+    def createListener(self, impl, arg):
+        raise Exception("no active listeners for webservices")
+
     def waitForEvents(self, timeout):
         # Webservices cannot do that yet
@@ -544 +584 @@
         return self.platform.createCallback(iface, impl, arg)
 
+    def createListener(self, impl, arg = None):
+        return self.platform.createListener(impl, arg)
+
     def waitForEvents(self, timeout):
         return self.platform.waitForEvents(timeout)