Changeset 30492 in vbox for trunk/src/VBox/Frontends/VBoxShell/vboxshell.py

Timestamp:

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

Author:

vboxsync

Message:

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

File:

• trunk/src/VBox/Frontends/VBoxShell/vboxshell.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(';')