6 import logging |
6 import logging |
7 |
7 |
8 from .model import setEngine, setPool |
8 from .model import setEngine, setPool |
9 from .controller.pool import startPool, dbPool |
9 from .controller.pool import startPool, dbPool |
10 from .view import xmlrpc |
10 from .view import xmlrpc |
|
11 import config |
11 |
12 |
12 def runReactor(reactor, engine, root): |
13 def runReactor(reactor, engine, port, root): |
13 setEngine(engine) |
14 setEngine(engine) |
14 startPool(reactor) |
15 startPool(reactor) |
15 setPool(dbPool) |
16 setPool(dbPool) |
16 |
17 |
17 reactor.listenTCP(7080, server.Site(root)) |
18 reactor.listenTCP(port, server.Site(root)) |
18 logging.info("Server is running now...") |
19 logging.info("Server is running now...") |
19 reactor.run() |
20 reactor.run() |
20 |
21 |
21 |
22 |
22 if __name__ == '__main__': |
23 if __name__ == '__main__': |
23 engine = create_engine('mysql://test:test@localhost/test', |
24 |
|
25 config.readConfig() |
|
26 |
|
27 engine = create_engine(config.main.dburl, |
24 poolclass = pool.SingletonThreadPool, pool_size=dbPool.maxthreads, ) |
28 poolclass = pool.SingletonThreadPool, pool_size=dbPool.maxthreads, ) |
25 |
29 |
26 |
30 |
27 root = resource.Resource() |
31 root = resource.Resource() |
28 root = xmlrpc.appendResource(root) |
32 root = xmlrpc.appendResource(root) |
30 v2 = resource.Resource() |
34 v2 = resource.Resource() |
31 v2 = xmlrpc.appendResource(root) |
35 v2 = xmlrpc.appendResource(root) |
32 root.addChild('2.0', v2) |
36 root.addChild('2.0', v2) |
33 |
37 |
34 |
38 |
35 runReactor(reactor, engine, root) |
39 runReactor(reactor, engine, config.main.port, root) |