[Xen-changelog] Remove python virq code.

[Xen patchbot -unstable <patchbot-unstable@xxxxxxxxxxxxxxxxxxx>]

# HG changeset patch
# User cl349@xxxxxxxxxxxxxxxxxxxx
# Node ID 652bd7876153830eead6c292d3787a9c29256e36
# Parent  c9e1ddf853243e47b91cbd46a465092e932ea6d0
Remove python virq code.
Signed-off-by: Christian Limpach <Christian.Limpach@xxxxxxxxxxxx>

diff -r c9e1ddf85324 -r 652bd7876153 tools/python/xen/xend/server/SrvDaemon.py
--- a/tools/python/xen/xend/server/SrvDaemon.py Wed Sep  7 13:41:49 2005
+++ b/tools/python/xen/xend/server/SrvDaemon.py Wed Sep  7 14:19:05 2005
@@ -316,10 +316,6 @@
         self.channelF = channel.channelFactory()
 
     def listenChannels(self):
-        def virqReceived(virq):
-            eserver.inject('xend.virq', virq)
-
-        self.channelF.setVirqHandler(virqReceived)
         self.channelF.start()
 
     def exit(self, rc=0):
diff -r c9e1ddf85324 -r 652bd7876153 tools/python/xen/xend/server/channel.py
--- a/tools/python/xen/xend/server/channel.py   Wed Sep  7 13:41:49 2005
+++ b/tools/python/xen/xend/server/channel.py   Wed Sep  7 14:19:05 2005
@@ -145,22 +145,10 @@
 
     notifier = None
 
-    """Map of ports to the virq they signal."""
-    virqPorts = None
-
     def __init__(self):
         """Constructor - do not use. Use the channelFactory function."""
         self.channels = {}
-        self.virqPorts = {}
         self.notifier = xu.notifier()
-        # Register interest in virqs.
-        self.bind_virq(xen.lowlevel.xc.VIRQ_DOM_EXC)
-        self.virqHandler = None
-
-    def bind_virq(self, virq):
-        port = self.notifier.bind_virq(virq)
-        self.virqPorts[port] = virq
-        log.info("Virq %s on port %s", virq, port)
 
     def start(self):
         """Fork a thread to read messages.
@@ -184,11 +172,7 @@
             if self.thread == None: return
             port = self.notifier.read()
             if port:
-                virq = self.virqPorts.get(port)
-                if virq is not None:
-                    self.virqReceived(virq)
-                else:
-                    self.msgReceived(port)
+                self.msgReceived(port)
             else:
                 select.select([self.notifier], [], [], 1.0)
 
@@ -218,15 +202,6 @@
         thread.setDaemon(True)
         thread.start()
 
-    def setVirqHandler(self, virqHandler):
-        self.virqHandler = virqHandler
-
-    def virqReceived(self, virq):
-        if DEBUG:
-            print 'virqReceived>', virq
-        if not self.virqHandler: return
-        self.runInThread(lambda virq=virq: self.virqHandler(virq))
-
     def newChannel(self, dom, local_port, remote_port):
         """Create a new channel.
         """
@@ -547,9 +522,6 @@
             printMsg(msg)
         self.queue.response(getMessageId(msg), msg)
 
-    def virq(self):
-        self.factory.virq()
-
 class Response:
     """Entry in the response queue.
     Used to signal a response to a message.

_______________________________________________
Xen-changelog mailing list
Xen-changelog@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-changelog