pythentic.py 文件源码

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)