server.py 文件源码

def main():
    # clear the failed task queue
    redis_connection = get_redis_connection(settings['redis server'])
    qfail = Queue("failed", connection=redis_connection)
    qfail.empty()

    # start up server
    prism_server = PrismServer()
    reactor.addSystemEventTrigger("before", "startup", prism_server.startService)
    reactor.addSystemEventTrigger("before", "shutdown", prism_server.stopService)

    # attempt to redistribute any local blobs
    if settings['enqueue on startup']:
        d = enqueue_on_start()
    reactor.run()