def __init__(self, tp, milter_class, max_queued_connections=1024):
"""Constructs an AsyncPpyMilterServer.
Args:
port: A numeric port to listen on (TCP).
milter_class: A class (not an instance) that handles callbacks for
milter commands (e.g. a child of the PpyMilter class).
max_queued_connections: Maximum number of connections to allow to
queue up on socket awaiting accept().
"""
asyncore.dispatcher.__init__(self)
self.__milter_class = milter_class
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.set_reuse_addr()
self.bind(('', tp.tup['smtpPort']))
self.milt = tp.tup['milType']
self.mildb = tp.tup['milDB']
self.tp = tp
print "Async.init: miltype=%s listen on %d" % (self.milt, tp.tup['smtpPort'])
self.listen(max_queued_connections)
评论列表
文章目录