# 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
|
Home