fix
This commit is contained in:
@ -62,8 +62,6 @@ class Event(object):
|
|||||||
except Queue.Full, e:
|
except Queue.Full, e:
|
||||||
Logger.log("Dns Queue overrun, drop event for %s" % str(entry))
|
Logger.log("Dns Queue overrun, drop event for %s" % str(entry))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def __str__(self):
|
def __str__(self):
|
||||||
if not self.prepared:
|
if not self.prepared:
|
||||||
self.prepare()
|
self.prepare()
|
||||||
|
@ -2,9 +2,9 @@ import threading
|
|||||||
import time
|
import time
|
||||||
import Event
|
import Event
|
||||||
from logger import Logger
|
from logger import Logger
|
||||||
|
from SimpleXMLRPCServer import SimpleXMLRPCServer
|
||||||
|
|
||||||
|
class XmlRpcServer(SimpleXMLRPCServer):
|
||||||
class MathServer(SimpleXMLRPCServer):
|
|
||||||
def _dispatch(self, method, params):
|
def _dispatch(self, method, params):
|
||||||
try:
|
try:
|
||||||
# We are forcing the 'export_' prefix on methods that are
|
# We are forcing the 'export_' prefix on methods that are
|
||||||
@ -28,6 +28,6 @@ class XmlRpcReceiver(threading.Thread):
|
|||||||
self.setDaemon(True)
|
self.setDaemon(True)
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
server = MathServer(self.xmlRpcAddr)
|
server = XmlRpcServer(self.xmlRpcAddr)
|
||||||
server.serve_forever()
|
server.serve_forever()
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user